gke

Documentation

Overview

gke implements service discovery for GKE clusters with k8s services annotated for federation scraping.

Index

• type Factory
  • func NewSourceFactory(project, filename string) *Factory
  • func (f *Factory) Create() (discovery.Source, error)
• type Source
  • func (source *Source) Collect() error
  • func (source *Source) Save() error

Types

type Factory

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

Factory stores information needed to create new Source instances.

func NewSourceFactory

func NewSourceFactory(project, filename string) *Factory

NewSourceFactory returns a new Factory object that can create new GKE Sources.

func (*Factory) Create

func (f *Factory) Create() (discovery.Source, error)

Create returns a discovery.Source initialized with authenticated clients for Compute & Container APIs, ready for Collection.

type Source

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

Source caches information collected from the GCE, GKE, and K8S APIs during target discovery.

func (*Source) Collect

func (source *Source) Collect() error

Collect uses the Compute Engine, Container Engine, and Kubernetes APIs to check every GCE zone for Container Engine (gke) clusters, and checks each cluster for services annotated for federated scraping.

Collect returns every gke cluster with a k8s service annotation that equals:

gke-prometheus-federation/scrape: true

func (*Source) Save

func (source *Source) Save() error

Saves collected targets to the given filename.