etcdhealth

Documentation

Index

• Constants
• type EtcdReplicaHealthMonitor
  • func NewEtcdReplicaHealthMonitor(name string, fractionOfStorageInUseLimit float64, ...) *EtcdReplicaHealthMonitor
  • func (srv *EtcdReplicaHealthMonitor) BlockUntilNextMetricsCollection(ctx *armadacontext.Context)
  • func (srv *EtcdReplicaHealthMonitor) Collect(c chan<- prometheus.Metric)
  • func (srv *EtcdReplicaHealthMonitor) Describe(c chan<- *prometheus.Desc)
  • func (srv *EtcdReplicaHealthMonitor) IsHealthy() (bool, string, error)
  • func (srv *EtcdReplicaHealthMonitor) Run(ctx *armadacontext.Context, log *logrus.Entry) error
  • func (srv *EtcdReplicaHealthMonitor) WithMetricsPrefix(v string) *EtcdReplicaHealthMonitor

Constants

const (
	EtcdReplicaSizeInUseExceededReason string = "etcdReplicaSizeInUseExceeded"
	EtcdReplicaSizeExceededReason      string = "etcdReplicaSizeExceeded"
)

Types

type EtcdReplicaHealthMonitor

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

EtcdReplicaHealthMonitor is a health monitor for monitoring the health of an individual etcd replica.

func NewEtcdReplicaHealthMonitor

func NewEtcdReplicaHealthMonitor(
	name string,
	fractionOfStorageInUseLimit float64,
	fractionOfStorageLimit float64,
	replicaTimeout time.Duration,
	scrapeInterval time.Duration,
	metricsCollectionDelayBucketsStart float64,
	metricsCollectionDelayBucketsFactor float64,
	metricsCollectionDelayBucketsCount int,
	metricsProvider metrics.MetricsProvider,
) *EtcdReplicaHealthMonitor

func (*EtcdReplicaHealthMonitor) BlockUntilNextMetricsCollection

func (srv *EtcdReplicaHealthMonitor) BlockUntilNextMetricsCollection(ctx *armadacontext.Context)

BlockUntilNextMetricsCollection blocks until the next metrics collection has completed, or until ctx is cancelled, whichever occurs first.

func (*EtcdReplicaHealthMonitor) Collect

func (srv *EtcdReplicaHealthMonitor) Collect(c chan<- prometheus.Metric)

func (*EtcdReplicaHealthMonitor) Describe

func (srv *EtcdReplicaHealthMonitor) Describe(c chan<- *prometheus.Desc)

func (*EtcdReplicaHealthMonitor) IsHealthy

func (srv *EtcdReplicaHealthMonitor) IsHealthy() (bool, string, error)

func (*EtcdReplicaHealthMonitor) Run

func (srv *EtcdReplicaHealthMonitor) Run(ctx *armadacontext.Context, log *logrus.Entry) error

func (*EtcdReplicaHealthMonitor) WithMetricsPrefix

func (srv *EtcdReplicaHealthMonitor) WithMetricsPrefix(v string) *EtcdReplicaHealthMonitor

WithMetricsPrefix adds a prefix to exported Prometheus metrics. Must be called before Describe or Collect.