Documentation ¶
Index ¶
- Variables
- func RegisterTranscoderServer(s *grpc.Server, srv TranscoderServer)
- type SubscribeRequest
- func (*SubscribeRequest) Descriptor() ([]byte, []int)deprecated
- func (m *SubscribeRequest) GetOperation() isSubscribeRequest_Operation
- func (x *SubscribeRequest) GetRequest() *TranscodeRequest
- func (x *SubscribeRequest) GetSignal() *anypb.Any
- func (*SubscribeRequest) ProtoMessage()
- func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
- func (x *SubscribeRequest) Reset()
- func (x *SubscribeRequest) String() string
- type SubscribeRequest_Request
- type SubscribeRequest_Signal
- type TranscodeRequest
- func (*TranscodeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TranscodeRequest) GetGstreamerPipeline() string
- func (x *TranscodeRequest) GetMimeType() string
- func (x *TranscodeRequest) GetRtpStreamId() string
- func (x *TranscodeRequest) GetStreamId() string
- func (x *TranscodeRequest) GetTrackId() string
- func (*TranscodeRequest) ProtoMessage()
- func (x *TranscodeRequest) ProtoReflect() protoreflect.Message
- func (x *TranscodeRequest) Reset()
- func (x *TranscodeRequest) String() string
- type TranscoderClient
- type TranscoderServer
- type Transcoder_PublishClient
- type Transcoder_PublishServer
- type Transcoder_SubscribeClient
- type Transcoder_SubscribeServer
- type UnimplementedTranscoderServer
Constants ¶
This section is empty.
Variables ¶
View Source
var File_transcoder_proto protoreflect.FileDescriptor
Functions ¶
func RegisterTranscoderServer ¶
func RegisterTranscoderServer(s *grpc.Server, srv TranscoderServer)
Types ¶
type SubscribeRequest ¶ added in v0.4.1
type SubscribeRequest struct { // Types that are assignable to Operation: // *SubscribeRequest_Request // *SubscribeRequest_Signal Operation isSubscribeRequest_Operation `protobuf_oneof:"operation"` // contains filtered or unexported fields }
func (*SubscribeRequest) Descriptor
deprecated
added in
v0.4.1
func (*SubscribeRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.
func (*SubscribeRequest) GetOperation ¶ added in v0.4.1
func (m *SubscribeRequest) GetOperation() isSubscribeRequest_Operation
func (*SubscribeRequest) GetRequest ¶ added in v0.4.1
func (x *SubscribeRequest) GetRequest() *TranscodeRequest
func (*SubscribeRequest) GetSignal ¶ added in v0.4.1
func (x *SubscribeRequest) GetSignal() *anypb.Any
func (*SubscribeRequest) ProtoMessage ¶ added in v0.4.1
func (*SubscribeRequest) ProtoMessage()
func (*SubscribeRequest) ProtoReflect ¶ added in v0.4.1
func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
func (*SubscribeRequest) Reset ¶ added in v0.4.1
func (x *SubscribeRequest) Reset()
func (*SubscribeRequest) String ¶ added in v0.4.1
func (x *SubscribeRequest) String() string
type SubscribeRequest_Request ¶ added in v0.4.1
type SubscribeRequest_Request struct {
Request *TranscodeRequest `protobuf:"bytes,1,opt,name=request,proto3,oneof"`
}
type SubscribeRequest_Signal ¶ added in v0.4.1
type TranscodeRequest ¶ added in v0.2.0
type TranscodeRequest struct { StreamId string `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"` TrackId string `protobuf:"bytes,2,opt,name=track_id,json=trackId,proto3" json:"track_id,omitempty"` RtpStreamId string `protobuf:"bytes,3,opt,name=rtp_stream_id,json=rtpStreamId,proto3" json:"rtp_stream_id,omitempty"` MimeType string `protobuf:"bytes,4,opt,name=mime_type,json=mimeType,proto3" json:"mime_type,omitempty"` GstreamerPipeline string `protobuf:"bytes,5,opt,name=gstreamer_pipeline,json=gstreamerPipeline,proto3" json:"gstreamer_pipeline,omitempty"` // contains filtered or unexported fields }
func (*TranscodeRequest) Descriptor
deprecated
added in
v0.2.0
func (*TranscodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use TranscodeRequest.ProtoReflect.Descriptor instead.
func (*TranscodeRequest) GetGstreamerPipeline ¶ added in v0.2.0
func (x *TranscodeRequest) GetGstreamerPipeline() string
func (*TranscodeRequest) GetMimeType ¶ added in v0.2.0
func (x *TranscodeRequest) GetMimeType() string
func (*TranscodeRequest) GetRtpStreamId ¶ added in v0.2.0
func (x *TranscodeRequest) GetRtpStreamId() string
func (*TranscodeRequest) GetStreamId ¶ added in v0.2.0
func (x *TranscodeRequest) GetStreamId() string
func (*TranscodeRequest) GetTrackId ¶ added in v0.2.0
func (x *TranscodeRequest) GetTrackId() string
func (*TranscodeRequest) ProtoMessage ¶ added in v0.2.0
func (*TranscodeRequest) ProtoMessage()
func (*TranscodeRequest) ProtoReflect ¶ added in v0.2.0
func (x *TranscodeRequest) ProtoReflect() protoreflect.Message
func (*TranscodeRequest) Reset ¶ added in v0.2.0
func (x *TranscodeRequest) Reset()
func (*TranscodeRequest) String ¶ added in v0.2.0
func (x *TranscodeRequest) String() string
type TranscoderClient ¶
type TranscoderClient interface { Publish(ctx context.Context, opts ...grpc.CallOption) (Transcoder_PublishClient, error) Subscribe(ctx context.Context, opts ...grpc.CallOption) (Transcoder_SubscribeClient, error) }
TranscoderClient is the client API for Transcoder service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewTranscoderClient ¶
func NewTranscoderClient(cc grpc.ClientConnInterface) TranscoderClient
type TranscoderServer ¶
type TranscoderServer interface { Publish(Transcoder_PublishServer) error Subscribe(Transcoder_SubscribeServer) error }
TranscoderServer is the server API for Transcoder service.
type Transcoder_PublishClient ¶ added in v0.4.1
type Transcoder_PublishServer ¶ added in v0.4.1
type Transcoder_SubscribeClient ¶ added in v0.4.1
type Transcoder_SubscribeClient interface { Send(*SubscribeRequest) error Recv() (*anypb.Any, error) grpc.ClientStream }
type Transcoder_SubscribeServer ¶ added in v0.4.1
type Transcoder_SubscribeServer interface { Send(*anypb.Any) error Recv() (*SubscribeRequest, error) grpc.ServerStream }
type UnimplementedTranscoderServer ¶
type UnimplementedTranscoderServer struct { }
UnimplementedTranscoderServer can be embedded to have forward compatible implementations.
func (*UnimplementedTranscoderServer) Publish ¶ added in v0.4.1
func (*UnimplementedTranscoderServer) Publish(Transcoder_PublishServer) error
func (*UnimplementedTranscoderServer) Subscribe ¶ added in v0.4.1
func (*UnimplementedTranscoderServer) Subscribe(Transcoder_SubscribeServer) error
Click to show internal directories.
Click to hide internal directories.