server

Documentation

Index

• type Config
  • func (c *Config) Load(file string) error
• type Peer
  • func NewPeer() *Peer
  • func (p *Peer) Close()
  • func (p *Peer) SID() string
  • func (p *Peer) UID() string
• type Room
  • func (r *Room) Name() string
  • func (r *Room) SID() string
• type RoomServer
  • func New() *RoomServer
  • func (s *RoomServer) Close()
  • 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
• type RoomService
  • 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
  • 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

Types

type Config

type Config struct {
	runner.ConfigBase
	Global global    `mapstructure:"global"`
	Log    logConf   `mapstructure:"log"`
	Nats   natsConf  `mapstructure:"nats"`
	Redis  db.Config `mapstructure:"redis"`
}

Config for room node

func (*Config) Load

func (c *Config) Load(file string) error

type Peer

type Peer struct {
	// contains filtered or unexported fields
}

Peer represents a peer for client

func NewPeer

func NewPeer() *Peer

NewPeer create a peer args: sid, uid, dest, name, role, protocol, direction, info, avatar, vendor at least sid and uid

func (*Peer) Close

func (p *Peer) Close()

Close peer

func (*Peer) SID

func (p *Peer) SID() string

SID return session id

func (*Peer) UID

func (p *Peer) UID() string

UID return peer uid

type Room

type Room struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Room represents a Room which manage peers

func (*Room) Name

func (r *Room) Name() string

Room name

func (*Room) SID

func (r *Room) SID() string

SID room id

type RoomServer

type RoomServer struct {
	// for standalone running
	runner.Service

	// grpc room service
	RoomService
	RoomSignalService

	// for distributed node running
	ion.Node
	// contains filtered or unexported fields
}

func New

func New() *RoomServer

New create a room node instance

func (*RoomServer) Close

func (s *RoomServer) Close()

func (*RoomServer) ConfigBase

func (r *RoomServer) ConfigBase() runner.ConfigBase

ConfigBase used for runner

func (*RoomServer) Load

func (r *RoomServer) Load(confFile string) error

Load load config file

func (*RoomServer) Start

func (r *RoomServer) Start() error

Start for distributed node

func (*RoomServer) StartGRPC

func (r *RoomServer) StartGRPC(registrar grpc.ServiceRegistrar) error

StartGRPC for standalone bin

type RoomService

type RoomService struct {
	room.UnimplementedRoomServiceServer
	// contains filtered or unexported fields
}

func NewRoomService

func NewRoomService(config db.Config) *RoomService

func (*RoomService) AddPeer

func (s *RoomService) AddPeer(ctx context.Context, in *room.AddPeerRequest) (*room.AddPeerReply, error)

AddPeer invite a peer (webrtc/rtsp/rtmp/.. stream)

func (*RoomService) Close

func (s *RoomService) Close()

func (*RoomService) CreateRoom

func (s *RoomService) CreateRoom(ctx context.Context, in *room.CreateRoomRequest) (*room.CreateRoomReply, error)

CreateRoom create a room

func (*RoomService) EndRoom

func (s *RoomService) EndRoom(ctx context.Context, in *room.EndRoomRequest) (*room.EndRoomReply, error)

EndRoom end a room

func (*RoomService) GetPeers

func (s *RoomService) GetPeers(ctx context.Context, in *room.GetPeersRequest) (*room.GetPeersReply, error)

GetPeers get all peers in room

func (*RoomService) RemovePeer

func (s *RoomService) RemovePeer(ctx context.Context, in *room.RemovePeerRequest) (*room.RemovePeerReply, error)

RemovePeer delete a peer

func (*RoomService) UpdatePeer

func (s *RoomService) UpdatePeer(ctx context.Context, in *room.UpdatePeerRequest) (*room.UpdatePeerReply, error)

UpdatePeer update a peer

func (*RoomService) UpdateRoom

func (s *RoomService) UpdateRoom(ctx context.Context, in *room.UpdateRoomRequest) (*room.UpdateRoomReply, error)

UpdateRoom update a room. can lock room and change password

type RoomSignalService

type RoomSignalService struct {
	room.UnimplementedRoomSignalServer
	// contains filtered or unexported fields
}

RoomSignalService represents an RoomSignalService instance

func NewRoomSignalService

func NewRoomSignalService(rs *RoomService) *RoomSignalService

NewRoomService creates a new room app server instance

func (*RoomSignalService) Join

func (s *RoomSignalService) Join(in *room.Request_Join) (*room.Reply_Join, *Peer, error)

func (*RoomSignalService) Leave

func (s *RoomSignalService) Leave(in *room.Request_Leave) (*room.Reply_Leave, error)

func (*RoomSignalService) SendMessage

func (s *RoomSignalService) SendMessage(in *room.Request_SendMessage) (*room.Reply_SendMessage, error)

func (*RoomSignalService) Signal

func (s *RoomSignalService) Signal(stream room.RoomSignal_SignalServer) error