rtc

Documentation

Index

• Variables
• func CheckPlugins(config plugins.Config) error
• func Close()
• func DelRouter(id string)
• func InitIce(iceServers []webrtc.ICEServer, icePortStart, icePortEnd uint16) error
• func InitPlugins(config plugins.Config)
• func InitRTP(port int, kcpKey, kcpSalt string) error
• func MapRouter(fn func(id string, r *Router))
• type Router
  • func AddRouter(id string) *Router
  • func GetOrNewRouter(id string) *Router
  • func GetRouter(id string) *Router
  • func NewRouter(id string) *Router
  • func (r *Router) AddPub(id string, t transport.Transport) transport.Transport
  • func (r *Router) AddSub(id string, t transport.Transport) transport.Transport
  • func (r *Router) Alive() bool
  • func (r *Router) Close()
  • func (r *Router) DelPub()
  • func (r *Router) DelSub(id string)
  • func (r *Router) DelSubs()
  • func (r *Router) GetPub() transport.Transport
  • func (r *Router) GetSub(id string) transport.Transport
  • func (r *Router) GetSubs() map[string]transport.Transport
  • func (r *Router) HasNoneSub() bool
  • func (r *Router) InitPlugins(config plugins.Config) error
  • func (r *Router) ReSendRTP(sid string, ssrc uint32, sn uint16) bool

Variables

var (

	//CleanChannel return the dead pub's mid
	CleanChannel = make(chan string, maxCleanSize)
)

Functions

func CheckPlugins

func CheckPlugins(config plugins.Config) error

CheckPlugins plugins config

func Close

func Close()

Close close all Router

func DelRouter

func DelRouter(id string)

DelRouter delete pub

func InitIce

func InitIce(iceServers []webrtc.ICEServer, icePortStart, icePortEnd uint16) error

InitIce ice urls

func InitPlugins

func InitPlugins(config plugins.Config)

InitPlugins plugins config

func InitRTP

func InitRTP(port int, kcpKey, kcpSalt string) error

InitRTP rtp port

func MapRouter

func MapRouter(fn func(id string, r *Router))

Types

type Router

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

+--->sub
|

pub--->pubCh-->pluginChain-->subCh---+--->sub

|
+--->sub

Router is rtp router

func AddRouter

func AddRouter(id string) *Router

AddRouter add a new router

func GetOrNewRouter

func GetOrNewRouter(id string) *Router

func GetRouter

func GetRouter(id string) *Router

GetRouter get router from map

func NewRouter

func NewRouter(id string) *Router

NewRouter return a new Router

func (*Router) AddPub

func (r *Router) AddPub(id string, t transport.Transport) transport.Transport

AddPub add a pub transport

func (*Router) AddSub

func (r *Router) AddSub(id string, t transport.Transport) transport.Transport

AddSub add a pub to router

func (*Router) Alive

func (r *Router) Alive() bool

Alive return router status

func (*Router) Close

func (r *Router) Close()

Close release all

func (*Router) DelPub

func (r *Router) DelPub()

DelPub del pub

func (*Router) DelSub

func (r *Router) DelSub(id string)

DelSub del sub by id

func (*Router) DelSubs

func (r *Router) DelSubs()

DelSubs del all sub

func (*Router) GetPub

func (r *Router) GetPub() transport.Transport

GetPub get pub

func (*Router) GetSub

func (r *Router) GetSub(id string) transport.Transport

GetSub get a sub by id

func (*Router) GetSubs

func (r *Router) GetSubs() map[string]transport.Transport

GetSubs get all subs

func (*Router) HasNoneSub

func (r *Router) HasNoneSub() bool

HasNoneSub check if sub == 0

func (*Router) InitPlugins

func (r *Router) InitPlugins(config plugins.Config) error

func (*Router) ReSendRTP

func (r *Router) ReSendRTP(sid string, ssrc uint32, sn uint16) bool