biz

Documentation

Index

• type BIZ
  • func NewBIZ(nid string) *BIZ
  • func (b *BIZ) Close()
  • func (b *BIZ) Service() *BizServer
  • func (b *BIZ) Start(conf Config) error
• type BizServer
  • func (s *BizServer) Signal(stream biz.Biz_SignalServer) error
• type Config
• type Peer
  • func NewPeer(sid string, uid string, info []byte, senCh chan *biz.SignalReply) *Peer
  • func (p *Peer) Close()
  • func (p *Peer) SID() string
  • func (p *Peer) UID() string
• type Room
  • func (r *Room) SID() string
• type SFUSignalBridge
  • func (s *SFUSignalBridge) Signal(sstream sfu.SFU_SignalServer) error

Types

type BIZ

type BIZ struct {
	ion.Node
	// contains filtered or unexported fields
}

BIZ represents biz node

func NewBIZ

func NewBIZ(nid string) *BIZ

NewBIZ create a biz node instance

func (*BIZ) Close

func (b *BIZ) Close()

Close all

func (*BIZ) Service

func (b *BIZ) Service() *BizServer

Service return grpc services.

func (*BIZ) Start

func (b *BIZ) Start(conf Config) error

Start biz node

type BizServer

type BizServer struct {
	biz.UnimplementedBizServer
	// contains filtered or unexported fields
}

BizServer represents an BizServer instance

func (*BizServer) Signal

func (s *BizServer) Signal(stream biz.Biz_SignalServer) error

Signal process biz request.

type Config

type Config struct {
	Global global     `mapstructure:"global"`
	Log    logConf    `mapstructure:"log"`
	Nats   natsConf   `mapstructure:"nats"`
	Avp    avpConf    `mapstructure:"avp"`
	Signal signalConf `mapstructure:"signal"`
}

Config for biz node

type Peer

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

Peer represents a peer for client

func NewPeer

func NewPeer(sid string, uid string, info []byte, senCh chan *biz.SignalReply) *Peer

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) SID

func (r *Room) SID() string

SID room id

type SFUSignalBridge

type SFUSignalBridge struct {
	sfu.UnimplementedSFUServer
	BizServer *BizServer
}

func (*SFUSignalBridge) Signal

func (s *SFUSignalBridge) Signal(sstream sfu.SFU_SignalServer) error

Signal bridge SFU signaling between client and sfu node.