reducers

Documentation

Index

• Constants
• Variables
• func DefaultPipeline(golpExchange string, shardPrefixes []string) (reducers []health.Reducer, starTimeOffset time.Duration)
• func StatsReducer(statsWindows []time.Duration) health.ReducerFunc
• 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 (
	ConditionTranscoding health.ConditionType = "Transcoding"
	ConditionRealTime    health.ConditionType = "RealTime"
	ConditionNoErrors    health.ConditionType = "NoErrors"
)

Variables

var HealthReducer = health.ReducerFunc(reduceHealth)

Functions

func DefaultPipeline

func DefaultPipeline(golpExchange string, shardPrefixes []string) (reducers []health.Reducer, starTimeOffset time.Duration)

func StatsReducer

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

Types

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{})