Versions in this module Expand all Collapse all v1 v1.10.0 Nov 9, 2021 Changes in this version + type Config struct + Global global + Log logConf + Nats natsConf + Redis db.Config + func (c *Config) Load(file string) error + type Peer struct + func NewPeer() *Peer + func (p *Peer) Close() + func (p *Peer) SID() string + func (p *Peer) UID() string + type Room struct + func (r *Room) Name() string + func (r *Room) SID() string + type RoomServer struct + func New() *RoomServer + func (r *RoomServer) ConfigBase() runner.ConfigBase + func (r *RoomServer) Load(confFile string) error + func (r *RoomServer) Start() error + func (r *RoomServer) StartGRPC(registrar grpc.ServiceRegistrar) error + func (s *RoomServer) Close() + type RoomService struct + func NewRoomService(config db.Config) *RoomService + func (s *RoomService) AddPeer(ctx context.Context, in *room.AddPeerRequest) (*room.AddPeerReply, error) + func (s *RoomService) Close() + func (s *RoomService) CreateRoom(ctx context.Context, in *room.CreateRoomRequest) (*room.CreateRoomReply, error) + func (s *RoomService) EndRoom(ctx context.Context, in *room.EndRoomRequest) (*room.EndRoomReply, error) + func (s *RoomService) GetPeers(ctx context.Context, in *room.GetPeersRequest) (*room.GetPeersReply, error) + func (s *RoomService) RemovePeer(ctx context.Context, in *room.RemovePeerRequest) (*room.RemovePeerReply, error) + func (s *RoomService) UpdatePeer(ctx context.Context, in *room.UpdatePeerRequest) (*room.UpdatePeerReply, error) + func (s *RoomService) UpdateRoom(ctx context.Context, in *room.UpdateRoomRequest) (*room.UpdateRoomReply, error) + type RoomSignalService struct + func NewRoomSignalService(rs *RoomService) *RoomSignalService + func (s *RoomSignalService) Join(in *room.Request_Join) (*room.Reply_Join, *Peer, error) + func (s *RoomSignalService) Leave(in *room.Request_Leave) (*room.Reply_Leave, error) + func (s *RoomSignalService) SendMessage(in *room.Request_SendMessage) (*room.Reply_SendMessage, error) + func (s *RoomSignalService) Signal(stream room.RoomSignal_SignalServer) error
Go to main page