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 ActiveConditionExtraData
  • func GetLastActiveData(status *data.HealthStatus) ActiveConditionExtraData
• type MediaServerMetrics
  • func (t MediaServerMetrics) Bindings() []event.BindingArgs
  • func (t MediaServerMetrics) Conditions() []data.ConditionType
  • func (t MediaServerMetrics) Reduce(current *data.HealthStatus, _ interface{}, evtIface data.Event) (*data.HealthStatus, interface{})
• type MultistreamReducer
  • func (t MultistreamReducer) Bindings() []event.BindingArgs
  • func (t MultistreamReducer) Conditions() []data.ConditionType
  • func (t MultistreamReducer) Reduce(current *data.HealthStatus, _ interface{}, evtIface data.Event) (*data.HealthStatus, interface{})
• type Pipeline
  • func (p Pipeline) Bindings() []event.BindingArgs
  • func (p Pipeline) Conditions() []data.ConditionType
  • func (p Pipeline) Reduce(current *data.HealthStatus, stateIface interface{}, evt data.Event) (*data.HealthStatus, interface{})
• type StreamStateReducer
  • func (t StreamStateReducer) Bindings() []event.BindingArgs
  • func (t StreamStateReducer) Conditions() []data.ConditionType
  • func (t StreamStateReducer) Reduce(current *data.HealthStatus, _ interface{}, evtIface data.Event) (*data.HealthStatus, interface{})
• type TranscodeReducer
  • func (t TranscodeReducer) Bindings() []event.BindingArgs
  • func (t TranscodeReducer) Conditions() []data.ConditionType
  • func (t TranscodeReducer) Reduce(current *data.HealthStatus, _ interface{}, evtIface data.Event) (*data.HealthStatus, interface{})

Constants

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

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

	MetricTranscodeRealtimeRatio data.MetricName = "TranscodeRealtimeRatio"
)

const (
	ConditionActive data.ConditionType = "Active"
)

const (
	ConditionMultistreaming data.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 ActiveConditionExtraData

type ActiveConditionExtraData struct {
	NodeID string `json:"nodeId"`
	Region string `json:"region"`
}

func GetLastActiveData

func GetLastActiveData(status *data.HealthStatus) ActiveConditionExtraData

type MediaServerMetrics

type MediaServerMetrics struct{}

func (MediaServerMetrics) Bindings

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

func (MediaServerMetrics) Conditions

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

func (MediaServerMetrics) Reduce

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

type MultistreamReducer

type MultistreamReducer struct{}

func (MultistreamReducer) Bindings

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

func (MultistreamReducer) Conditions

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

func (MultistreamReducer) Reduce

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

type Pipeline

type Pipeline []health.Reducer

func (Pipeline) Bindings

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

func (Pipeline) Conditions

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

func (Pipeline) Reduce

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

type StreamStateReducer

type StreamStateReducer struct{}

func (StreamStateReducer) Bindings

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

func (StreamStateReducer) Conditions

func (t StreamStateReducer) Conditions() []data.ConditionType

func (StreamStateReducer) Reduce

func (t StreamStateReducer) Reduce(current *data.HealthStatus, _ interface{}, evtIface data.Event) (*data.HealthStatus, 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() []data.ConditionType

func (TranscodeReducer) Reduce

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