Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

collectors

package

Go to main page

Versions in this module

v1

v1.5.0

Jan 11, 2019

Changes in this version

+ type Builder struct

+ func NewBuilder(ctx context.Context) *Builder

+ func (b *Builder) Build() []*Collector

+ func (b *Builder) WithEnabledCollectors(c []string)

+ func (b *Builder) WithKubeClient(c clientset.Interface)

+ func (b *Builder) WithNamespaces(n options.NamespaceList)

+ func (b *Builder) WithWhiteBlackList(l whiteBlackLister)

+ type Collector struct

+ Store Store

+ func NewCollector(s Store) *Collector

+ func (c *Collector) Collect(w io.Writer)

+ type Store interface

+ WriteAll func(io.Writer)

v1.5.0-beta.0

Dec 11, 2018

v1.5.0-alpha.0

Nov 30, 2018

v1.4.0

Aug 23, 2018

Changes in this version

+ var AvailableCollectors = map[string]func(registry prometheus.Registerer, kubeClient kubernetes.Interface, ...)

+ var ResourcesPerScrapeMetric = prometheus.NewSummaryVec(prometheus.SummaryOpts{ ... }, []string{ ... })

+ var ScrapeErrorTotalMetric = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ func DaemonSetLabelsDesc(labelKeys []string) *prometheus.Desc

+ func RegisterConfigMapCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, ...)

+ func RegisterCronJobCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, ...)

+ func RegisterDaemonSetCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, ...)

+ func RegisterDeploymentCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, ...)

+ func RegisterEndpointCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, ...)

+ func RegisterHorizontalPodAutoScalerCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, ...)

+ func RegisterJobCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, ...)

+ func RegisterLimitRangeCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, ...)

+ func RegisterNamespaceCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, ...)

+ func RegisterNodeCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, ...)

+ func RegisterPersistentVolumeClaimCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, ...)

+ func RegisterPersistentVolumeCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, ...)

+ func RegisterPodCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, ...)

+ func RegisterReplicaSetCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, ...)

+ func RegisterReplicationControllerCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, ...)

+ func RegisterResourceQuotaCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, ...)

+ func RegisterSecretCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, ...)

+ func RegisterServiceCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, ...)

+ func RegisterStatefulSetCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, ...)

+ type ConfigMapLister func() ([]v1.ConfigMap, error)

+ func (l ConfigMapLister) List() ([]v1.ConfigMap, error)

+ type CronJobLister func() ([]batchv1beta1.CronJob, error)

+ func (l CronJobLister) List() ([]batchv1beta1.CronJob, error)

+ type DaemonSetLister func() ([]v1beta1.DaemonSet, error)

+ func (l DaemonSetLister) List() ([]v1beta1.DaemonSet, error)

+ type DeploymentLister func() ([]v1beta1.Deployment, error)

+ func (l DeploymentLister) List() ([]v1beta1.Deployment, error)

+ type EndpointLister func() ([]v1.Endpoints, error)

+ func (l EndpointLister) List() ([]v1.Endpoints, error)

+ type HPALister func() (autoscaling.HorizontalPodAutoscalerList, error)

+ func (l HPALister) List() (autoscaling.HorizontalPodAutoscalerList, error)

+ type JobLister func() ([]v1batch.Job, error)

+ func (l JobLister) List() ([]v1batch.Job, error)

+ type LimitRangeLister func() (v1.LimitRangeList, error)

+ func (l LimitRangeLister) List() (v1.LimitRangeList, error)

+ type NamespaceLister func() ([]v1.Namespace, error)

+ func (l NamespaceLister) List() ([]v1.Namespace, error)

+ type NodeLister func() (v1.NodeList, error)

+ func (l NodeLister) List() (v1.NodeList, error)

+ type PersistentVolumeClaimLister func() (v1.PersistentVolumeClaimList, error)

+ func (l PersistentVolumeClaimLister) List() (v1.PersistentVolumeClaimList, error)

+ type PersistentVolumeLister func() (v1.PersistentVolumeList, error)

+ func (pvl PersistentVolumeLister) List() (v1.PersistentVolumeList, error)

+ type PodLister func() ([]v1.Pod, error)

+ func (l PodLister) List() ([]v1.Pod, error)

+ type ReplicaSetLister func() ([]v1beta1.ReplicaSet, error)

+ func (l ReplicaSetLister) List() ([]v1beta1.ReplicaSet, error)

+ type ReplicationControllerLister func() ([]v1.ReplicationController, error)

+ func (l ReplicationControllerLister) List() ([]v1.ReplicationController, error)

+ type ResourceQuotaLister func() (v1.ResourceQuotaList, error)

+ func (l ResourceQuotaLister) List() (v1.ResourceQuotaList, error)

+ type SecretLister func() ([]v1.Secret, error)

+ func (l SecretLister) List() ([]v1.Secret, error)

+ type ServiceLister func() ([]v1.Service, error)

+ func (l ServiceLister) List() ([]v1.Service, error)

+ type SharedInformerList []cache.SharedInformer

+ func NewSharedInformerList(client rest.Interface, resource string, namespaces []string, ...) *SharedInformerList

+ func (sil SharedInformerList) Run(stopCh <-chan struct{})

+ type StatefulSetLister func() ([]v1beta1.StatefulSet, error)

+ func (l StatefulSetLister) List() ([]v1beta1.StatefulSet, error)

v1.4.0-rc.0

Aug 9, 2018