Documentation
¶
Index ¶
- Constants
- type 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 ¶
View Source
const ( EtcdReplicaSizeInUseExceededReason string = "etcdReplicaSizeInUseExceeded" EtcdReplicaSizeExceededReason string = "etcdReplicaSizeExceeded" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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.
Source Files
Click to show internal directories.
Click to hide internal directories.