Documentation ¶
Index ¶
- Variables
- func RegisterSFUService(s grpc.ServiceRegistrar, srv *SFUService)
- type JoinReply
- type JoinRequest
- func (*JoinRequest) Descriptor() ([]byte, []int)deprecated
- func (x *JoinRequest) GetOffer() *SessionDescription
- func (x *JoinRequest) GetSid() string
- func (*JoinRequest) ProtoMessage()
- func (x *JoinRequest) ProtoReflect() protoreflect.Message
- func (x *JoinRequest) Reset()
- func (x *JoinRequest) String() string
- type SFUClient
- type SFUService
- type SFU_SignalClient
- type SFU_SignalServer
- type SessionDescription
- func (*SessionDescription) Descriptor() ([]byte, []int)deprecated
- func (x *SessionDescription) GetSdp() []byte
- func (x *SessionDescription) GetType() string
- func (*SessionDescription) ProtoMessage()
- func (x *SessionDescription) ProtoReflect() protoreflect.Message
- func (x *SessionDescription) Reset()
- func (x *SessionDescription) String() string
- type SignalReply
- func (*SignalReply) Descriptor() ([]byte, []int)deprecated
- func (x *SignalReply) GetJoin() *JoinReply
- func (x *SignalReply) GetNegotiate() *SessionDescription
- func (m *SignalReply) GetPayload() isSignalReply_Payload
- func (x *SignalReply) GetTrickle() *Trickle
- func (*SignalReply) ProtoMessage()
- func (x *SignalReply) ProtoReflect() protoreflect.Message
- func (x *SignalReply) Reset()
- func (x *SignalReply) String() string
- type SignalReply_Join
- type SignalReply_Negotiate
- type SignalReply_Trickle
- type SignalRequest
- func (*SignalRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SignalRequest) GetJoin() *JoinRequest
- func (x *SignalRequest) GetNegotiate() *SessionDescription
- func (m *SignalRequest) GetPayload() isSignalRequest_Payload
- func (x *SignalRequest) GetTrickle() *Trickle
- func (*SignalRequest) ProtoMessage()
- func (x *SignalRequest) ProtoReflect() protoreflect.Message
- func (x *SignalRequest) Reset()
- func (x *SignalRequest) String() string
- type SignalRequest_Join
- type SignalRequest_Negotiate
- type SignalRequest_Trickle
- type Trickle
- type UnstableSFUService
Constants ¶
This section is empty.
Variables ¶
var File_cmd_server_grpc_proto_sfu_proto protoreflect.FileDescriptor
Functions ¶
func RegisterSFUService ¶ added in v1.0.13
func RegisterSFUService(s grpc.ServiceRegistrar, srv *SFUService)
RegisterSFUService registers a service implementation with a gRPC server.
Types ¶
type JoinReply ¶
type JoinReply struct { Pid string `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"` Answer *SessionDescription `protobuf:"bytes,2,opt,name=answer,proto3" json:"answer,omitempty"` // contains filtered or unexported fields }
func (*JoinReply) Descriptor
deprecated
func (*JoinReply) GetAnswer ¶
func (x *JoinReply) GetAnswer() *SessionDescription
func (*JoinReply) ProtoMessage ¶
func (*JoinReply) ProtoMessage()
func (*JoinReply) ProtoReflect ¶
func (x *JoinReply) ProtoReflect() protoreflect.Message
type JoinRequest ¶
type JoinRequest struct { Sid string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"` Offer *SessionDescription `protobuf:"bytes,2,opt,name=offer,proto3" json:"offer,omitempty"` // contains filtered or unexported fields }
func (*JoinRequest) Descriptor
deprecated
func (*JoinRequest) Descriptor() ([]byte, []int)
Deprecated: Use JoinRequest.ProtoReflect.Descriptor instead.
func (*JoinRequest) GetOffer ¶
func (x *JoinRequest) GetOffer() *SessionDescription
func (*JoinRequest) GetSid ¶
func (x *JoinRequest) GetSid() 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 SFUService ¶ added in v1.0.13
type SFUService struct {
Signal func(SFU_SignalServer) error
}
SFUService is the service API for SFU service. Fields should be assigned to their respective handler implementations only before RegisterSFUService is called. Any unassigned fields will result in the handler for that method returning an Unimplemented error.
func NewSFUService ¶ added in v1.0.13
func NewSFUService(s interface{}) *SFUService
NewSFUService creates a new SFUService containing the implemented methods of the SFU service in s. Any unimplemented methods will result in the gRPC server returning an UNIMPLEMENTED status to the client. This includes situations where the method handler is misspelled or has the wrong signature. For this reason, this function should be used with great care and is not recommended to be used by most users.
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 SessionDescription ¶
type SessionDescription struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` // "answer" | "offer" | "pranswer" | "rollback" Sdp []byte `protobuf:"bytes,2,opt,name=sdp,proto3" json:"sdp,omitempty"` // contains filtered or unexported fields }
func (*SessionDescription) Descriptor
deprecated
func (*SessionDescription) Descriptor() ([]byte, []int)
Deprecated: Use SessionDescription.ProtoReflect.Descriptor instead.
func (*SessionDescription) GetSdp ¶
func (x *SessionDescription) GetSdp() []byte
func (*SessionDescription) GetType ¶
func (x *SessionDescription) GetType() string
func (*SessionDescription) ProtoMessage ¶
func (*SessionDescription) ProtoMessage()
func (*SessionDescription) ProtoReflect ¶
func (x *SessionDescription) ProtoReflect() protoreflect.Message
func (*SessionDescription) Reset ¶
func (x *SessionDescription) Reset()
func (*SessionDescription) String ¶
func (x *SessionDescription) String() string
type SignalReply ¶
type SignalReply struct { // Types that are assignable to Payload: // *SignalReply_Join // *SignalReply_Negotiate // *SignalReply_Trickle 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) GetJoin ¶
func (x *SignalReply) GetJoin() *JoinReply
func (*SignalReply) GetNegotiate ¶
func (x *SignalReply) GetNegotiate() *SessionDescription
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_Join ¶
type SignalReply_Join struct {
Join *JoinReply `protobuf:"bytes,1,opt,name=join,proto3,oneof"`
}
type SignalReply_Negotiate ¶
type SignalReply_Negotiate struct {
Negotiate *SessionDescription `protobuf:"bytes,2,opt,name=negotiate,proto3,oneof"`
}
type SignalReply_Trickle ¶
type SignalReply_Trickle struct {
Trickle *Trickle `protobuf:"bytes,3,opt,name=trickle,proto3,oneof"`
}
type SignalRequest ¶
type SignalRequest struct { // Types that are assignable to Payload: // *SignalRequest_Join // *SignalRequest_Negotiate // *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) GetJoin ¶
func (x *SignalRequest) GetJoin() *JoinRequest
func (*SignalRequest) GetNegotiate ¶
func (x *SignalRequest) GetNegotiate() *SessionDescription
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_Join ¶
type SignalRequest_Join struct {
Join *JoinRequest `protobuf:"bytes,1,opt,name=join,proto3,oneof"`
}
type SignalRequest_Negotiate ¶
type SignalRequest_Negotiate struct {
Negotiate *SessionDescription `protobuf:"bytes,2,opt,name=negotiate,proto3,oneof"`
}
type SignalRequest_Trickle ¶
type SignalRequest_Trickle struct {
Trickle *Trickle `protobuf:"bytes,3,opt,name=trickle,proto3,oneof"`
}
type Trickle ¶
type Trickle struct { Init string `protobuf:"bytes,1,opt,name=init,proto3" json:"init,omitempty"` // contains filtered or unexported fields }
func (*Trickle) Descriptor
deprecated
func (*Trickle) ProtoMessage ¶
func (*Trickle) ProtoMessage()
func (*Trickle) ProtoReflect ¶
func (x *Trickle) ProtoReflect() protoreflect.Message
type UnstableSFUService ¶ added in v1.0.13
type UnstableSFUService interface {
Signal(SFU_SignalServer) error
}
UnstableSFUService is the service API for SFU service. New methods may be added to this interface if they are added to the service definition, which is not a backward-compatible change. For this reason, use of this type is not recommended.