reducers

Documentation

Index

• Constants
• Variables
• func Default(golpExchange string, shardPrefixes []string) health.Reducer
• func DefaultStarTimeOffset() time.Duration
• func StatsReducer(statsWindows []time.Duration) health.ReducerFunc
• type MediaServerMetrics
  • func (t MediaServerMetrics) Bindings() []event.BindingArgs
  • func (t MediaServerMetrics) Conditions() []health.ConditionType
  • func (t MediaServerMetrics) Reduce(current *health.Status, _ interface{}, evtIface data.Event) (*health.Status, interface{})
• type MultistreamReducer
  • func (t MultistreamReducer) Bindings() []event.BindingArgs
  • func (t MultistreamReducer) Conditions() []health.ConditionType
  • func (t MultistreamReducer) Reduce(current *health.Status, _ interface{}, evtIface data.Event) (*health.Status, interface{})
• type Pipeline
  • func (p Pipeline) Bindings() []event.BindingArgs
  • func (p Pipeline) Conditions() []health.ConditionType
  • func (p Pipeline) Reduce(current *health.Status, stateIface interface{}, evt data.Event) (*health.Status, interface{})
• type TranscodeReducer
  • func (t TranscodeReducer) Bindings() []event.BindingArgs
  • func (t TranscodeReducer) Conditions() []health.ConditionType
  • func (t TranscodeReducer) Reduce(current *health.Status, _ interface{}, evtIface data.Event) (*health.Status, interface{})

Constants

const (
	MetricViewerCount                health.MetricName = "ViewerCount"
	MetricMediaTimeMillis            health.MetricName = "MediaTimeMillis"
	MetricMultistreamMediaTimeMillis health.MetricName = "MultistreamMediaTimeMillis"
	MetricMultistreamActiveSec       health.MetricName = "MultistreamActiveSec"
	MetricMultistreamBytes           health.MetricName = "MultistreamBytes"
	MetricMultistreamBitrateSec      health.MetricName = "MultistreamBitrateSec"
)

const (
	ConditionTranscoding       health.ConditionType = "Transcoding"
	ConditionTranscodeRealTime health.ConditionType = "TranscodeRealTime"
	ConditionTranscodeNoErrors health.ConditionType = "TranscodeNoErrors"

	MetricTranscodeRealtimeRatio health.MetricName = "TranscodeRealtimeRatio"
)

const (
	ConditionMultistreaming health.ConditionType = "Multistreaming"
)

Variables

var HealthReducer = health.ReducerFunc(reduceHealth)

Functions

func Default

func Default(golpExchange string, shardPrefixes []string) health.Reducer

func DefaultStarTimeOffset

func DefaultStarTimeOffset() time.Duration

func StatsReducer

func StatsReducer(statsWindows []time.Duration) health.ReducerFunc

Types

type MediaServerMetrics

type MediaServerMetrics struct{}

func (MediaServerMetrics) Bindings

func (t MediaServerMetrics) Bindings() []event.BindingArgs

func (MediaServerMetrics) Conditions

func (t MediaServerMetrics) Conditions() []health.ConditionType

func (MediaServerMetrics) Reduce

func (t MediaServerMetrics) Reduce(current *health.Status, _ interface{}, evtIface data.Event) (*health.Status, interface{})

type MultistreamReducer

type MultistreamReducer struct{}

func (MultistreamReducer) Bindings

func (t MultistreamReducer) Bindings() []event.BindingArgs

func (MultistreamReducer) Conditions

func (t MultistreamReducer) Conditions() []health.ConditionType

func (MultistreamReducer) Reduce

func (t MultistreamReducer) Reduce(current *health.Status, _ interface{}, evtIface data.Event) (*health.Status, interface{})

type Pipeline

type Pipeline []health.Reducer

func (Pipeline) Bindings

func (p Pipeline) Bindings() []event.BindingArgs

func (Pipeline) Conditions

func (p Pipeline) Conditions() []health.ConditionType

func (Pipeline) Reduce

func (p Pipeline) Reduce(current *health.Status, stateIface interface{}, evt data.Event) (*health.Status, interface{})

type TranscodeReducer

type TranscodeReducer struct {
	GolpExchange  string
	ShardPrefixes []string
}

func (TranscodeReducer) Bindings

func (t TranscodeReducer) Bindings() []event.BindingArgs

func (TranscodeReducer) Conditions

func (t TranscodeReducer) Conditions() []health.ConditionType

func (TranscodeReducer) Reduce

func (t TranscodeReducer) Reduce(current *health.Status, _ interface{}, evtIface data.Event) (*health.Status, interface{})