collectors

package
v1.3.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 9, 2018 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ScrapeErrorTotalMetric = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Name: "ksm_scrape_error_total",
			Help: "Total scrape errors encountered when scraping a resource",
		},
		[]string{"resource"},
	)

	ResourcesPerScrapeMetric = prometheus.NewSummaryVec(
		prometheus.SummaryOpts{
			Name: "ksm_resources_per_scrape",
			Help: "Number of resources returned per scrape",
		},
		[]string{"resource"},
	)
)
View Source 
var AvailableCollectors = map[string]func(registry prometheus.Registerer, kubeClient kubernetes.Interface, namespaces []string, opts *options.Options){
	"cronjobs":                 RegisterCronJobCollector,
	"daemonsets":               RegisterDaemonSetCollector,
	"deployments":              RegisterDeploymentCollector,
	"jobs":                     RegisterJobCollector,
	"limitranges":              RegisterLimitRangeCollector,
	"nodes":                    RegisterNodeCollector,
	"pods":                     RegisterPodCollector,
	"replicasets":              RegisterReplicaSetCollector,
	"replicationcontrollers":   RegisterReplicationControllerCollector,
	"resourcequotas":           RegisterResourceQuotaCollector,
	"services":                 RegisterServiceCollector,
	"statefulsets":             RegisterStatefulSetCollector,
	"persistentvolumes":        RegisterPersistentVolumeCollector,
	"persistentvolumeclaims":   RegisterPersistentVolumeClaimCollector,
	"namespaces":               RegisterNamespaceCollector,
	"horizontalpodautoscalers": RegisterHorizontalPodAutoScalerCollector,
	"endpoints":                RegisterEndpointCollector,
	"secrets":                  RegisterSecretCollector,
	"configmaps":               RegisterConfigMapCollector,
}

Functions

func DaemonSetLabelsDesc 

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

func RegisterConfigMapCollector 

func RegisterConfigMapCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, namespaces []string, opts *options.Options)

func RegisterCronJobCollector 

func RegisterCronJobCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, namespaces []string, opts *options.Options)

func RegisterDaemonSetCollector 

func RegisterDaemonSetCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, namespaces []string, opts *options.Options)

func RegisterDeploymentCollector 

func RegisterDeploymentCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, namespaces []string, opts *options.Options)

func RegisterEndpointCollector 

func RegisterEndpointCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, namespaces []string, opts *options.Options)

func RegisterHorizontalPodAutoScalerCollector 

func RegisterHorizontalPodAutoScalerCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, namespaces []string, opts *options.Options)

func RegisterJobCollector 

func RegisterJobCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, namespaces []string, opts *options.Options)

func RegisterLimitRangeCollector 

func RegisterLimitRangeCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, namespaces []string, opts *options.Options)

func RegisterNamespaceCollector 

func RegisterNamespaceCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, namespaces []string, opts *options.Options)

RegisterNamespaceCollector registry namespace collector

func RegisterNodeCollector 

func RegisterNodeCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, namespaces []string, opts *options.Options)

func RegisterPersistentVolumeClaimCollector 

func RegisterPersistentVolumeClaimCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, namespaces []string, opts *options.Options)

func RegisterPersistentVolumeCollector 

func RegisterPersistentVolumeCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, namespaces []string, opts *options.Options)

func RegisterPodCollector 

func RegisterPodCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, namespaces []string, opts *options.Options)

func RegisterReplicaSetCollector 

func RegisterReplicaSetCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, namespaces []string, opts *options.Options)

func RegisterReplicationControllerCollector 

func RegisterReplicationControllerCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, namespaces []string, opts *options.Options)

func RegisterResourceQuotaCollector 

func RegisterResourceQuotaCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, namespaces []string, opts *options.Options)

func RegisterSecretCollector 

func RegisterSecretCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, namespaces []string, opts *options.Options)

func RegisterServiceCollector 

func RegisterServiceCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, namespaces []string, opts *options.Options)

func RegisterStatefulSetCollector 

func RegisterStatefulSetCollector(registry prometheus.Registerer, kubeClient kubernetes.Interface, namespaces []string, opts *options.Options)

Types

type ConfigMapLister 

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

func (ConfigMapLister) List 

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

type CronJobLister 

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

func (CronJobLister) List 

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

type DaemonSetLister 

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

func (DaemonSetLister) List 

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

type DeploymentLister 

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

func (DeploymentLister) List 

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

type EndpointLister 

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

func (EndpointLister) List 

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

type HPALister 

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

func (HPALister) List 

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

type JobLister 

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

func (JobLister) List 

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

type LimitRangeLister 

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

func (LimitRangeLister) List 

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

type NamespaceLister 

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

NamespaceLister define NamespaceLister type

func (NamespaceLister) List 

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

List return namespace list

type NodeLister 

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

func (NodeLister) List 

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

type PersistentVolumeClaimLister 

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

func (PersistentVolumeClaimLister) List 

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

type PersistentVolumeLister 

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

func (PersistentVolumeLister) List 

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

type PodLister 

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

func (PodLister) List 

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

type ReplicaSetLister 

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

func (ReplicaSetLister) List 

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

type ReplicationControllerLister 

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

func (ReplicationControllerLister) List 

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

type ResourceQuotaLister 

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

func (ResourceQuotaLister) List 

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

type SecretLister 

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

func (SecretLister) List 

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

type ServiceLister 

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

func (ServiceLister) List 

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

type SharedInformerList 

type SharedInformerList []cache.SharedInformer

func NewSharedInformerList 

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

func (SharedInformerList) Run 

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

type StatefulSetLister 

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

func (StatefulSetLister) List 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.