avp

Documentation

Index

• type AVP
  • func NewAVP(nid string) *AVP
  • func (a *AVP) Close()
  • func (a *AVP) Start(conf Config) error
• type AVPProcesser
  • func NewAVPProcesser(c avp.Config, elems map[string]avp.ElementFun) *AVPProcesser
  • func (a *AVPProcesser) Process(ctx context.Context, addr, pid, sid, tid, eid string, config []byte) error
• type Config
• type SFU
  • func NewSFU(addr string, config avp.Config) (*SFU, error)
  • func (s *SFU) GetTransport(sid string) (*avp.WebRTCTransport, error)
  • func (s *SFU) OnClose(f func())

Types

type AVP

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

AVP represents avp node

func NewAVP

func NewAVP(nid string) *AVP

NewAVP create a avp node instance

func (*AVP) Close

func (a *AVP) Close()

Close all

func (*AVP) Start

func (a *AVP) Start(conf Config) error

Start avp node

type AVPProcesser

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

AVPProcesser represents an avp instance

func NewAVPProcesser

func NewAVPProcesser(c avp.Config, elems map[string]avp.ElementFun) *AVPProcesser

NewAVPProcesser creates a new avp instance

func (*AVPProcesser) Process

func (a *AVPProcesser) Process(ctx context.Context, addr, pid, sid, tid, eid string, config []byte) error

Process starts a process for a track.

type Config

type Config struct {
	Global      global      `mapstructure:"global"`
	Nats        natsConf    `mapstructure:"nats"`
	Node        nodeConf    `mapstructure:"node"`
	Element     elementConf `mapstructure:"element"`
	iavp.Config `mapstructure:"avp"`
}

Config for avp node

type SFU

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

SFU client

func NewSFU

func NewSFU(addr string, config avp.Config) (*SFU, error)

NewSFU intializes a new SFU client

func (*SFU) GetTransport

func (s *SFU) GetTransport(sid string) (*avp.WebRTCTransport, error)

GetTransport returns a webrtc transport for a session

func (*SFU) OnClose

func (s *SFU) OnClose(f func())

OnClose handler called when sfu client is closed