Documentation
¶
Index ¶
- Variables
- func RegisterCliServiceServer(s grpc.ServiceRegistrar, srv CliServiceServer)
- func RegisterDistributorServiceServer(s grpc.ServiceRegistrar, srv DistributorServiceServer)
- type AudioCodec
- type AudioSettings
- type CliServiceClient
- type CliServiceServer
- type CliService_ProgressClient
- type CliService_ProgressServer
- type ClusterClientOffer
- func (*ClusterClientOffer) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterClientOffer) GetMaxConcurrentJobs() int64
- func (*ClusterClientOffer) ProtoMessage()
- func (x *ClusterClientOffer) ProtoReflect() protoreflect.Message
- func (x *ClusterClientOffer) Reset()
- func (x *ClusterClientOffer) String() string
- type DistributorServiceClient
- type DistributorServiceServer
- type DistributorService_JoinClusterClient
- type DistributorService_JoinClusterServer
- type Empty
- type Job
- func (*Job) Descriptor() ([]byte, []int)deprecated
- func (x *Job) GetId() string
- func (x *Job) GetInputFileData() []byte
- func (x *Job) GetInputFileName() string
- func (x *Job) GetReferenceNumber() int64
- func (x *Job) GetTranscodingSettings() *TranscodingSettings
- func (*Job) ProtoMessage()
- func (x *Job) ProtoReflect() protoreflect.Message
- func (x *Job) Reset()
- func (x *Job) String() string
- type MediaFileType
- func (MediaFileType) Descriptor() protoreflect.EnumDescriptor
- func (x MediaFileType) Enum() *MediaFileType
- func (MediaFileType) EnumDescriptor() ([]byte, []int)deprecated
- func (x MediaFileType) Number() protoreflect.EnumNumber
- func (x MediaFileType) String() string
- func (MediaFileType) Type() protoreflect.EnumType
- type ProgressRequest
- type ProgressResponse
- func (*ProgressResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ProgressResponse) GetProgress() float32
- func (x *ProgressResponse) GetState() ProgressState
- func (*ProgressResponse) ProtoMessage()
- func (x *ProgressResponse) ProtoReflect() protoreflect.Message
- func (x *ProgressResponse) Reset()
- func (x *ProgressResponse) String() string
- type ProgressState
- func (ProgressState) Descriptor() protoreflect.EnumDescriptor
- func (x ProgressState) Enum() *ProgressState
- func (ProgressState) EnumDescriptor() ([]byte, []int)deprecated
- func (x ProgressState) Number() protoreflect.EnumNumber
- func (x ProgressState) String() string
- func (ProgressState) Type() protoreflect.EnumType
- type Result
- func (*Result) Descriptor() ([]byte, []int)deprecated
- func (x *Result) GetJobId() string
- func (x *Result) GetJobReferenceNumber() int64
- func (x *Result) GetOutputFileData() []byte
- func (x *Result) GetStatusCode() UploadStatusCode
- func (*Result) ProtoMessage()
- func (x *Result) ProtoReflect() protoreflect.Message
- func (x *Result) Reset()
- func (x *Result) String() string
- type RetrieveRequest
- type RetrieveResponse
- func (*RetrieveResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RetrieveResponse) GetOutputFileData() []byte
- func (x *RetrieveResponse) GetOutputFileName() string
- func (*RetrieveResponse) ProtoMessage()
- func (x *RetrieveResponse) ProtoReflect() protoreflect.Message
- func (x *RetrieveResponse) Reset()
- func (x *RetrieveResponse) String() string
- type TranscodeRequest
- func (*TranscodeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TranscodeRequest) GetInputFileData() []byte
- func (x *TranscodeRequest) GetInputFileName() string
- func (x *TranscodeRequest) GetTranscodingSettings() *TranscodingSettings
- func (*TranscodeRequest) ProtoMessage()
- func (x *TranscodeRequest) ProtoReflect() protoreflect.Message
- func (x *TranscodeRequest) Reset()
- func (x *TranscodeRequest) String() string
- type TranscodeResponse
- func (*TranscodeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TranscodeResponse) GetStatusCode() UploadStatusCode
- func (x *TranscodeResponse) GetUuid() string
- func (*TranscodeResponse) ProtoMessage()
- func (x *TranscodeResponse) ProtoReflect() protoreflect.Message
- func (x *TranscodeResponse) Reset()
- func (x *TranscodeResponse) String() string
- type TranscodingSettings
- func (*TranscodingSettings) Descriptor() ([]byte, []int)deprecated
- func (x *TranscodingSettings) GetAudioSettings() *AudioSettings
- func (x *TranscodingSettings) GetMediaFileType() MediaFileType
- func (x *TranscodingSettings) GetVideoSettings() *VideoSettings
- func (*TranscodingSettings) ProtoMessage()
- func (x *TranscodingSettings) ProtoReflect() protoreflect.Message
- func (x *TranscodingSettings) Reset()
- func (x *TranscodingSettings) String() string
- type UnimplementedCliServiceServer
- func (UnimplementedCliServiceServer) Progress(*ProgressRequest, CliService_ProgressServer) error
- func (UnimplementedCliServiceServer) Retrieve(context.Context, *RetrieveRequest) (*RetrieveResponse, error)
- func (UnimplementedCliServiceServer) Transcode(context.Context, *TranscodeRequest) (*TranscodeResponse, error)
- type UnimplementedDistributorServiceServer
- type UnsafeCliServiceServer
- type UnsafeDistributorServiceServer
- type UploadStatusCode
- func (UploadStatusCode) Descriptor() protoreflect.EnumDescriptor
- func (x UploadStatusCode) Enum() *UploadStatusCode
- func (UploadStatusCode) EnumDescriptor() ([]byte, []int)deprecated
- func (x UploadStatusCode) Number() protoreflect.EnumNumber
- func (x UploadStatusCode) String() string
- func (UploadStatusCode) Type() protoreflect.EnumType
- type VideoCodec
- type VideoSettings
Constants ¶
This section is empty.
Variables ¶
var ( VideoCodec_name = map[int32]string{ 0: "Libx264", 1: "Libx265", 2: "Vpx", 3: "Vp8", 4: "Vp9", } VideoCodec_value = map[string]int32{ "Libx264": 0, "Libx265": 1, "Vpx": 2, "Vp8": 3, "Vp9": 4, } )
Enum value maps for VideoCodec.
var ( AudioCodec_name = map[int32]string{ 0: "Aac", 1: "Ac3", 2: "Opus", } AudioCodec_value = map[string]int32{ "Aac": 0, "Ac3": 1, "Opus": 2, } )
Enum value maps for AudioCodec.
var ( MediaFileType_name = map[int32]string{ 0: "Mp4", 1: "Mkv", 2: "Webm", } MediaFileType_value = map[string]int32{ "Mp4": 0, "Mkv": 1, "Webm": 2, } )
Enum value maps for MediaFileType.
var ( UploadStatusCode_name = map[int32]string{ 0: "Unknown", 1: "Ok", 2: "Failed", } UploadStatusCode_value = map[string]int32{ "Unknown": 0, "Ok": 1, "Failed": 2, } )
Enum value maps for UploadStatusCode.
var ( ProgressState_name = map[int32]string{ 0: "Distributing", 1: "Transcoding", } ProgressState_value = map[string]int32{ "Distributing": 0, "Transcoding": 1, } )
Enum value maps for ProgressState.
var CliService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "CliService", HandlerType: (*CliServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Transcode", Handler: _CliService_Transcode_Handler, }, { MethodName: "Retrieve", Handler: _CliService_Retrieve_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Progress", Handler: _CliService_Progress_Handler, ServerStreams: true, }, }, Metadata: "distributor-service.proto", }
CliService_ServiceDesc is the grpc.ServiceDesc for CliService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var DistributorService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "DistributorService", HandlerType: (*DistributorServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "UploadResult", Handler: _DistributorService_UploadResult_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "JoinCluster", Handler: _DistributorService_JoinCluster_Handler, ServerStreams: true, }, }, Metadata: "distributor-service.proto", }
DistributorService_ServiceDesc is the grpc.ServiceDesc for DistributorService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_distributor_service_proto protoreflect.FileDescriptor
Functions ¶
func RegisterCliServiceServer ¶
func RegisterCliServiceServer(s grpc.ServiceRegistrar, srv CliServiceServer)
func RegisterDistributorServiceServer ¶
func RegisterDistributorServiceServer(s grpc.ServiceRegistrar, srv DistributorServiceServer)
Types ¶
type AudioCodec ¶
type AudioCodec int32
const ( AudioCodec_Aac AudioCodec = 0 AudioCodec_Ac3 AudioCodec = 1 AudioCodec_Opus AudioCodec = 2 )
func (AudioCodec) Descriptor ¶
func (AudioCodec) Descriptor() protoreflect.EnumDescriptor
func (AudioCodec) Enum ¶
func (x AudioCodec) Enum() *AudioCodec
func (AudioCodec) EnumDescriptor
deprecated
func (AudioCodec) EnumDescriptor() ([]byte, []int)
Deprecated: Use AudioCodec.Descriptor instead.
func (AudioCodec) Number ¶
func (x AudioCodec) Number() protoreflect.EnumNumber
func (AudioCodec) String ¶
func (x AudioCodec) String() string
func (AudioCodec) Type ¶
func (AudioCodec) Type() protoreflect.EnumType
type AudioSettings ¶
type AudioSettings struct {
Codec AudioCodec `protobuf:"varint,2,opt,name=codec,proto3,enum=AudioCodec" json:"codec,omitempty"`
// contains filtered or unexported fields
}
func (*AudioSettings) Descriptor
deprecated
func (*AudioSettings) Descriptor() ([]byte, []int)
Deprecated: Use AudioSettings.ProtoReflect.Descriptor instead.
func (*AudioSettings) GetCodec ¶
func (x *AudioSettings) GetCodec() AudioCodec
func (*AudioSettings) ProtoMessage ¶
func (*AudioSettings) ProtoMessage()
func (*AudioSettings) ProtoReflect ¶
func (x *AudioSettings) ProtoReflect() protoreflect.Message
func (*AudioSettings) Reset ¶
func (x *AudioSettings) Reset()
func (*AudioSettings) String ¶
func (x *AudioSettings) String() string
type CliServiceClient ¶
type CliServiceClient interface {
Transcode(ctx context.Context, in *TranscodeRequest, opts ...grpc.CallOption) (*TranscodeResponse, error)
Progress(ctx context.Context, in *ProgressRequest, opts ...grpc.CallOption) (CliService_ProgressClient, error)
Retrieve(ctx context.Context, in *RetrieveRequest, opts ...grpc.CallOption) (*RetrieveResponse, error)
}
CliServiceClient is the client API for CliService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewCliServiceClient ¶
func NewCliServiceClient(cc grpc.ClientConnInterface) CliServiceClient
type CliServiceServer ¶
type CliServiceServer interface {
Transcode(context.Context, *TranscodeRequest) (*TranscodeResponse, error)
Progress(*ProgressRequest, CliService_ProgressServer) error
Retrieve(context.Context, *RetrieveRequest) (*RetrieveResponse, error)
// contains filtered or unexported methods
}
CliServiceServer is the server API for CliService service. All implementations must embed UnimplementedCliServiceServer for forward compatibility
type CliService_ProgressClient ¶
type CliService_ProgressClient interface {
Recv() (*ProgressResponse, error)
grpc.ClientStream
}
type CliService_ProgressServer ¶
type CliService_ProgressServer interface {
Send(*ProgressResponse) error
grpc.ServerStream
}
type ClusterClientOffer ¶
type ClusterClientOffer struct {
MaxConcurrentJobs int64 `protobuf:"varint,1,opt,name=max_concurrent_jobs,json=maxConcurrentJobs,proto3" json:"max_concurrent_jobs,omitempty"`
// contains filtered or unexported fields
}
func (*ClusterClientOffer) Descriptor
deprecated
func (*ClusterClientOffer) Descriptor() ([]byte, []int)
Deprecated: Use ClusterClientOffer.ProtoReflect.Descriptor instead.
func (*ClusterClientOffer) GetMaxConcurrentJobs ¶
func (x *ClusterClientOffer) GetMaxConcurrentJobs() int64
func (*ClusterClientOffer) ProtoMessage ¶
func (*ClusterClientOffer) ProtoMessage()
func (*ClusterClientOffer) ProtoReflect ¶
func (x *ClusterClientOffer) ProtoReflect() protoreflect.Message
func (*ClusterClientOffer) Reset ¶
func (x *ClusterClientOffer) Reset()
func (*ClusterClientOffer) String ¶
func (x *ClusterClientOffer) String() string
type DistributorServiceClient ¶
type DistributorServiceClient interface {
JoinCluster(ctx context.Context, in *ClusterClientOffer, opts ...grpc.CallOption) (DistributorService_JoinClusterClient, error)
UploadResult(ctx context.Context, in *Result, opts ...grpc.CallOption) (*Empty, error)
}
DistributorServiceClient is the client API for DistributorService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewDistributorServiceClient ¶
func NewDistributorServiceClient(cc grpc.ClientConnInterface) DistributorServiceClient
type DistributorServiceServer ¶
type DistributorServiceServer interface {
JoinCluster(*ClusterClientOffer, DistributorService_JoinClusterServer) error
UploadResult(context.Context, *Result) (*Empty, error)
// contains filtered or unexported methods
}
DistributorServiceServer is the server API for DistributorService service. All implementations must embed UnimplementedDistributorServiceServer for forward compatibility
type DistributorService_JoinClusterClient ¶
type DistributorService_JoinClusterClient interface {
Recv() (*Job, error)
grpc.ClientStream
}
type DistributorService_JoinClusterServer ¶
type DistributorService_JoinClusterServer interface {
Send(*Job) error
grpc.ServerStream
}
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor
deprecated
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
type Job ¶
type Job struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
ReferenceNumber int64 `protobuf:"varint,2,opt,name=reference_number,json=referenceNumber,proto3" json:"reference_number,omitempty"`
TranscodingSettings *TranscodingSettings `protobuf:"bytes,3,opt,name=transcoding_settings,json=transcodingSettings,proto3" json:"transcoding_settings,omitempty"`
InputFileName string `protobuf:"bytes,4,opt,name=input_file_name,json=inputFileName,proto3" json:"input_file_name,omitempty"`
InputFileData []byte `protobuf:"bytes,5,opt,name=input_file_data,json=inputFileData,proto3" json:"input_file_data,omitempty"`
// contains filtered or unexported fields
}
func (*Job) Descriptor
deprecated
func (*Job) GetInputFileData ¶
func (*Job) GetInputFileName ¶
func (*Job) GetReferenceNumber ¶
func (*Job) GetTranscodingSettings ¶
func (x *Job) GetTranscodingSettings() *TranscodingSettings
func (*Job) ProtoMessage ¶
func (*Job) ProtoMessage()
func (*Job) ProtoReflect ¶
func (x *Job) ProtoReflect() protoreflect.Message
type MediaFileType ¶
type MediaFileType int32
const ( MediaFileType_Mp4 MediaFileType = 0 MediaFileType_Mkv MediaFileType = 1 MediaFileType_Webm MediaFileType = 2 )
func (MediaFileType) Descriptor ¶
func (MediaFileType) Descriptor() protoreflect.EnumDescriptor
func (MediaFileType) Enum ¶
func (x MediaFileType) Enum() *MediaFileType
func (MediaFileType) EnumDescriptor
deprecated
func (MediaFileType) EnumDescriptor() ([]byte, []int)
Deprecated: Use MediaFileType.Descriptor instead.
func (MediaFileType) Number ¶
func (x MediaFileType) Number() protoreflect.EnumNumber
func (MediaFileType) String ¶
func (x MediaFileType) String() string
func (MediaFileType) Type ¶
func (MediaFileType) Type() protoreflect.EnumType
type ProgressRequest ¶
type ProgressRequest struct {
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
// contains filtered or unexported fields
}
func (*ProgressRequest) Descriptor
deprecated
func (*ProgressRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProgressRequest.ProtoReflect.Descriptor instead.
func (*ProgressRequest) GetUuid ¶
func (x *ProgressRequest) GetUuid() string
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 ProgressResponse ¶
type ProgressResponse struct {
State ProgressState `protobuf:"varint,1,opt,name=state,proto3,enum=ProgressState" json:"state,omitempty"`
Progress float32 `protobuf:"fixed32,2,opt,name=progress,proto3" json:"progress,omitempty"`
// contains filtered or unexported fields
}
func (*ProgressResponse) Descriptor
deprecated
func (*ProgressResponse) Descriptor() ([]byte, []int)
Deprecated: Use ProgressResponse.ProtoReflect.Descriptor instead.
func (*ProgressResponse) GetProgress ¶
func (x *ProgressResponse) GetProgress() float32
func (*ProgressResponse) GetState ¶
func (x *ProgressResponse) GetState() ProgressState
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 ProgressState ¶
type ProgressState int32
const ( ProgressState_Distributing ProgressState = 0 ProgressState_Transcoding ProgressState = 1 )
func (ProgressState) Descriptor ¶
func (ProgressState) Descriptor() protoreflect.EnumDescriptor
func (ProgressState) Enum ¶
func (x ProgressState) Enum() *ProgressState
func (ProgressState) EnumDescriptor
deprecated
func (ProgressState) EnumDescriptor() ([]byte, []int)
Deprecated: Use ProgressState.Descriptor instead.
func (ProgressState) Number ¶
func (x ProgressState) Number() protoreflect.EnumNumber
func (ProgressState) String ¶
func (x ProgressState) String() string
func (ProgressState) Type ¶
func (ProgressState) Type() protoreflect.EnumType
type Result ¶
type Result struct {
JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
JobReferenceNumber int64 `protobuf:"varint,2,opt,name=job_reference_number,json=jobReferenceNumber,proto3" json:"job_reference_number,omitempty"`
StatusCode UploadStatusCode `protobuf:"varint,3,opt,name=status_code,json=statusCode,proto3,enum=UploadStatusCode" json:"status_code,omitempty"`
OutputFileData []byte `protobuf:"bytes,4,opt,name=output_file_data,json=outputFileData,proto3" json:"output_file_data,omitempty"`
// contains filtered or unexported fields
}
func (*Result) Descriptor
deprecated
func (*Result) GetJobReferenceNumber ¶
func (*Result) GetOutputFileData ¶
func (*Result) GetStatusCode ¶
func (x *Result) GetStatusCode() UploadStatusCode
func (*Result) ProtoMessage ¶
func (*Result) ProtoMessage()
func (*Result) ProtoReflect ¶
func (x *Result) ProtoReflect() protoreflect.Message
type RetrieveRequest ¶
type RetrieveRequest struct {
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
// contains filtered or unexported fields
}
func (*RetrieveRequest) Descriptor
deprecated
func (*RetrieveRequest) Descriptor() ([]byte, []int)
Deprecated: Use RetrieveRequest.ProtoReflect.Descriptor instead.
func (*RetrieveRequest) GetUuid ¶
func (x *RetrieveRequest) GetUuid() string
func (*RetrieveRequest) ProtoMessage ¶
func (*RetrieveRequest) ProtoMessage()
func (*RetrieveRequest) ProtoReflect ¶
func (x *RetrieveRequest) ProtoReflect() protoreflect.Message
func (*RetrieveRequest) Reset ¶
func (x *RetrieveRequest) Reset()
func (*RetrieveRequest) String ¶
func (x *RetrieveRequest) String() string
type RetrieveResponse ¶
type RetrieveResponse struct {
OutputFileName string `protobuf:"bytes,1,opt,name=output_file_name,json=outputFileName,proto3" json:"output_file_name,omitempty"`
OutputFileData []byte `protobuf:"bytes,2,opt,name=output_file_data,json=outputFileData,proto3" json:"output_file_data,omitempty"`
// contains filtered or unexported fields
}
func (*RetrieveResponse) Descriptor
deprecated
func (*RetrieveResponse) Descriptor() ([]byte, []int)
Deprecated: Use RetrieveResponse.ProtoReflect.Descriptor instead.
func (*RetrieveResponse) GetOutputFileData ¶
func (x *RetrieveResponse) GetOutputFileData() []byte
func (*RetrieveResponse) GetOutputFileName ¶
func (x *RetrieveResponse) GetOutputFileName() string
func (*RetrieveResponse) ProtoMessage ¶
func (*RetrieveResponse) ProtoMessage()
func (*RetrieveResponse) ProtoReflect ¶
func (x *RetrieveResponse) ProtoReflect() protoreflect.Message
func (*RetrieveResponse) Reset ¶
func (x *RetrieveResponse) Reset()
func (*RetrieveResponse) String ¶
func (x *RetrieveResponse) String() string
type TranscodeRequest ¶
type TranscodeRequest struct {
InputFileName string `protobuf:"bytes,1,opt,name=input_file_name,json=inputFileName,proto3" json:"input_file_name,omitempty"`
InputFileData []byte `protobuf:"bytes,2,opt,name=input_file_data,json=inputFileData,proto3" json:"input_file_data,omitempty"`
TranscodingSettings *TranscodingSettings `protobuf:"bytes,3,opt,name=transcoding_settings,json=transcodingSettings,proto3" json:"transcoding_settings,omitempty"`
// contains filtered or unexported fields
}
func (*TranscodeRequest) Descriptor
deprecated
func (*TranscodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use TranscodeRequest.ProtoReflect.Descriptor instead.
func (*TranscodeRequest) GetInputFileData ¶
func (x *TranscodeRequest) GetInputFileData() []byte
func (*TranscodeRequest) GetInputFileName ¶
func (x *TranscodeRequest) GetInputFileName() string
func (*TranscodeRequest) GetTranscodingSettings ¶
func (x *TranscodeRequest) GetTranscodingSettings() *TranscodingSettings
func (*TranscodeRequest) ProtoMessage ¶
func (*TranscodeRequest) ProtoMessage()
func (*TranscodeRequest) ProtoReflect ¶
func (x *TranscodeRequest) ProtoReflect() protoreflect.Message
func (*TranscodeRequest) Reset ¶
func (x *TranscodeRequest) Reset()
func (*TranscodeRequest) String ¶
func (x *TranscodeRequest) String() string
type TranscodeResponse ¶
type TranscodeResponse struct {
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
StatusCode UploadStatusCode `protobuf:"varint,2,opt,name=status_code,json=statusCode,proto3,enum=UploadStatusCode" json:"status_code,omitempty"`
// contains filtered or unexported fields
}
func (*TranscodeResponse) Descriptor
deprecated
func (*TranscodeResponse) Descriptor() ([]byte, []int)
Deprecated: Use TranscodeResponse.ProtoReflect.Descriptor instead.
func (*TranscodeResponse) GetStatusCode ¶
func (x *TranscodeResponse) GetStatusCode() UploadStatusCode
func (*TranscodeResponse) GetUuid ¶
func (x *TranscodeResponse) GetUuid() string
func (*TranscodeResponse) ProtoMessage ¶
func (*TranscodeResponse) ProtoMessage()
func (*TranscodeResponse) ProtoReflect ¶
func (x *TranscodeResponse) ProtoReflect() protoreflect.Message
func (*TranscodeResponse) Reset ¶
func (x *TranscodeResponse) Reset()
func (*TranscodeResponse) String ¶
func (x *TranscodeResponse) String() string
type TranscodingSettings ¶
type TranscodingSettings struct {
VideoSettings *VideoSettings `protobuf:"bytes,1,opt,name=video_settings,json=videoSettings,proto3" json:"video_settings,omitempty"`
AudioSettings *AudioSettings `protobuf:"bytes,2,opt,name=audio_settings,json=audioSettings,proto3" json:"audio_settings,omitempty"`
MediaFileType MediaFileType `protobuf:"varint,3,opt,name=media_file_type,json=mediaFileType,proto3,enum=MediaFileType" json:"media_file_type,omitempty"`
// contains filtered or unexported fields
}
func (*TranscodingSettings) Descriptor
deprecated
func (*TranscodingSettings) Descriptor() ([]byte, []int)
Deprecated: Use TranscodingSettings.ProtoReflect.Descriptor instead.
func (*TranscodingSettings) GetAudioSettings ¶
func (x *TranscodingSettings) GetAudioSettings() *AudioSettings
func (*TranscodingSettings) GetMediaFileType ¶
func (x *TranscodingSettings) GetMediaFileType() MediaFileType
func (*TranscodingSettings) GetVideoSettings ¶
func (x *TranscodingSettings) GetVideoSettings() *VideoSettings
func (*TranscodingSettings) ProtoMessage ¶
func (*TranscodingSettings) ProtoMessage()
func (*TranscodingSettings) ProtoReflect ¶
func (x *TranscodingSettings) ProtoReflect() protoreflect.Message
func (*TranscodingSettings) Reset ¶
func (x *TranscodingSettings) Reset()
func (*TranscodingSettings) String ¶
func (x *TranscodingSettings) String() string
type UnimplementedCliServiceServer ¶
type UnimplementedCliServiceServer struct {
}
UnimplementedCliServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedCliServiceServer) Progress ¶
func (UnimplementedCliServiceServer) Progress(*ProgressRequest, CliService_ProgressServer) error
func (UnimplementedCliServiceServer) Retrieve ¶
func (UnimplementedCliServiceServer) Retrieve(context.Context, *RetrieveRequest) (*RetrieveResponse, error)
func (UnimplementedCliServiceServer) Transcode ¶
func (UnimplementedCliServiceServer) Transcode(context.Context, *TranscodeRequest) (*TranscodeResponse, error)
type UnimplementedDistributorServiceServer ¶
type UnimplementedDistributorServiceServer struct {
}
UnimplementedDistributorServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedDistributorServiceServer) JoinCluster ¶
func (UnimplementedDistributorServiceServer) JoinCluster(*ClusterClientOffer, DistributorService_JoinClusterServer) error
func (UnimplementedDistributorServiceServer) UploadResult ¶
type UnsafeCliServiceServer ¶
type UnsafeCliServiceServer interface {
// contains filtered or unexported methods
}
UnsafeCliServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CliServiceServer will result in compilation errors.
type UnsafeDistributorServiceServer ¶
type UnsafeDistributorServiceServer interface {
// contains filtered or unexported methods
}
UnsafeDistributorServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DistributorServiceServer will result in compilation errors.
type UploadStatusCode ¶
type UploadStatusCode int32
const ( UploadStatusCode_Unknown UploadStatusCode = 0 UploadStatusCode_Ok UploadStatusCode = 1 UploadStatusCode_Failed UploadStatusCode = 2 )
func (UploadStatusCode) Descriptor ¶
func (UploadStatusCode) Descriptor() protoreflect.EnumDescriptor
func (UploadStatusCode) Enum ¶
func (x UploadStatusCode) Enum() *UploadStatusCode
func (UploadStatusCode) EnumDescriptor
deprecated
func (UploadStatusCode) EnumDescriptor() ([]byte, []int)
Deprecated: Use UploadStatusCode.Descriptor instead.
func (UploadStatusCode) Number ¶
func (x UploadStatusCode) Number() protoreflect.EnumNumber
func (UploadStatusCode) String ¶
func (x UploadStatusCode) String() string
func (UploadStatusCode) Type ¶
func (UploadStatusCode) Type() protoreflect.EnumType
type VideoCodec ¶
type VideoCodec int32
const ( VideoCodec_Libx264 VideoCodec = 0 VideoCodec_Libx265 VideoCodec = 1 VideoCodec_Vpx VideoCodec = 2 VideoCodec_Vp8 VideoCodec = 3 VideoCodec_Vp9 VideoCodec = 4 )
func (VideoCodec) Descriptor ¶
func (VideoCodec) Descriptor() protoreflect.EnumDescriptor
func (VideoCodec) Enum ¶
func (x VideoCodec) Enum() *VideoCodec
func (VideoCodec) EnumDescriptor
deprecated
func (VideoCodec) EnumDescriptor() ([]byte, []int)
Deprecated: Use VideoCodec.Descriptor instead.
func (VideoCodec) Number ¶
func (x VideoCodec) Number() protoreflect.EnumNumber
func (VideoCodec) String ¶
func (x VideoCodec) String() string
func (VideoCodec) Type ¶
func (VideoCodec) Type() protoreflect.EnumType
type VideoSettings ¶
type VideoSettings struct {
Codec VideoCodec `protobuf:"varint,1,opt,name=codec,proto3,enum=VideoCodec" json:"codec,omitempty"`
// contains filtered or unexported fields
}
func (*VideoSettings) Descriptor
deprecated
func (*VideoSettings) Descriptor() ([]byte, []int)
Deprecated: Use VideoSettings.ProtoReflect.Descriptor instead.
func (*VideoSettings) GetCodec ¶
func (x *VideoSettings) GetCodec() VideoCodec
func (*VideoSettings) ProtoMessage ¶
func (*VideoSettings) ProtoMessage()
func (*VideoSettings) ProtoReflect ¶
func (x *VideoSettings) ProtoReflect() protoreflect.Message
func (*VideoSettings) Reset ¶
func (x *VideoSettings) Reset()
func (*VideoSettings) String ¶
func (x *VideoSettings) String() string