Documentation
¶
Index ¶
- Constants
- Variables
- func KeyNodeMap() string
- func KeyNodeRooms(nodeID string) string
- func KeyRoomData(roomID string) string
- func KeyRoomUsers(roomID string) string
- func KeyTopicFromPeer(peerID string) string
- func KeyTopicToPeer(peerID string) string
- func KeyUserData(userID string) string
- func KeyWorkerTopic(nodeID string) string
- func RegisterNoirSFUServer(s grpc.ServiceRegistrar, srv NoirSFUServer)
- type JoinReply
- type JoinRequest
- func (*JoinRequest) Descriptor() ([]byte, []int)deprecated
- func (x *JoinRequest) GetDescription() []byte
- func (x *JoinRequest) GetSid() string
- func (*JoinRequest) ProtoMessage()
- func (x *JoinRequest) ProtoReflect() protoreflect.Message
- func (x *JoinRequest) Reset()
- func (x *JoinRequest) String() string
- type KeyGroup
- type KeyMap
- type NodeData
- type NoirObject
- func (*NoirObject) Descriptor() ([]byte, []int)deprecated
- func (m *NoirObject) GetData() isNoirObject_Data
- func (x *NoirObject) GetNode() *NodeData
- func (x *NoirObject) GetRoom() *RoomData
- func (x *NoirObject) GetUser() *UserData
- func (*NoirObject) ProtoMessage()
- func (x *NoirObject) ProtoReflect() protoreflect.Message
- func (x *NoirObject) Reset()
- func (x *NoirObject) String() string
- type NoirObject_Node
- type NoirObject_Room
- type NoirObject_User
- type NoirReply
- func (*NoirReply) Descriptor() ([]byte, []int)deprecated
- func (x *NoirReply) GetAt() string
- func (m *NoirReply) GetCommand() isNoirReply_Command
- func (x *NoirReply) GetError() string
- func (x *NoirReply) GetId() string
- func (x *NoirReply) GetRoomAdmin() *RoomAdminReply
- func (x *NoirReply) GetSignal() *SignalReply
- func (*NoirReply) ProtoMessage()
- func (x *NoirReply) ProtoReflect() protoreflect.Message
- func (x *NoirReply) Reset()
- func (x *NoirReply) String() string
- type NoirReply_Error
- type NoirReply_RoomAdmin
- type NoirReply_Signal
- type NoirRequest
- func (*NoirRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NoirRequest) GetAction() string
- func (x *NoirRequest) GetAt() string
- func (m *NoirRequest) GetCommand() isNoirRequest_Command
- func (x *NoirRequest) GetId() string
- func (x *NoirRequest) GetRoomAdmin() *RoomAdminRequest
- func (x *NoirRequest) GetSignal() *SignalRequest
- func (*NoirRequest) ProtoMessage()
- func (x *NoirRequest) ProtoReflect() protoreflect.Message
- func (x *NoirRequest) Reset()
- func (x *NoirRequest) String() string
- type NoirRequest_RoomAdmin
- type NoirRequest_Signal
- type NoirSFUClient
- type NoirSFUServer
- type NoirSFU_AdminClient
- type NoirSFU_AdminServer
- type OpenRoomRequest
- type PlayFileReply
- func (*PlayFileReply) Descriptor() ([]byte, []int)deprecated
- func (x *PlayFileReply) GetFilename() string
- func (x *PlayFileReply) GetPid() string
- func (x *PlayFileReply) GetRepeat() bool
- func (x *PlayFileReply) GetStatus() bool
- func (*PlayFileReply) ProtoMessage()
- func (x *PlayFileReply) ProtoReflect() protoreflect.Message
- func (x *PlayFileReply) Reset()
- func (x *PlayFileReply) String() string
- type PlayFileRequest
- func (*PlayFileRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PlayFileRequest) GetFilename() string
- func (x *PlayFileRequest) GetPid() string
- func (x *PlayFileRequest) GetRepeat() bool
- func (*PlayFileRequest) ProtoMessage()
- func (x *PlayFileRequest) ProtoReflect() protoreflect.Message
- func (x *PlayFileRequest) Reset()
- func (x *PlayFileRequest) String() string
- type RoomAdminReply
- func (*RoomAdminReply) Descriptor() ([]byte, []int)deprecated
- func (x *RoomAdminReply) GetError() string
- func (m *RoomAdminReply) GetPayload() isRoomAdminReply_Payload
- func (x *RoomAdminReply) GetRoomID() string
- func (*RoomAdminReply) ProtoMessage()
- func (x *RoomAdminReply) ProtoReflect() protoreflect.Message
- func (x *RoomAdminReply) Reset()
- func (x *RoomAdminReply) String() string
- type RoomAdminReply_Error
- type RoomAdminRequest
- func (*RoomAdminRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RoomAdminRequest) GetOpenRoom() *OpenRoomRequest
- func (m *RoomAdminRequest) GetPayload() isRoomAdminRequest_Payload
- func (x *RoomAdminRequest) GetPlayFile() *PlayFileRequest
- func (x *RoomAdminRequest) GetRoomID() string
- func (*RoomAdminRequest) ProtoMessage()
- func (x *RoomAdminRequest) ProtoReflect() protoreflect.Message
- func (x *RoomAdminRequest) Reset()
- func (x *RoomAdminRequest) String() string
- type RoomAdminRequest_OpenRoom
- type RoomAdminRequest_PlayFile
- type RoomData
- func (*RoomData) Descriptor() ([]byte, []int)deprecated
- func (x *RoomData) GetCreated() *timestamp.Timestamp
- func (x *RoomData) GetId() string
- func (x *RoomData) GetLastUpdate() *timestamp.Timestamp
- func (x *RoomData) GetNodeID() string
- func (x *RoomData) GetOptions() *RoomOptions
- func (x *RoomData) GetPublisher() string
- func (*RoomData) ProtoMessage()
- func (x *RoomData) ProtoReflect() protoreflect.Message
- func (x *RoomData) Reset()
- func (x *RoomData) String() string
- type RoomOptions
- func (*RoomOptions) Descriptor() ([]byte, []int)deprecated
- func (x *RoomOptions) GetDebug() int32
- func (x *RoomOptions) GetIsChannel() bool
- func (x *RoomOptions) GetJoinPassword() string
- func (x *RoomOptions) GetKeyExpiryFactor() int32
- func (x *RoomOptions) GetMaxAgeSeconds() int32
- func (x *RoomOptions) GetMaxPeers() int32
- func (x *RoomOptions) GetPublishPassword() string
- func (x *RoomOptions) GetTitle() string
- func (*RoomOptions) ProtoMessage()
- func (x *RoomOptions) ProtoReflect() protoreflect.Message
- func (x *RoomOptions) Reset()
- func (x *RoomOptions) String() string
- type SignalReply
- func (*SignalReply) Descriptor() ([]byte, []int)deprecated
- func (x *SignalReply) GetDescription() []byte
- func (x *SignalReply) GetError() string
- func (x *SignalReply) GetIceConnectionState() string
- func (x *SignalReply) GetId() string
- func (x *SignalReply) GetJoin() *JoinReply
- func (x *SignalReply) GetKill() bool
- func (m *SignalReply) GetPayload() isSignalReply_Payload
- func (x *SignalReply) GetRequestId() string
- 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_Description
- type SignalReply_Error
- type SignalReply_IceConnectionState
- type SignalReply_Join
- type SignalReply_Kill
- type SignalReply_Trickle
- type SignalRequest
- func (*SignalRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SignalRequest) GetDescription() []byte
- func (x *SignalRequest) GetId() string
- func (x *SignalRequest) GetJoin() *JoinRequest
- func (x *SignalRequest) GetKill() bool
- func (m *SignalRequest) GetPayload() isSignalRequest_Payload
- func (x *SignalRequest) GetRequestId() string
- 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_Description
- type SignalRequest_Join
- type SignalRequest_Kill
- type SignalRequest_Trickle
- type Trickle
- type Trickle_Target
- func (Trickle_Target) Descriptor() protoreflect.EnumDescriptor
- func (x Trickle_Target) Enum() *Trickle_Target
- func (Trickle_Target) EnumDescriptor() ([]byte, []int)deprecated
- func (x Trickle_Target) Number() protoreflect.EnumNumber
- func (x Trickle_Target) String() string
- func (Trickle_Target) Type() protoreflect.EnumType
- type UnimplementedNoirSFUServer
- type UnsafeNoirSFUServer
- type UserData
- func (*UserData) Descriptor() ([]byte, []int)deprecated
- func (x *UserData) GetCreated() *timestamp.Timestamp
- func (x *UserData) GetId() string
- func (x *UserData) GetLastUpdate() *timestamp.Timestamp
- func (x *UserData) GetOptions() *UserOptions
- func (x *UserData) GetPublishing() bool
- func (x *UserData) GetRoomID() string
- func (*UserData) ProtoMessage()
- func (x *UserData) ProtoReflect() protoreflect.Message
- func (x *UserData) Reset()
- func (x *UserData) String() string
- type UserOptions
- func (*UserOptions) Descriptor() ([]byte, []int)deprecated
- func (x *UserOptions) GetDebug() int32
- func (x *UserOptions) GetKeyExpiryFactor() int32
- func (x *UserOptions) GetMaxAgeSeconds() int32
- func (x *UserOptions) GetTitle() string
- func (*UserOptions) ProtoMessage()
- func (x *UserOptions) ProtoReflect() protoreflect.Message
- func (x *UserOptions) Reset()
- func (x *UserOptions) String() string
Constants ¶
const ( TYPE_SET = 0 TYPE_SETNX = 1 TYPE_MAP = 2 TYPE_LIST = 3 )
Variables ¶
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.
var File_pkg_proto_noir_proto protoreflect.FileDescriptor
var NoirSFU_ServiceDesc = grpc.ServiceDesc{ ServiceName: "noir.NoirSFU", HandlerType: (*NoirSFUServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Admin", Handler: _NoirSFU_Admin_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "pkg/proto/noir.proto", }
NoirSFU_ServiceDesc is the grpc.ServiceDesc for NoirSFU service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func KeyNodeMap ¶ added in v0.2.1
func KeyNodeMap() string
func KeyNodeRooms ¶ added in v0.2.1
func KeyRoomData ¶ added in v0.2.1
func KeyRoomUsers ¶ added in v0.2.1
func KeyTopicFromPeer ¶
func KeyTopicToPeer ¶
func KeyUserData ¶ added in v0.2.1
func KeyWorkerTopic ¶
func RegisterNoirSFUServer ¶
func RegisterNoirSFUServer(s grpc.ServiceRegistrar, srv NoirSFUServer)
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) GetDescription ¶
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"` Description []byte `protobuf:"bytes,2,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) 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 NodeData ¶ added in v0.2.1
type NodeData struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` LastUpdate *timestamp.Timestamp `protobuf:"bytes,2,opt,name=lastUpdate,proto3" json:"lastUpdate,omitempty"` // contains filtered or unexported fields }
func (*NodeData) Descriptor
deprecated
added in
v0.2.1
func (*NodeData) GetLastUpdate ¶ added in v0.2.1
func (*NodeData) ProtoMessage ¶ added in v0.2.1
func (*NodeData) ProtoMessage()
func (*NodeData) ProtoReflect ¶ added in v0.2.1
func (x *NodeData) ProtoReflect() protoreflect.Message
type NoirObject ¶ added in v0.2.1
type NoirObject struct { // Types that are assignable to Data: // *NoirObject_Node // *NoirObject_Room // *NoirObject_User Data isNoirObject_Data `protobuf_oneof:"data"` // contains filtered or unexported fields }
func (*NoirObject) Descriptor
deprecated
added in
v0.2.1
func (*NoirObject) Descriptor() ([]byte, []int)
Deprecated: Use NoirObject.ProtoReflect.Descriptor instead.
func (*NoirObject) GetData ¶ added in v0.2.1
func (m *NoirObject) GetData() isNoirObject_Data
func (*NoirObject) GetNode ¶ added in v0.2.1
func (x *NoirObject) GetNode() *NodeData
func (*NoirObject) GetRoom ¶ added in v0.2.1
func (x *NoirObject) GetRoom() *RoomData
func (*NoirObject) GetUser ¶ added in v0.2.1
func (x *NoirObject) GetUser() *UserData
func (*NoirObject) ProtoMessage ¶ added in v0.2.1
func (*NoirObject) ProtoMessage()
func (*NoirObject) ProtoReflect ¶ added in v0.2.1
func (x *NoirObject) ProtoReflect() protoreflect.Message
func (*NoirObject) Reset ¶ added in v0.2.1
func (x *NoirObject) Reset()
func (*NoirObject) String ¶ added in v0.2.1
func (x *NoirObject) String() string
type NoirObject_Node ¶ added in v0.2.1
type NoirObject_Node struct {
Node *NodeData `protobuf:"bytes,1,opt,name=node,proto3,oneof"`
}
type NoirObject_Room ¶ added in v0.2.1
type NoirObject_Room struct {
Room *RoomData `protobuf:"bytes,2,opt,name=room,proto3,oneof"`
}
type NoirObject_User ¶ added in v0.2.1
type NoirObject_User struct {
User *UserData `protobuf:"bytes,3,opt,name=user,proto3,oneof"`
}
type NoirReply ¶
type NoirReply struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` At string `protobuf:"bytes,2,opt,name=at,proto3" json:"at,omitempty"` // Types that are assignable to Command: // *NoirReply_Signal // *NoirReply_RoomAdmin // *NoirReply_Error Command isNoirReply_Command `protobuf_oneof:"command"` // contains filtered or unexported fields }
func (*NoirReply) Descriptor
deprecated
func (*NoirReply) GetCommand ¶
func (m *NoirReply) GetCommand() isNoirReply_Command
func (*NoirReply) GetRoomAdmin ¶ added in v0.2.1
func (x *NoirReply) GetRoomAdmin() *RoomAdminReply
func (*NoirReply) GetSignal ¶
func (x *NoirReply) GetSignal() *SignalReply
func (*NoirReply) ProtoMessage ¶
func (*NoirReply) ProtoMessage()
func (*NoirReply) ProtoReflect ¶
func (x *NoirReply) ProtoReflect() protoreflect.Message
type NoirReply_Error ¶
type NoirReply_Error struct {
Error string `protobuf:"bytes,5,opt,name=error,proto3,oneof"`
}
type NoirReply_RoomAdmin ¶ added in v0.2.1
type NoirReply_RoomAdmin struct {
RoomAdmin *RoomAdminReply `protobuf:"bytes,4,opt,name=roomAdmin,proto3,oneof"`
}
type NoirReply_Signal ¶
type NoirReply_Signal struct {
Signal *SignalReply `protobuf:"bytes,3,opt,name=signal,proto3,oneof"`
}
type NoirRequest ¶
type NoirRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` At string `protobuf:"bytes,2,opt,name=at,proto3" json:"at,omitempty"` Action string `protobuf:"bytes,3,opt,name=action,proto3" json:"action,omitempty"` // Types that are assignable to Command: // *NoirRequest_Signal // *NoirRequest_RoomAdmin Command isNoirRequest_Command `protobuf_oneof:"command"` // contains filtered or unexported fields }
func (*NoirRequest) Descriptor
deprecated
func (*NoirRequest) Descriptor() ([]byte, []int)
Deprecated: Use NoirRequest.ProtoReflect.Descriptor instead.
func (*NoirRequest) GetAction ¶
func (x *NoirRequest) GetAction() string
func (*NoirRequest) GetAt ¶
func (x *NoirRequest) GetAt() string
func (*NoirRequest) GetCommand ¶
func (m *NoirRequest) GetCommand() isNoirRequest_Command
func (*NoirRequest) GetId ¶
func (x *NoirRequest) GetId() string
func (*NoirRequest) GetRoomAdmin ¶ added in v0.2.1
func (x *NoirRequest) GetRoomAdmin() *RoomAdminRequest
func (*NoirRequest) GetSignal ¶
func (x *NoirRequest) GetSignal() *SignalRequest
func (*NoirRequest) ProtoMessage ¶
func (*NoirRequest) ProtoMessage()
func (*NoirRequest) ProtoReflect ¶
func (x *NoirRequest) ProtoReflect() protoreflect.Message
func (*NoirRequest) Reset ¶
func (x *NoirRequest) Reset()
func (*NoirRequest) String ¶
func (x *NoirRequest) String() string
type NoirRequest_RoomAdmin ¶ added in v0.2.1
type NoirRequest_RoomAdmin struct {
RoomAdmin *RoomAdminRequest `protobuf:"bytes,5,opt,name=roomAdmin,proto3,oneof"`
}
type NoirRequest_Signal ¶
type NoirRequest_Signal struct {
Signal *SignalRequest `protobuf:"bytes,4,opt,name=signal,proto3,oneof"`
}
type NoirSFUClient ¶
type NoirSFUClient interface {
Admin(ctx context.Context, opts ...grpc.CallOption) (NoirSFU_AdminClient, error)
}
NoirSFUClient is the client API for NoirSFU 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 NewNoirSFUClient ¶
func NewNoirSFUClient(cc grpc.ClientConnInterface) NoirSFUClient
type NoirSFUServer ¶
type NoirSFUServer interface { Admin(NoirSFU_AdminServer) error // contains filtered or unexported methods }
NoirSFUServer is the server API for NoirSFU service. All implementations must embed UnimplementedNoirSFUServer for forward compatibility
type NoirSFU_AdminClient ¶
type NoirSFU_AdminClient interface { Send(*NoirRequest) error Recv() (*NoirReply, error) grpc.ClientStream }
type NoirSFU_AdminServer ¶
type NoirSFU_AdminServer interface { Send(*NoirReply) error Recv() (*NoirRequest, error) grpc.ServerStream }
type OpenRoomRequest ¶ added in v0.2.1
type OpenRoomRequest struct { Options *RoomOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"` // contains filtered or unexported fields }
func (*OpenRoomRequest) Descriptor
deprecated
added in
v0.2.1
func (*OpenRoomRequest) Descriptor() ([]byte, []int)
Deprecated: Use OpenRoomRequest.ProtoReflect.Descriptor instead.
func (*OpenRoomRequest) GetOptions ¶ added in v0.2.1
func (x *OpenRoomRequest) GetOptions() *RoomOptions
func (*OpenRoomRequest) ProtoMessage ¶ added in v0.2.1
func (*OpenRoomRequest) ProtoMessage()
func (*OpenRoomRequest) ProtoReflect ¶ added in v0.2.1
func (x *OpenRoomRequest) ProtoReflect() protoreflect.Message
func (*OpenRoomRequest) Reset ¶ added in v0.2.1
func (x *OpenRoomRequest) Reset()
func (*OpenRoomRequest) String ¶ added in v0.2.1
func (x *OpenRoomRequest) String() string
type PlayFileReply ¶
type PlayFileReply struct { Pid string `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"` // peer id will be random if not specified Filename string `protobuf:"bytes,2,opt,name=filename,proto3" json:"filename,omitempty"` Repeat bool `protobuf:"varint,3,opt,name=repeat,proto3" json:"repeat,omitempty"` Status bool `protobuf:"varint,4,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*PlayFileReply) Descriptor
deprecated
func (*PlayFileReply) Descriptor() ([]byte, []int)
Deprecated: Use PlayFileReply.ProtoReflect.Descriptor instead.
func (*PlayFileReply) GetFilename ¶
func (x *PlayFileReply) GetFilename() string
func (*PlayFileReply) GetPid ¶
func (x *PlayFileReply) GetPid() string
func (*PlayFileReply) GetRepeat ¶
func (x *PlayFileReply) GetRepeat() bool
func (*PlayFileReply) GetStatus ¶
func (x *PlayFileReply) GetStatus() bool
func (*PlayFileReply) ProtoMessage ¶
func (*PlayFileReply) ProtoMessage()
func (*PlayFileReply) ProtoReflect ¶
func (x *PlayFileReply) ProtoReflect() protoreflect.Message
func (*PlayFileReply) Reset ¶
func (x *PlayFileReply) Reset()
func (*PlayFileReply) String ¶
func (x *PlayFileReply) String() string
type PlayFileRequest ¶
type PlayFileRequest struct { Pid string `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"` // peer id will be random if not specified Filename string `protobuf:"bytes,2,opt,name=filename,proto3" json:"filename,omitempty"` Repeat bool `protobuf:"varint,3,opt,name=repeat,proto3" json:"repeat,omitempty"` // contains filtered or unexported fields }
func (*PlayFileRequest) Descriptor
deprecated
func (*PlayFileRequest) Descriptor() ([]byte, []int)
Deprecated: Use PlayFileRequest.ProtoReflect.Descriptor instead.
func (*PlayFileRequest) GetFilename ¶
func (x *PlayFileRequest) GetFilename() string
func (*PlayFileRequest) GetPid ¶
func (x *PlayFileRequest) GetPid() string
func (*PlayFileRequest) GetRepeat ¶
func (x *PlayFileRequest) GetRepeat() bool
func (*PlayFileRequest) ProtoMessage ¶
func (*PlayFileRequest) ProtoMessage()
func (*PlayFileRequest) ProtoReflect ¶
func (x *PlayFileRequest) ProtoReflect() protoreflect.Message
func (*PlayFileRequest) Reset ¶
func (x *PlayFileRequest) Reset()
func (*PlayFileRequest) String ¶
func (x *PlayFileRequest) String() string
type RoomAdminReply ¶ added in v0.2.1
type RoomAdminReply struct { RoomID string `protobuf:"bytes,1,opt,name=roomID,proto3" json:"roomID,omitempty"` // Types that are assignable to Payload: // *RoomAdminReply_Error Payload isRoomAdminReply_Payload `protobuf_oneof:"payload"` // contains filtered or unexported fields }
func (*RoomAdminReply) Descriptor
deprecated
added in
v0.2.1
func (*RoomAdminReply) Descriptor() ([]byte, []int)
Deprecated: Use RoomAdminReply.ProtoReflect.Descriptor instead.
func (*RoomAdminReply) GetError ¶ added in v0.2.1
func (x *RoomAdminReply) GetError() string
func (*RoomAdminReply) GetPayload ¶ added in v0.2.1
func (m *RoomAdminReply) GetPayload() isRoomAdminReply_Payload
func (*RoomAdminReply) GetRoomID ¶ added in v0.2.1
func (x *RoomAdminReply) GetRoomID() string
func (*RoomAdminReply) ProtoMessage ¶ added in v0.2.1
func (*RoomAdminReply) ProtoMessage()
func (*RoomAdminReply) ProtoReflect ¶ added in v0.2.1
func (x *RoomAdminReply) ProtoReflect() protoreflect.Message
func (*RoomAdminReply) Reset ¶ added in v0.2.1
func (x *RoomAdminReply) Reset()
func (*RoomAdminReply) String ¶ added in v0.2.1
func (x *RoomAdminReply) String() string
type RoomAdminReply_Error ¶ added in v0.2.1
type RoomAdminReply_Error struct {
Error string `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}
type RoomAdminRequest ¶ added in v0.2.1
type RoomAdminRequest struct { RoomID string `protobuf:"bytes,1,opt,name=roomID,proto3" json:"roomID,omitempty"` // Types that are assignable to Payload: // *RoomAdminRequest_OpenRoom // *RoomAdminRequest_PlayFile Payload isRoomAdminRequest_Payload `protobuf_oneof:"payload"` // contains filtered or unexported fields }
**************************************************** Room Admin Commands ***************************************************
func (*RoomAdminRequest) Descriptor
deprecated
added in
v0.2.1
func (*RoomAdminRequest) Descriptor() ([]byte, []int)
Deprecated: Use RoomAdminRequest.ProtoReflect.Descriptor instead.
func (*RoomAdminRequest) GetOpenRoom ¶ added in v0.2.1
func (x *RoomAdminRequest) GetOpenRoom() *OpenRoomRequest
func (*RoomAdminRequest) GetPayload ¶ added in v0.2.1
func (m *RoomAdminRequest) GetPayload() isRoomAdminRequest_Payload
func (*RoomAdminRequest) GetPlayFile ¶ added in v0.2.1
func (x *RoomAdminRequest) GetPlayFile() *PlayFileRequest
func (*RoomAdminRequest) GetRoomID ¶ added in v0.2.1
func (x *RoomAdminRequest) GetRoomID() string
func (*RoomAdminRequest) ProtoMessage ¶ added in v0.2.1
func (*RoomAdminRequest) ProtoMessage()
func (*RoomAdminRequest) ProtoReflect ¶ added in v0.2.1
func (x *RoomAdminRequest) ProtoReflect() protoreflect.Message
func (*RoomAdminRequest) Reset ¶ added in v0.2.1
func (x *RoomAdminRequest) Reset()
func (*RoomAdminRequest) String ¶ added in v0.2.1
func (x *RoomAdminRequest) String() string
type RoomAdminRequest_OpenRoom ¶ added in v0.2.1
type RoomAdminRequest_OpenRoom struct {
OpenRoom *OpenRoomRequest `protobuf:"bytes,2,opt,name=openRoom,proto3,oneof"`
}
type RoomAdminRequest_PlayFile ¶ added in v0.2.1
type RoomAdminRequest_PlayFile struct {
PlayFile *PlayFileRequest `protobuf:"bytes,3,opt,name=play_file,json=playFile,proto3,oneof"`
}
type RoomData ¶ added in v0.2.1
type RoomData struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Created *timestamp.Timestamp `protobuf:"bytes,2,opt,name=created,proto3" json:"created,omitempty"` LastUpdate *timestamp.Timestamp `protobuf:"bytes,3,opt,name=lastUpdate,proto3" json:"lastUpdate,omitempty"` NodeID string `protobuf:"bytes,4,opt,name=nodeID,proto3" json:"nodeID,omitempty"` Options *RoomOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"` Publisher string `protobuf:"bytes,6,opt,name=publisher,proto3" json:"publisher,omitempty"` // contains filtered or unexported fields }
func (*RoomData) Descriptor
deprecated
added in
v0.2.1
func (*RoomData) GetCreated ¶ added in v0.2.1
func (*RoomData) GetLastUpdate ¶ added in v0.2.1
func (*RoomData) GetOptions ¶ added in v0.2.1
func (x *RoomData) GetOptions() *RoomOptions
func (*RoomData) GetPublisher ¶ added in v0.2.1
func (*RoomData) ProtoMessage ¶ added in v0.2.1
func (*RoomData) ProtoMessage()
func (*RoomData) ProtoReflect ¶ added in v0.2.1
func (x *RoomData) ProtoReflect() protoreflect.Message
type RoomOptions ¶ added in v0.2.1
type RoomOptions struct { Debug int32 `protobuf:"varint,1,opt,name=debug,proto3" json:"debug,omitempty"` Title string `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"` MaxAgeSeconds int32 `protobuf:"varint,3,opt,name=maxAgeSeconds,proto3" json:"maxAgeSeconds,omitempty"` KeyExpiryFactor int32 `protobuf:"varint,4,opt,name=keyExpiryFactor,proto3" json:"keyExpiryFactor,omitempty"` JoinPassword string `protobuf:"bytes,5,opt,name=joinPassword,proto3" json:"joinPassword,omitempty"` PublishPassword string `protobuf:"bytes,6,opt,name=publishPassword,proto3" json:"publishPassword,omitempty"` MaxPeers int32 `protobuf:"varint,7,opt,name=maxPeers,proto3" json:"maxPeers,omitempty"` IsChannel bool `protobuf:"varint,8,opt,name=isChannel,proto3" json:"isChannel,omitempty"` // contains filtered or unexported fields }
func (*RoomOptions) Descriptor
deprecated
added in
v0.2.1
func (*RoomOptions) Descriptor() ([]byte, []int)
Deprecated: Use RoomOptions.ProtoReflect.Descriptor instead.
func (*RoomOptions) GetDebug ¶ added in v0.2.1
func (x *RoomOptions) GetDebug() int32
func (*RoomOptions) GetIsChannel ¶ added in v0.2.1
func (x *RoomOptions) GetIsChannel() bool
func (*RoomOptions) GetJoinPassword ¶ added in v0.2.1
func (x *RoomOptions) GetJoinPassword() string
func (*RoomOptions) GetKeyExpiryFactor ¶ added in v0.2.1
func (x *RoomOptions) GetKeyExpiryFactor() int32
func (*RoomOptions) GetMaxAgeSeconds ¶ added in v0.2.1
func (x *RoomOptions) GetMaxAgeSeconds() int32
func (*RoomOptions) GetMaxPeers ¶ added in v0.2.1
func (x *RoomOptions) GetMaxPeers() int32
func (*RoomOptions) GetPublishPassword ¶ added in v0.2.1
func (x *RoomOptions) GetPublishPassword() string
func (*RoomOptions) GetTitle ¶ added in v0.2.1
func (x *RoomOptions) GetTitle() string
func (*RoomOptions) ProtoMessage ¶ added in v0.2.1
func (*RoomOptions) ProtoMessage()
func (*RoomOptions) ProtoReflect ¶ added in v0.2.1
func (x *RoomOptions) ProtoReflect() protoreflect.Message
func (*RoomOptions) Reset ¶ added in v0.2.1
func (x *RoomOptions) Reset()
func (*RoomOptions) String ¶ added in v0.2.1
func (x *RoomOptions) String() string
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 // *SignalReply_Kill Payload isSignalReply_Payload `protobuf_oneof:"payload"` RequestId string `protobuf:"bytes,8,opt,name=requestId,proto3" json:"requestId,omitempty"` // optional, for requests with replies // 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) GetKill ¶ added in v0.2.1
func (x *SignalReply) GetKill() bool
func (*SignalReply) GetPayload ¶
func (m *SignalReply) GetPayload() isSignalReply_Payload
func (*SignalReply) GetRequestId ¶
func (x *SignalReply) GetRequestId() string
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_Kill ¶ added in v0.2.1
type SignalReply_Kill struct {
Kill bool `protobuf:"varint,7,opt,name=kill,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"` // SignalRequest.id should be called pid but we are ion-sfu compatible // Types that are assignable to Payload: // *SignalRequest_Join // *SignalRequest_Description // *SignalRequest_Trickle // *SignalRequest_Kill Payload isSignalRequest_Payload `protobuf_oneof:"payload"` RequestId string `protobuf:"bytes,6,opt,name=requestId,proto3" json:"requestId,omitempty"` // optional, for requests with replies // contains filtered or unexported fields }
**************************************************** SIGNAL COMMANDS - ION-SFU COMPATIBLE 1 SIGNAL = 1 CLIENT CONNECTION ***************************************************
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) GetKill ¶ added in v0.2.1
func (x *SignalRequest) GetKill() bool
func (*SignalRequest) GetPayload ¶
func (m *SignalRequest) GetPayload() isSignalRequest_Payload
func (*SignalRequest) GetRequestId ¶
func (x *SignalRequest) GetRequestId() string
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_Kill ¶ added in v0.2.1
type SignalRequest_Kill struct {
Kill bool `protobuf:"varint,5,opt,name=kill,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=noir.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) GetTarget ¶
func (x *Trickle) GetTarget() Trickle_Target
func (*Trickle) ProtoMessage ¶
func (*Trickle) ProtoMessage()
func (*Trickle) ProtoReflect ¶
func (x *Trickle) ProtoReflect() protoreflect.Message
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) Descriptor() protoreflect.EnumDescriptor
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 (x Trickle_Target) Number() protoreflect.EnumNumber
func (Trickle_Target) String ¶
func (x Trickle_Target) String() string
func (Trickle_Target) Type ¶
func (Trickle_Target) Type() protoreflect.EnumType
type UnimplementedNoirSFUServer ¶
type UnimplementedNoirSFUServer struct { }
UnimplementedNoirSFUServer must be embedded to have forward compatible implementations.
func (UnimplementedNoirSFUServer) Admin ¶
func (UnimplementedNoirSFUServer) Admin(NoirSFU_AdminServer) error
type UnsafeNoirSFUServer ¶
type UnsafeNoirSFUServer interface {
// contains filtered or unexported methods
}
UnsafeNoirSFUServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NoirSFUServer will result in compilation errors.
type UserData ¶ added in v0.2.1
type UserData struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Created *timestamp.Timestamp `protobuf:"bytes,2,opt,name=created,proto3" json:"created,omitempty"` LastUpdate *timestamp.Timestamp `protobuf:"bytes,3,opt,name=lastUpdate,proto3" json:"lastUpdate,omitempty"` RoomID string `protobuf:"bytes,4,opt,name=roomID,proto3" json:"roomID,omitempty"` Options *UserOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"` Publishing bool `protobuf:"varint,6,opt,name=publishing,proto3" json:"publishing,omitempty"` // contains filtered or unexported fields }
func (*UserData) Descriptor
deprecated
added in
v0.2.1
func (*UserData) GetCreated ¶ added in v0.2.1
func (*UserData) GetLastUpdate ¶ added in v0.2.1
func (*UserData) GetOptions ¶ added in v0.2.1
func (x *UserData) GetOptions() *UserOptions
func (*UserData) GetPublishing ¶ added in v0.2.1
func (*UserData) ProtoMessage ¶ added in v0.2.1
func (*UserData) ProtoMessage()
func (*UserData) ProtoReflect ¶ added in v0.2.1
func (x *UserData) ProtoReflect() protoreflect.Message
type UserOptions ¶ added in v0.2.1
type UserOptions struct { Debug int32 `protobuf:"varint,1,opt,name=debug,proto3" json:"debug,omitempty"` Title string `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"` MaxAgeSeconds int32 `protobuf:"varint,3,opt,name=maxAgeSeconds,proto3" json:"maxAgeSeconds,omitempty"` KeyExpiryFactor int32 `protobuf:"varint,4,opt,name=keyExpiryFactor,proto3" json:"keyExpiryFactor,omitempty"` // contains filtered or unexported fields }
func (*UserOptions) Descriptor
deprecated
added in
v0.2.1
func (*UserOptions) Descriptor() ([]byte, []int)
Deprecated: Use UserOptions.ProtoReflect.Descriptor instead.
func (*UserOptions) GetDebug ¶ added in v0.2.1
func (x *UserOptions) GetDebug() int32
func (*UserOptions) GetKeyExpiryFactor ¶ added in v0.2.1
func (x *UserOptions) GetKeyExpiryFactor() int32
func (*UserOptions) GetMaxAgeSeconds ¶ added in v0.2.1
func (x *UserOptions) GetMaxAgeSeconds() int32
func (*UserOptions) GetTitle ¶ added in v0.2.1
func (x *UserOptions) GetTitle() string
func (*UserOptions) ProtoMessage ¶ added in v0.2.1
func (*UserOptions) ProtoMessage()
func (*UserOptions) ProtoReflect ¶ added in v0.2.1
func (x *UserOptions) ProtoReflect() protoreflect.Message
func (*UserOptions) Reset ¶ added in v0.2.1
func (x *UserOptions) Reset()
func (*UserOptions) String ¶ added in v0.2.1
func (x *UserOptions) String() string