server

Documentation

Index

• func NewAVPServer(conf avp.Config, elems map[string]avp.ElementFun) pb.AVPServer
• type AVP
  • func NewAVP(c avp.Config, elems map[string]avp.ElementFun) *AVP
  • func (a *AVP) CloseSession(addr, sid string) error
  • func (a *AVP) Process(ctx context.Context, addr, pid, sid, tid, eid string, config []byte) error
• 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())

Functions

func NewAVPServer

func NewAVPServer(conf avp.Config, elems map[string]avp.ElementFun) pb.AVPServer

Types

type AVP

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

AVP represents an avp instance

func NewAVP

func NewAVP(c avp.Config, elems map[string]avp.ElementFun) *AVP

NewAVP creates a new avp instance

func (*AVP) CloseSession

func (a *AVP) CloseSession(addr, sid string) error

CloseSession stops all processing for a session. Call it when the session ends.

func (*AVP) Process

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

Process starts a process for a track.

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