Documentation ¶
Index ¶
- Variables
- func RegisterRecoderServer(s grpc.ServiceRegistrar, srv RecoderServer)
- type CloseInputReply
- type CloseInputRequest
- type CloseOutputReply
- type CloseOutputRequest
- func (*CloseOutputRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CloseOutputRequest) GetOutputID() uint64
- func (*CloseOutputRequest) ProtoMessage()
- func (x *CloseOutputRequest) ProtoReflect() protoreflect.Message
- func (x *CloseOutputRequest) Reset()
- func (x *CloseOutputRequest) String() string
- type Error
- type GetRecoderStatsReply
- func (*GetRecoderStatsReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetRecoderStatsReply) GetBytesCountRead() uint64
- func (x *GetRecoderStatsReply) GetBytesCountWrote() uint64
- func (*GetRecoderStatsReply) ProtoMessage()
- func (x *GetRecoderStatsReply) ProtoReflect() protoreflect.Message
- func (x *GetRecoderStatsReply) Reset()
- func (x *GetRecoderStatsReply) String() string
- type GetRecoderStatsRequest
- func (*GetRecoderStatsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetRecoderStatsRequest) GetRecoderID() uint64
- func (*GetRecoderStatsRequest) ProtoMessage()
- func (x *GetRecoderStatsRequest) ProtoReflect() protoreflect.Message
- func (x *GetRecoderStatsRequest) Reset()
- func (x *GetRecoderStatsRequest) String() string
- type InputConfig
- type LoggingLevel
- func (LoggingLevel) Descriptor() protoreflect.EnumDescriptor
- func (x LoggingLevel) Enum() *LoggingLevel
- func (LoggingLevel) EnumDescriptor() ([]byte, []int)deprecated
- func (x LoggingLevel) Number() protoreflect.EnumNumber
- func (x LoggingLevel) String() string
- func (LoggingLevel) Type() protoreflect.EnumType
- type NewInputReply
- type NewInputRequest
- func (*NewInputRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NewInputRequest) GetConfig() *InputConfig
- func (x *NewInputRequest) GetPath() *ResourcePath
- func (*NewInputRequest) ProtoMessage()
- func (x *NewInputRequest) ProtoReflect() protoreflect.Message
- func (x *NewInputRequest) Reset()
- func (x *NewInputRequest) String() string
- type NewOutputReply
- type NewOutputRequest
- func (*NewOutputRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NewOutputRequest) GetConfig() *OutputConfig
- func (x *NewOutputRequest) GetPath() *ResourcePath
- func (*NewOutputRequest) ProtoMessage()
- func (x *NewOutputRequest) ProtoReflect() protoreflect.Message
- func (x *NewOutputRequest) Reset()
- func (x *NewOutputRequest) String() string
- type NewRecoderReply
- type NewRecoderRequest
- func (*NewRecoderRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NewRecoderRequest) GetConfig() *RecoderConfig
- func (*NewRecoderRequest) ProtoMessage()
- func (x *NewRecoderRequest) ProtoReflect() protoreflect.Message
- func (x *NewRecoderRequest) Reset()
- func (x *NewRecoderRequest) String() string
- type OutputConfig
- type RecoderClient
- type RecoderConfig
- type RecoderServer
- type Recoder_RecodingEndedChanClient
- type Recoder_RecodingEndedChanServer
- type RecodingEndedChanReply
- type RecodingEndedChanRequest
- func (*RecodingEndedChanRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RecodingEndedChanRequest) GetRecoderID() uint64
- func (*RecodingEndedChanRequest) ProtoMessage()
- func (x *RecodingEndedChanRequest) ProtoReflect() protoreflect.Message
- func (x *RecodingEndedChanRequest) Reset()
- func (x *RecodingEndedChanRequest) String() string
- type ResourcePath
- func (*ResourcePath) Descriptor() ([]byte, []int)deprecated
- func (m *ResourcePath) GetResourcePath() isResourcePath_ResourcePath
- func (x *ResourcePath) GetUrl() *ResourcePathURL
- func (*ResourcePath) ProtoMessage()
- func (x *ResourcePath) ProtoReflect() protoreflect.Message
- func (x *ResourcePath) Reset()
- func (x *ResourcePath) String() string
- type ResourcePathURL
- func (*ResourcePathURL) Descriptor() ([]byte, []int)deprecated
- func (x *ResourcePathURL) GetAuthKey() string
- func (x *ResourcePathURL) GetUrl() string
- func (*ResourcePathURL) ProtoMessage()
- func (x *ResourcePathURL) ProtoReflect() protoreflect.Message
- func (x *ResourcePathURL) Reset()
- func (x *ResourcePathURL) String() string
- type ResourcePath_Url
- type SetLoggingLevelReply
- type SetLoggingLevelRequest
- func (*SetLoggingLevelRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetLoggingLevelRequest) GetLevel() LoggingLevel
- func (*SetLoggingLevelRequest) ProtoMessage()
- func (x *SetLoggingLevelRequest) ProtoReflect() protoreflect.Message
- func (x *SetLoggingLevelRequest) Reset()
- func (x *SetLoggingLevelRequest) String() string
- type StartRecodingReply
- type StartRecodingRequest
- func (*StartRecodingRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartRecodingRequest) GetInputID() uint64
- func (x *StartRecodingRequest) GetOutputID() uint64
- func (x *StartRecodingRequest) GetRecoderID() uint64
- func (*StartRecodingRequest) ProtoMessage()
- func (x *StartRecodingRequest) ProtoReflect() protoreflect.Message
- func (x *StartRecodingRequest) Reset()
- func (x *StartRecodingRequest) String() string
- type UnimplementedRecoderServer
- func (UnimplementedRecoderServer) CloseInput(context.Context, *CloseInputRequest) (*CloseInputReply, error)
- func (UnimplementedRecoderServer) CloseOutput(context.Context, *CloseOutputRequest) (*CloseOutputReply, error)
- func (UnimplementedRecoderServer) GetRecoderStats(context.Context, *GetRecoderStatsRequest) (*GetRecoderStatsReply, error)
- func (UnimplementedRecoderServer) NewInput(context.Context, *NewInputRequest) (*NewInputReply, error)
- func (UnimplementedRecoderServer) NewOutput(context.Context, *NewOutputRequest) (*NewOutputReply, error)
- func (UnimplementedRecoderServer) NewRecoder(context.Context, *NewRecoderRequest) (*NewRecoderReply, error)
- func (UnimplementedRecoderServer) RecodingEndedChan(*RecodingEndedChanRequest, Recoder_RecodingEndedChanServer) error
- func (UnimplementedRecoderServer) SetLoggingLevel(context.Context, *SetLoggingLevelRequest) (*SetLoggingLevelReply, error)
- func (UnimplementedRecoderServer) StartRecoding(context.Context, *StartRecodingRequest) (*StartRecodingReply, error)
- type UnsafeRecoderServer
Constants ¶
This section is empty.
Variables ¶
var ( LoggingLevel_name = map[int32]string{ 0: "LoggingLevelNone", 1: "LoggingLevelFatal", 2: "LoggingLevelPanic", 3: "LoggingLevelError", 4: "LoggingLevelWarn", 5: "LoggingLevelInfo", 6: "LoggingLevelDebug", 7: "LoggingLevelTrace", } LoggingLevel_value = map[string]int32{ "LoggingLevelNone": 0, "LoggingLevelFatal": 1, "LoggingLevelPanic": 2, "LoggingLevelError": 3, "LoggingLevelWarn": 4, "LoggingLevelInfo": 5, "LoggingLevelDebug": 6, "LoggingLevelTrace": 7, } )
Enum value maps for LoggingLevel.
var File_recoder_proto protoreflect.FileDescriptor
var Recoder_ServiceDesc = grpc.ServiceDesc{ ServiceName: "recoder_grpc.Recoder", HandlerType: (*RecoderServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SetLoggingLevel", Handler: _Recoder_SetLoggingLevel_Handler, }, { MethodName: "NewInput", Handler: _Recoder_NewInput_Handler, }, { MethodName: "NewOutput", Handler: _Recoder_NewOutput_Handler, }, { MethodName: "NewRecoder", Handler: _Recoder_NewRecoder_Handler, }, { MethodName: "CloseInput", Handler: _Recoder_CloseInput_Handler, }, { MethodName: "CloseOutput", Handler: _Recoder_CloseOutput_Handler, }, { MethodName: "GetRecoderStats", Handler: _Recoder_GetRecoderStats_Handler, }, { MethodName: "StartRecoding", Handler: _Recoder_StartRecoding_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "RecodingEndedChan", Handler: _Recoder_RecodingEndedChan_Handler, ServerStreams: true, }, }, Metadata: "recoder.proto", }
Recoder_ServiceDesc is the grpc.ServiceDesc for Recoder service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRecoderServer ¶
func RegisterRecoderServer(s grpc.ServiceRegistrar, srv RecoderServer)
Types ¶
type CloseInputReply ¶
type CloseInputReply struct {
// contains filtered or unexported fields
}
func (*CloseInputReply) Descriptor
deprecated
func (*CloseInputReply) Descriptor() ([]byte, []int)
Deprecated: Use CloseInputReply.ProtoReflect.Descriptor instead.
func (*CloseInputReply) ProtoMessage ¶
func (*CloseInputReply) ProtoMessage()
func (*CloseInputReply) ProtoReflect ¶
func (x *CloseInputReply) ProtoReflect() protoreflect.Message
func (*CloseInputReply) Reset ¶
func (x *CloseInputReply) Reset()
func (*CloseInputReply) String ¶
func (x *CloseInputReply) String() string
type CloseInputRequest ¶
type CloseInputRequest struct { InputID uint64 `protobuf:"varint,1,opt,name=inputID,proto3" json:"inputID,omitempty"` // contains filtered or unexported fields }
func (*CloseInputRequest) Descriptor
deprecated
func (*CloseInputRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloseInputRequest.ProtoReflect.Descriptor instead.
func (*CloseInputRequest) GetInputID ¶
func (x *CloseInputRequest) GetInputID() uint64
func (*CloseInputRequest) ProtoMessage ¶
func (*CloseInputRequest) ProtoMessage()
func (*CloseInputRequest) ProtoReflect ¶
func (x *CloseInputRequest) ProtoReflect() protoreflect.Message
func (*CloseInputRequest) Reset ¶
func (x *CloseInputRequest) Reset()
func (*CloseInputRequest) String ¶
func (x *CloseInputRequest) String() string
type CloseOutputReply ¶
type CloseOutputReply struct {
// contains filtered or unexported fields
}
func (*CloseOutputReply) Descriptor
deprecated
func (*CloseOutputReply) Descriptor() ([]byte, []int)
Deprecated: Use CloseOutputReply.ProtoReflect.Descriptor instead.
func (*CloseOutputReply) ProtoMessage ¶
func (*CloseOutputReply) ProtoMessage()
func (*CloseOutputReply) ProtoReflect ¶
func (x *CloseOutputReply) ProtoReflect() protoreflect.Message
func (*CloseOutputReply) Reset ¶
func (x *CloseOutputReply) Reset()
func (*CloseOutputReply) String ¶
func (x *CloseOutputReply) String() string
type CloseOutputRequest ¶
type CloseOutputRequest struct { OutputID uint64 `protobuf:"varint,2,opt,name=outputID,proto3" json:"outputID,omitempty"` // contains filtered or unexported fields }
func (*CloseOutputRequest) Descriptor
deprecated
func (*CloseOutputRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloseOutputRequest.ProtoReflect.Descriptor instead.
func (*CloseOutputRequest) GetOutputID ¶
func (x *CloseOutputRequest) GetOutputID() uint64
func (*CloseOutputRequest) ProtoMessage ¶
func (*CloseOutputRequest) ProtoMessage()
func (*CloseOutputRequest) ProtoReflect ¶
func (x *CloseOutputRequest) ProtoReflect() protoreflect.Message
func (*CloseOutputRequest) Reset ¶
func (x *CloseOutputRequest) Reset()
func (*CloseOutputRequest) String ¶
func (x *CloseOutputRequest) String() string
type Error ¶
type Error struct { Code uint64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*Error) Descriptor
deprecated
func (*Error) GetMessage ¶
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
func (*Error) ProtoReflect ¶
func (x *Error) ProtoReflect() protoreflect.Message
type GetRecoderStatsReply ¶
type GetRecoderStatsReply struct { BytesCountRead uint64 `protobuf:"varint,1,opt,name=bytesCountRead,proto3" json:"bytesCountRead,omitempty"` BytesCountWrote uint64 `protobuf:"varint,2,opt,name=bytesCountWrote,proto3" json:"bytesCountWrote,omitempty"` // contains filtered or unexported fields }
func (*GetRecoderStatsReply) Descriptor
deprecated
func (*GetRecoderStatsReply) Descriptor() ([]byte, []int)
Deprecated: Use GetRecoderStatsReply.ProtoReflect.Descriptor instead.
func (*GetRecoderStatsReply) GetBytesCountRead ¶
func (x *GetRecoderStatsReply) GetBytesCountRead() uint64
func (*GetRecoderStatsReply) GetBytesCountWrote ¶
func (x *GetRecoderStatsReply) GetBytesCountWrote() uint64
func (*GetRecoderStatsReply) ProtoMessage ¶
func (*GetRecoderStatsReply) ProtoMessage()
func (*GetRecoderStatsReply) ProtoReflect ¶
func (x *GetRecoderStatsReply) ProtoReflect() protoreflect.Message
func (*GetRecoderStatsReply) Reset ¶
func (x *GetRecoderStatsReply) Reset()
func (*GetRecoderStatsReply) String ¶
func (x *GetRecoderStatsReply) String() string
type GetRecoderStatsRequest ¶
type GetRecoderStatsRequest struct { RecoderID uint64 `protobuf:"varint,1,opt,name=recoderID,proto3" json:"recoderID,omitempty"` // contains filtered or unexported fields }
func (*GetRecoderStatsRequest) Descriptor
deprecated
func (*GetRecoderStatsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRecoderStatsRequest.ProtoReflect.Descriptor instead.
func (*GetRecoderStatsRequest) GetRecoderID ¶
func (x *GetRecoderStatsRequest) GetRecoderID() uint64
func (*GetRecoderStatsRequest) ProtoMessage ¶
func (*GetRecoderStatsRequest) ProtoMessage()
func (*GetRecoderStatsRequest) ProtoReflect ¶
func (x *GetRecoderStatsRequest) ProtoReflect() protoreflect.Message
func (*GetRecoderStatsRequest) Reset ¶
func (x *GetRecoderStatsRequest) Reset()
func (*GetRecoderStatsRequest) String ¶
func (x *GetRecoderStatsRequest) String() string
type InputConfig ¶
type InputConfig struct {
// contains filtered or unexported fields
}
func (*InputConfig) Descriptor
deprecated
func (*InputConfig) Descriptor() ([]byte, []int)
Deprecated: Use InputConfig.ProtoReflect.Descriptor instead.
func (*InputConfig) ProtoMessage ¶
func (*InputConfig) ProtoMessage()
func (*InputConfig) ProtoReflect ¶
func (x *InputConfig) ProtoReflect() protoreflect.Message
func (*InputConfig) Reset ¶
func (x *InputConfig) Reset()
func (*InputConfig) String ¶
func (x *InputConfig) String() string
type LoggingLevel ¶
type LoggingLevel int32
const ( LoggingLevel_LoggingLevelNone LoggingLevel = 0 LoggingLevel_LoggingLevelFatal LoggingLevel = 1 LoggingLevel_LoggingLevelPanic LoggingLevel = 2 LoggingLevel_LoggingLevelError LoggingLevel = 3 LoggingLevel_LoggingLevelWarn LoggingLevel = 4 LoggingLevel_LoggingLevelInfo LoggingLevel = 5 LoggingLevel_LoggingLevelDebug LoggingLevel = 6 LoggingLevel_LoggingLevelTrace LoggingLevel = 7 )
func (LoggingLevel) Descriptor ¶
func (LoggingLevel) Descriptor() protoreflect.EnumDescriptor
func (LoggingLevel) Enum ¶
func (x LoggingLevel) Enum() *LoggingLevel
func (LoggingLevel) EnumDescriptor
deprecated
func (LoggingLevel) EnumDescriptor() ([]byte, []int)
Deprecated: Use LoggingLevel.Descriptor instead.
func (LoggingLevel) Number ¶
func (x LoggingLevel) Number() protoreflect.EnumNumber
func (LoggingLevel) String ¶
func (x LoggingLevel) String() string
func (LoggingLevel) Type ¶
func (LoggingLevel) Type() protoreflect.EnumType
type NewInputReply ¶
type NewInputReply struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*NewInputReply) Descriptor
deprecated
func (*NewInputReply) Descriptor() ([]byte, []int)
Deprecated: Use NewInputReply.ProtoReflect.Descriptor instead.
func (*NewInputReply) GetId ¶
func (x *NewInputReply) GetId() uint64
func (*NewInputReply) ProtoMessage ¶
func (*NewInputReply) ProtoMessage()
func (*NewInputReply) ProtoReflect ¶
func (x *NewInputReply) ProtoReflect() protoreflect.Message
func (*NewInputReply) Reset ¶
func (x *NewInputReply) Reset()
func (*NewInputReply) String ¶
func (x *NewInputReply) String() string
type NewInputRequest ¶
type NewInputRequest struct { Path *ResourcePath `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` Config *InputConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"` // contains filtered or unexported fields }
func (*NewInputRequest) Descriptor
deprecated
func (*NewInputRequest) Descriptor() ([]byte, []int)
Deprecated: Use NewInputRequest.ProtoReflect.Descriptor instead.
func (*NewInputRequest) GetConfig ¶
func (x *NewInputRequest) GetConfig() *InputConfig
func (*NewInputRequest) GetPath ¶
func (x *NewInputRequest) GetPath() *ResourcePath
func (*NewInputRequest) ProtoMessage ¶
func (*NewInputRequest) ProtoMessage()
func (*NewInputRequest) ProtoReflect ¶
func (x *NewInputRequest) ProtoReflect() protoreflect.Message
func (*NewInputRequest) Reset ¶
func (x *NewInputRequest) Reset()
func (*NewInputRequest) String ¶
func (x *NewInputRequest) String() string
type NewOutputReply ¶
type NewOutputReply struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*NewOutputReply) Descriptor
deprecated
func (*NewOutputReply) Descriptor() ([]byte, []int)
Deprecated: Use NewOutputReply.ProtoReflect.Descriptor instead.
func (*NewOutputReply) GetId ¶
func (x *NewOutputReply) GetId() uint64
func (*NewOutputReply) ProtoMessage ¶
func (*NewOutputReply) ProtoMessage()
func (*NewOutputReply) ProtoReflect ¶
func (x *NewOutputReply) ProtoReflect() protoreflect.Message
func (*NewOutputReply) Reset ¶
func (x *NewOutputReply) Reset()
func (*NewOutputReply) String ¶
func (x *NewOutputReply) String() string
type NewOutputRequest ¶
type NewOutputRequest struct { Path *ResourcePath `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` Config *OutputConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"` // contains filtered or unexported fields }
func (*NewOutputRequest) Descriptor
deprecated
func (*NewOutputRequest) Descriptor() ([]byte, []int)
Deprecated: Use NewOutputRequest.ProtoReflect.Descriptor instead.
func (*NewOutputRequest) GetConfig ¶
func (x *NewOutputRequest) GetConfig() *OutputConfig
func (*NewOutputRequest) GetPath ¶
func (x *NewOutputRequest) GetPath() *ResourcePath
func (*NewOutputRequest) ProtoMessage ¶
func (*NewOutputRequest) ProtoMessage()
func (*NewOutputRequest) ProtoReflect ¶
func (x *NewOutputRequest) ProtoReflect() protoreflect.Message
func (*NewOutputRequest) Reset ¶
func (x *NewOutputRequest) Reset()
func (*NewOutputRequest) String ¶
func (x *NewOutputRequest) String() string
type NewRecoderReply ¶
type NewRecoderReply struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*NewRecoderReply) Descriptor
deprecated
func (*NewRecoderReply) Descriptor() ([]byte, []int)
Deprecated: Use NewRecoderReply.ProtoReflect.Descriptor instead.
func (*NewRecoderReply) GetId ¶
func (x *NewRecoderReply) GetId() uint64
func (*NewRecoderReply) ProtoMessage ¶
func (*NewRecoderReply) ProtoMessage()
func (*NewRecoderReply) ProtoReflect ¶
func (x *NewRecoderReply) ProtoReflect() protoreflect.Message
func (*NewRecoderReply) Reset ¶
func (x *NewRecoderReply) Reset()
func (*NewRecoderReply) String ¶
func (x *NewRecoderReply) String() string
type NewRecoderRequest ¶
type NewRecoderRequest struct { Config *RecoderConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` // contains filtered or unexported fields }
func (*NewRecoderRequest) Descriptor
deprecated
func (*NewRecoderRequest) Descriptor() ([]byte, []int)
Deprecated: Use NewRecoderRequest.ProtoReflect.Descriptor instead.
func (*NewRecoderRequest) GetConfig ¶
func (x *NewRecoderRequest) GetConfig() *RecoderConfig
func (*NewRecoderRequest) ProtoMessage ¶
func (*NewRecoderRequest) ProtoMessage()
func (*NewRecoderRequest) ProtoReflect ¶
func (x *NewRecoderRequest) ProtoReflect() protoreflect.Message
func (*NewRecoderRequest) Reset ¶
func (x *NewRecoderRequest) Reset()
func (*NewRecoderRequest) String ¶
func (x *NewRecoderRequest) String() string
type OutputConfig ¶
type OutputConfig struct {
// contains filtered or unexported fields
}
func (*OutputConfig) Descriptor
deprecated
func (*OutputConfig) Descriptor() ([]byte, []int)
Deprecated: Use OutputConfig.ProtoReflect.Descriptor instead.
func (*OutputConfig) ProtoMessage ¶
func (*OutputConfig) ProtoMessage()
func (*OutputConfig) ProtoReflect ¶
func (x *OutputConfig) ProtoReflect() protoreflect.Message
func (*OutputConfig) Reset ¶
func (x *OutputConfig) Reset()
func (*OutputConfig) String ¶
func (x *OutputConfig) String() string
type RecoderClient ¶
type RecoderClient interface { SetLoggingLevel(ctx context.Context, in *SetLoggingLevelRequest, opts ...grpc.CallOption) (*SetLoggingLevelReply, error) NewInput(ctx context.Context, in *NewInputRequest, opts ...grpc.CallOption) (*NewInputReply, error) NewOutput(ctx context.Context, in *NewOutputRequest, opts ...grpc.CallOption) (*NewOutputReply, error) NewRecoder(ctx context.Context, in *NewRecoderRequest, opts ...grpc.CallOption) (*NewRecoderReply, error) CloseInput(ctx context.Context, in *CloseInputRequest, opts ...grpc.CallOption) (*CloseInputReply, error) CloseOutput(ctx context.Context, in *CloseOutputRequest, opts ...grpc.CallOption) (*CloseOutputReply, error) GetRecoderStats(ctx context.Context, in *GetRecoderStatsRequest, opts ...grpc.CallOption) (*GetRecoderStatsReply, error) StartRecoding(ctx context.Context, in *StartRecodingRequest, opts ...grpc.CallOption) (*StartRecodingReply, error) RecodingEndedChan(ctx context.Context, in *RecodingEndedChanRequest, opts ...grpc.CallOption) (Recoder_RecodingEndedChanClient, error) }
RecoderClient is the client API for Recoder 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 NewRecoderClient ¶
func NewRecoderClient(cc grpc.ClientConnInterface) RecoderClient
type RecoderConfig ¶
type RecoderConfig struct {
// contains filtered or unexported fields
}
func (*RecoderConfig) Descriptor
deprecated
func (*RecoderConfig) Descriptor() ([]byte, []int)
Deprecated: Use RecoderConfig.ProtoReflect.Descriptor instead.
func (*RecoderConfig) ProtoMessage ¶
func (*RecoderConfig) ProtoMessage()
func (*RecoderConfig) ProtoReflect ¶
func (x *RecoderConfig) ProtoReflect() protoreflect.Message
func (*RecoderConfig) Reset ¶
func (x *RecoderConfig) Reset()
func (*RecoderConfig) String ¶
func (x *RecoderConfig) String() string
type RecoderServer ¶
type RecoderServer interface { SetLoggingLevel(context.Context, *SetLoggingLevelRequest) (*SetLoggingLevelReply, error) NewInput(context.Context, *NewInputRequest) (*NewInputReply, error) NewOutput(context.Context, *NewOutputRequest) (*NewOutputReply, error) NewRecoder(context.Context, *NewRecoderRequest) (*NewRecoderReply, error) CloseInput(context.Context, *CloseInputRequest) (*CloseInputReply, error) CloseOutput(context.Context, *CloseOutputRequest) (*CloseOutputReply, error) GetRecoderStats(context.Context, *GetRecoderStatsRequest) (*GetRecoderStatsReply, error) StartRecoding(context.Context, *StartRecodingRequest) (*StartRecodingReply, error) RecodingEndedChan(*RecodingEndedChanRequest, Recoder_RecodingEndedChanServer) error // contains filtered or unexported methods }
RecoderServer is the server API for Recoder service. All implementations must embed UnimplementedRecoderServer for forward compatibility
type Recoder_RecodingEndedChanClient ¶
type Recoder_RecodingEndedChanClient interface { Recv() (*RecodingEndedChanReply, error) grpc.ClientStream }
type Recoder_RecodingEndedChanServer ¶
type Recoder_RecodingEndedChanServer interface { Send(*RecodingEndedChanReply) error grpc.ServerStream }
type RecodingEndedChanReply ¶
type RecodingEndedChanReply struct {
// contains filtered or unexported fields
}
func (*RecodingEndedChanReply) Descriptor
deprecated
func (*RecodingEndedChanReply) Descriptor() ([]byte, []int)
Deprecated: Use RecodingEndedChanReply.ProtoReflect.Descriptor instead.
func (*RecodingEndedChanReply) ProtoMessage ¶
func (*RecodingEndedChanReply) ProtoMessage()
func (*RecodingEndedChanReply) ProtoReflect ¶
func (x *RecodingEndedChanReply) ProtoReflect() protoreflect.Message
func (*RecodingEndedChanReply) Reset ¶
func (x *RecodingEndedChanReply) Reset()
func (*RecodingEndedChanReply) String ¶
func (x *RecodingEndedChanReply) String() string
type RecodingEndedChanRequest ¶
type RecodingEndedChanRequest struct { RecoderID uint64 `protobuf:"varint,1,opt,name=recoderID,proto3" json:"recoderID,omitempty"` // contains filtered or unexported fields }
func (*RecodingEndedChanRequest) Descriptor
deprecated
func (*RecodingEndedChanRequest) Descriptor() ([]byte, []int)
Deprecated: Use RecodingEndedChanRequest.ProtoReflect.Descriptor instead.
func (*RecodingEndedChanRequest) GetRecoderID ¶
func (x *RecodingEndedChanRequest) GetRecoderID() uint64
func (*RecodingEndedChanRequest) ProtoMessage ¶
func (*RecodingEndedChanRequest) ProtoMessage()
func (*RecodingEndedChanRequest) ProtoReflect ¶
func (x *RecodingEndedChanRequest) ProtoReflect() protoreflect.Message
func (*RecodingEndedChanRequest) Reset ¶
func (x *RecodingEndedChanRequest) Reset()
func (*RecodingEndedChanRequest) String ¶
func (x *RecodingEndedChanRequest) String() string
type ResourcePath ¶
type ResourcePath struct { // Types that are assignable to ResourcePath: // // *ResourcePath_Url ResourcePath isResourcePath_ResourcePath `protobuf_oneof:"ResourcePath"` // contains filtered or unexported fields }
func (*ResourcePath) Descriptor
deprecated
func (*ResourcePath) Descriptor() ([]byte, []int)
Deprecated: Use ResourcePath.ProtoReflect.Descriptor instead.
func (*ResourcePath) GetResourcePath ¶
func (m *ResourcePath) GetResourcePath() isResourcePath_ResourcePath
func (*ResourcePath) GetUrl ¶
func (x *ResourcePath) GetUrl() *ResourcePathURL
func (*ResourcePath) ProtoMessage ¶
func (*ResourcePath) ProtoMessage()
func (*ResourcePath) ProtoReflect ¶
func (x *ResourcePath) ProtoReflect() protoreflect.Message
func (*ResourcePath) Reset ¶
func (x *ResourcePath) Reset()
func (*ResourcePath) String ¶
func (x *ResourcePath) String() string
type ResourcePathURL ¶
type ResourcePathURL struct { Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"` AuthKey string `protobuf:"bytes,2,opt,name=authKey,proto3" json:"authKey,omitempty"` // contains filtered or unexported fields }
func (*ResourcePathURL) Descriptor
deprecated
func (*ResourcePathURL) Descriptor() ([]byte, []int)
Deprecated: Use ResourcePathURL.ProtoReflect.Descriptor instead.
func (*ResourcePathURL) GetAuthKey ¶
func (x *ResourcePathURL) GetAuthKey() string
func (*ResourcePathURL) GetUrl ¶
func (x *ResourcePathURL) GetUrl() string
func (*ResourcePathURL) ProtoMessage ¶
func (*ResourcePathURL) ProtoMessage()
func (*ResourcePathURL) ProtoReflect ¶
func (x *ResourcePathURL) ProtoReflect() protoreflect.Message
func (*ResourcePathURL) Reset ¶
func (x *ResourcePathURL) Reset()
func (*ResourcePathURL) String ¶
func (x *ResourcePathURL) String() string
type ResourcePath_Url ¶
type ResourcePath_Url struct {
Url *ResourcePathURL `protobuf:"bytes,1,opt,name=url,proto3,oneof"`
}
type SetLoggingLevelReply ¶
type SetLoggingLevelReply struct {
// contains filtered or unexported fields
}
func (*SetLoggingLevelReply) Descriptor
deprecated
func (*SetLoggingLevelReply) Descriptor() ([]byte, []int)
Deprecated: Use SetLoggingLevelReply.ProtoReflect.Descriptor instead.
func (*SetLoggingLevelReply) ProtoMessage ¶
func (*SetLoggingLevelReply) ProtoMessage()
func (*SetLoggingLevelReply) ProtoReflect ¶
func (x *SetLoggingLevelReply) ProtoReflect() protoreflect.Message
func (*SetLoggingLevelReply) Reset ¶
func (x *SetLoggingLevelReply) Reset()
func (*SetLoggingLevelReply) String ¶
func (x *SetLoggingLevelReply) String() string
type SetLoggingLevelRequest ¶
type SetLoggingLevelRequest struct { Level LoggingLevel `protobuf:"varint,1,opt,name=level,proto3,enum=recoder_grpc.LoggingLevel" json:"level,omitempty"` // contains filtered or unexported fields }
func (*SetLoggingLevelRequest) Descriptor
deprecated
func (*SetLoggingLevelRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetLoggingLevelRequest.ProtoReflect.Descriptor instead.
func (*SetLoggingLevelRequest) GetLevel ¶
func (x *SetLoggingLevelRequest) GetLevel() LoggingLevel
func (*SetLoggingLevelRequest) ProtoMessage ¶
func (*SetLoggingLevelRequest) ProtoMessage()
func (*SetLoggingLevelRequest) ProtoReflect ¶
func (x *SetLoggingLevelRequest) ProtoReflect() protoreflect.Message
func (*SetLoggingLevelRequest) Reset ¶
func (x *SetLoggingLevelRequest) Reset()
func (*SetLoggingLevelRequest) String ¶
func (x *SetLoggingLevelRequest) String() string
type StartRecodingReply ¶
type StartRecodingReply struct {
// contains filtered or unexported fields
}
func (*StartRecodingReply) Descriptor
deprecated
func (*StartRecodingReply) Descriptor() ([]byte, []int)
Deprecated: Use StartRecodingReply.ProtoReflect.Descriptor instead.
func (*StartRecodingReply) ProtoMessage ¶
func (*StartRecodingReply) ProtoMessage()
func (*StartRecodingReply) ProtoReflect ¶
func (x *StartRecodingReply) ProtoReflect() protoreflect.Message
func (*StartRecodingReply) Reset ¶
func (x *StartRecodingReply) Reset()
func (*StartRecodingReply) String ¶
func (x *StartRecodingReply) String() string
type StartRecodingRequest ¶
type StartRecodingRequest struct { RecoderID uint64 `protobuf:"varint,1,opt,name=recoderID,proto3" json:"recoderID,omitempty"` InputID uint64 `protobuf:"varint,2,opt,name=inputID,proto3" json:"inputID,omitempty"` OutputID uint64 `protobuf:"varint,3,opt,name=outputID,proto3" json:"outputID,omitempty"` // contains filtered or unexported fields }
func (*StartRecodingRequest) Descriptor
deprecated
func (*StartRecodingRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartRecodingRequest.ProtoReflect.Descriptor instead.
func (*StartRecodingRequest) GetInputID ¶
func (x *StartRecodingRequest) GetInputID() uint64
func (*StartRecodingRequest) GetOutputID ¶
func (x *StartRecodingRequest) GetOutputID() uint64
func (*StartRecodingRequest) GetRecoderID ¶
func (x *StartRecodingRequest) GetRecoderID() uint64
func (*StartRecodingRequest) ProtoMessage ¶
func (*StartRecodingRequest) ProtoMessage()
func (*StartRecodingRequest) ProtoReflect ¶
func (x *StartRecodingRequest) ProtoReflect() protoreflect.Message
func (*StartRecodingRequest) Reset ¶
func (x *StartRecodingRequest) Reset()
func (*StartRecodingRequest) String ¶
func (x *StartRecodingRequest) String() string
type UnimplementedRecoderServer ¶
type UnimplementedRecoderServer struct { }
UnimplementedRecoderServer must be embedded to have forward compatible implementations.
func (UnimplementedRecoderServer) CloseInput ¶
func (UnimplementedRecoderServer) CloseInput(context.Context, *CloseInputRequest) (*CloseInputReply, error)
func (UnimplementedRecoderServer) CloseOutput ¶
func (UnimplementedRecoderServer) CloseOutput(context.Context, *CloseOutputRequest) (*CloseOutputReply, error)
func (UnimplementedRecoderServer) GetRecoderStats ¶
func (UnimplementedRecoderServer) GetRecoderStats(context.Context, *GetRecoderStatsRequest) (*GetRecoderStatsReply, error)
func (UnimplementedRecoderServer) NewInput ¶
func (UnimplementedRecoderServer) NewInput(context.Context, *NewInputRequest) (*NewInputReply, error)
func (UnimplementedRecoderServer) NewOutput ¶
func (UnimplementedRecoderServer) NewOutput(context.Context, *NewOutputRequest) (*NewOutputReply, error)
func (UnimplementedRecoderServer) NewRecoder ¶
func (UnimplementedRecoderServer) NewRecoder(context.Context, *NewRecoderRequest) (*NewRecoderReply, error)
func (UnimplementedRecoderServer) RecodingEndedChan ¶
func (UnimplementedRecoderServer) RecodingEndedChan(*RecodingEndedChanRequest, Recoder_RecodingEndedChanServer) error
func (UnimplementedRecoderServer) SetLoggingLevel ¶
func (UnimplementedRecoderServer) SetLoggingLevel(context.Context, *SetLoggingLevelRequest) (*SetLoggingLevelReply, error)
func (UnimplementedRecoderServer) StartRecoding ¶
func (UnimplementedRecoderServer) StartRecoding(context.Context, *StartRecodingRequest) (*StartRecodingReply, error)
type UnsafeRecoderServer ¶
type UnsafeRecoderServer interface {
// contains filtered or unexported methods
}
UnsafeRecoderServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RecoderServer will result in compilation errors.