kube

Documentation

Index

• Variables
• func ResourceMapping(kubeLabelNames, kubeAnnotationsNames []string, maxRevisions int) collector.Mapping
• func ResourceToSample(resource *unstructured.Unstructured) collector.Sample
• type InformerController
  • func NewResourcesInformer(config *rest.Config, namespaces []string, ...) (*InformerController, error)
  • func (c *InformerController) Run(ctx context.Context, errorCh chan<- error)

Variables

var (
	ExporterMetricName = "kube_annotations_exporter"
)

Functions

func ResourceMapping

func ResourceMapping(kubeLabelNames, kubeAnnotationsNames []string, maxRevisions int) collector.Mapping

ResourceMapping creates the mapping for the prometheus metrics vault. The order of the labels here should match the one from the sample converter function.

func ResourceToSample

func ResourceToSample(resource *unstructured.Unstructured) collector.Sample

ResourceToSample converts Kubernetes unstructured.Unstructured to the prometheus metric sample.

Types

type InformerController

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

InformerController handles Kubernetes events for resourcess. The is the shim between metrics storage and Kubernetes cluster.

func NewResourcesInformer

func NewResourcesInformer(config *rest.Config, namespaces []string, resources []schema.GroupVersionResource, metricCollector *collector.MetricsVault) (*InformerController, error)

NewResourcesInformer creates cached informer to track resources from a Kubernetes cluster.

func (*InformerController) Run

func (c *InformerController) Run(ctx context.Context, errorCh chan<- error)

Run starts the informers for different resources with various handlers and waits for the first cache synchronization.