elements

Documentation

Index

• Constants
• Variables
• func NewMultiplexer(el avp.Element) avp.Element
• type Converter
  • func NewConverter(typ int) *Converter
  • func (c *Converter) Write(sample *avp.Sample) error
• type FileWriter
  • func NewFileWriter(path string, bufSize int) *FileWriter
  • func (w *FileWriter) Close()
  • func (w *FileWriter) Write(sample *avp.Sample) error
• type Filter
  • func NewFilter(condition func(*avp.Sample) bool) *Filter
  • func (f *Filter) Write(sample *avp.Sample) error
• type Leaf
  • func (e *Leaf) Attach(el avp.Element)
  • func (e *Leaf) Close()
  • func (e *Leaf) Write(sample *avp.Sample) error
• type Map
  • func NewMap(fn func(*avp.Sample) *avp.Sample) *Map
  • func (m *Map) Write(sample *avp.Sample) error
• type Multiplexer
  • func (m *Multiplexer) Attach(el avp.Element)
  • func (m *Multiplexer) Close()
  • func (m *Multiplexer) Write(sample *avp.Sample) error
• type Node
  • func (e *Node) Attach(el avp.Element)
  • func (e *Node) Close()
  • func (e *Node) Write(sample *avp.Sample) error
• type Pipeline
  • func NewPipeline(elements []avp.Element) *Pipeline
  • func (p *Pipeline) Attach(el avp.Element)
  • func (p *Pipeline) Close()
  • func (p *Pipeline) Write(sample *avp.Sample) error
• type SampleWriter
  • func NewSampleWriter() *SampleWriter
  • func (w *SampleWriter) Close() error
  • func (w *SampleWriter) Write(p []byte) (n int, err error)
• type WebmSaver
  • func NewWebmSaver() *WebmSaver
  • func (s *WebmSaver) Attach(e avp.Element)
  • func (s *WebmSaver) Close()
  • func (s *WebmSaver) Write(sample *avp.Sample) error

Constants

const (
	TypeMetadata = 100
	TypeBinary   = 101
	TypeRGB24    = 102
	TypeWebM     = 103
	TypeYCbCr    = 104
	TypeJPEG     = 105
	TypeRGBA     = 106
)

Types for samples

Variables

var (
	// ErrAttachNotSupported returned when attaching elements is not supported
	ErrAttachNotSupported = errors.New("attach not supported")
	// ErrElementAlreadyAttached returned when attaching an element that is already attached
	ErrElementAlreadyAttached = errors.New("element already attached")
)

Functions

func NewMultiplexer

func NewMultiplexer(el avp.Element) avp.Element

Types

type Converter

type Converter struct {
	Node
	// contains filtered or unexported fields
}

Converter instance

func NewConverter

func NewConverter(typ int) *Converter

NewConverter instance. Converter converts between media types.

Currently supports:

• YCbCR -> JPEG

func (*Converter) Write

func (c *Converter) Write(sample *avp.Sample) error

type FileWriter

type FileWriter struct {
	Leaf
	// contains filtered or unexported fields
}

FileWriter instance

func NewFileWriter

func NewFileWriter(path string, bufSize int) *FileWriter

NewFileWriter instance bufSize is the buffer size in bytes. Pass <=0 to disable buffering.

func (*FileWriter) Close

func (w *FileWriter) Close()

func (*FileWriter) Write

func (w *FileWriter) Write(sample *avp.Sample) error

type Filter

type Filter struct {
	Node
	// contains filtered or unexported fields
}

Filter instance

func NewFilter

func NewFilter(condition func(*avp.Sample) bool) *Filter

NewFilter instance. Filter contitionally forwards a payload based on the return of the provided function.

func (*Filter) Write

func (f *Filter) Write(sample *avp.Sample) error

type Leaf

type Leaf struct{}

func (*Leaf) Attach

func (e *Leaf) Attach(el avp.Element)

func (*Leaf) Close

func (e *Leaf) Close()

func (*Leaf) Write

func (e *Leaf) Write(sample *avp.Sample) error

type Map

type Map struct {
	Node
	// contains filtered or unexported fields
}

Map instance

func NewMap

func NewMap(fn func(*avp.Sample) *avp.Sample) *Map

NewMap creates a new sample mapper which maps samples using the provided function

func (*Map) Write

func (m *Map) Write(sample *avp.Sample) error

type Multiplexer

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

func (*Multiplexer) Attach

func (m *Multiplexer) Attach(el avp.Element)

func (*Multiplexer) Close

func (m *Multiplexer) Close()

func (*Multiplexer) Write

func (m *Multiplexer) Write(sample *avp.Sample) error

type Node

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

func (*Node) Attach

func (e *Node) Attach(el avp.Element)

func (*Node) Close

func (e *Node) Close()

func (*Node) Write

func (e *Node) Write(sample *avp.Sample) error

type Pipeline

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

func NewPipeline

func NewPipeline(elements []avp.Element) *Pipeline

func (*Pipeline) Attach

func (p *Pipeline) Attach(el avp.Element)

func (*Pipeline) Close

func (p *Pipeline) Close()

func (*Pipeline) Write

func (p *Pipeline) Write(sample *avp.Sample) error

type SampleWriter

type SampleWriter struct {
	Node
}

SampleWriter for writing samples

func NewSampleWriter

func NewSampleWriter() *SampleWriter

NewSampleWriter creates a new sample writer

func (*SampleWriter) Close

func (w *SampleWriter) Close() error

func (*SampleWriter) Write

func (w *SampleWriter) Write(p []byte) (n int, err error)

Write sample

type WebmSaver

type WebmSaver struct {
	sync.Mutex
	// contains filtered or unexported fields
}

WebmSaver Module for saving rtp streams to webm

func NewWebmSaver

func NewWebmSaver() *WebmSaver

NewWebmSaver Initialize a new webm saver

func (*WebmSaver) Attach

func (s *WebmSaver) Attach(e avp.Element)

Attach attach a child element

func (*WebmSaver) Close

func (s *WebmSaver) Close()

Close Close the WebmSaver

func (*WebmSaver) Write

func (s *WebmSaver) Write(sample *avp.Sample) error

Write sample to webmsaver