proto

Documentation

Index

• Variables
• func RegisterAVPServer(s *grpc.Server, srv AVPServer)
• type AVPClient
  • func NewAVPClient(cc grpc.ClientConnInterface) AVPClient
• type AVPServer
• type AVP_SignalClient
• type AVP_SignalServer
• type Process
  • func (*Process) Descriptor() ([]byte, []int)
  • func (x *Process) GetConfig() []byte
  • func (x *Process) GetEid() string
  • func (x *Process) GetPid() string
  • func (x *Process) GetSfu() string
  • func (x *Process) GetSid() string
  • func (x *Process) GetTid() string
  • func (*Process) ProtoMessage()
  • func (x *Process) ProtoReflect() protoreflect.Message
  • func (x *Process) Reset()
  • func (x *Process) String() string
• type SignalReply
  • func (*SignalReply) Descriptor() ([]byte, []int)
  • func (*SignalReply) ProtoMessage()
  • func (x *SignalReply) ProtoReflect() protoreflect.Message
  • func (x *SignalReply) Reset()
  • func (x *SignalReply) String() string
• type SignalRequest
  • func (*SignalRequest) Descriptor() ([]byte, []int)
  • func (m *SignalRequest) GetPayload() isSignalRequest_Payload
  • func (x *SignalRequest) GetProcess() *Process
  • func (*SignalRequest) ProtoMessage()
  • func (x *SignalRequest) ProtoReflect() protoreflect.Message
  • func (x *SignalRequest) Reset()
  • func (x *SignalRequest) String() string
• type SignalRequest_Process
• type UnimplementedAVPServer
  • func (*UnimplementedAVPServer) Signal(AVP_SignalServer) error

Variables

var File_cmd_server_grpc_proto_avp_proto protoreflect.FileDescriptor

Functions

func RegisterAVPServer

func RegisterAVPServer(s *grpc.Server, srv AVPServer)

Types

type AVPClient

type AVPClient interface {
	Signal(ctx context.Context, opts ...grpc.CallOption) (AVP_SignalClient, error)
}

AVPClient is the client API for AVP service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAVPClient

func NewAVPClient(cc grpc.ClientConnInterface) AVPClient

type AVPServer

type AVPServer interface {
	Signal(AVP_SignalServer) error
	// contains filtered or unexported methods
}

AVPServer is the server API for AVP service. All implementations must embed UnimplementedAVPServer for forward compatibility

type AVP_SignalClient

type AVP_SignalClient interface {
	Send(*SignalRequest) error
	Recv() (*SignalReply, error)
	grpc.ClientStream
}

type AVP_SignalServer

type AVP_SignalServer interface {
	Send(*SignalReply) error
	Recv() (*SignalRequest, error)
	grpc.ServerStream
}

type Process

type Process struct {
	Sfu    string `protobuf:"bytes,1,opt,name=sfu,proto3" json:"sfu,omitempty"` // media sfu
	Pid    string `protobuf:"bytes,2,opt,name=pid,proto3" json:"pid,omitempty"` // pipeline id
	Sid    string `protobuf:"bytes,3,opt,name=sid,proto3" json:"sid,omitempty"` // session id
	Tid    string `protobuf:"bytes,4,opt,name=tid,proto3" json:"tid,omitempty"` // track id
	Eid    string `protobuf:"bytes,5,opt,name=eid,proto3" json:"eid,omitempty"` // element id
	Config []byte `protobuf:"bytes,6,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

Process describes an a/v process

func (*Process) Descriptor

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

Deprecated: Use Process.ProtoReflect.Descriptor instead.

func (*Process) GetConfig

func (x *Process) GetConfig() []byte

func (*Process) GetEid

func (x *Process) GetEid() string

func (*Process) GetPid

func (x *Process) GetPid() string

func (*Process) GetSfu

func (x *Process) GetSfu() string

func (*Process) GetSid

func (x *Process) GetSid() string

func (*Process) GetTid

func (x *Process) GetTid() string

func (*Process) ProtoMessage

func (*Process) ProtoMessage()

func (*Process) ProtoReflect

func (x *Process) ProtoReflect() protoreflect.Message

func (*Process) Reset

func (x *Process) Reset()

func (*Process) String

func (x *Process) String() string

type SignalReply

type SignalReply struct {
	// contains filtered or unexported fields
}

func (*SignalReply) Descriptor

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

Deprecated: Use SignalReply.ProtoReflect.Descriptor instead.

func (*SignalReply) ProtoMessage

func (*SignalReply) ProtoMessage()

func (*SignalReply) ProtoReflect

func (x *SignalReply) ProtoReflect() protoreflect.Message

func (*SignalReply) Reset

func (x *SignalReply) Reset()

func (*SignalReply) String

func (x *SignalReply) String() string

type SignalRequest

type SignalRequest struct {

	// Types that are assignable to Payload:
	//	*SignalRequest_Process
	Payload isSignalRequest_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*SignalRequest) Descriptor

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

Deprecated: Use SignalRequest.ProtoReflect.Descriptor instead.

func (*SignalRequest) GetPayload

func (m *SignalRequest) GetPayload() isSignalRequest_Payload

func (*SignalRequest) GetProcess

func (x *SignalRequest) GetProcess() *Process

func (*SignalRequest) ProtoMessage

func (*SignalRequest) ProtoMessage()

func (*SignalRequest) ProtoReflect

func (x *SignalRequest) ProtoReflect() protoreflect.Message

func (*SignalRequest) Reset

func (x *SignalRequest) Reset()

func (*SignalRequest) String

func (x *SignalRequest) String() string

type SignalRequest_Process

type SignalRequest_Process struct {
	Process *Process `protobuf:"bytes,1,opt,name=process,proto3,oneof"`
}

type UnimplementedAVPServer

type UnimplementedAVPServer struct {
}

UnimplementedAVPServer must be embedded to have forward compatible implementations.

func (*UnimplementedAVPServer) Signal

func (*UnimplementedAVPServer) Signal(AVP_SignalServer) error