Documentation
¶
Index ¶
- Variables
- func RegisterTranscoderServer(s *grpc.Server, srv TranscoderServer)
- type SignalMessage
- func (*SignalMessage) Descriptor() ([]byte, []int)deprecated
- func (x *SignalMessage) GetAnswerSdp() string
- func (x *SignalMessage) GetOfferSdp() string
- func (m *SignalMessage) GetPayload() isSignalMessage_Payload
- func (x *SignalMessage) GetTrickle() string
- func (*SignalMessage) ProtoMessage()
- func (x *SignalMessage) ProtoReflect() protoreflect.Message
- func (x *SignalMessage) Reset()
- func (x *SignalMessage) String() string
- type SignalMessage_AnswerSdp
- type SignalMessage_OfferSdp
- type SignalMessage_Trickle
- 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 TranscodeResponse
- func (*TranscodeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TranscodeResponse) GetRtpStreamId() string
- func (x *TranscodeResponse) GetStreamId() string
- func (x *TranscodeResponse) GetTrackId() string
- func (*TranscodeResponse) ProtoMessage()
- func (x *TranscodeResponse) ProtoReflect() protoreflect.Message
- func (x *TranscodeResponse) Reset()
- func (x *TranscodeResponse) String() string
- type TranscoderClient
- type TranscoderServer
- type Transcoder_SignalClient
- type Transcoder_SignalServer
- 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 SignalMessage ¶ added in v0.2.0
type SignalMessage struct {
// Types that are assignable to Payload:
// *SignalMessage_OfferSdp
// *SignalMessage_AnswerSdp
// *SignalMessage_Trickle
Payload isSignalMessage_Payload `protobuf_oneof:"payload"`
// contains filtered or unexported fields
}
func (*SignalMessage) Descriptor
deprecated
added in
v0.2.0
func (*SignalMessage) Descriptor() ([]byte, []int)
Deprecated: Use SignalMessage.ProtoReflect.Descriptor instead.
func (*SignalMessage) GetAnswerSdp ¶ added in v0.2.0
func (x *SignalMessage) GetAnswerSdp() string
func (*SignalMessage) GetOfferSdp ¶ added in v0.2.0
func (x *SignalMessage) GetOfferSdp() string
func (*SignalMessage) GetPayload ¶ added in v0.2.0
func (m *SignalMessage) GetPayload() isSignalMessage_Payload
func (*SignalMessage) GetTrickle ¶ added in v0.2.0
func (x *SignalMessage) GetTrickle() string
func (*SignalMessage) ProtoMessage ¶ added in v0.2.0
func (*SignalMessage) ProtoMessage()
func (*SignalMessage) ProtoReflect ¶ added in v0.2.0
func (x *SignalMessage) ProtoReflect() protoreflect.Message
func (*SignalMessage) Reset ¶ added in v0.2.0
func (x *SignalMessage) Reset()
func (*SignalMessage) String ¶ added in v0.2.0
func (x *SignalMessage) String() string
type SignalMessage_AnswerSdp ¶ added in v0.2.0
type SignalMessage_AnswerSdp struct {
AnswerSdp string `protobuf:"bytes,2,opt,name=answer_sdp,json=answerSdp,proto3,oneof"`
}
type SignalMessage_OfferSdp ¶ added in v0.2.0
type SignalMessage_OfferSdp struct {
OfferSdp string `protobuf:"bytes,1,opt,name=offer_sdp,json=offerSdp,proto3,oneof"`
}
type SignalMessage_Trickle ¶ added in v0.2.0
type SignalMessage_Trickle struct {
Trickle string `protobuf:"bytes,3,opt,name=trickle,proto3,oneof"`
}
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"`
// gstreamer_pipeline must be compatible with mime_type.
GstreamerPipeline string `protobuf:"bytes,4,opt,name=gstreamer_pipeline,json=gstreamerPipeline,proto3" json:"gstreamer_pipeline,omitempty"`
MimeType string `protobuf:"bytes,5,opt,name=mime_type,json=mimeType,proto3" json:"mime_type,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 TranscodeResponse ¶ added in v0.2.0
type TranscodeResponse 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"`
// contains filtered or unexported fields
}
func (*TranscodeResponse) Descriptor
deprecated
added in
v0.2.0
func (*TranscodeResponse) Descriptor() ([]byte, []int)
Deprecated: Use TranscodeResponse.ProtoReflect.Descriptor instead.
func (*TranscodeResponse) GetRtpStreamId ¶ added in v0.2.0
func (x *TranscodeResponse) GetRtpStreamId() string
func (*TranscodeResponse) GetStreamId ¶ added in v0.2.0
func (x *TranscodeResponse) GetStreamId() string
func (*TranscodeResponse) GetTrackId ¶ added in v0.2.0
func (x *TranscodeResponse) GetTrackId() string
func (*TranscodeResponse) ProtoMessage ¶ added in v0.2.0
func (*TranscodeResponse) ProtoMessage()
func (*TranscodeResponse) ProtoReflect ¶ added in v0.2.0
func (x *TranscodeResponse) ProtoReflect() protoreflect.Message
func (*TranscodeResponse) Reset ¶ added in v0.2.0
func (x *TranscodeResponse) Reset()
func (*TranscodeResponse) String ¶ added in v0.2.0
func (x *TranscodeResponse) String() string
type TranscoderClient ¶
type TranscoderClient interface {
Signal(ctx context.Context, opts ...grpc.CallOption) (Transcoder_SignalClient, error)
Transcode(ctx context.Context, in *TranscodeRequest, opts ...grpc.CallOption) (*TranscodeResponse, 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 {
Signal(Transcoder_SignalServer) error
Transcode(context.Context, *TranscodeRequest) (*TranscodeResponse, error)
}
TranscoderServer is the server API for Transcoder service.
type Transcoder_SignalClient ¶
type Transcoder_SignalClient interface {
Send(*SignalMessage) error
Recv() (*SignalMessage, error)
grpc.ClientStream
}
type Transcoder_SignalServer ¶
type Transcoder_SignalServer interface {
Send(*SignalMessage) error
Recv() (*SignalMessage, error)
grpc.ServerStream
}
type UnimplementedTranscoderServer ¶
type UnimplementedTranscoderServer struct {
}
UnimplementedTranscoderServer can be embedded to have forward compatible implementations.
func (*UnimplementedTranscoderServer) Signal ¶
func (*UnimplementedTranscoderServer) Signal(Transcoder_SignalServer) error
func (*UnimplementedTranscoderServer) Transcode ¶ added in v0.2.0
func (*UnimplementedTranscoderServer) Transcode(context.Context, *TranscodeRequest) (*TranscodeResponse, error)
Click to show internal directories.
Click to hide internal directories.