api

package
v0.2.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 17, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.