proto

package
v1.9.11 Latest Latest
Warning

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

Go to latest
Published: May 10, 2021 License: MIT Imports: 8 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Trickle_Target_name = map[int32]string{
		0: "PUBLISHER",
		1: "SUBSCRIBER",
	}
	Trickle_Target_value = map[string]int32{
		"PUBLISHER":  0,
		"SUBSCRIBER": 1,
	}
)

Enum value maps for Trickle_Target.

View Source
var File_cmd_signal_grpc_proto_sfu_proto protoreflect.FileDescriptor
View Source
var SFU_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sfu.SFU",
	HandlerType: (*SFUServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Signal",
			Handler:       _SFU_Signal_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "cmd/signal/grpc/proto/sfu.proto",
}

SFU_ServiceDesc is the grpc.ServiceDesc for SFU service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterSFUServer

func RegisterSFUServer(s grpc.ServiceRegistrar, srv SFUServer)

Types

type JoinReply

type JoinReply struct {
	Description []byte `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinReply) Descriptor deprecated

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

Deprecated: Use JoinReply.ProtoReflect.Descriptor instead.

func (*JoinReply) GetDescription

func (x *JoinReply) GetDescription() []byte

func (*JoinReply) ProtoMessage

func (*JoinReply) ProtoMessage()

func (*JoinReply) ProtoReflect

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

func (*JoinReply) Reset

func (x *JoinReply) Reset()

func (*JoinReply) String

func (x *JoinReply) String() string

type JoinRequest

type JoinRequest struct {
	Sid         string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"`
	Uid         string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	Description []byte `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinRequest) Descriptor deprecated

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

Deprecated: Use JoinRequest.ProtoReflect.Descriptor instead.

func (*JoinRequest) GetDescription

func (x *JoinRequest) GetDescription() []byte

func (*JoinRequest) GetSid

func (x *JoinRequest) GetSid() string

func (*JoinRequest) GetUid

func (x *JoinRequest) GetUid() string

func (*JoinRequest) ProtoMessage

func (*JoinRequest) ProtoMessage()

func (*JoinRequest) ProtoReflect

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

func (*JoinRequest) Reset

func (x *JoinRequest) Reset()

func (*JoinRequest) String

func (x *JoinRequest) String() string

type SFUClient

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

SFUClient is the client API for SFU 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 NewSFUClient

func NewSFUClient(cc grpc.ClientConnInterface) SFUClient

type SFUServer

type SFUServer interface {
	Signal(SFU_SignalServer) error
	// contains filtered or unexported methods
}

SFUServer is the server API for SFU service. All implementations must embed UnimplementedSFUServer for forward compatibility

type SFU_SignalClient

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

type SFU_SignalServer

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

type SignalReply

type SignalReply struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Payload:
	//	*SignalReply_Join
	//	*SignalReply_Description
	//	*SignalReply_Trickle
	//	*SignalReply_IceConnectionState
	//	*SignalReply_Error
	Payload isSignalReply_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*SignalReply) Descriptor deprecated

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

Deprecated: Use SignalReply.ProtoReflect.Descriptor instead.

func (*SignalReply) GetDescription

func (x *SignalReply) GetDescription() []byte

func (*SignalReply) GetError

func (x *SignalReply) GetError() string

func (*SignalReply) GetIceConnectionState

func (x *SignalReply) GetIceConnectionState() string

func (*SignalReply) GetId

func (x *SignalReply) GetId() string

func (*SignalReply) GetJoin

func (x *SignalReply) GetJoin() *JoinReply

func (*SignalReply) GetPayload

func (m *SignalReply) GetPayload() isSignalReply_Payload

func (*SignalReply) GetTrickle

func (x *SignalReply) GetTrickle() *Trickle

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 SignalReply_Description

type SignalReply_Description struct {
	Description []byte `protobuf:"bytes,3,opt,name=description,proto3,oneof"`
}

type SignalReply_Error

type SignalReply_Error struct {
	Error string `protobuf:"bytes,6,opt,name=error,proto3,oneof"`
}

type SignalReply_IceConnectionState

type SignalReply_IceConnectionState struct {
	IceConnectionState string `protobuf:"bytes,5,opt,name=iceConnectionState,proto3,oneof"`
}

type SignalReply_Join

type SignalReply_Join struct {
	Join *JoinReply `protobuf:"bytes,2,opt,name=join,proto3,oneof"`
}

type SignalReply_Trickle

type SignalReply_Trickle struct {
	Trickle *Trickle `protobuf:"bytes,4,opt,name=trickle,proto3,oneof"`
}

type SignalRequest

type SignalRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Payload:
	//	*SignalRequest_Join
	//	*SignalRequest_Description
	//	*SignalRequest_Trickle
	Payload isSignalRequest_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*SignalRequest) Descriptor deprecated

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

Deprecated: Use SignalRequest.ProtoReflect.Descriptor instead.

func (*SignalRequest) GetDescription

func (x *SignalRequest) GetDescription() []byte

func (*SignalRequest) GetId

func (x *SignalRequest) GetId() string

func (*SignalRequest) GetJoin

func (x *SignalRequest) GetJoin() *JoinRequest

func (*SignalRequest) GetPayload

func (m *SignalRequest) GetPayload() isSignalRequest_Payload

func (*SignalRequest) GetTrickle

func (x *SignalRequest) GetTrickle() *Trickle

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_Description

type SignalRequest_Description struct {
	Description []byte `protobuf:"bytes,3,opt,name=description,proto3,oneof"`
}

type SignalRequest_Join

type SignalRequest_Join struct {
	Join *JoinRequest `protobuf:"bytes,2,opt,name=join,proto3,oneof"`
}

type SignalRequest_Trickle

type SignalRequest_Trickle struct {
	Trickle *Trickle `protobuf:"bytes,4,opt,name=trickle,proto3,oneof"`
}

type Trickle

type Trickle struct {
	Target Trickle_Target `protobuf:"varint,1,opt,name=target,proto3,enum=sfu.Trickle_Target" json:"target,omitempty"`
	Init   string         `protobuf:"bytes,2,opt,name=init,proto3" json:"init,omitempty"`
	// contains filtered or unexported fields
}

func (*Trickle) Descriptor deprecated

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

Deprecated: Use Trickle.ProtoReflect.Descriptor instead.

func (*Trickle) GetInit

func (x *Trickle) GetInit() string

func (*Trickle) GetTarget

func (x *Trickle) GetTarget() Trickle_Target

func (*Trickle) ProtoMessage

func (*Trickle) ProtoMessage()

func (*Trickle) ProtoReflect

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

func (*Trickle) Reset

func (x *Trickle) Reset()

func (*Trickle) String

func (x *Trickle) String() string

type Trickle_Target

type Trickle_Target int32
const (
	Trickle_PUBLISHER  Trickle_Target = 0
	Trickle_SUBSCRIBER Trickle_Target = 1
)

func (Trickle_Target) Descriptor

func (Trickle_Target) Enum

func (x Trickle_Target) Enum() *Trickle_Target

func (Trickle_Target) EnumDescriptor deprecated

func (Trickle_Target) EnumDescriptor() ([]byte, []int)

Deprecated: Use Trickle_Target.Descriptor instead.

func (Trickle_Target) Number

func (Trickle_Target) String

func (x Trickle_Target) String() string

func (Trickle_Target) Type

type UnimplementedSFUServer

type UnimplementedSFUServer struct {
}

UnimplementedSFUServer must be embedded to have forward compatible implementations.

func (UnimplementedSFUServer) Signal

type UnsafeSFUServer

type UnsafeSFUServer interface {
	// contains filtered or unexported methods
}

UnsafeSFUServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SFUServer will result in compilation errors.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL