api

Documentation

Index

• Variables
• func RegisterTranscoderServer(s *grpc.Server, srv TranscoderServer)
• type TranscodeRequest
  • func (*TranscodeRequest) Descriptor() ([]byte, []int)
  • 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)
  • 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
  • func NewTranscoderClient(cc grpc.ClientConnInterface) TranscoderClient
• type TranscoderServer
• type Transcoder_SignalClient
• type Transcoder_SignalServer
• type UnimplementedTranscoderServer
  • func (*UnimplementedTranscoderServer) Signal(Transcoder_SignalServer) error
  • func (*UnimplementedTranscoderServer) Transcode(context.Context, *TranscodeRequest) (*TranscodeResponse, error)

Variables

var File_transcoder_proto protoreflect.FileDescriptor

Functions

func RegisterTranscoderServer

func RegisterTranscoderServer(s *grpc.Server, srv TranscoderServer)

Types

type TranscodeRequest

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

func (*TranscodeRequest) Descriptor() ([]byte, []int)

Deprecated: Use TranscodeRequest.ProtoReflect.Descriptor instead.

func (*TranscodeRequest) GetGstreamerPipeline

func (x *TranscodeRequest) GetGstreamerPipeline() string

func (*TranscodeRequest) GetMimeType

func (x *TranscodeRequest) GetMimeType() string

func (*TranscodeRequest) GetRtpStreamId

func (x *TranscodeRequest) GetRtpStreamId() string

func (*TranscodeRequest) GetStreamId

func (x *TranscodeRequest) GetStreamId() string

func (*TranscodeRequest) GetTrackId

func (x *TranscodeRequest) GetTrackId() string

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 {
	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

func (*TranscodeResponse) Descriptor() ([]byte, []int)

Deprecated: Use TranscodeResponse.ProtoReflect.Descriptor instead.

func (*TranscodeResponse) GetRtpStreamId

func (x *TranscodeResponse) GetRtpStreamId() string

func (*TranscodeResponse) GetStreamId

func (x *TranscodeResponse) GetStreamId() string

func (*TranscodeResponse) GetTrackId

func (x *TranscodeResponse) GetTrackId() 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 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(*anypb.Any) error
	Recv() (*anypb.Any, error)
	grpc.ClientStream
}

type Transcoder_SignalServer

type Transcoder_SignalServer interface {
	Send(*anypb.Any) error
	Recv() (*anypb.Any, 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

func (*UnimplementedTranscoderServer) Transcode(context.Context, *TranscodeRequest) (*TranscodeResponse, error)