reducers

package
v0.2.0-alpha Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 18, 2021 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ConditionMultistreamHealthy health.ConditionType = "MultistreamHealthy"

	ConditionSingleMultistreamConnected health.ConditionType = "Connected"
)
View Source
const (
	ConditionTranscoding health.ConditionType = "Transcoding"
	ConditionRealTime    health.ConditionType = "RealTime"
	ConditionNoErrors    health.ConditionType = "NoErrors"
)

Variables

View Source
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 added in v0.2.0

type MultistreamReducer struct{}

func (MultistreamReducer) Bindings added in v0.2.0

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

func (MultistreamReducer) Conditions added in v0.2.0

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

func (MultistreamReducer) Reduce added in v0.2.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL