pkg

Documentation

Index

• Constants
• Variables
• type Config
• type Handler
  • func (h *Handler) GetNamespaces() (ns []string, err error)
  • func (h *Handler) SetupCollector(mu *sync.RWMutex) (err error)
  • func (h *Handler) UpdateNamespaces(namespaces []string)
• type KubeMetricsCollector
  • func NewKubeMetricsCollector(logger *zap.Logger, clientset *versioned.Clientset, mu *sync.RWMutex) *KubeMetricsCollector
  • func (c *KubeMetricsCollector) Collect(metrics chan<- prometheus.Metric)
  • func (c *KubeMetricsCollector) Describe(descs chan<- *prometheus.Desc)
  • func (c *KubeMetricsCollector) UpdateNamespaces(namespaces []string)

Constants

const (
	LabelNamespace = "namespace"
	LabelPod       = "pod"
	LabelContainer = "container"
)

Variables

var (
	CommonLabels = []string{LabelNamespace, LabelPod, LabelContainer}
	DescCpuUsage = prometheus.NewDesc("container_cpu_usage_cores", "CPU cores used", CommonLabels, nil)
	DescMemUsage = prometheus.NewDesc("container_memory_usage_bytes", "memory used", CommonLabels, nil)
)

Types

type Config

type Config struct {
	Namespace        string   `default:"default" usage:"the namespace of the pods to collect"`
	IgnoreNamespaces []string `default:"kube-system" usage:"when 'namespace' is empty, this lists namespaces to ignore"`
	HttpBinding      string   `usage:"binding of http listener for metrics export" default:":8080"`
	MetricsPath      string   `usage:"http path for metrics export" default:"/metrics"`
	Debug            bool     `usage:"enable debug logging"`
}

configuration for the exporter

type Handler

type Handler struct {
	ExporterConfig Config
	Logger         *zap.Logger
	ClientSet      *versioned.Clientset
	KubeConfig     *rest.Config
	// contains filtered or unexported fields
}

func (*Handler) GetNamespaces

func (h *Handler) GetNamespaces() (ns []string, err error)

func (*Handler) SetupCollector

func (h *Handler) SetupCollector(mu *sync.RWMutex) (err error)

func (*Handler) UpdateNamespaces

func (h *Handler) UpdateNamespaces(namespaces []string)

type KubeMetricsCollector

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

func NewKubeMetricsCollector

func NewKubeMetricsCollector(logger *zap.Logger, clientset *versioned.Clientset, mu *sync.RWMutex) *KubeMetricsCollector

func (*KubeMetricsCollector) Collect

func (c *KubeMetricsCollector) Collect(metrics chan<- prometheus.Metric)

func (*KubeMetricsCollector) Describe

func (c *KubeMetricsCollector) Describe(descs chan<- *prometheus.Desc)

func (*KubeMetricsCollector) UpdateNamespaces

func (c *KubeMetricsCollector) UpdateNamespaces(namespaces []string)