avp

Documentation

Index

• Constants
• Variables
• func Init(r *Registry)
• type AVP
  • func NewAVP(c Config) *AVP
  • func (a *AVP) Process(ctx context.Context, addr, pid, sid, tid, eid string, config []byte)
• type Builder
  • func NewBuilder(track *webrtc.Track, maxLate uint16) *Builder
  • func (b *Builder) AttachElement(e Element)
  • func (b *Builder) OnStop(f func())
  • func (b *Builder) Track() *webrtc.Track
• type Config
• type Element
• type PendingProcess
• type Registry
  • func NewRegistry() *Registry
  • func (r *Registry) AddElement(eid string, f func(sid, pid, tid string, config []byte) Element)
  • func (r *Registry) GetElement(id string) func(string, string, string, []byte) Element
• type SFU
  • func NewSFU(addr string, config Config) *SFU
  • func (s *SFU) GetTransport(sid string) *WebRTCTransport
  • func (s *SFU) OnClose(f func())
• type Sample
• type WebRTCTransport
  • func NewWebRTCTransport(id string, c Config) *WebRTCTransport
  • func (t *WebRTCTransport) AddICECandidate(candidate webrtc.ICECandidateInit) error
  • func (t *WebRTCTransport) Close() error
  • func (t *WebRTCTransport) CreateAnswer() (webrtc.SessionDescription, error)
  • func (t *WebRTCTransport) CreateOffer() (webrtc.SessionDescription, error)
  • func (t *WebRTCTransport) OnClose(f func())
  • func (t *WebRTCTransport) OnICECandidate(f func(c *webrtc.ICECandidate))
  • func (t *WebRTCTransport) Process(pid, tid, eid string, config []byte)
  • func (t *WebRTCTransport) SetLocalDescription(desc webrtc.SessionDescription) error
  • func (t *WebRTCTransport) SetRemoteDescription(desc webrtc.SessionDescription) error

Constants

const (
	TypeOpus = 1
	TypeVP8  = 2
	TypeVP9  = 3
	TypeH264 = 4
)

Types for samples

Variables

var (
	// ErrCodecNotSupported is returned when a rtp packed it pushed with an unsupported codec
	ErrCodecNotSupported = errors.New("codec not supported")
)

Functions

func Init

func Init(r *Registry)

Init avp with a registry of elements

Types

type AVP

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

AVP represents an avp instance

func NewAVP

func NewAVP(c Config) *AVP

NewAVP creates a new avp instance

func (*AVP) Process

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

Process starts a process for a track.

type Builder

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

Builder Module for building video/audio samples from rtp streams

func NewBuilder

func NewBuilder(track *webrtc.Track, maxLate uint16) *Builder

NewBuilder Initialize a new audio sample builder

func (*Builder) AttachElement

func (b *Builder) AttachElement(e Element)

AttachElement attaches a element to a builder

func (*Builder) OnStop

func (b *Builder) OnStop(f func())

OnStop is called when a builder is stopped

func (*Builder) Track

func (b *Builder) Track() *webrtc.Track

Track returns the builders underlying track

type Config

type Config struct {
	Log           log.Config        `mapstructure:"log"`
	Pipeline      pipelineconf      `mapstructure:"pipeline"`
	SampleBuilder samplebuilderconf `mapstructure:"samplebuilder"`
	WebRTC        webrtcconf        `mapstructure:"webrtc"`
}

Config for base AVP

type Element

type Element interface {
	Write(*Sample) error
	Attach(Element)
	Close()
}

Element interface

type PendingProcess

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

type Registry

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

Registry provides a registry of elements

func NewRegistry

func NewRegistry() *Registry

NewRegistry returns new registry instance

func (*Registry) AddElement

func (r *Registry) AddElement(eid string, f func(sid, pid, tid string, config []byte) Element)

AddElement to registry

func (*Registry) GetElement

func (r *Registry) GetElement(id string) func(string, string, string, []byte) Element

GetElement to registry

type SFU

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

SFU client

func NewSFU

func NewSFU(addr string, config Config) *SFU

NewSFU intializes a new SFU client

func (*SFU) GetTransport

func (s *SFU) GetTransport(sid string) *WebRTCTransport

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

type Sample

type Sample struct {
	Type           int
	Timestamp      uint32
	SequenceNumber uint16
	Payload        interface{}
}

Sample of audio or video

type WebRTCTransport

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

WebRTCTransport represents a webrtc transport

func NewWebRTCTransport

func NewWebRTCTransport(id string, c Config) *WebRTCTransport

NewWebRTCTransport creates a new webrtc transport

func (*WebRTCTransport) AddICECandidate

func (t *WebRTCTransport) AddICECandidate(candidate webrtc.ICECandidateInit) error

AddICECandidate accepts an ICE candidate string and adds it to the existing set of candidates

func (*WebRTCTransport) Close

func (t *WebRTCTransport) Close() error

Close the webrtc transport

func (*WebRTCTransport) CreateAnswer

func (t *WebRTCTransport) CreateAnswer() (webrtc.SessionDescription, error)

CreateAnswer starts the PeerConnection and generates the localDescription

func (*WebRTCTransport) CreateOffer

func (t *WebRTCTransport) CreateOffer() (webrtc.SessionDescription, error)

CreateOffer starts the PeerConnection and generates the localDescription

func (*WebRTCTransport) OnClose

func (t *WebRTCTransport) OnClose(f func())

OnClose sets a handler that is called when the webrtc transport is closed

func (*WebRTCTransport) OnICECandidate

func (t *WebRTCTransport) OnICECandidate(f func(c *webrtc.ICECandidate))

OnICECandidate sets an event handler which is invoked when a new ICE candidate is found. Take note that the handler is gonna be called with a nil pointer when gathering is finished.

func (*WebRTCTransport) Process

func (t *WebRTCTransport) Process(pid, tid, eid string, config []byte)

Process creates a pipeline

func (*WebRTCTransport) SetLocalDescription

func (t *WebRTCTransport) SetLocalDescription(desc webrtc.SessionDescription) error

SetLocalDescription sets the SessionDescription of the local peer

func (*WebRTCTransport) SetRemoteDescription

func (t *WebRTCTransport) SetRemoteDescription(desc webrtc.SessionDescription) error

SetRemoteDescription sets the SessionDescription of the remote peer