Documentation ¶
Index ¶
- Variables
- func RegisterRoomServiceServer(s grpc.ServiceRegistrar, srv RoomServiceServer)
- func RegisterRoomSignalServer(s grpc.ServiceRegistrar, srv RoomSignalServer)
- type AddPeerReply
- func (*AddPeerReply) Descriptor() ([]byte, []int)deprecated
- func (x *AddPeerReply) GetError() *Error
- func (x *AddPeerReply) GetSuccess() bool
- func (*AddPeerReply) ProtoMessage()
- func (x *AddPeerReply) ProtoReflect() protoreflect.Message
- func (x *AddPeerReply) Reset()
- func (x *AddPeerReply) String() string
- type AddPeerRequest
- type CreateRoomReply
- func (*CreateRoomReply) Descriptor() ([]byte, []int)deprecated
- func (x *CreateRoomReply) GetError() *Error
- func (x *CreateRoomReply) GetSuccess() bool
- func (*CreateRoomReply) ProtoMessage()
- func (x *CreateRoomReply) ProtoReflect() protoreflect.Message
- func (x *CreateRoomReply) Reset()
- func (x *CreateRoomReply) String() string
- type CreateRoomRequest
- type DeleteRoomReply
- func (*DeleteRoomReply) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteRoomReply) GetError() *Error
- func (x *DeleteRoomReply) GetSuccess() bool
- func (*DeleteRoomReply) ProtoMessage()
- func (x *DeleteRoomReply) ProtoReflect() protoreflect.Message
- func (x *DeleteRoomReply) Reset()
- func (x *DeleteRoomReply) String() string
- type DeleteRoomRequest
- type Disconnect
- type EndRoomReply
- func (*EndRoomReply) Descriptor() ([]byte, []int)deprecated
- func (x *EndRoomReply) GetError() *Error
- func (x *EndRoomReply) GetSuccess() bool
- func (*EndRoomReply) ProtoMessage()
- func (x *EndRoomReply) ProtoReflect() protoreflect.Message
- func (x *EndRoomReply) Reset()
- func (x *EndRoomReply) String() string
- type EndRoomRequest
- func (*EndRoomRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EndRoomRequest) GetDelete() bool
- func (x *EndRoomRequest) GetReason() string
- func (x *EndRoomRequest) GetSid() string
- func (*EndRoomRequest) ProtoMessage()
- func (x *EndRoomRequest) ProtoReflect() protoreflect.Message
- func (x *EndRoomRequest) Reset()
- func (x *EndRoomRequest) String() string
- type Error
- type ErrorType
- type GetPeersReply
- func (*GetPeersReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetPeersReply) GetError() *Error
- func (x *GetPeersReply) GetPeers() []*Peer
- func (x *GetPeersReply) GetSuccess() bool
- func (*GetPeersReply) ProtoMessage()
- func (x *GetPeersReply) ProtoReflect() protoreflect.Message
- func (x *GetPeersReply) Reset()
- func (x *GetPeersReply) String() string
- type GetPeersRequest
- type GetRoomsReply
- func (*GetRoomsReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetRoomsReply) GetError() *Error
- func (x *GetRoomsReply) GetRooms() []*Room
- func (x *GetRoomsReply) GetSuccess() bool
- func (*GetRoomsReply) ProtoMessage()
- func (x *GetRoomsReply) ProtoReflect() protoreflect.Message
- func (x *GetRoomsReply) Reset()
- func (x *GetRoomsReply) String() string
- type GetRoomsRequest
- type JoinReply
- func (*JoinReply) Descriptor() ([]byte, []int)deprecated
- func (x *JoinReply) GetError() *Error
- func (x *JoinReply) GetRole() Role
- func (x *JoinReply) GetRoom() *Room
- func (x *JoinReply) GetSuccess() bool
- func (*JoinReply) ProtoMessage()
- func (x *JoinReply) ProtoReflect() protoreflect.Message
- func (x *JoinReply) Reset()
- func (x *JoinReply) String() string
- type JoinRequest
- func (*JoinRequest) Descriptor() ([]byte, []int)deprecated
- func (x *JoinRequest) GetPassword() string
- func (x *JoinRequest) GetPeer() *Peer
- func (*JoinRequest) ProtoMessage()
- func (x *JoinRequest) ProtoReflect() protoreflect.Message
- func (x *JoinRequest) Reset()
- func (x *JoinRequest) String() string
- type LeaveReply
- type LeaveRequest
- func (*LeaveRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LeaveRequest) GetSid() string
- func (x *LeaveRequest) GetUid() string
- func (*LeaveRequest) ProtoMessage()
- func (x *LeaveRequest) ProtoReflect() protoreflect.Message
- func (x *LeaveRequest) Reset()
- func (x *LeaveRequest) String() string
- type Message
- func (*Message) Descriptor() ([]byte, []int)deprecated
- func (x *Message) GetFrom() string
- func (x *Message) GetPayload() []byte
- func (x *Message) GetTo() string
- func (x *Message) GetType() string
- func (*Message) ProtoMessage()
- func (x *Message) ProtoReflect() protoreflect.Message
- func (x *Message) Reset()
- func (x *Message) String() string
- type Peer
- func (*Peer) Descriptor() ([]byte, []int)deprecated
- 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 (*Peer) ProtoMessage()
- func (x *Peer) ProtoReflect() protoreflect.Message
- func (x *Peer) Reset()
- func (x *Peer) String() string
- type PeerEvent
- type PeerState
- type Peer_Direction
- func (Peer_Direction) Descriptor() protoreflect.EnumDescriptor
- func (x Peer_Direction) Enum() *Peer_Direction
- func (Peer_Direction) EnumDescriptor() ([]byte, []int)deprecated
- func (x Peer_Direction) Number() protoreflect.EnumNumber
- func (x Peer_Direction) String() string
- func (Peer_Direction) Type() protoreflect.EnumType
- type Protocol
- type RemovePeerReply
- func (*RemovePeerReply) Descriptor() ([]byte, []int)deprecated
- func (x *RemovePeerReply) GetError() *Error
- func (x *RemovePeerReply) GetSuccess() bool
- func (*RemovePeerReply) ProtoMessage()
- func (x *RemovePeerReply) ProtoReflect() protoreflect.Message
- func (x *RemovePeerReply) Reset()
- func (x *RemovePeerReply) String() string
- type RemovePeerRequest
- func (*RemovePeerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemovePeerRequest) GetSid() string
- func (x *RemovePeerRequest) GetUid() string
- func (*RemovePeerRequest) ProtoMessage()
- func (x *RemovePeerRequest) ProtoReflect() protoreflect.Message
- func (x *RemovePeerRequest) Reset()
- func (x *RemovePeerRequest) String() string
- type Reply
- func (*Reply) Descriptor() ([]byte, []int)deprecated
- func (x *Reply) GetDisconnect() *Disconnect
- func (x *Reply) GetJoin() *JoinReply
- func (x *Reply) GetLeave() *LeaveReply
- func (x *Reply) GetMessage() *Message
- func (m *Reply) GetPayload() isReply_Payload
- func (x *Reply) GetPeer() *PeerEvent
- func (x *Reply) GetRoom() *Room
- func (x *Reply) GetSendMessage() *SendMessageReply
- func (*Reply) ProtoMessage()
- func (x *Reply) ProtoReflect() protoreflect.Message
- func (x *Reply) Reset()
- func (x *Reply) String() string
- type Reply_Disconnect
- type Reply_Join
- type Reply_Leave
- type Reply_Message
- type Reply_Peer
- type Reply_Room
- type Reply_SendMessage
- type Request
- func (*Request) Descriptor() ([]byte, []int)deprecated
- func (x *Request) GetJoin() *JoinRequest
- func (x *Request) GetLeave() *LeaveRequest
- func (m *Request) GetPayload() isRequest_Payload
- func (x *Request) GetSendMessage() *SendMessageRequest
- func (*Request) ProtoMessage()
- func (x *Request) ProtoReflect() protoreflect.Message
- func (x *Request) Reset()
- func (x *Request) String() string
- type Request_Join
- type Request_Leave
- type Request_SendMessage
- type Role
- type Room
- func (*Room) Descriptor() ([]byte, []int)deprecated
- 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 (*Room) ProtoMessage()
- func (x *Room) ProtoReflect() protoreflect.Message
- func (x *Room) Reset()
- func (x *Room) String() string
- type RoomServiceClient
- type RoomServiceServer
- type RoomSignalClient
- type RoomSignalServer
- type RoomSignal_SignalClient
- type RoomSignal_SignalServer
- type SendMessageReply
- func (*SendMessageReply) Descriptor() ([]byte, []int)deprecated
- func (x *SendMessageReply) GetError() *Error
- func (x *SendMessageReply) GetSuccess() bool
- func (*SendMessageReply) ProtoMessage()
- func (x *SendMessageReply) ProtoReflect() protoreflect.Message
- func (x *SendMessageReply) Reset()
- func (x *SendMessageReply) String() string
- type SendMessageRequest
- func (*SendMessageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SendMessageRequest) GetMessage() *Message
- func (x *SendMessageRequest) GetSid() string
- func (*SendMessageRequest) ProtoMessage()
- func (x *SendMessageRequest) ProtoReflect() protoreflect.Message
- func (x *SendMessageRequest) Reset()
- func (x *SendMessageRequest) String() string
- type UnimplementedRoomServiceServer
- 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
- type UnsafeRoomServiceServer
- type UnsafeRoomSignalServer
- type UpdatePeerReply
- func (*UpdatePeerReply) Descriptor() ([]byte, []int)deprecated
- func (x *UpdatePeerReply) GetError() *Error
- func (x *UpdatePeerReply) GetSuccess() bool
- func (*UpdatePeerReply) ProtoMessage()
- func (x *UpdatePeerReply) ProtoReflect() protoreflect.Message
- func (x *UpdatePeerReply) Reset()
- func (x *UpdatePeerReply) String() string
- type UpdatePeerRequest
- type UpdateRoomReply
- func (*UpdateRoomReply) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateRoomReply) GetError() *Error
- func (x *UpdateRoomReply) GetSuccess() bool
- func (*UpdateRoomReply) ProtoMessage()
- func (x *UpdateRoomReply) ProtoReflect() protoreflect.Message
- func (x *UpdateRoomReply) Reset()
- func (x *UpdateRoomReply) String() string
- type UpdateRoomRequest
Constants ¶
This section is empty.
Variables ¶
var ( ErrorType_name = map[int32]string{ 0: "None", 1: "UnkownError", 2: "PermissionDenied", 3: "ServiceUnavailable", 4: "RoomLocked", 5: "PasswordRequired", 6: "RoomAlreadyExist", 7: "RoomNotExist", 8: "InvalidParams", 9: "PeerAlreadyExist", 10: "PeerNotExist", } ErrorType_value = map[string]int32{ "None": 0, "UnkownError": 1, "PermissionDenied": 2, "ServiceUnavailable": 3, "RoomLocked": 4, "PasswordRequired": 5, "RoomAlreadyExist": 6, "RoomNotExist": 7, "InvalidParams": 8, "PeerAlreadyExist": 9, "PeerNotExist": 10, } )
Enum value maps for ErrorType.
var ( Role_name = map[int32]string{ 0: "Host", 1: "Guest", } Role_value = map[string]int32{ "Host": 0, "Guest": 1, } )
Enum value maps for Role.
var ( Protocol_name = map[int32]string{ 0: "ProtocolUnknown", 1: "WebRTC", 2: "SIP", 3: "RTMP", 4: "RTSP", } Protocol_value = map[string]int32{ "ProtocolUnknown": 0, "WebRTC": 1, "SIP": 2, "RTMP": 3, "RTSP": 4, } )
Enum value maps for Protocol.
var ( PeerState_name = map[int32]string{ 0: "JOIN", 1: "UPDATE", 2: "LEAVE", } PeerState_value = map[string]int32{ "JOIN": 0, "UPDATE": 1, "LEAVE": 2, } )
Enum value maps for PeerState.
var ( Peer_Direction_name = map[int32]string{ 0: "INCOMING", 1: "OUTGOING", 2: "BILATERAL", } Peer_Direction_value = map[string]int32{ "INCOMING": 0, "OUTGOING": 1, "BILATERAL": 2, } )
Enum value maps for Peer_Direction.
var File_apps_room_proto_room_proto protoreflect.FileDescriptor
var RoomService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "room.RoomService", HandlerType: (*RoomServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateRoom", Handler: _RoomService_CreateRoom_Handler, }, { MethodName: "UpdateRoom", Handler: _RoomService_UpdateRoom_Handler, }, { MethodName: "EndRoom", Handler: _RoomService_EndRoom_Handler, }, { MethodName: "GetRooms", Handler: _RoomService_GetRooms_Handler, }, { MethodName: "AddPeer", Handler: _RoomService_AddPeer_Handler, }, { MethodName: "UpdatePeer", Handler: _RoomService_UpdatePeer_Handler, }, { MethodName: "RemovePeer", Handler: _RoomService_RemovePeer_Handler, }, { MethodName: "GetPeers", Handler: _RoomService_GetPeers_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "apps/room/proto/room.proto", }
RoomService_ServiceDesc is the grpc.ServiceDesc for RoomService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var RoomSignal_ServiceDesc = grpc.ServiceDesc{ ServiceName: "room.RoomSignal", HandlerType: (*RoomSignalServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Signal", Handler: _RoomSignal_Signal_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "apps/room/proto/room.proto", }
RoomSignal_ServiceDesc is the grpc.ServiceDesc for RoomSignal service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRoomServiceServer ¶
func RegisterRoomServiceServer(s grpc.ServiceRegistrar, srv RoomServiceServer)
func RegisterRoomSignalServer ¶
func RegisterRoomSignalServer(s grpc.ServiceRegistrar, srv RoomSignalServer)
Types ¶
type AddPeerReply ¶
type AddPeerReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*AddPeerReply) Descriptor
deprecated
func (*AddPeerReply) Descriptor() ([]byte, []int)
Deprecated: Use AddPeerReply.ProtoReflect.Descriptor instead.
func (*AddPeerReply) GetError ¶
func (x *AddPeerReply) GetError() *Error
func (*AddPeerReply) GetSuccess ¶
func (x *AddPeerReply) GetSuccess() bool
func (*AddPeerReply) ProtoMessage ¶
func (*AddPeerReply) ProtoMessage()
func (*AddPeerReply) ProtoReflect ¶
func (x *AddPeerReply) ProtoReflect() protoreflect.Message
func (*AddPeerReply) Reset ¶
func (x *AddPeerReply) Reset()
func (*AddPeerReply) String ¶
func (x *AddPeerReply) String() string
type AddPeerRequest ¶
type AddPeerRequest struct { Peer *Peer `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer,omitempty"` // contains filtered or unexported fields }
func (*AddPeerRequest) Descriptor
deprecated
func (*AddPeerRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddPeerRequest.ProtoReflect.Descriptor instead.
func (*AddPeerRequest) GetPeer ¶
func (x *AddPeerRequest) GetPeer() *Peer
func (*AddPeerRequest) ProtoMessage ¶
func (*AddPeerRequest) ProtoMessage()
func (*AddPeerRequest) ProtoReflect ¶
func (x *AddPeerRequest) ProtoReflect() protoreflect.Message
func (*AddPeerRequest) Reset ¶
func (x *AddPeerRequest) Reset()
func (*AddPeerRequest) String ¶
func (x *AddPeerRequest) String() string
type CreateRoomReply ¶
type CreateRoomReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*CreateRoomReply) Descriptor
deprecated
func (*CreateRoomReply) Descriptor() ([]byte, []int)
Deprecated: Use CreateRoomReply.ProtoReflect.Descriptor instead.
func (*CreateRoomReply) GetError ¶
func (x *CreateRoomReply) GetError() *Error
func (*CreateRoomReply) GetSuccess ¶
func (x *CreateRoomReply) GetSuccess() bool
func (*CreateRoomReply) ProtoMessage ¶
func (*CreateRoomReply) ProtoMessage()
func (*CreateRoomReply) ProtoReflect ¶
func (x *CreateRoomReply) ProtoReflect() protoreflect.Message
func (*CreateRoomReply) Reset ¶
func (x *CreateRoomReply) Reset()
func (*CreateRoomReply) String ¶
func (x *CreateRoomReply) String() string
type CreateRoomRequest ¶
type CreateRoomRequest struct { Room *Room `protobuf:"bytes,1,opt,name=room,proto3" json:"room,omitempty"` // contains filtered or unexported fields }
func (*CreateRoomRequest) Descriptor
deprecated
func (*CreateRoomRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateRoomRequest.ProtoReflect.Descriptor instead.
func (*CreateRoomRequest) GetRoom ¶
func (x *CreateRoomRequest) GetRoom() *Room
func (*CreateRoomRequest) ProtoMessage ¶
func (*CreateRoomRequest) ProtoMessage()
func (*CreateRoomRequest) ProtoReflect ¶
func (x *CreateRoomRequest) ProtoReflect() protoreflect.Message
func (*CreateRoomRequest) Reset ¶
func (x *CreateRoomRequest) Reset()
func (*CreateRoomRequest) String ¶
func (x *CreateRoomRequest) String() string
type DeleteRoomReply ¶
type DeleteRoomReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*DeleteRoomReply) Descriptor
deprecated
func (*DeleteRoomReply) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRoomReply.ProtoReflect.Descriptor instead.
func (*DeleteRoomReply) GetError ¶
func (x *DeleteRoomReply) GetError() *Error
func (*DeleteRoomReply) GetSuccess ¶
func (x *DeleteRoomReply) GetSuccess() bool
func (*DeleteRoomReply) ProtoMessage ¶
func (*DeleteRoomReply) ProtoMessage()
func (*DeleteRoomReply) ProtoReflect ¶
func (x *DeleteRoomReply) ProtoReflect() protoreflect.Message
func (*DeleteRoomReply) Reset ¶
func (x *DeleteRoomReply) Reset()
func (*DeleteRoomReply) String ¶
func (x *DeleteRoomReply) String() string
type DeleteRoomRequest ¶
type DeleteRoomRequest struct { Sid string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"` // contains filtered or unexported fields }
func (*DeleteRoomRequest) Descriptor
deprecated
func (*DeleteRoomRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRoomRequest.ProtoReflect.Descriptor instead.
func (*DeleteRoomRequest) GetSid ¶
func (x *DeleteRoomRequest) GetSid() string
func (*DeleteRoomRequest) ProtoMessage ¶
func (*DeleteRoomRequest) ProtoMessage()
func (*DeleteRoomRequest) ProtoReflect ¶
func (x *DeleteRoomRequest) ProtoReflect() protoreflect.Message
func (*DeleteRoomRequest) Reset ¶
func (x *DeleteRoomRequest) Reset()
func (*DeleteRoomRequest) String ¶
func (x *DeleteRoomRequest) String() string
type Disconnect ¶
type Disconnect struct { Sid string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*Disconnect) Descriptor
deprecated
func (*Disconnect) Descriptor() ([]byte, []int)
Deprecated: Use Disconnect.ProtoReflect.Descriptor instead.
func (*Disconnect) GetReason ¶
func (x *Disconnect) GetReason() string
func (*Disconnect) GetSid ¶
func (x *Disconnect) GetSid() string
func (*Disconnect) ProtoMessage ¶
func (*Disconnect) ProtoMessage()
func (*Disconnect) ProtoReflect ¶
func (x *Disconnect) ProtoReflect() protoreflect.Message
func (*Disconnect) Reset ¶
func (x *Disconnect) Reset()
func (*Disconnect) String ¶
func (x *Disconnect) String() string
type EndRoomReply ¶
type EndRoomReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*EndRoomReply) Descriptor
deprecated
func (*EndRoomReply) Descriptor() ([]byte, []int)
Deprecated: Use EndRoomReply.ProtoReflect.Descriptor instead.
func (*EndRoomReply) GetError ¶
func (x *EndRoomReply) GetError() *Error
func (*EndRoomReply) GetSuccess ¶
func (x *EndRoomReply) GetSuccess() bool
func (*EndRoomReply) ProtoMessage ¶
func (*EndRoomReply) ProtoMessage()
func (*EndRoomReply) ProtoReflect ¶
func (x *EndRoomReply) ProtoReflect() protoreflect.Message
func (*EndRoomReply) Reset ¶
func (x *EndRoomReply) Reset()
func (*EndRoomReply) String ¶
func (x *EndRoomReply) String() string
type EndRoomRequest ¶
type EndRoomRequest struct { Sid string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` Delete bool `protobuf:"varint,3,opt,name=delete,proto3" json:"delete,omitempty"` // contains filtered or unexported fields }
func (*EndRoomRequest) Descriptor
deprecated
func (*EndRoomRequest) Descriptor() ([]byte, []int)
Deprecated: Use EndRoomRequest.ProtoReflect.Descriptor instead.
func (*EndRoomRequest) GetDelete ¶
func (x *EndRoomRequest) GetDelete() bool
func (*EndRoomRequest) GetReason ¶
func (x *EndRoomRequest) GetReason() string
func (*EndRoomRequest) GetSid ¶
func (x *EndRoomRequest) GetSid() string
func (*EndRoomRequest) ProtoMessage ¶
func (*EndRoomRequest) ProtoMessage()
func (*EndRoomRequest) ProtoReflect ¶
func (x *EndRoomRequest) ProtoReflect() protoreflect.Message
func (*EndRoomRequest) Reset ¶
func (x *EndRoomRequest) Reset()
func (*EndRoomRequest) String ¶
func (x *EndRoomRequest) String() string
type Error ¶
type Error struct { Code ErrorType `protobuf:"varint,1,opt,name=code,proto3,enum=room.ErrorType" json:"code,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*Error) Descriptor
deprecated
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
func (*Error) ProtoReflect ¶
func (x *Error) ProtoReflect() protoreflect.Message
type ErrorType ¶
type ErrorType int32
const ( ErrorType_None ErrorType = 0 ErrorType_UnkownError ErrorType = 1 ErrorType_PermissionDenied ErrorType = 2 ErrorType_RoomLocked ErrorType = 4 ErrorType_PasswordRequired ErrorType = 5 ErrorType_RoomAlreadyExist ErrorType = 6 ErrorType_RoomNotExist ErrorType = 7 ErrorType_InvalidParams ErrorType = 8 ErrorType_PeerAlreadyExist ErrorType = 9 ErrorType_PeerNotExist ErrorType = 10 )
func (ErrorType) Descriptor ¶
func (ErrorType) Descriptor() protoreflect.EnumDescriptor
func (ErrorType) EnumDescriptor
deprecated
func (ErrorType) Number ¶
func (x ErrorType) Number() protoreflect.EnumNumber
func (ErrorType) Type ¶
func (ErrorType) Type() protoreflect.EnumType
type GetPeersReply ¶
type GetPeersReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` Peers []*Peer `protobuf:"bytes,3,rep,name=Peers,proto3" json:"Peers,omitempty"` // contains filtered or unexported fields }
func (*GetPeersReply) Descriptor
deprecated
func (*GetPeersReply) Descriptor() ([]byte, []int)
Deprecated: Use GetPeersReply.ProtoReflect.Descriptor instead.
func (*GetPeersReply) GetError ¶
func (x *GetPeersReply) GetError() *Error
func (*GetPeersReply) GetPeers ¶
func (x *GetPeersReply) GetPeers() []*Peer
func (*GetPeersReply) GetSuccess ¶
func (x *GetPeersReply) GetSuccess() bool
func (*GetPeersReply) ProtoMessage ¶
func (*GetPeersReply) ProtoMessage()
func (*GetPeersReply) ProtoReflect ¶
func (x *GetPeersReply) ProtoReflect() protoreflect.Message
func (*GetPeersReply) Reset ¶
func (x *GetPeersReply) Reset()
func (*GetPeersReply) String ¶
func (x *GetPeersReply) String() string
type GetPeersRequest ¶
type GetPeersRequest struct { Sid string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"` // contains filtered or unexported fields }
func (*GetPeersRequest) Descriptor
deprecated
func (*GetPeersRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetPeersRequest.ProtoReflect.Descriptor instead.
func (*GetPeersRequest) GetSid ¶
func (x *GetPeersRequest) GetSid() string
func (*GetPeersRequest) ProtoMessage ¶
func (*GetPeersRequest) ProtoMessage()
func (*GetPeersRequest) ProtoReflect ¶
func (x *GetPeersRequest) ProtoReflect() protoreflect.Message
func (*GetPeersRequest) Reset ¶
func (x *GetPeersRequest) Reset()
func (*GetPeersRequest) String ¶
func (x *GetPeersRequest) String() string
type GetRoomsReply ¶
type GetRoomsReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` Rooms []*Room `protobuf:"bytes,3,rep,name=rooms,proto3" json:"rooms,omitempty"` // contains filtered or unexported fields }
func (*GetRoomsReply) Descriptor
deprecated
func (*GetRoomsReply) Descriptor() ([]byte, []int)
Deprecated: Use GetRoomsReply.ProtoReflect.Descriptor instead.
func (*GetRoomsReply) GetError ¶
func (x *GetRoomsReply) GetError() *Error
func (*GetRoomsReply) GetRooms ¶
func (x *GetRoomsReply) GetRooms() []*Room
func (*GetRoomsReply) GetSuccess ¶
func (x *GetRoomsReply) GetSuccess() bool
func (*GetRoomsReply) ProtoMessage ¶
func (*GetRoomsReply) ProtoMessage()
func (*GetRoomsReply) ProtoReflect ¶
func (x *GetRoomsReply) ProtoReflect() protoreflect.Message
func (*GetRoomsReply) Reset ¶
func (x *GetRoomsReply) Reset()
func (*GetRoomsReply) String ¶
func (x *GetRoomsReply) String() string
type GetRoomsRequest ¶
type GetRoomsRequest struct {
// contains filtered or unexported fields
}
func (*GetRoomsRequest) Descriptor
deprecated
func (*GetRoomsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRoomsRequest.ProtoReflect.Descriptor instead.
func (*GetRoomsRequest) ProtoMessage ¶
func (*GetRoomsRequest) ProtoMessage()
func (*GetRoomsRequest) ProtoReflect ¶
func (x *GetRoomsRequest) ProtoReflect() protoreflect.Message
func (*GetRoomsRequest) Reset ¶
func (x *GetRoomsRequest) Reset()
func (*GetRoomsRequest) String ¶
func (x *GetRoomsRequest) String() string
type JoinReply ¶
type JoinReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` Role Role `protobuf:"varint,3,opt,name=role,proto3,enum=room.Role" json:"role,omitempty"` Room *Room `protobuf:"bytes,4,opt,name=room,proto3" json:"room,omitempty"` // contains filtered or unexported fields }
func (*JoinReply) Descriptor
deprecated
func (*JoinReply) GetSuccess ¶
func (*JoinReply) ProtoMessage ¶
func (*JoinReply) ProtoMessage()
func (*JoinReply) ProtoReflect ¶
func (x *JoinReply) ProtoReflect() protoreflect.Message
type JoinRequest ¶
type JoinRequest struct { Peer *Peer `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer,omitempty"` Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"` // contains filtered or unexported fields }
func (*JoinRequest) Descriptor
deprecated
func (*JoinRequest) Descriptor() ([]byte, []int)
Deprecated: Use JoinRequest.ProtoReflect.Descriptor instead.
func (*JoinRequest) GetPassword ¶
func (x *JoinRequest) GetPassword() string
func (*JoinRequest) GetPeer ¶
func (x *JoinRequest) GetPeer() *Peer
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 LeaveReply ¶
type LeaveReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*LeaveReply) Descriptor
deprecated
func (*LeaveReply) Descriptor() ([]byte, []int)
Deprecated: Use LeaveReply.ProtoReflect.Descriptor instead.
func (*LeaveReply) GetError ¶
func (x *LeaveReply) GetError() *Error
func (*LeaveReply) GetSuccess ¶
func (x *LeaveReply) GetSuccess() bool
func (*LeaveReply) ProtoMessage ¶
func (*LeaveReply) ProtoMessage()
func (*LeaveReply) ProtoReflect ¶
func (x *LeaveReply) ProtoReflect() protoreflect.Message
func (*LeaveReply) Reset ¶
func (x *LeaveReply) Reset()
func (*LeaveReply) String ¶
func (x *LeaveReply) String() string
type LeaveRequest ¶
type LeaveRequest 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"` // contains filtered or unexported fields }
func (*LeaveRequest) Descriptor
deprecated
func (*LeaveRequest) Descriptor() ([]byte, []int)
Deprecated: Use LeaveRequest.ProtoReflect.Descriptor instead.
func (*LeaveRequest) GetSid ¶
func (x *LeaveRequest) GetSid() string
func (*LeaveRequest) GetUid ¶
func (x *LeaveRequest) GetUid() string
func (*LeaveRequest) ProtoMessage ¶
func (*LeaveRequest) ProtoMessage()
func (*LeaveRequest) ProtoReflect ¶
func (x *LeaveRequest) ProtoReflect() protoreflect.Message
func (*LeaveRequest) Reset ¶
func (x *LeaveRequest) Reset()
func (*LeaveRequest) String ¶
func (x *LeaveRequest) String() string
type Message ¶
type Message struct { From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"` // UUID of the sending Peer. To string `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"` // UUID of the receiving Peer. Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` // MIME content-type of the message, usually text/plain. Payload []byte `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"` // Payload message contents. // contains filtered or unexported fields }
func (*Message) Descriptor
deprecated
func (*Message) GetPayload ¶
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) ProtoReflect ¶
func (x *Message) ProtoReflect() protoreflect.Message
type Peer ¶
type Peer 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"` DisplayName string `protobuf:"bytes,3,opt,name=displayName,proto3" json:"displayName,omitempty"` ExtraInfo []byte `protobuf:"bytes,4,opt,name=extraInfo,proto3" json:"extraInfo,omitempty"` Destination string `protobuf:"bytes,5,opt,name=destination,proto3" json:"destination,omitempty"` // rtsp/rtmp/sip url Role Role `protobuf:"varint,6,opt,name=role,proto3,enum=room.Role" json:"role,omitempty"` Protocol Protocol `protobuf:"varint,7,opt,name=protocol,proto3,enum=room.Protocol" json:"protocol,omitempty"` Avatar string `protobuf:"bytes,8,opt,name=avatar,proto3" json:"avatar,omitempty"` Direction Peer_Direction `protobuf:"varint,9,opt,name=direction,proto3,enum=room.Peer_Direction" json:"direction,omitempty"` Vendor string `protobuf:"bytes,10,opt,name=vendor,proto3" json:"vendor,omitempty"` // contains filtered or unexported fields }
func (*Peer) Descriptor
deprecated
func (*Peer) GetDestination ¶
func (*Peer) GetDirection ¶
func (x *Peer) GetDirection() Peer_Direction
func (*Peer) GetDisplayName ¶
func (*Peer) GetExtraInfo ¶
func (*Peer) GetProtocol ¶
func (*Peer) ProtoMessage ¶
func (*Peer) ProtoMessage()
func (*Peer) ProtoReflect ¶
func (x *Peer) ProtoReflect() protoreflect.Message
type PeerEvent ¶
type PeerEvent struct { Peer *Peer `protobuf:"bytes,1,opt,name=Peer,proto3" json:"Peer,omitempty"` State PeerState `protobuf:"varint,2,opt,name=state,proto3,enum=room.PeerState" json:"state,omitempty"` // contains filtered or unexported fields }
func (*PeerEvent) Descriptor
deprecated
func (*PeerEvent) ProtoMessage ¶
func (*PeerEvent) ProtoMessage()
func (*PeerEvent) ProtoReflect ¶
func (x *PeerEvent) ProtoReflect() protoreflect.Message
type PeerState ¶
type PeerState int32
func (PeerState) Descriptor ¶
func (PeerState) Descriptor() protoreflect.EnumDescriptor
func (PeerState) EnumDescriptor
deprecated
func (PeerState) Number ¶
func (x PeerState) Number() protoreflect.EnumNumber
func (PeerState) Type ¶
func (PeerState) Type() protoreflect.EnumType
type Peer_Direction ¶
type Peer_Direction int32
const ( Peer_INCOMING Peer_Direction = 0 Peer_OUTGOING Peer_Direction = 1 Peer_BILATERAL Peer_Direction = 2 )
func (Peer_Direction) Descriptor ¶
func (Peer_Direction) Descriptor() protoreflect.EnumDescriptor
func (Peer_Direction) Enum ¶
func (x Peer_Direction) Enum() *Peer_Direction
func (Peer_Direction) EnumDescriptor
deprecated
func (Peer_Direction) EnumDescriptor() ([]byte, []int)
Deprecated: Use Peer_Direction.Descriptor instead.
func (Peer_Direction) Number ¶
func (x Peer_Direction) Number() protoreflect.EnumNumber
func (Peer_Direction) String ¶
func (x Peer_Direction) String() string
func (Peer_Direction) Type ¶
func (Peer_Direction) Type() protoreflect.EnumType
type Protocol ¶
type Protocol int32
func (Protocol) Descriptor ¶
func (Protocol) Descriptor() protoreflect.EnumDescriptor
func (Protocol) EnumDescriptor
deprecated
func (Protocol) Number ¶
func (x Protocol) Number() protoreflect.EnumNumber
func (Protocol) Type ¶
func (Protocol) Type() protoreflect.EnumType
type RemovePeerReply ¶
type RemovePeerReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*RemovePeerReply) Descriptor
deprecated
func (*RemovePeerReply) Descriptor() ([]byte, []int)
Deprecated: Use RemovePeerReply.ProtoReflect.Descriptor instead.
func (*RemovePeerReply) GetError ¶
func (x *RemovePeerReply) GetError() *Error
func (*RemovePeerReply) GetSuccess ¶
func (x *RemovePeerReply) GetSuccess() bool
func (*RemovePeerReply) ProtoMessage ¶
func (*RemovePeerReply) ProtoMessage()
func (*RemovePeerReply) ProtoReflect ¶
func (x *RemovePeerReply) ProtoReflect() protoreflect.Message
func (*RemovePeerReply) Reset ¶
func (x *RemovePeerReply) Reset()
func (*RemovePeerReply) String ¶
func (x *RemovePeerReply) String() string
type RemovePeerRequest ¶
type RemovePeerRequest 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"` // contains filtered or unexported fields }
func (*RemovePeerRequest) Descriptor
deprecated
func (*RemovePeerRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemovePeerRequest.ProtoReflect.Descriptor instead.
func (*RemovePeerRequest) GetSid ¶
func (x *RemovePeerRequest) GetSid() string
func (*RemovePeerRequest) GetUid ¶
func (x *RemovePeerRequest) GetUid() string
func (*RemovePeerRequest) ProtoMessage ¶
func (*RemovePeerRequest) ProtoMessage()
func (*RemovePeerRequest) ProtoReflect ¶
func (x *RemovePeerRequest) ProtoReflect() protoreflect.Message
func (*RemovePeerRequest) Reset ¶
func (x *RemovePeerRequest) Reset()
func (*RemovePeerRequest) String ¶
func (x *RemovePeerRequest) String() string
type Reply ¶
type Reply struct { // Types that are assignable to Payload: // *Reply_Join // *Reply_Leave // *Reply_SendMessage // *Reply_Peer // *Reply_Message // *Reply_Disconnect // *Reply_Room Payload isReply_Payload `protobuf_oneof:"payload"` // contains filtered or unexported fields }
func (*Reply) Descriptor
deprecated
func (*Reply) GetDisconnect ¶
func (x *Reply) GetDisconnect() *Disconnect
func (*Reply) GetLeave ¶
func (x *Reply) GetLeave() *LeaveReply
func (*Reply) GetMessage ¶
func (*Reply) GetPayload ¶
func (m *Reply) GetPayload() isReply_Payload
func (*Reply) GetSendMessage ¶
func (x *Reply) GetSendMessage() *SendMessageReply
func (*Reply) ProtoMessage ¶
func (*Reply) ProtoMessage()
func (*Reply) ProtoReflect ¶
func (x *Reply) ProtoReflect() protoreflect.Message
type Reply_Disconnect ¶
type Reply_Disconnect struct {
Disconnect *Disconnect `protobuf:"bytes,6,opt,name=disconnect,proto3,oneof"`
}
type Reply_Join ¶
type Reply_Join struct {
Join *JoinReply `protobuf:"bytes,1,opt,name=join,proto3,oneof"`
}
type Reply_Leave ¶
type Reply_Leave struct {
Leave *LeaveReply `protobuf:"bytes,2,opt,name=leave,proto3,oneof"`
}
type Reply_Message ¶
type Reply_Message struct {
Message *Message `protobuf:"bytes,5,opt,name=message,proto3,oneof"`
}
type Reply_Peer ¶
type Reply_Peer struct {
Peer *PeerEvent `protobuf:"bytes,4,opt,name=Peer,proto3,oneof"`
}
type Reply_Room ¶
type Reply_Room struct {
Room *Room `protobuf:"bytes,7,opt,name=room,proto3,oneof"`
}
type Reply_SendMessage ¶
type Reply_SendMessage struct {
SendMessage *SendMessageReply `protobuf:"bytes,3,opt,name=sendMessage,proto3,oneof"`
}
type Request ¶
type Request struct { // Types that are assignable to Payload: // *Request_Join // *Request_Leave // *Request_SendMessage Payload isRequest_Payload `protobuf_oneof:"payload"` // contains filtered or unexported fields }
func (*Request) Descriptor
deprecated
func (*Request) GetJoin ¶
func (x *Request) GetJoin() *JoinRequest
func (*Request) GetLeave ¶
func (x *Request) GetLeave() *LeaveRequest
func (*Request) GetPayload ¶
func (m *Request) GetPayload() isRequest_Payload
func (*Request) GetSendMessage ¶
func (x *Request) GetSendMessage() *SendMessageRequest
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
func (*Request) ProtoReflect ¶
func (x *Request) ProtoReflect() protoreflect.Message
type Request_Join ¶
type Request_Join struct {
Join *JoinRequest `protobuf:"bytes,1,opt,name=join,proto3,oneof"`
}
type Request_Leave ¶
type Request_Leave struct {
Leave *LeaveRequest `protobuf:"bytes,2,opt,name=leave,proto3,oneof"`
}
type Request_SendMessage ¶
type Request_SendMessage struct {
SendMessage *SendMessageRequest `protobuf:"bytes,3,opt,name=sendMessage,proto3,oneof"`
}
type Role ¶
type Role int32
func (Role) Descriptor ¶
func (Role) Descriptor() protoreflect.EnumDescriptor
func (Role) EnumDescriptor
deprecated
func (Role) Number ¶
func (x Role) Number() protoreflect.EnumNumber
func (Role) Type ¶
func (Role) Type() protoreflect.EnumType
type Room ¶
type Room struct { Sid string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Lock bool `protobuf:"varint,3,opt,name=lock,proto3" json:"lock,omitempty"` Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"` Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"` MaxPeers uint32 `protobuf:"varint,6,opt,name=maxPeers,proto3" json:"maxPeers,omitempty"` // contains filtered or unexported fields }
func (*Room) Descriptor
deprecated
func (*Room) GetDescription ¶
func (*Room) GetMaxPeers ¶
func (*Room) GetPassword ¶
func (*Room) ProtoMessage ¶
func (*Room) ProtoMessage()
func (*Room) ProtoReflect ¶
func (x *Room) ProtoReflect() protoreflect.Message
type RoomServiceClient ¶
type RoomServiceClient interface { // Manager API // Room API CreateRoom(ctx context.Context, in *CreateRoomRequest, opts ...grpc.CallOption) (*CreateRoomReply, error) UpdateRoom(ctx context.Context, in *UpdateRoomRequest, opts ...grpc.CallOption) (*UpdateRoomReply, error) EndRoom(ctx context.Context, in *EndRoomRequest, opts ...grpc.CallOption) (*EndRoomReply, error) GetRooms(ctx context.Context, in *GetRoomsRequest, opts ...grpc.CallOption) (*GetRoomsReply, error) // Peer API AddPeer(ctx context.Context, in *AddPeerRequest, opts ...grpc.CallOption) (*AddPeerReply, error) UpdatePeer(ctx context.Context, in *UpdatePeerRequest, opts ...grpc.CallOption) (*UpdatePeerReply, error) RemovePeer(ctx context.Context, in *RemovePeerRequest, opts ...grpc.CallOption) (*RemovePeerReply, error) GetPeers(ctx context.Context, in *GetPeersRequest, opts ...grpc.CallOption) (*GetPeersReply, error) }
RoomServiceClient is the client API for RoomService 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 NewRoomServiceClient ¶
func NewRoomServiceClient(cc grpc.ClientConnInterface) RoomServiceClient
type RoomServiceServer ¶
type RoomServiceServer interface { // Manager API // Room API CreateRoom(context.Context, *CreateRoomRequest) (*CreateRoomReply, error) UpdateRoom(context.Context, *UpdateRoomRequest) (*UpdateRoomReply, error) EndRoom(context.Context, *EndRoomRequest) (*EndRoomReply, error) GetRooms(context.Context, *GetRoomsRequest) (*GetRoomsReply, error) // Peer API AddPeer(context.Context, *AddPeerRequest) (*AddPeerReply, error) UpdatePeer(context.Context, *UpdatePeerRequest) (*UpdatePeerReply, error) RemovePeer(context.Context, *RemovePeerRequest) (*RemovePeerReply, error) GetPeers(context.Context, *GetPeersRequest) (*GetPeersReply, error) // contains filtered or unexported methods }
RoomServiceServer is the server API for RoomService service. All implementations must embed UnimplementedRoomServiceServer for forward compatibility
type RoomSignalClient ¶
type RoomSignalClient interface { // Signal Signal(ctx context.Context, opts ...grpc.CallOption) (RoomSignal_SignalClient, error) }
RoomSignalClient is the client API for RoomSignal 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 NewRoomSignalClient ¶
func NewRoomSignalClient(cc grpc.ClientConnInterface) RoomSignalClient
type RoomSignalServer ¶
type RoomSignalServer interface { // Signal Signal(RoomSignal_SignalServer) error // contains filtered or unexported methods }
RoomSignalServer is the server API for RoomSignal service. All implementations must embed UnimplementedRoomSignalServer for forward compatibility
type RoomSignal_SignalClient ¶
type RoomSignal_SignalServer ¶
type SendMessageReply ¶
type SendMessageReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*SendMessageReply) Descriptor
deprecated
func (*SendMessageReply) Descriptor() ([]byte, []int)
Deprecated: Use SendMessageReply.ProtoReflect.Descriptor instead.
func (*SendMessageReply) GetError ¶
func (x *SendMessageReply) GetError() *Error
func (*SendMessageReply) GetSuccess ¶
func (x *SendMessageReply) GetSuccess() bool
func (*SendMessageReply) ProtoMessage ¶
func (*SendMessageReply) ProtoMessage()
func (*SendMessageReply) ProtoReflect ¶
func (x *SendMessageReply) ProtoReflect() protoreflect.Message
func (*SendMessageReply) Reset ¶
func (x *SendMessageReply) Reset()
func (*SendMessageReply) String ¶
func (x *SendMessageReply) String() string
type SendMessageRequest ¶
type SendMessageRequest struct { Sid string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"` Message *Message `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*SendMessageRequest) Descriptor
deprecated
func (*SendMessageRequest) Descriptor() ([]byte, []int)
Deprecated: Use SendMessageRequest.ProtoReflect.Descriptor instead.
func (*SendMessageRequest) GetMessage ¶
func (x *SendMessageRequest) GetMessage() *Message
func (*SendMessageRequest) GetSid ¶
func (x *SendMessageRequest) GetSid() string
func (*SendMessageRequest) ProtoMessage ¶
func (*SendMessageRequest) ProtoMessage()
func (*SendMessageRequest) ProtoReflect ¶
func (x *SendMessageRequest) ProtoReflect() protoreflect.Message
func (*SendMessageRequest) Reset ¶
func (x *SendMessageRequest) Reset()
func (*SendMessageRequest) String ¶
func (x *SendMessageRequest) String() string
type UnimplementedRoomServiceServer ¶
type UnimplementedRoomServiceServer struct { }
UnimplementedRoomServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedRoomServiceServer) AddPeer ¶
func (UnimplementedRoomServiceServer) AddPeer(context.Context, *AddPeerRequest) (*AddPeerReply, error)
func (UnimplementedRoomServiceServer) CreateRoom ¶
func (UnimplementedRoomServiceServer) CreateRoom(context.Context, *CreateRoomRequest) (*CreateRoomReply, error)
func (UnimplementedRoomServiceServer) EndRoom ¶
func (UnimplementedRoomServiceServer) EndRoom(context.Context, *EndRoomRequest) (*EndRoomReply, error)
func (UnimplementedRoomServiceServer) GetPeers ¶
func (UnimplementedRoomServiceServer) GetPeers(context.Context, *GetPeersRequest) (*GetPeersReply, error)
func (UnimplementedRoomServiceServer) GetRooms ¶
func (UnimplementedRoomServiceServer) GetRooms(context.Context, *GetRoomsRequest) (*GetRoomsReply, error)
func (UnimplementedRoomServiceServer) RemovePeer ¶
func (UnimplementedRoomServiceServer) RemovePeer(context.Context, *RemovePeerRequest) (*RemovePeerReply, error)
func (UnimplementedRoomServiceServer) UpdatePeer ¶
func (UnimplementedRoomServiceServer) UpdatePeer(context.Context, *UpdatePeerRequest) (*UpdatePeerReply, error)
func (UnimplementedRoomServiceServer) UpdateRoom ¶
func (UnimplementedRoomServiceServer) UpdateRoom(context.Context, *UpdateRoomRequest) (*UpdateRoomReply, error)
type UnimplementedRoomSignalServer ¶
type UnimplementedRoomSignalServer struct { }
UnimplementedRoomSignalServer must be embedded to have forward compatible implementations.
func (UnimplementedRoomSignalServer) Signal ¶
func (UnimplementedRoomSignalServer) Signal(RoomSignal_SignalServer) error
type UnsafeRoomServiceServer ¶
type UnsafeRoomServiceServer interface {
// contains filtered or unexported methods
}
UnsafeRoomServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RoomServiceServer will result in compilation errors.
type UnsafeRoomSignalServer ¶
type UnsafeRoomSignalServer interface {
// contains filtered or unexported methods
}
UnsafeRoomSignalServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RoomSignalServer will result in compilation errors.
type UpdatePeerReply ¶
type UpdatePeerReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*UpdatePeerReply) Descriptor
deprecated
func (*UpdatePeerReply) Descriptor() ([]byte, []int)
Deprecated: Use UpdatePeerReply.ProtoReflect.Descriptor instead.
func (*UpdatePeerReply) GetError ¶
func (x *UpdatePeerReply) GetError() *Error
func (*UpdatePeerReply) GetSuccess ¶
func (x *UpdatePeerReply) GetSuccess() bool
func (*UpdatePeerReply) ProtoMessage ¶
func (*UpdatePeerReply) ProtoMessage()
func (*UpdatePeerReply) ProtoReflect ¶
func (x *UpdatePeerReply) ProtoReflect() protoreflect.Message
func (*UpdatePeerReply) Reset ¶
func (x *UpdatePeerReply) Reset()
func (*UpdatePeerReply) String ¶
func (x *UpdatePeerReply) String() string
type UpdatePeerRequest ¶
type UpdatePeerRequest struct { Peer *Peer `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer,omitempty"` // contains filtered or unexported fields }
func (*UpdatePeerRequest) Descriptor
deprecated
func (*UpdatePeerRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdatePeerRequest.ProtoReflect.Descriptor instead.
func (*UpdatePeerRequest) GetPeer ¶
func (x *UpdatePeerRequest) GetPeer() *Peer
func (*UpdatePeerRequest) ProtoMessage ¶
func (*UpdatePeerRequest) ProtoMessage()
func (*UpdatePeerRequest) ProtoReflect ¶
func (x *UpdatePeerRequest) ProtoReflect() protoreflect.Message
func (*UpdatePeerRequest) Reset ¶
func (x *UpdatePeerRequest) Reset()
func (*UpdatePeerRequest) String ¶
func (x *UpdatePeerRequest) String() string
type UpdateRoomReply ¶
type UpdateRoomReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*UpdateRoomReply) Descriptor
deprecated
func (*UpdateRoomReply) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRoomReply.ProtoReflect.Descriptor instead.
func (*UpdateRoomReply) GetError ¶
func (x *UpdateRoomReply) GetError() *Error
func (*UpdateRoomReply) GetSuccess ¶
func (x *UpdateRoomReply) GetSuccess() bool
func (*UpdateRoomReply) ProtoMessage ¶
func (*UpdateRoomReply) ProtoMessage()
func (*UpdateRoomReply) ProtoReflect ¶
func (x *UpdateRoomReply) ProtoReflect() protoreflect.Message
func (*UpdateRoomReply) Reset ¶
func (x *UpdateRoomReply) Reset()
func (*UpdateRoomReply) String ¶
func (x *UpdateRoomReply) String() string
type UpdateRoomRequest ¶
type UpdateRoomRequest struct { Room *Room `protobuf:"bytes,1,opt,name=room,proto3" json:"room,omitempty"` // contains filtered or unexported fields }
func (*UpdateRoomRequest) Descriptor
deprecated
func (*UpdateRoomRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRoomRequest.ProtoReflect.Descriptor instead.
func (*UpdateRoomRequest) GetRoom ¶
func (x *UpdateRoomRequest) GetRoom() *Room
func (*UpdateRoomRequest) ProtoMessage ¶
func (*UpdateRoomRequest) ProtoMessage()
func (*UpdateRoomRequest) ProtoReflect ¶
func (x *UpdateRoomRequest) ProtoReflect() protoreflect.Message
func (*UpdateRoomRequest) Reset ¶
func (x *UpdateRoomRequest) Reset()
func (*UpdateRoomRequest) String ¶
func (x *UpdateRoomRequest) String() string