Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterRunnerServiceServer(s grpc.ServiceRegistrar, srv RunnerServiceServer)
- type AuthRequest
- func (*AuthRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AuthRequest) GetDocker() bool
- func (x *AuthRequest) GetHostname() string
- func (x *AuthRequest) GetIdent() string
- func (x *AuthRequest) GetUser() string
- func (*AuthRequest) ProtoMessage()
- func (x *AuthRequest) ProtoReflect() protoreflect.Message
- func (x *AuthRequest) Reset()
- func (x *AuthRequest) String() string
- type AuthResponse
- func (*AuthResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AuthResponse) GetExpiresAt() *timestamppb.Timestamp
- func (x *AuthResponse) GetToken() string
- func (*AuthResponse) ProtoMessage()
- func (x *AuthResponse) ProtoReflect() protoreflect.Message
- func (x *AuthResponse) Reset()
- func (x *AuthResponse) String() string
- type CloseRequest
- type CloseResponse
- type InterruptRequest
- type InterruptResponse
- type MetadataImage
- func (*MetadataImage) Descriptor() ([]byte, []int)deprecated
- func (x *MetadataImage) GetSha256() string
- func (x *MetadataImage) GetSize() int64
- func (*MetadataImage) ProtoMessage()
- func (x *MetadataImage) ProtoReflect() protoreflect.Message
- func (x *MetadataImage) Reset()
- func (x *MetadataImage) String() string
- type MetadataRequest
- func (*MetadataRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MetadataRequest) GetDuration() float64deprecated
- func (x *MetadataRequest) GetImage() *MetadataImage
- func (x *MetadataRequest) GetImageSha256() stringdeprecated
- func (x *MetadataRequest) GetImageSize() int64deprecated
- func (x *MetadataRequest) GetVideo() *MetadataVideo
- func (x *MetadataRequest) GetVideoCrc32() stringdeprecated
- func (x *MetadataRequest) GetVideoSha256() stringdeprecated
- func (x *MetadataRequest) GetVideoSize() int64deprecated
- func (*MetadataRequest) ProtoMessage()
- func (x *MetadataRequest) ProtoReflect() protoreflect.Message
- func (x *MetadataRequest) Reset()
- func (x *MetadataRequest) String() string
- type MetadataResponse
- type MetadataVideo
- func (*MetadataVideo) Descriptor() ([]byte, []int)deprecated
- func (x *MetadataVideo) GetCrc32() string
- func (x *MetadataVideo) GetDimension() *MetadataVideoDimension
- func (x *MetadataVideo) GetDuration() float64
- func (x *MetadataVideo) GetSha256() string
- func (x *MetadataVideo) GetSize() int64
- func (*MetadataVideo) ProtoMessage()
- func (x *MetadataVideo) ProtoReflect() protoreflect.Message
- func (x *MetadataVideo) Reset()
- func (x *MetadataVideo) String() string
- type MetadataVideoDimension
- func (*MetadataVideoDimension) Descriptor() ([]byte, []int)deprecated
- func (x *MetadataVideoDimension) GetHeight() int64
- func (x *MetadataVideoDimension) GetWidth() int64
- func (*MetadataVideoDimension) ProtoMessage()
- func (x *MetadataVideoDimension) ProtoReflect() protoreflect.Message
- func (x *MetadataVideoDimension) Reset()
- func (x *MetadataVideoDimension) String() string
- type OpenRequest
- type OpenResponse
- func (*OpenResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OpenResponse) GetAddress() string
- func (x *OpenResponse) GetSize() int64
- func (*OpenResponse) ProtoMessage()
- func (x *OpenResponse) ProtoReflect() protoreflect.Message
- func (x *OpenResponse) Reset()
- func (x *OpenResponse) String() string
- type Operation
- type OperationRequest
- func (*OperationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OperationRequest) GetCloseRequest() *CloseRequest
- func (x *OperationRequest) GetInterruptRequest() *InterruptRequest
- func (x *OperationRequest) GetMetadataRequest() *MetadataRequest
- func (x *OperationRequest) GetOpenRequest() *OpenRequest
- func (x *OperationRequest) GetOperation() Operation
- func (x *OperationRequest) GetProgressRequest() *ProgressRequest
- func (m *OperationRequest) GetRequest() isOperationRequest_Request
- func (*OperationRequest) ProtoMessage()
- func (x *OperationRequest) ProtoReflect() protoreflect.Message
- func (x *OperationRequest) Reset()
- func (x *OperationRequest) String() string
- type OperationRequest_CloseRequest
- type OperationRequest_InterruptRequest
- type OperationRequest_MetadataRequest
- type OperationRequest_OpenRequest
- type OperationRequest_ProgressRequest
- type OperationResponse
- func (*OperationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OperationResponse) GetCloseResponse() *CloseResponse
- func (x *OperationResponse) GetInterruptResponse() *InterruptResponse
- func (x *OperationResponse) GetMetadataResponse() *MetadataResponse
- func (x *OperationResponse) GetOpenResponse() *OpenResponse
- func (x *OperationResponse) GetOperation() Operation
- func (x *OperationResponse) GetProgressResponse() *ProgressResponse
- func (m *OperationResponse) GetResponse() isOperationResponse_Response
- func (*OperationResponse) ProtoMessage()
- func (x *OperationResponse) ProtoReflect() protoreflect.Message
- func (x *OperationResponse) Reset()
- func (x *OperationResponse) String() string
- type OperationResponse_CloseResponse
- type OperationResponse_InterruptResponse
- type OperationResponse_MetadataResponse
- type OperationResponse_OpenResponse
- type OperationResponse_ProgressResponse
- type ProgressRequest
- func (*ProgressRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ProgressRequest) GetCurrentDuration() float64
- func (x *ProgressRequest) GetCurrentFilesize() float64
- func (x *ProgressRequest) GetDuration() float64
- func (x *ProgressRequest) GetFilesize() float64
- func (x *ProgressRequest) GetPercentage() float64
- func (x *ProgressRequest) GetSpeed() float64
- func (x *ProgressRequest) GetType() ProgressRequest_Type
- func (*ProgressRequest) ProtoMessage()
- func (x *ProgressRequest) ProtoReflect() protoreflect.Message
- func (x *ProgressRequest) Reset()
- func (x *ProgressRequest) String() string
- type ProgressRequest_Type
- func (ProgressRequest_Type) Descriptor() protoreflect.EnumDescriptor
- func (x ProgressRequest_Type) Enum() *ProgressRequest_Type
- func (ProgressRequest_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x ProgressRequest_Type) Number() protoreflect.EnumNumber
- func (x ProgressRequest_Type) String() string
- func (ProgressRequest_Type) Type() protoreflect.EnumType
- type ProgressResponse
- type RunnerServiceClient
- type RunnerServiceServer
- type RunnerService_OperationClient
- type RunnerService_OperationServer
- type StreamRequest
- func (*StreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamRequest) GetAdler32() uint32
- func (x *StreamRequest) GetContent() []byte
- func (x *StreamRequest) GetEnd() int64
- func (x *StreamRequest) GetOffset() int64
- func (x *StreamRequest) GetSize() int64
- func (x *StreamRequest) GetStart() int64
- func (x *StreamRequest) GetStream() StreamType
- func (*StreamRequest) ProtoMessage()
- func (x *StreamRequest) ProtoReflect() protoreflect.Message
- func (x *StreamRequest) Reset()
- func (x *StreamRequest) String() string
- type StreamResponse
- func (*StreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StreamResponse) GetEnd() int64
- func (x *StreamResponse) GetError() string
- func (x *StreamResponse) GetStart() int64
- func (x *StreamResponse) GetStream() StreamType
- func (*StreamResponse) ProtoMessage()
- func (x *StreamResponse) ProtoReflect() protoreflect.Message
- func (x *StreamResponse) Reset()
- func (x *StreamResponse) String() string
- type StreamType
- type UnimplementedRunnerServiceServer
- type UnsafeRunnerServiceServer
Constants ¶
const ( RunnerService_Auth_FullMethodName = "/grpc_runner_v1.RunnerService/Auth" RunnerService_Stream_FullMethodName = "/grpc_runner_v1.RunnerService/Stream" RunnerService_Operation_FullMethodName = "/grpc_runner_v1.RunnerService/Operation" )
Variables ¶
var ( StreamType_name = map[int32]string{ 0: "IMAGE", 1: "VIDEO", } StreamType_value = map[string]int32{ "IMAGE": 0, "VIDEO": 1, } )
Enum value maps for StreamType.
var ( Operation_name = map[int32]string{ 0: "OPEN", 1: "INTERRUPT", 2: "CLOSE", 3: "PROGRESS", 4: "METADATA", } Operation_value = map[string]int32{ "OPEN": 0, "INTERRUPT": 1, "CLOSE": 2, "PROGRESS": 3, "METADATA": 4, } )
Enum value maps for Operation.
var ( ProgressRequest_Type_name = map[int32]string{ 0: "DOWNLOAD", 1: "METADATA", 2: "TRANSCODE", 3: "UPLOAD", } ProgressRequest_Type_value = map[string]int32{ "DOWNLOAD": 0, "METADATA": 1, "TRANSCODE": 2, "UPLOAD": 3, } )
Enum value maps for ProgressRequest_Type.
var File_api_grpc_runner_v1_grpc_runner_proto protoreflect.FileDescriptor
var RunnerService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "grpc_runner_v1.RunnerService", HandlerType: (*RunnerServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Auth", Handler: _RunnerService_Auth_Handler, }, { MethodName: "Stream", Handler: _RunnerService_Stream_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Operation", Handler: _RunnerService_Operation_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "api/grpc_runner/v1/grpc_runner.proto", }
RunnerService_ServiceDesc is the grpc.ServiceDesc for RunnerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRunnerServiceServer ¶
func RegisterRunnerServiceServer(s grpc.ServiceRegistrar, srv RunnerServiceServer)
Types ¶
type AuthRequest ¶
type AuthRequest struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"` Ident string `protobuf:"bytes,3,opt,name=ident,proto3" json:"ident,omitempty"` Docker bool `protobuf:"varint,4,opt,name=docker,proto3" json:"docker,omitempty"` // contains filtered or unexported fields }
func (*AuthRequest) Descriptor
deprecated
func (*AuthRequest) Descriptor() ([]byte, []int)
Deprecated: Use AuthRequest.ProtoReflect.Descriptor instead.
func (*AuthRequest) GetDocker ¶
func (x *AuthRequest) GetDocker() bool
func (*AuthRequest) GetHostname ¶
func (x *AuthRequest) GetHostname() string
func (*AuthRequest) GetIdent ¶
func (x *AuthRequest) GetIdent() string
func (*AuthRequest) GetUser ¶
func (x *AuthRequest) GetUser() string
func (*AuthRequest) ProtoMessage ¶
func (*AuthRequest) ProtoMessage()
func (*AuthRequest) ProtoReflect ¶
func (x *AuthRequest) ProtoReflect() protoreflect.Message
func (*AuthRequest) Reset ¶
func (x *AuthRequest) Reset()
func (*AuthRequest) String ¶
func (x *AuthRequest) String() string
type AuthResponse ¶
type AuthResponse struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` ExpiresAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"` // contains filtered or unexported fields }
func (*AuthResponse) Descriptor
deprecated
func (*AuthResponse) Descriptor() ([]byte, []int)
Deprecated: Use AuthResponse.ProtoReflect.Descriptor instead.
func (*AuthResponse) GetExpiresAt ¶
func (x *AuthResponse) GetExpiresAt() *timestamppb.Timestamp
func (*AuthResponse) GetToken ¶
func (x *AuthResponse) GetToken() string
func (*AuthResponse) ProtoMessage ¶
func (*AuthResponse) ProtoMessage()
func (*AuthResponse) ProtoReflect ¶
func (x *AuthResponse) ProtoReflect() protoreflect.Message
func (*AuthResponse) Reset ¶
func (x *AuthResponse) Reset()
func (*AuthResponse) String ¶
func (x *AuthResponse) String() string
type CloseRequest ¶
type CloseRequest struct { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*CloseRequest) Descriptor
deprecated
func (*CloseRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloseRequest.ProtoReflect.Descriptor instead.
func (*CloseRequest) GetError ¶
func (x *CloseRequest) GetError() string
func (*CloseRequest) ProtoMessage ¶
func (*CloseRequest) ProtoMessage()
func (*CloseRequest) ProtoReflect ¶
func (x *CloseRequest) ProtoReflect() protoreflect.Message
func (*CloseRequest) Reset ¶
func (x *CloseRequest) Reset()
func (*CloseRequest) String ¶
func (x *CloseRequest) String() string
type CloseResponse ¶
type CloseResponse struct {
// contains filtered or unexported fields
}
func (*CloseResponse) Descriptor
deprecated
func (*CloseResponse) Descriptor() ([]byte, []int)
Deprecated: Use CloseResponse.ProtoReflect.Descriptor instead.
func (*CloseResponse) ProtoMessage ¶
func (*CloseResponse) ProtoMessage()
func (*CloseResponse) ProtoReflect ¶
func (x *CloseResponse) ProtoReflect() protoreflect.Message
func (*CloseResponse) Reset ¶
func (x *CloseResponse) Reset()
func (*CloseResponse) String ¶
func (x *CloseResponse) String() string
type InterruptRequest ¶
type InterruptRequest struct { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*InterruptRequest) Descriptor
deprecated
func (*InterruptRequest) Descriptor() ([]byte, []int)
Deprecated: Use InterruptRequest.ProtoReflect.Descriptor instead.
func (*InterruptRequest) GetError ¶
func (x *InterruptRequest) GetError() string
func (*InterruptRequest) ProtoMessage ¶
func (*InterruptRequest) ProtoMessage()
func (*InterruptRequest) ProtoReflect ¶
func (x *InterruptRequest) ProtoReflect() protoreflect.Message
func (*InterruptRequest) Reset ¶
func (x *InterruptRequest) Reset()
func (*InterruptRequest) String ¶
func (x *InterruptRequest) String() string
type InterruptResponse ¶
type InterruptResponse struct {
// contains filtered or unexported fields
}
func (*InterruptResponse) Descriptor
deprecated
func (*InterruptResponse) Descriptor() ([]byte, []int)
Deprecated: Use InterruptResponse.ProtoReflect.Descriptor instead.
func (*InterruptResponse) ProtoMessage ¶
func (*InterruptResponse) ProtoMessage()
func (*InterruptResponse) ProtoReflect ¶
func (x *InterruptResponse) ProtoReflect() protoreflect.Message
func (*InterruptResponse) Reset ¶
func (x *InterruptResponse) Reset()
func (*InterruptResponse) String ¶
func (x *InterruptResponse) String() string
type MetadataImage ¶
type MetadataImage struct { Sha256 string `protobuf:"bytes,1,opt,name=sha256,proto3" json:"sha256,omitempty"` Size int64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"` // contains filtered or unexported fields }
func (*MetadataImage) Descriptor
deprecated
func (*MetadataImage) Descriptor() ([]byte, []int)
Deprecated: Use MetadataImage.ProtoReflect.Descriptor instead.
func (*MetadataImage) GetSha256 ¶
func (x *MetadataImage) GetSha256() string
func (*MetadataImage) GetSize ¶
func (x *MetadataImage) GetSize() int64
func (*MetadataImage) ProtoMessage ¶
func (*MetadataImage) ProtoMessage()
func (*MetadataImage) ProtoReflect ¶
func (x *MetadataImage) ProtoReflect() protoreflect.Message
func (*MetadataImage) Reset ¶
func (x *MetadataImage) Reset()
func (*MetadataImage) String ¶
func (x *MetadataImage) String() string
type MetadataRequest ¶
type MetadataRequest struct { // Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto. VideoSha256 string `protobuf:"bytes,1,opt,name=video_sha256,json=videoSha256,proto3" json:"video_sha256,omitempty"` // Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto. ImageSha256 string `protobuf:"bytes,2,opt,name=image_sha256,json=imageSha256,proto3" json:"image_sha256,omitempty"` // Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto. VideoCrc32 string `protobuf:"bytes,3,opt,name=video_crc32,json=videoCrc32,proto3" json:"video_crc32,omitempty"` // Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto. ImageSize int64 `protobuf:"varint,4,opt,name=image_size,json=imageSize,proto3" json:"image_size,omitempty"` // Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto. VideoSize int64 `protobuf:"varint,5,opt,name=video_size,json=videoSize,proto3" json:"video_size,omitempty"` // Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto. Duration float64 `protobuf:"fixed64,6,opt,name=duration,proto3" json:"duration,omitempty"` Video *MetadataVideo `protobuf:"bytes,7,opt,name=video,proto3" json:"video,omitempty"` Image *MetadataImage `protobuf:"bytes,8,opt,name=image,proto3" json:"image,omitempty"` // contains filtered or unexported fields }
func (*MetadataRequest) Descriptor
deprecated
func (*MetadataRequest) Descriptor() ([]byte, []int)
Deprecated: Use MetadataRequest.ProtoReflect.Descriptor instead.
func (*MetadataRequest) GetDuration
deprecated
func (x *MetadataRequest) GetDuration() float64
Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto.
func (*MetadataRequest) GetImage ¶
func (x *MetadataRequest) GetImage() *MetadataImage
func (*MetadataRequest) GetImageSha256
deprecated
func (x *MetadataRequest) GetImageSha256() string
Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto.
func (*MetadataRequest) GetImageSize
deprecated
func (x *MetadataRequest) GetImageSize() int64
Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto.
func (*MetadataRequest) GetVideo ¶
func (x *MetadataRequest) GetVideo() *MetadataVideo
func (*MetadataRequest) GetVideoCrc32
deprecated
func (x *MetadataRequest) GetVideoCrc32() string
Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto.
func (*MetadataRequest) GetVideoSha256
deprecated
func (x *MetadataRequest) GetVideoSha256() string
Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto.
func (*MetadataRequest) GetVideoSize
deprecated
func (x *MetadataRequest) GetVideoSize() int64
Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto.
func (*MetadataRequest) ProtoMessage ¶
func (*MetadataRequest) ProtoMessage()
func (*MetadataRequest) ProtoReflect ¶
func (x *MetadataRequest) ProtoReflect() protoreflect.Message
func (*MetadataRequest) Reset ¶
func (x *MetadataRequest) Reset()
func (*MetadataRequest) String ¶
func (x *MetadataRequest) String() string
type MetadataResponse ¶
type MetadataResponse struct {
// contains filtered or unexported fields
}
func (*MetadataResponse) Descriptor
deprecated
func (*MetadataResponse) Descriptor() ([]byte, []int)
Deprecated: Use MetadataResponse.ProtoReflect.Descriptor instead.
func (*MetadataResponse) ProtoMessage ¶
func (*MetadataResponse) ProtoMessage()
func (*MetadataResponse) ProtoReflect ¶
func (x *MetadataResponse) ProtoReflect() protoreflect.Message
func (*MetadataResponse) Reset ¶
func (x *MetadataResponse) Reset()
func (*MetadataResponse) String ¶
func (x *MetadataResponse) String() string
type MetadataVideo ¶
type MetadataVideo struct { Sha256 string `protobuf:"bytes,1,opt,name=sha256,proto3" json:"sha256,omitempty"` Size int64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"` Crc32 string `protobuf:"bytes,3,opt,name=crc32,proto3" json:"crc32,omitempty"` Duration float64 `protobuf:"fixed64,4,opt,name=duration,proto3" json:"duration,omitempty"` Dimension *MetadataVideoDimension `protobuf:"bytes,5,opt,name=dimension,proto3" json:"dimension,omitempty"` // contains filtered or unexported fields }
func (*MetadataVideo) Descriptor
deprecated
func (*MetadataVideo) Descriptor() ([]byte, []int)
Deprecated: Use MetadataVideo.ProtoReflect.Descriptor instead.
func (*MetadataVideo) GetCrc32 ¶
func (x *MetadataVideo) GetCrc32() string
func (*MetadataVideo) GetDimension ¶
func (x *MetadataVideo) GetDimension() *MetadataVideoDimension
func (*MetadataVideo) GetDuration ¶
func (x *MetadataVideo) GetDuration() float64
func (*MetadataVideo) GetSha256 ¶
func (x *MetadataVideo) GetSha256() string
func (*MetadataVideo) GetSize ¶
func (x *MetadataVideo) GetSize() int64
func (*MetadataVideo) ProtoMessage ¶
func (*MetadataVideo) ProtoMessage()
func (*MetadataVideo) ProtoReflect ¶
func (x *MetadataVideo) ProtoReflect() protoreflect.Message
func (*MetadataVideo) Reset ¶
func (x *MetadataVideo) Reset()
func (*MetadataVideo) String ¶
func (x *MetadataVideo) String() string
type MetadataVideoDimension ¶
type MetadataVideoDimension struct { Height int64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"` Width int64 `protobuf:"varint,2,opt,name=width,proto3" json:"width,omitempty"` // contains filtered or unexported fields }
func (*MetadataVideoDimension) Descriptor
deprecated
func (*MetadataVideoDimension) Descriptor() ([]byte, []int)
Deprecated: Use MetadataVideoDimension.ProtoReflect.Descriptor instead.
func (*MetadataVideoDimension) GetHeight ¶
func (x *MetadataVideoDimension) GetHeight() int64
func (*MetadataVideoDimension) GetWidth ¶
func (x *MetadataVideoDimension) GetWidth() int64
func (*MetadataVideoDimension) ProtoMessage ¶
func (*MetadataVideoDimension) ProtoMessage()
func (*MetadataVideoDimension) ProtoReflect ¶
func (x *MetadataVideoDimension) ProtoReflect() protoreflect.Message
func (*MetadataVideoDimension) Reset ¶
func (x *MetadataVideoDimension) Reset()
func (*MetadataVideoDimension) String ¶
func (x *MetadataVideoDimension) String() string
type OpenRequest ¶
type OpenRequest struct { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*OpenRequest) Descriptor
deprecated
func (*OpenRequest) Descriptor() ([]byte, []int)
Deprecated: Use OpenRequest.ProtoReflect.Descriptor instead.
func (*OpenRequest) GetError ¶
func (x *OpenRequest) GetError() string
func (*OpenRequest) ProtoMessage ¶
func (*OpenRequest) ProtoMessage()
func (*OpenRequest) ProtoReflect ¶
func (x *OpenRequest) ProtoReflect() protoreflect.Message
func (*OpenRequest) Reset ¶
func (x *OpenRequest) Reset()
func (*OpenRequest) String ¶
func (x *OpenRequest) String() string
type OpenResponse ¶
type OpenResponse struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` Size int64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"` // contains filtered or unexported fields }
func (*OpenResponse) Descriptor
deprecated
func (*OpenResponse) Descriptor() ([]byte, []int)
Deprecated: Use OpenResponse.ProtoReflect.Descriptor instead.
func (*OpenResponse) GetAddress ¶
func (x *OpenResponse) GetAddress() string
func (*OpenResponse) GetSize ¶
func (x *OpenResponse) GetSize() int64
func (*OpenResponse) ProtoMessage ¶
func (*OpenResponse) ProtoMessage()
func (*OpenResponse) ProtoReflect ¶
func (x *OpenResponse) ProtoReflect() protoreflect.Message
func (*OpenResponse) Reset ¶
func (x *OpenResponse) Reset()
func (*OpenResponse) String ¶
func (x *OpenResponse) String() string
type Operation ¶
type Operation int32
func (Operation) Descriptor ¶
func (Operation) Descriptor() protoreflect.EnumDescriptor
func (Operation) EnumDescriptor
deprecated
func (Operation) Number ¶
func (x Operation) Number() protoreflect.EnumNumber
func (Operation) Type ¶
func (Operation) Type() protoreflect.EnumType
type OperationRequest ¶
type OperationRequest struct { Operation Operation `protobuf:"varint,1,opt,name=operation,proto3,enum=grpc_runner_v1.Operation" json:"operation,omitempty"` // Types that are assignable to Request: // // *OperationRequest_OpenRequest // *OperationRequest_InterruptRequest // *OperationRequest_CloseRequest // *OperationRequest_ProgressRequest // *OperationRequest_MetadataRequest Request isOperationRequest_Request `protobuf_oneof:"request"` // contains filtered or unexported fields }
func (*OperationRequest) Descriptor
deprecated
func (*OperationRequest) Descriptor() ([]byte, []int)
Deprecated: Use OperationRequest.ProtoReflect.Descriptor instead.
func (*OperationRequest) GetCloseRequest ¶
func (x *OperationRequest) GetCloseRequest() *CloseRequest
func (*OperationRequest) GetInterruptRequest ¶
func (x *OperationRequest) GetInterruptRequest() *InterruptRequest
func (*OperationRequest) GetMetadataRequest ¶
func (x *OperationRequest) GetMetadataRequest() *MetadataRequest
func (*OperationRequest) GetOpenRequest ¶
func (x *OperationRequest) GetOpenRequest() *OpenRequest
func (*OperationRequest) GetOperation ¶
func (x *OperationRequest) GetOperation() Operation
func (*OperationRequest) GetProgressRequest ¶
func (x *OperationRequest) GetProgressRequest() *ProgressRequest
func (*OperationRequest) GetRequest ¶
func (m *OperationRequest) GetRequest() isOperationRequest_Request
func (*OperationRequest) ProtoMessage ¶
func (*OperationRequest) ProtoMessage()
func (*OperationRequest) ProtoReflect ¶
func (x *OperationRequest) ProtoReflect() protoreflect.Message
func (*OperationRequest) Reset ¶
func (x *OperationRequest) Reset()
func (*OperationRequest) String ¶
func (x *OperationRequest) String() string
type OperationRequest_CloseRequest ¶
type OperationRequest_CloseRequest struct {
CloseRequest *CloseRequest `protobuf:"bytes,5,opt,name=close_request,json=closeRequest,proto3,oneof"`
}
type OperationRequest_InterruptRequest ¶
type OperationRequest_InterruptRequest struct {
InterruptRequest *InterruptRequest `protobuf:"bytes,4,opt,name=interrupt_request,json=interruptRequest,proto3,oneof"`
}
type OperationRequest_MetadataRequest ¶
type OperationRequest_MetadataRequest struct {
MetadataRequest *MetadataRequest `protobuf:"bytes,7,opt,name=metadata_request,json=metadataRequest,proto3,oneof"`
}
type OperationRequest_OpenRequest ¶
type OperationRequest_OpenRequest struct {
OpenRequest *OpenRequest `protobuf:"bytes,2,opt,name=open_request,json=openRequest,proto3,oneof"`
}
type OperationRequest_ProgressRequest ¶
type OperationRequest_ProgressRequest struct {
ProgressRequest *ProgressRequest `protobuf:"bytes,6,opt,name=progress_request,json=progressRequest,proto3,oneof"`
}
type OperationResponse ¶
type OperationResponse struct { Operation Operation `protobuf:"varint,1,opt,name=operation,proto3,enum=grpc_runner_v1.Operation" json:"operation,omitempty"` // Types that are assignable to Response: // // *OperationResponse_OpenResponse // *OperationResponse_InterruptResponse // *OperationResponse_CloseResponse // *OperationResponse_ProgressResponse // *OperationResponse_MetadataResponse Response isOperationResponse_Response `protobuf_oneof:"response"` // contains filtered or unexported fields }
func (*OperationResponse) Descriptor
deprecated
func (*OperationResponse) Descriptor() ([]byte, []int)
Deprecated: Use OperationResponse.ProtoReflect.Descriptor instead.
func (*OperationResponse) GetCloseResponse ¶
func (x *OperationResponse) GetCloseResponse() *CloseResponse
func (*OperationResponse) GetInterruptResponse ¶
func (x *OperationResponse) GetInterruptResponse() *InterruptResponse
func (*OperationResponse) GetMetadataResponse ¶
func (x *OperationResponse) GetMetadataResponse() *MetadataResponse
func (*OperationResponse) GetOpenResponse ¶
func (x *OperationResponse) GetOpenResponse() *OpenResponse
func (*OperationResponse) GetOperation ¶
func (x *OperationResponse) GetOperation() Operation
func (*OperationResponse) GetProgressResponse ¶
func (x *OperationResponse) GetProgressResponse() *ProgressResponse
func (*OperationResponse) GetResponse ¶
func (m *OperationResponse) GetResponse() isOperationResponse_Response
func (*OperationResponse) ProtoMessage ¶
func (*OperationResponse) ProtoMessage()
func (*OperationResponse) ProtoReflect ¶
func (x *OperationResponse) ProtoReflect() protoreflect.Message
func (*OperationResponse) Reset ¶
func (x *OperationResponse) Reset()
func (*OperationResponse) String ¶
func (x *OperationResponse) String() string
type OperationResponse_CloseResponse ¶
type OperationResponse_CloseResponse struct {
CloseResponse *CloseResponse `protobuf:"bytes,5,opt,name=close_response,json=closeResponse,proto3,oneof"`
}
type OperationResponse_InterruptResponse ¶
type OperationResponse_InterruptResponse struct {
InterruptResponse *InterruptResponse `protobuf:"bytes,4,opt,name=interrupt_response,json=interruptResponse,proto3,oneof"`
}
type OperationResponse_MetadataResponse ¶
type OperationResponse_MetadataResponse struct {
MetadataResponse *MetadataResponse `protobuf:"bytes,7,opt,name=metadata_response,json=metadataResponse,proto3,oneof"`
}
type OperationResponse_OpenResponse ¶
type OperationResponse_OpenResponse struct {
OpenResponse *OpenResponse `protobuf:"bytes,2,opt,name=open_response,json=openResponse,proto3,oneof"`
}
type OperationResponse_ProgressResponse ¶
type OperationResponse_ProgressResponse struct {
ProgressResponse *ProgressResponse `protobuf:"bytes,6,opt,name=progress_response,json=progressResponse,proto3,oneof"`
}
type ProgressRequest ¶
type ProgressRequest struct { Type ProgressRequest_Type `protobuf:"varint,1,opt,name=type,proto3,enum=grpc_runner_v1.ProgressRequest_Type" json:"type,omitempty"` Percentage float64 `protobuf:"fixed64,2,opt,name=percentage,proto3" json:"percentage,omitempty"` Speed float64 `protobuf:"fixed64,3,opt,name=speed,proto3" json:"speed,omitempty"` CurrentDuration *float64 `protobuf:"fixed64,4,opt,name=current_duration,json=currentDuration,proto3,oneof" json:"current_duration,omitempty"` Duration *float64 `protobuf:"fixed64,5,opt,name=duration,proto3,oneof" json:"duration,omitempty"` CurrentFilesize *float64 `protobuf:"fixed64,6,opt,name=current_filesize,json=currentFilesize,proto3,oneof" json:"current_filesize,omitempty"` Filesize *float64 `protobuf:"fixed64,7,opt,name=filesize,proto3,oneof" json:"filesize,omitempty"` // contains filtered or unexported fields }
func (*ProgressRequest) Descriptor
deprecated
func (*ProgressRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProgressRequest.ProtoReflect.Descriptor instead.
func (*ProgressRequest) GetCurrentDuration ¶
func (x *ProgressRequest) GetCurrentDuration() float64
func (*ProgressRequest) GetCurrentFilesize ¶
func (x *ProgressRequest) GetCurrentFilesize() float64
func (*ProgressRequest) GetDuration ¶
func (x *ProgressRequest) GetDuration() float64
func (*ProgressRequest) GetFilesize ¶
func (x *ProgressRequest) GetFilesize() float64
func (*ProgressRequest) GetPercentage ¶
func (x *ProgressRequest) GetPercentage() float64
func (*ProgressRequest) GetSpeed ¶
func (x *ProgressRequest) GetSpeed() float64
func (*ProgressRequest) GetType ¶
func (x *ProgressRequest) GetType() ProgressRequest_Type
func (*ProgressRequest) ProtoMessage ¶
func (*ProgressRequest) ProtoMessage()
func (*ProgressRequest) ProtoReflect ¶
func (x *ProgressRequest) ProtoReflect() protoreflect.Message
func (*ProgressRequest) Reset ¶
func (x *ProgressRequest) Reset()
func (*ProgressRequest) String ¶
func (x *ProgressRequest) String() string
type ProgressRequest_Type ¶
type ProgressRequest_Type int32
const ( ProgressRequest_DOWNLOAD ProgressRequest_Type = 0 ProgressRequest_METADATA ProgressRequest_Type = 1 ProgressRequest_TRANSCODE ProgressRequest_Type = 2 ProgressRequest_UPLOAD ProgressRequest_Type = 3 )
func (ProgressRequest_Type) Descriptor ¶
func (ProgressRequest_Type) Descriptor() protoreflect.EnumDescriptor
func (ProgressRequest_Type) Enum ¶
func (x ProgressRequest_Type) Enum() *ProgressRequest_Type
func (ProgressRequest_Type) EnumDescriptor
deprecated
func (ProgressRequest_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use ProgressRequest_Type.Descriptor instead.
func (ProgressRequest_Type) Number ¶
func (x ProgressRequest_Type) Number() protoreflect.EnumNumber
func (ProgressRequest_Type) String ¶
func (x ProgressRequest_Type) String() string
func (ProgressRequest_Type) Type ¶
func (ProgressRequest_Type) Type() protoreflect.EnumType
type ProgressResponse ¶
type ProgressResponse struct {
// contains filtered or unexported fields
}
func (*ProgressResponse) Descriptor
deprecated
func (*ProgressResponse) Descriptor() ([]byte, []int)
Deprecated: Use ProgressResponse.ProtoReflect.Descriptor instead.
func (*ProgressResponse) ProtoMessage ¶
func (*ProgressResponse) ProtoMessage()
func (*ProgressResponse) ProtoReflect ¶
func (x *ProgressResponse) ProtoReflect() protoreflect.Message
func (*ProgressResponse) Reset ¶
func (x *ProgressResponse) Reset()
func (*ProgressResponse) String ¶
func (x *ProgressResponse) String() string
type RunnerServiceClient ¶
type RunnerServiceClient interface { Auth(ctx context.Context, in *AuthRequest, opts ...grpc.CallOption) (*AuthResponse, error) Stream(ctx context.Context, in *StreamRequest, opts ...grpc.CallOption) (*StreamResponse, error) Operation(ctx context.Context, opts ...grpc.CallOption) (RunnerService_OperationClient, error) }
RunnerServiceClient is the client API for RunnerService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewRunnerServiceClient ¶
func NewRunnerServiceClient(cc grpc.ClientConnInterface) RunnerServiceClient
type RunnerServiceServer ¶
type RunnerServiceServer interface { Auth(context.Context, *AuthRequest) (*AuthResponse, error) Stream(context.Context, *StreamRequest) (*StreamResponse, error) Operation(RunnerService_OperationServer) error // contains filtered or unexported methods }
RunnerServiceServer is the server API for RunnerService service. All implementations must embed UnimplementedRunnerServiceServer for forward compatibility
type RunnerService_OperationClient ¶
type RunnerService_OperationClient interface { Send(*OperationRequest) error Recv() (*OperationResponse, error) grpc.ClientStream }
type RunnerService_OperationServer ¶
type RunnerService_OperationServer interface { Send(*OperationResponse) error Recv() (*OperationRequest, error) grpc.ServerStream }
type StreamRequest ¶
type StreamRequest struct { Stream StreamType `protobuf:"varint,1,opt,name=stream,proto3,enum=grpc_runner_v1.StreamType" json:"stream,omitempty"` Start int64 `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"` End int64 `protobuf:"varint,3,opt,name=end,proto3" json:"end,omitempty"` Size int64 `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"` Content []byte `protobuf:"bytes,5,opt,name=content,proto3" json:"content,omitempty"` Offset int64 `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"` Adler32 uint32 `protobuf:"fixed32,7,opt,name=adler32,proto3" json:"adler32,omitempty"` // contains filtered or unexported fields }
func (*StreamRequest) Descriptor
deprecated
func (*StreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamRequest.ProtoReflect.Descriptor instead.
func (*StreamRequest) GetAdler32 ¶
func (x *StreamRequest) GetAdler32() uint32
func (*StreamRequest) GetContent ¶
func (x *StreamRequest) GetContent() []byte
func (*StreamRequest) GetEnd ¶
func (x *StreamRequest) GetEnd() int64
func (*StreamRequest) GetOffset ¶
func (x *StreamRequest) GetOffset() int64
func (*StreamRequest) GetSize ¶
func (x *StreamRequest) GetSize() int64
func (*StreamRequest) GetStart ¶
func (x *StreamRequest) GetStart() int64
func (*StreamRequest) GetStream ¶
func (x *StreamRequest) GetStream() StreamType
func (*StreamRequest) ProtoMessage ¶
func (*StreamRequest) ProtoMessage()
func (*StreamRequest) ProtoReflect ¶
func (x *StreamRequest) ProtoReflect() protoreflect.Message
func (*StreamRequest) Reset ¶
func (x *StreamRequest) Reset()
func (*StreamRequest) String ¶
func (x *StreamRequest) String() string
type StreamResponse ¶
type StreamResponse struct { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Stream StreamType `protobuf:"varint,2,opt,name=stream,proto3,enum=grpc_runner_v1.StreamType" json:"stream,omitempty"` Start int64 `protobuf:"varint,3,opt,name=start,proto3" json:"start,omitempty"` End int64 `protobuf:"varint,4,opt,name=end,proto3" json:"end,omitempty"` // contains filtered or unexported fields }
func (*StreamResponse) Descriptor
deprecated
func (*StreamResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamResponse.ProtoReflect.Descriptor instead.
func (*StreamResponse) GetEnd ¶
func (x *StreamResponse) GetEnd() int64
func (*StreamResponse) GetError ¶
func (x *StreamResponse) GetError() string
func (*StreamResponse) GetStart ¶
func (x *StreamResponse) GetStart() int64
func (*StreamResponse) GetStream ¶
func (x *StreamResponse) GetStream() StreamType
func (*StreamResponse) ProtoMessage ¶
func (*StreamResponse) ProtoMessage()
func (*StreamResponse) ProtoReflect ¶
func (x *StreamResponse) ProtoReflect() protoreflect.Message
func (*StreamResponse) Reset ¶
func (x *StreamResponse) Reset()
func (*StreamResponse) String ¶
func (x *StreamResponse) String() string
type StreamType ¶
type StreamType int32
const ( StreamType_IMAGE StreamType = 0 StreamType_VIDEO StreamType = 1 )
func (StreamType) Descriptor ¶
func (StreamType) Descriptor() protoreflect.EnumDescriptor
func (StreamType) Enum ¶
func (x StreamType) Enum() *StreamType
func (StreamType) EnumDescriptor
deprecated
func (StreamType) EnumDescriptor() ([]byte, []int)
Deprecated: Use StreamType.Descriptor instead.
func (StreamType) Number ¶
func (x StreamType) Number() protoreflect.EnumNumber
func (StreamType) String ¶
func (x StreamType) String() string
func (StreamType) Type ¶
func (StreamType) Type() protoreflect.EnumType
type UnimplementedRunnerServiceServer ¶
type UnimplementedRunnerServiceServer struct { }
UnimplementedRunnerServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedRunnerServiceServer) Auth ¶
func (UnimplementedRunnerServiceServer) Auth(context.Context, *AuthRequest) (*AuthResponse, error)
func (UnimplementedRunnerServiceServer) Operation ¶
func (UnimplementedRunnerServiceServer) Operation(RunnerService_OperationServer) error
func (UnimplementedRunnerServiceServer) Stream ¶
func (UnimplementedRunnerServiceServer) Stream(context.Context, *StreamRequest) (*StreamResponse, error)
type UnsafeRunnerServiceServer ¶
type UnsafeRunnerServiceServer interface {
// contains filtered or unexported methods
}
UnsafeRunnerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RunnerServiceServer will result in compilation errors.