Versions in this module Expand all Collapse all v1 v1.10.0 Nov 9, 2021 Changes in this version + var ErrorType_name = map[int32]string + var ErrorType_value = map[string]int32 + var File_apps_room_proto_room_proto protoreflect.FileDescriptor + var PeerState_name = map[int32]string + var PeerState_value = map[string]int32 + var Peer_Direction_name = map[int32]string + var Peer_Direction_value = map[string]int32 + var Protocol_name = map[int32]string + var Protocol_value = map[string]int32 + var Role_name = map[int32]string + var Role_value = map[string]int32 + var RoomService_ServiceDesc = grpc.ServiceDesc + var RoomSignal_ServiceDesc = grpc.ServiceDesc + func RegisterRoomServiceServer(s grpc.ServiceRegistrar, srv RoomServiceServer) + func RegisterRoomSignalServer(s grpc.ServiceRegistrar, srv RoomSignalServer) + type AddPeerReply struct + Error *Error + Success bool + func (*AddPeerReply) Descriptor() ([]byte, []int) + func (*AddPeerReply) ProtoMessage() + func (x *AddPeerReply) GetError() *Error + func (x *AddPeerReply) GetSuccess() bool + func (x *AddPeerReply) ProtoReflect() protoreflect.Message + func (x *AddPeerReply) Reset() + func (x *AddPeerReply) String() string + type AddPeerRequest struct + Peer *Peer + func (*AddPeerRequest) Descriptor() ([]byte, []int) + func (*AddPeerRequest) ProtoMessage() + func (x *AddPeerRequest) GetPeer() *Peer + func (x *AddPeerRequest) ProtoReflect() protoreflect.Message + func (x *AddPeerRequest) Reset() + func (x *AddPeerRequest) String() string + type CreateRoomReply struct + Error *Error + Success bool + func (*CreateRoomReply) Descriptor() ([]byte, []int) + func (*CreateRoomReply) ProtoMessage() + func (x *CreateRoomReply) GetError() *Error + func (x *CreateRoomReply) GetSuccess() bool + func (x *CreateRoomReply) ProtoReflect() protoreflect.Message + func (x *CreateRoomReply) Reset() + func (x *CreateRoomReply) String() string + type CreateRoomRequest struct + Room *Room + func (*CreateRoomRequest) Descriptor() ([]byte, []int) + func (*CreateRoomRequest) ProtoMessage() + func (x *CreateRoomRequest) GetRoom() *Room + func (x *CreateRoomRequest) ProtoReflect() protoreflect.Message + func (x *CreateRoomRequest) Reset() + func (x *CreateRoomRequest) String() string + type DeleteRoomReply struct + Error *Error + Success bool + func (*DeleteRoomReply) Descriptor() ([]byte, []int) + func (*DeleteRoomReply) ProtoMessage() + func (x *DeleteRoomReply) GetError() *Error + func (x *DeleteRoomReply) GetSuccess() bool + func (x *DeleteRoomReply) ProtoReflect() protoreflect.Message + func (x *DeleteRoomReply) Reset() + func (x *DeleteRoomReply) String() string + type DeleteRoomRequest struct + Sid string + func (*DeleteRoomRequest) Descriptor() ([]byte, []int) + func (*DeleteRoomRequest) ProtoMessage() + func (x *DeleteRoomRequest) GetSid() string + func (x *DeleteRoomRequest) ProtoReflect() protoreflect.Message + func (x *DeleteRoomRequest) Reset() + func (x *DeleteRoomRequest) String() string + type Disconnect struct + Reason string + Sid string + func (*Disconnect) Descriptor() ([]byte, []int) + func (*Disconnect) ProtoMessage() + func (x *Disconnect) GetReason() string + func (x *Disconnect) GetSid() string + func (x *Disconnect) ProtoReflect() protoreflect.Message + func (x *Disconnect) Reset() + func (x *Disconnect) String() string + type EndRoomReply struct + Error *Error + Success bool + func (*EndRoomReply) Descriptor() ([]byte, []int) + func (*EndRoomReply) ProtoMessage() + func (x *EndRoomReply) GetError() *Error + func (x *EndRoomReply) GetSuccess() bool + func (x *EndRoomReply) ProtoReflect() protoreflect.Message + func (x *EndRoomReply) Reset() + func (x *EndRoomReply) String() string + type EndRoomRequest struct + Delete bool + Reason string + Sid string + func (*EndRoomRequest) Descriptor() ([]byte, []int) + func (*EndRoomRequest) ProtoMessage() + func (x *EndRoomRequest) GetDelete() bool + func (x *EndRoomRequest) GetReason() string + func (x *EndRoomRequest) GetSid() string + func (x *EndRoomRequest) ProtoReflect() protoreflect.Message + func (x *EndRoomRequest) Reset() + func (x *EndRoomRequest) String() string + type Error struct + Code ErrorType + Reason string + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (x *Error) GetCode() ErrorType + func (x *Error) GetReason() string + func (x *Error) ProtoReflect() protoreflect.Message + func (x *Error) Reset() + func (x *Error) String() string + type ErrorType int32 + const ErrorType_InvalidParams + const ErrorType_None + const ErrorType_PasswordRequired + const ErrorType_PeerAlreadyExist + const ErrorType_PeerNotExist + const ErrorType_PermissionDenied + const ErrorType_RoomAlreadyExist + const ErrorType_RoomLocked + const ErrorType_RoomNotExist + const ErrorType_ServiceUnavailable + const ErrorType_UnkownError + func (ErrorType) Descriptor() protoreflect.EnumDescriptor + func (ErrorType) EnumDescriptor() ([]byte, []int) + func (ErrorType) Type() protoreflect.EnumType + func (x ErrorType) Enum() *ErrorType + func (x ErrorType) Number() protoreflect.EnumNumber + func (x ErrorType) String() string + type GetPeersReply struct + Error *Error + Peers []*Peer + Success bool + func (*GetPeersReply) Descriptor() ([]byte, []int) + func (*GetPeersReply) ProtoMessage() + func (x *GetPeersReply) GetError() *Error + func (x *GetPeersReply) GetPeers() []*Peer + func (x *GetPeersReply) GetSuccess() bool + func (x *GetPeersReply) ProtoReflect() protoreflect.Message + func (x *GetPeersReply) Reset() + func (x *GetPeersReply) String() string + type GetPeersRequest struct + Sid string + func (*GetPeersRequest) Descriptor() ([]byte, []int) + func (*GetPeersRequest) ProtoMessage() + func (x *GetPeersRequest) GetSid() string + func (x *GetPeersRequest) ProtoReflect() protoreflect.Message + func (x *GetPeersRequest) Reset() + func (x *GetPeersRequest) String() string + type GetRoomsReply struct + Error *Error + Rooms []*Room + Success bool + func (*GetRoomsReply) Descriptor() ([]byte, []int) + func (*GetRoomsReply) ProtoMessage() + func (x *GetRoomsReply) GetError() *Error + func (x *GetRoomsReply) GetRooms() []*Room + func (x *GetRoomsReply) GetSuccess() bool + func (x *GetRoomsReply) ProtoReflect() protoreflect.Message + func (x *GetRoomsReply) Reset() + func (x *GetRoomsReply) String() string + type GetRoomsRequest struct + func (*GetRoomsRequest) Descriptor() ([]byte, []int) + func (*GetRoomsRequest) ProtoMessage() + func (x *GetRoomsRequest) ProtoReflect() protoreflect.Message + func (x *GetRoomsRequest) Reset() + func (x *GetRoomsRequest) String() string + type JoinReply struct + Error *Error + Role Role + Room *Room + Success bool + func (*JoinReply) Descriptor() ([]byte, []int) + func (*JoinReply) ProtoMessage() + func (x *JoinReply) GetError() *Error + func (x *JoinReply) GetRole() Role + func (x *JoinReply) GetRoom() *Room + func (x *JoinReply) GetSuccess() bool + func (x *JoinReply) ProtoReflect() protoreflect.Message + func (x *JoinReply) Reset() + func (x *JoinReply) String() string + type JoinRequest struct + Password string + Peer *Peer + func (*JoinRequest) Descriptor() ([]byte, []int) + func (*JoinRequest) ProtoMessage() + func (x *JoinRequest) GetPassword() string + func (x *JoinRequest) GetPeer() *Peer + func (x *JoinRequest) ProtoReflect() protoreflect.Message + func (x *JoinRequest) Reset() + func (x *JoinRequest) String() string + type LeaveReply struct + Error *Error + Success bool + func (*LeaveReply) Descriptor() ([]byte, []int) + func (*LeaveReply) ProtoMessage() + func (x *LeaveReply) GetError() *Error + func (x *LeaveReply) GetSuccess() bool + func (x *LeaveReply) ProtoReflect() protoreflect.Message + func (x *LeaveReply) Reset() + func (x *LeaveReply) String() string + type LeaveRequest struct + Sid string + Uid string + func (*LeaveRequest) Descriptor() ([]byte, []int) + func (*LeaveRequest) ProtoMessage() + func (x *LeaveRequest) GetSid() string + func (x *LeaveRequest) GetUid() string + func (x *LeaveRequest) ProtoReflect() protoreflect.Message + func (x *LeaveRequest) Reset() + func (x *LeaveRequest) String() string + type Message struct + From string + Payload []byte + To string + Type string + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (x *Message) GetFrom() string + func (x *Message) GetPayload() []byte + func (x *Message) GetTo() string + func (x *Message) GetType() string + func (x *Message) ProtoReflect() protoreflect.Message + func (x *Message) Reset() + func (x *Message) String() string + type Peer struct + Avatar string + Destination string + Direction Peer_Direction + DisplayName string + ExtraInfo []byte + Protocol Protocol + Role Role + Sid string + Uid string + Vendor string + func (*Peer) Descriptor() ([]byte, []int) + func (*Peer) ProtoMessage() + func (x *Peer) GetAvatar() string + func (x *Peer) GetDestination() string + func (x *Peer) GetDirection() Peer_Direction + func (x *Peer) GetDisplayName() string + func (x *Peer) GetExtraInfo() []byte + func (x *Peer) GetProtocol() Protocol + func (x *Peer) GetRole() Role + func (x *Peer) GetSid() string + func (x *Peer) GetUid() string + func (x *Peer) GetVendor() string + func (x *Peer) ProtoReflect() protoreflect.Message + func (x *Peer) Reset() + func (x *Peer) String() string + type PeerEvent struct + Peer *Peer + State PeerState + func (*PeerEvent) Descriptor() ([]byte, []int) + func (*PeerEvent) ProtoMessage() + func (x *PeerEvent) GetPeer() *Peer + func (x *PeerEvent) GetState() PeerState + func (x *PeerEvent) ProtoReflect() protoreflect.Message + func (x *PeerEvent) Reset() + func (x *PeerEvent) String() string + type PeerState int32 + const PeerState_JOIN + const PeerState_LEAVE + const PeerState_UPDATE + func (PeerState) Descriptor() protoreflect.EnumDescriptor + func (PeerState) EnumDescriptor() ([]byte, []int) + func (PeerState) Type() protoreflect.EnumType + func (x PeerState) Enum() *PeerState + func (x PeerState) Number() protoreflect.EnumNumber + func (x PeerState) String() string + type Peer_Direction int32 + const Peer_BILATERAL + const Peer_INCOMING + const Peer_OUTGOING + func (Peer_Direction) Descriptor() protoreflect.EnumDescriptor + func (Peer_Direction) EnumDescriptor() ([]byte, []int) + func (Peer_Direction) Type() protoreflect.EnumType + func (x Peer_Direction) Enum() *Peer_Direction + func (x Peer_Direction) Number() protoreflect.EnumNumber + func (x Peer_Direction) String() string + type Protocol int32 + const Protocol_ProtocolUnknown + const Protocol_RTMP + const Protocol_RTSP + const Protocol_SIP + const Protocol_WebRTC + func (Protocol) Descriptor() protoreflect.EnumDescriptor + func (Protocol) EnumDescriptor() ([]byte, []int) + func (Protocol) Type() protoreflect.EnumType + func (x Protocol) Enum() *Protocol + func (x Protocol) Number() protoreflect.EnumNumber + func (x Protocol) String() string + type RemovePeerReply struct + Error *Error + Success bool + func (*RemovePeerReply) Descriptor() ([]byte, []int) + func (*RemovePeerReply) ProtoMessage() + func (x *RemovePeerReply) GetError() *Error + func (x *RemovePeerReply) GetSuccess() bool + func (x *RemovePeerReply) ProtoReflect() protoreflect.Message + func (x *RemovePeerReply) Reset() + func (x *RemovePeerReply) String() string + type RemovePeerRequest struct + Sid string + Uid string + func (*RemovePeerRequest) Descriptor() ([]byte, []int) + func (*RemovePeerRequest) ProtoMessage() + func (x *RemovePeerRequest) GetSid() string + func (x *RemovePeerRequest) GetUid() string + func (x *RemovePeerRequest) ProtoReflect() protoreflect.Message + func (x *RemovePeerRequest) Reset() + func (x *RemovePeerRequest) String() string + type Reply struct + Payload isReply_Payload + func (*Reply) Descriptor() ([]byte, []int) + func (*Reply) ProtoMessage() + func (m *Reply) GetPayload() isReply_Payload + func (x *Reply) GetDisconnect() *Disconnect + func (x *Reply) GetJoin() *JoinReply + func (x *Reply) GetLeave() *LeaveReply + func (x *Reply) GetMessage() *Message + func (x *Reply) GetPeer() *PeerEvent + func (x *Reply) GetRoom() *Room + func (x *Reply) GetSendMessage() *SendMessageReply + func (x *Reply) ProtoReflect() protoreflect.Message + func (x *Reply) Reset() + func (x *Reply) String() string + type Reply_Disconnect struct + Disconnect *Disconnect + type Reply_Join struct + Join *JoinReply + type Reply_Leave struct + Leave *LeaveReply + type Reply_Message struct + Message *Message + type Reply_Peer struct + Peer *PeerEvent + type Reply_Room struct + Room *Room + type Reply_SendMessage struct + SendMessage *SendMessageReply + type Request struct + Payload isRequest_Payload + func (*Request) Descriptor() ([]byte, []int) + func (*Request) ProtoMessage() + func (m *Request) GetPayload() isRequest_Payload + func (x *Request) GetJoin() *JoinRequest + func (x *Request) GetLeave() *LeaveRequest + func (x *Request) GetSendMessage() *SendMessageRequest + func (x *Request) ProtoReflect() protoreflect.Message + func (x *Request) Reset() + func (x *Request) String() string + type Request_Join struct + Join *JoinRequest + type Request_Leave struct + Leave *LeaveRequest + type Request_SendMessage struct + SendMessage *SendMessageRequest + type Role int32 + const Role_Guest + const Role_Host + func (Role) Descriptor() protoreflect.EnumDescriptor + func (Role) EnumDescriptor() ([]byte, []int) + func (Role) Type() protoreflect.EnumType + func (x Role) Enum() *Role + func (x Role) Number() protoreflect.EnumNumber + func (x Role) String() string + type Room struct + Description string + Lock bool + MaxPeers uint32 + Name string + Password string + Sid string + func (*Room) Descriptor() ([]byte, []int) + func (*Room) ProtoMessage() + func (x *Room) GetDescription() string + func (x *Room) GetLock() bool + func (x *Room) GetMaxPeers() uint32 + func (x *Room) GetName() string + func (x *Room) GetPassword() string + func (x *Room) GetSid() string + func (x *Room) ProtoReflect() protoreflect.Message + func (x *Room) Reset() + func (x *Room) String() string + type RoomServiceClient interface + AddPeer func(ctx context.Context, in *AddPeerRequest, opts ...grpc.CallOption) (*AddPeerReply, error) + CreateRoom func(ctx context.Context, in *CreateRoomRequest, opts ...grpc.CallOption) (*CreateRoomReply, error) + EndRoom func(ctx context.Context, in *EndRoomRequest, opts ...grpc.CallOption) (*EndRoomReply, error) + GetPeers func(ctx context.Context, in *GetPeersRequest, opts ...grpc.CallOption) (*GetPeersReply, error) + GetRooms func(ctx context.Context, in *GetRoomsRequest, opts ...grpc.CallOption) (*GetRoomsReply, error) + RemovePeer func(ctx context.Context, in *RemovePeerRequest, opts ...grpc.CallOption) (*RemovePeerReply, error) + UpdatePeer func(ctx context.Context, in *UpdatePeerRequest, opts ...grpc.CallOption) (*UpdatePeerReply, error) + UpdateRoom func(ctx context.Context, in *UpdateRoomRequest, opts ...grpc.CallOption) (*UpdateRoomReply, error) + func NewRoomServiceClient(cc grpc.ClientConnInterface) RoomServiceClient + type RoomServiceServer interface + AddPeer func(context.Context, *AddPeerRequest) (*AddPeerReply, error) + CreateRoom func(context.Context, *CreateRoomRequest) (*CreateRoomReply, error) + EndRoom func(context.Context, *EndRoomRequest) (*EndRoomReply, error) + GetPeers func(context.Context, *GetPeersRequest) (*GetPeersReply, error) + GetRooms func(context.Context, *GetRoomsRequest) (*GetRoomsReply, error) + RemovePeer func(context.Context, *RemovePeerRequest) (*RemovePeerReply, error) + UpdatePeer func(context.Context, *UpdatePeerRequest) (*UpdatePeerReply, error) + UpdateRoom func(context.Context, *UpdateRoomRequest) (*UpdateRoomReply, error) + type RoomSignalClient interface + Signal func(ctx context.Context, opts ...grpc.CallOption) (RoomSignal_SignalClient, error) + func NewRoomSignalClient(cc grpc.ClientConnInterface) RoomSignalClient + type RoomSignalServer interface + Signal func(RoomSignal_SignalServer) error + type RoomSignal_SignalClient interface + Recv func() (*Reply, error) + Send func(*Request) error + type RoomSignal_SignalServer interface + Recv func() (*Request, error) + Send func(*Reply) error + type SendMessageReply struct + Error *Error + Success bool + func (*SendMessageReply) Descriptor() ([]byte, []int) + func (*SendMessageReply) ProtoMessage() + func (x *SendMessageReply) GetError() *Error + func (x *SendMessageReply) GetSuccess() bool + func (x *SendMessageReply) ProtoReflect() protoreflect.Message + func (x *SendMessageReply) Reset() + func (x *SendMessageReply) String() string + type SendMessageRequest struct + Message *Message + Sid string + func (*SendMessageRequest) Descriptor() ([]byte, []int) + func (*SendMessageRequest) ProtoMessage() + func (x *SendMessageRequest) GetMessage() *Message + func (x *SendMessageRequest) GetSid() string + func (x *SendMessageRequest) ProtoReflect() protoreflect.Message + func (x *SendMessageRequest) Reset() + func (x *SendMessageRequest) String() string + type UnimplementedRoomServiceServer struct + func (UnimplementedRoomServiceServer) AddPeer(context.Context, *AddPeerRequest) (*AddPeerReply, error) + func (UnimplementedRoomServiceServer) CreateRoom(context.Context, *CreateRoomRequest) (*CreateRoomReply, error) + func (UnimplementedRoomServiceServer) EndRoom(context.Context, *EndRoomRequest) (*EndRoomReply, error) + func (UnimplementedRoomServiceServer) GetPeers(context.Context, *GetPeersRequest) (*GetPeersReply, error) + func (UnimplementedRoomServiceServer) GetRooms(context.Context, *GetRoomsRequest) (*GetRoomsReply, error) + func (UnimplementedRoomServiceServer) RemovePeer(context.Context, *RemovePeerRequest) (*RemovePeerReply, error) + func (UnimplementedRoomServiceServer) UpdatePeer(context.Context, *UpdatePeerRequest) (*UpdatePeerReply, error) + func (UnimplementedRoomServiceServer) UpdateRoom(context.Context, *UpdateRoomRequest) (*UpdateRoomReply, error) + type UnimplementedRoomSignalServer struct + func (UnimplementedRoomSignalServer) Signal(RoomSignal_SignalServer) error + type UnsafeRoomServiceServer interface + type UnsafeRoomSignalServer interface + type UpdatePeerReply struct + Error *Error + Success bool + func (*UpdatePeerReply) Descriptor() ([]byte, []int) + func (*UpdatePeerReply) ProtoMessage() + func (x *UpdatePeerReply) GetError() *Error + func (x *UpdatePeerReply) GetSuccess() bool + func (x *UpdatePeerReply) ProtoReflect() protoreflect.Message + func (x *UpdatePeerReply) Reset() + func (x *UpdatePeerReply) String() string + type UpdatePeerRequest struct + Peer *Peer + func (*UpdatePeerRequest) Descriptor() ([]byte, []int) + func (*UpdatePeerRequest) ProtoMessage() + func (x *UpdatePeerRequest) GetPeer() *Peer + func (x *UpdatePeerRequest) ProtoReflect() protoreflect.Message + func (x *UpdatePeerRequest) Reset() + func (x *UpdatePeerRequest) String() string + type UpdateRoomReply struct + Error *Error + Success bool + func (*UpdateRoomReply) Descriptor() ([]byte, []int) + func (*UpdateRoomReply) ProtoMessage() + func (x *UpdateRoomReply) GetError() *Error + func (x *UpdateRoomReply) GetSuccess() bool + func (x *UpdateRoomReply) ProtoReflect() protoreflect.Message + func (x *UpdateRoomReply) Reset() + func (x *UpdateRoomReply) String() string + type UpdateRoomRequest struct + Room *Room + func (*UpdateRoomRequest) Descriptor() ([]byte, []int) + func (*UpdateRoomRequest) ProtoMessage() + func (x *UpdateRoomRequest) GetRoom() *Room + func (x *UpdateRoomRequest) ProtoReflect() protoreflect.Message + func (x *UpdateRoomRequest) Reset() + func (x *UpdateRoomRequest) String() string