mixer

Documentation

Index

• type ABRVideo
  • func (ABRVideo) Name() string
  • func (ABRVideo) WriteConf(baseDir string, g GlobalDesc, c FlowDesc) error
• type BurstProps
• type Bytes
  • func (b *Bytes) UnmarshalYAML(unmarshal func(interface{}) error) error
• type Description
  • func NewDescriptionFromFile(path string) (*Description, error)
  • func NewDescriptionFromYaml(buf []byte) (*Description, error)
• type FixedBitrateProps
• type FlowDesc
• type GlobalDesc
• type Greedy
  • func (Greedy) Name() string
  • func (Greedy) WriteConf(baseDir string, g GlobalDesc, c FlowDesc) error
• type Mixer
  • func NewABRVideo() Mixer
  • func NewGreedy() Mixer
  • func NewRealtimeAudio() Mixer
  • func NewRealtimeVideo() Mixer
  • func NewScavenger() Mixer
  • func NewWebPage() Mixer
• type MixerMap
  • func MixerInit() *MixerMap
  • func NewMixerMap() *MixerMap
  • func (m *MixerMap) LookupMixer(id string) (*Mixer, error)
  • func (m *MixerMap) MixerRegister(mixer Mixer)
• type PortsRange
  • func (pr *PortsRange) UnmarshalYAML(unmarshal func(interface{}) error) error
• type Ratio
  • func (r *Ratio) UnmarshalYAML(unmarshal func(interface{}) error) error
• type RealtimeAudio
  • func (RealtimeAudio) Name() string
  • func (RealtimeAudio) WriteConf(baseDir string, g GlobalDesc, c FlowDesc) error
• type RealtimeVideo
  • func (RealtimeVideo) Name() string
  • func (RealtimeVideo) WriteConf(baseDir string, g GlobalDesc, c FlowDesc) error
• type Scavenger
  • func (Scavenger) Name() string
  • func (Scavenger) WriteConf(baseDir string, g GlobalDesc, c FlowDesc) error
• type WebPage
  • func (WebPage) Name() string
  • func (WebPage) WriteConf(baseDir string, g GlobalDesc, c FlowDesc) error

Types

type ABRVideo

type ABRVideo struct{}

func (ABRVideo) Name

func (ABRVideo) Name() string

func (ABRVideo) WriteConf

func (ABRVideo) WriteConf(baseDir string, g GlobalDesc, c FlowDesc) error

type BurstProps

type BurstProps struct {
	Label          string
	Port           uint16
	Server         string
	ReportInterval string
	At             []int
}

type Bytes

type Bytes struct {
	Val units.MetricBytes
}

func (*Bytes) UnmarshalYAML

func (b *Bytes) UnmarshalYAML(unmarshal func(interface{}) error) error

type Description

type Description struct {
	Global GlobalDesc `yaml:",inline"`
	Flows  []FlowDesc `yaml:"flows"`
}

func NewDescriptionFromFile

func NewDescriptionFromFile(path string) (*Description, error)

func NewDescriptionFromYaml

func NewDescriptionFromYaml(buf []byte) (*Description, error)

type FixedBitrateProps

type FixedBitrateProps struct {
	Label          string
	Port           uint16
	Server         string
	ReportInterval string
	Time           string
	Instances      uint
}

type FlowDesc

type FlowDesc struct {
	Kind             string            `yaml:"kind"`
	PercentBandwidth Ratio             `yaml:"percent-bandwidth"`
	PortsRange       PortsRange        `yaml:"ports-range"`
	Template         string            `yaml:"template"`
	Props            map[string]string `yaml:"props"`
}

type GlobalDesc

type GlobalDesc struct {
	TotalBandwidth Bytes         `yaml:"total-bandwidth"`
	TotalTime      time.Duration `yaml:"total-time"`
	ReportInterval time.Duration `yaml:"report-interval"`
}

type Greedy

type Greedy struct{}

func (Greedy) Name

func (Greedy) Name() string

func (Greedy) WriteConf

func (Greedy) WriteConf(baseDir string, g GlobalDesc, c FlowDesc) error

type Mixer

type Mixer interface {
	// WriteConf writes one or more configuration files for the given flow
	WriteConf(string, GlobalDesc, FlowDesc) error

	// Name is used by a Mixer to provide its (unique) name
	Name() string
}

func NewABRVideo

func NewABRVideo() Mixer

func NewGreedy

func NewGreedy() Mixer

func NewRealtimeAudio

func NewRealtimeAudio() Mixer

func NewRealtimeVideo

func NewRealtimeVideo() Mixer

func NewScavenger

func NewScavenger() Mixer

func NewWebPage

func NewWebPage() Mixer

type MixerMap

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

func MixerInit

func MixerInit() *MixerMap

func NewMixerMap

func NewMixerMap() *MixerMap

func (*MixerMap) LookupMixer

func (m *MixerMap) LookupMixer(id string) (*Mixer, error)

func (*MixerMap) MixerRegister

func (m *MixerMap) MixerRegister(mixer Mixer)

type PortsRange

type PortsRange struct {
	First uint16
	Last  uint16
}

func (*PortsRange) UnmarshalYAML

func (pr *PortsRange) UnmarshalYAML(unmarshal func(interface{}) error) error

type Ratio

type Ratio struct {
	Val float64
}

func (*Ratio) UnmarshalYAML

func (r *Ratio) UnmarshalYAML(unmarshal func(interface{}) error) error

type RealtimeAudio

type RealtimeAudio struct{}

func (RealtimeAudio) Name

func (RealtimeAudio) Name() string

func (RealtimeAudio) WriteConf

func (RealtimeAudio) WriteConf(baseDir string, g GlobalDesc, c FlowDesc) error

type RealtimeVideo

type RealtimeVideo struct{}

func (RealtimeVideo) Name

func (RealtimeVideo) Name() string

func (RealtimeVideo) WriteConf

func (RealtimeVideo) WriteConf(baseDir string, g GlobalDesc, c FlowDesc) error

type Scavenger

type Scavenger struct{}

func (Scavenger) Name

func (Scavenger) Name() string

func (Scavenger) WriteConf

func (Scavenger) WriteConf(baseDir string, g GlobalDesc, c FlowDesc) error

type WebPage

type WebPage struct{}

func (WebPage) Name

func (WebPage) Name() string

func (WebPage) WriteConf

func (WebPage) WriteConf(baseDir string, g GlobalDesc, c FlowDesc) error