client

Documentation

Index

• func NewDiscoverer(logger *logrus.Logger, kubernetes client.Kubernetes) client.Discoverer
• func NewDiscoveryCacher(discoverer client.Discoverer, storage storage.Storage, ttl time.Duration, ...) client.Discoverer
• func NewDistributedDiscoveryCacher(innerDiscoverer client.MultiDiscoverer, storage storage.Storage, ...) client.MultiDiscoverer
• func NewDistributedPodLabelDiscoverer(ksmPodLabel string, nodeIP string, logger *logrus.Logger, ...) client.MultiDiscoverer
• func NewPodLabelDiscoverer(ksmPodLabel string, ksmPodPort int, ksmScheme string, logger *logrus.Logger, ...) client.Discoverer
• func NewStaticEndpointDiscoverer(ksmEndpoint string, logger *logrus.Logger, kubernetes client.Kubernetes) client.Discoverer

Functions

func NewDiscoverer

func NewDiscoverer(logger *logrus.Logger, kubernetes client.Kubernetes) client.Discoverer

NewDiscoverer instantiates a new Discoverer required for discovering node IP of kube-state-metrics pod and endpoint of kube-state-metrics service

func NewDiscoveryCacher

func NewDiscoveryCacher(discoverer client.Discoverer, storage storage.Storage, ttl time.Duration, logger *logrus.Logger) client.Discoverer

NewDiscoveryCacher creates a new DiscoveryCacher that wraps a discoverer and caches the data into the specified storage

func NewDistributedDiscoveryCacher

func NewDistributedDiscoveryCacher(innerDiscoverer client.MultiDiscoverer, storage storage.Storage, ttl time.Duration, logger *logrus.Logger) client.MultiDiscoverer

NewDistributedDiscoveryCacher initializes a client.MultiDiscoveryCacher with the given parameters. This should be the only way to create instances of client.MultiDiscoveryCacher, as it guarantees the cached data pointer is initialized.

func NewDistributedPodLabelDiscoverer

func NewDistributedPodLabelDiscoverer(ksmPodLabel string, nodeIP string, logger *logrus.Logger, k8sClient client.Kubernetes) client.MultiDiscoverer

NewDistributedPodLabelDiscoverer creates a new KSM discoverer that will find KSM pods using k8s labels

func NewPodLabelDiscoverer

func NewPodLabelDiscoverer(ksmPodLabel string, ksmPodPort int, ksmScheme string, logger *logrus.Logger, k8sClient client.Kubernetes) client.Discoverer

NewPodLabelDiscoverer creates a new KSM discoverer that will find KSM pods using k8s labels

func NewStaticEndpointDiscoverer

func NewStaticEndpointDiscoverer(ksmEndpoint string, logger *logrus.Logger, kubernetes client.Kubernetes) client.Discoverer

NewStaticEndpointDiscoverer instantiates a new Discoverer required for discovering only node IP of kube-state-metrics pod