health

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

type CoreOptions struct {
	StreamUri, AMQPUri string
	Streaming          StreamingOptions
	StartTimeOffset    time.Duration
	MemoryRecordsTtl   time.Duration
}

type Record struct {
	ID         string
	Conditions []data.ConditionType

	sync.RWMutex

	PastEvents []data.Event
	EventsByID map[uuid.UUID]data.Event
	EventSubs  []chan<- data.Event

	ReducerState interface{}
	LastStatus   *data.HealthStatus
	// contains filtered or unexported fields
}

type RecordStorage struct {
	SizeGauge prometheus.Gauge
	// contains filtered or unexported fields
}

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

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

type StreamingOptions struct {
	Stream, ConsumerName string

	event.RawStreamOptions

	// EventFlowSilenceTolerance determines the amount of time to tolerate zero
	// messages in the stream before giving an error on the service healthcheck.
	// This is a workaround for a bug in the rabbitmq streams client in which it
	// freezes when the stream has leader election issues in a clustered setup.
	EventFlowSilenceTolerance time.Duration
}