statemetrics

Documentation

Index

• type Kubernetes
• type KubernetesOpts
• type KubernetesVec
  • func NewKubernetesVec(opts KubernetesOpts, labelNames []string) *KubernetesVec
  • func (v *KubernetesVec) Collect(ch chan<- prometheus.Metric)
  • func (v *KubernetesVec) Delete(uid types.UID)
  • func (v *KubernetesVec) Describe(ch chan<- *prometheus.Desc)
  • func (v *KubernetesVec) WithLabelValues(uid types.UID, lvs ...string) Kubernetes
• type LabelsVec
  • func NewLabelsVec(opts KubernetesOpts) *LabelsVec
  • func (v *LabelsVec) Collect(ch chan<- prometheus.Metric)
  • func (v *LabelsVec) Delete(uid types.UID)
  • func (v *LabelsVec) Describe(chan<- *prometheus.Desc)
  • func (v *LabelsVec) With(uid types.UID, l prometheus.Labels) Kubernetes
• type StateMetricProxy
  • func NewStateMetricProxy(enqueuer handler.EventHandler, ...) *StateMetricProxy
  • func (s *StateMetricProxy) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (s *StateMetricProxy) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (s *StateMetricProxy) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (s *StateMetricProxy) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

Types

type Kubernetes

type Kubernetes interface {
	prometheus.Metric
	prometheus.Collector

	// Set sets the tracked number to an arbitrary value.
	Set(float64)
}

Kubernetes is a metric tracking a numerical value that can arbitrary go up and down.

type KubernetesOpts

type KubernetesOpts prometheus.Opts

KubernetesOpts is an alias for Opts.

type KubernetesVec

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

KubernetesVec is a Collector that bundles a set of Kubernetes metrics that all share the same Desc, but have different values for their variable labels. This is used if you want to count the same thing partitioned by various dimensions (e.g., namespaces, types). Create instances with NewKubernetesVec.

func NewKubernetesVec

func NewKubernetesVec(opts KubernetesOpts, labelNames []string) *KubernetesVec

NewKubernetesVec creates a new KubernetesVec based on the provided KubernetesOpts and partitioned by the given label names.

func (*KubernetesVec) Collect

func (v *KubernetesVec) Collect(ch chan<- prometheus.Metric)

Collect implements Collector.

func (*KubernetesVec) Delete

func (v *KubernetesVec) Delete(uid types.UID)

Delete deletes the metric stored for this uid.

func (*KubernetesVec) Describe

func (v *KubernetesVec) Describe(ch chan<- *prometheus.Desc)

Describe implements Collector.

func (*KubernetesVec) WithLabelValues

func (v *KubernetesVec) WithLabelValues(uid types.UID, lvs ...string) Kubernetes

WithLabelValues returns the Kubernetes metric for the given slice of label values (in the same order as the variable labels).

Consecutive calls for the same uid replace earlier metrics.

type LabelsVec

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

LabelsVec is a Collector that bundles a set of unchecked Kubernetes metrics that all share the same Desc, but have different labels. This is used if you want to count the same thing partitioned by unbounded dimensions (e.g., Kubernetes labels). Create instances with NewLabelsVec.

func NewLabelsVec

func NewLabelsVec(opts KubernetesOpts) *LabelsVec

NewLabelsVec creates a new LabelsVec based on the provided KubernetesOpts.

func (*LabelsVec) Collect

func (v *LabelsVec) Collect(ch chan<- prometheus.Metric)

Collect implements Collector.

func (*LabelsVec) Delete

func (v *LabelsVec) Delete(uid types.UID)

Delete deletes the metric stored for this uid.

func (*LabelsVec) Describe

func (v *LabelsVec) Describe(chan<- *prometheus.Desc)

Describe implements Collector. No Desc are sent on the channel to make this an unchecked collector.

func (*LabelsVec) With

func (v *LabelsVec) With(uid types.UID, l prometheus.Labels) Kubernetes

With returns the Kubernetes metric for the given Labels map.

Consecutive calls with the same uid replace earlier metrics.

type StateMetricProxy

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

StateMetricProxy updates state metrics by intercepting events as they are passed to event handlers.

func NewStateMetricProxy

func NewStateMetricProxy(enqueuer handler.EventHandler, info, created, resourceVersion, lbType, peerKey *KubernetesVec, labels *LabelsVec) *StateMetricProxy

NewStateMetricProxy returns a StateMetricsProxy. All metrics must be non-nil.

func (*StateMetricProxy) Create

func (s *StateMetricProxy) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

Create implements EventHandler.

func (*StateMetricProxy) Delete

func (s *StateMetricProxy) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

Delete implements EventHandler.

func (*StateMetricProxy) Generic

func (s *StateMetricProxy) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

Generic implements EventHandler.

func (*StateMetricProxy) Update

func (s *StateMetricProxy) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

Update implements EventHandler.