api

type SubscribeRequest struct {

	// Types that are assignable to Operation:
	//	*SubscribeRequest_Request
	//	*SubscribeRequest_Signal
	Operation isSubscribeRequest_Operation `protobuf_oneof:"operation"`
	// contains filtered or unexported fields
}

type SubscribeRequest_Request struct {
	Request *TranscodeRequest `protobuf:"bytes,1,opt,name=request,proto3,oneof"`
}

type SubscribeRequest_Signal struct {
	Signal *anypb.Any `protobuf:"bytes,2,opt,name=signal,proto3,oneof"`
}

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
}

type TranscoderClient interface {
	Publish(ctx context.Context, opts ...grpc.CallOption) (Transcoder_PublishClient, error)
	Subscribe(ctx context.Context, opts ...grpc.CallOption) (Transcoder_SubscribeClient, error)
}

type TranscoderServer interface {
	Publish(Transcoder_PublishServer) error
	Subscribe(Transcoder_SubscribeServer) error
}

type Transcoder_PublishClient interface {
	Send(*anypb.Any) error
	Recv() (*anypb.Any, error)
	grpc.ClientStream
}

type Transcoder_PublishServer interface {
	Send(*anypb.Any) error
	Recv() (*anypb.Any, error)
	grpc.ServerStream
}

type Transcoder_SubscribeClient interface {
	Send(*SubscribeRequest) error
	Recv() (*anypb.Any, error)
	grpc.ClientStream
}

type Transcoder_SubscribeServer interface {
	Send(*anypb.Any) error
	Recv() (*SubscribeRequest, error)
	grpc.ServerStream
}

type UnimplementedTranscoderServer struct {
}