health

type Condition struct {
	Type               ConditionType  `json:"type,omitempty"`
	Status             *bool          `json:"status"`
	Frequency          stats.ByWindow `json:"frequency,omitempty"`
	LastProbeTime      *time.Time     `json:"lastProbeTime"`
	LastTransitionTime *time.Time     `json:"lastTransitionsTime"`
}

type ConditionType string

type Core struct {
	RecordStorage
	// contains filtered or unexported fields
}

type CoreOptions struct {
	Streaming       StreamingOptions
	StartTimeOffset time.Duration
}

type Event interface {
	ManifestID() string
	Timestamp() time.Time
}

type OrchestratorMetadata struct {
	Address       string `json:"address"`
	TranscoderUri string `json:"transcodeUri"`
}

type Record struct {
	ID         string
	Conditions []ConditionType

	PastEvents []Event

	ReducersState map[int]interface{}
	LastStatus    Status
}

type RecordStorage struct {
	// contains filtered or unexported fields
}

type Reducer interface {
	Bindings(golpExchange string) []event.BindingArgs
	Conditions() []ConditionType
	Reduce(current Status, state interface{}, evt Event) (Status, interface{})
}

type ReducerFunc func(Status, interface{}, Event) (Status, interface{})

type SegmentMetadata struct {
	Name     string  `json:"name"`
	SeqNo    uint64  `json:"seqNo"`
	Duration float64 `json:"duration"`
}

type Status struct {
	ID         string       `json:"id"`
	Healthy    Condition    `json:"healthy"`
	Conditions []*Condition `json:"conditions"`
}

type StreamingOptions struct {
	Stream, Exchange string
	ConsumerName     string

	event.RawStreamOptions
}

type TranscodeAttemptInfo struct {
	Orchestrator OrchestratorMetadata `json:"orchestrator"`
	LatencyMs    int64                `json:"latencyMs"`
	Error        *string              `json:"error"`
}

type TranscodeEvent struct {
	NodeID      string                 `json:"nodeId"`
	ManifestID_ string                 `json:"manifestId"`
	Segment     SegmentMetadata        `json:"segment"`
	StartTime   int64                  `json:"startTime"`
	LatencyMs   int64                  `json:"latencyMs"`
	Success     bool                   `json:"success"`
	Attempts    []TranscodeAttemptInfo `json:"attempts"`
}