healthandmetrics

type HealthCheckFailedObserver func(HealthCheckObject, error)

type HealthCheckObject interface {
	HealthCheckAddress() string
}

type HealthCheckProcessor interface {
	Check(HealthCheckObject) error
}

type HealthCheckSuccessObserver func(HealthCheckObject)

type HealthChecker interface {
	AddHealthCheckObject(HealthCheckObject) error
	RemoveHealthCheckObject(HealthCheckObject) error
	AddSuccessObserver(HealthCheckSuccessObserver)
	AddFailedObserver(HealthCheckFailedObserver)
	Start() error
}

type MetricsConsumer interface {
	AddMetricsObservable(MetricsObservable) error
	RemoveMetricsObservable(MetricsObservable) error
	AddObserver(MetricsObserver)
	Start() error
}

type MetricsObservable interface {
	MetricsAddress() string
}

type MetricsObserver func(MetricsObservable, *MetricsRead)

type MetricsRead struct {
	ActiveConnections int

	DelayMean         int
	DelayMedian       int
	Delay95Percentile int
	Delay99Percentile int
	DelayMax          int

	Raw []dto.MetricFamily
}

type MetricsReader interface {
	Read(MetricsObservable) (*MetricsRead, error)
}

type Server interface {
	ListenAndServe() error
	Shutdown(ctx context.Context) error
	Port() string
}