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 Record struct {
	ID         string
	Conditions []ConditionType

	PastEvents []data.Event

	ReducersState map[int]interface{}
	LastStatus    Status
}

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

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

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

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

type StreamingOptions struct {
	Stream, ConsumerName string

	event.RawStreamOptions
}