metrics

Documentation

Index

• Constants
• func NewMetricsCollector(...) prometheus.Collector
• func ProcessMetricsData(metricsReader io.Reader) (map[string]*dto.MetricFamily, error)
• type FakeMetricsManager
  • func (*FakeMetricsManager) InitializeHTTPHandler()
  • func (*FakeMetricsManager) RegisterMetricsCollector(_, _, _, _ string)
  • func (*FakeMetricsManager) UnregisterMetricsCollector(_ string)
• type Manager
  • func NewMetricsManager(metricsEndpoint, fuseSocketDir string, clientset clientset.Interface) Manager

Constants

const (
	SocketName = "metrics.sock"
)

Functions

func NewMetricsCollector

func NewMetricsCollector(socketBasePath, emptyDirBasePath, namespace, podName, podUID, volumeName string, labels map[string]string, clientset clientset.Interface) prometheus.Collector

NewMetricsCollector returns a new Collector exposing metrics read from the give path.

func ProcessMetricsData

func ProcessMetricsData(metricsReader io.Reader) (map[string]*dto.MetricFamily, error)

ProcessMetricsData processes metrics that follow Prometheus text format: https://prometheus.io/docs/instrumenting/exposition_formats/, returning its MetricFamily.

Types

type FakeMetricsManager

type FakeMetricsManager struct{}

func (*FakeMetricsManager) InitializeHTTPHandler

func (*FakeMetricsManager) InitializeHTTPHandler()

func (*FakeMetricsManager) RegisterMetricsCollector

func (*FakeMetricsManager) RegisterMetricsCollector(_, _, _, _ string)

func (*FakeMetricsManager) UnregisterMetricsCollector

func (*FakeMetricsManager) UnregisterMetricsCollector(_ string)

type Manager

type Manager interface {
	InitializeHTTPHandler()
	RegisterMetricsCollector(targetPath, podNamespace, podName, bucketName string)
	UnregisterMetricsCollector(targetPath string)
}

func NewMetricsManager

func NewMetricsManager(metricsEndpoint, fuseSocketDir string, clientset clientset.Interface) Manager