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 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 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"
	ConditionTranscodeRealTime health.ConditionType = "TranscodeRealTime"
	ConditionTranscodeNoErrors health.ConditionType = "TranscodeNoErrors"
)

const (
	ConditionMultistreaming health.ConditionType = "Multistreaming"
)

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