metricscollector

package
v1.6.1 Latest Latest
Warning

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

Go to latest
Published: Mar 28, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InitMetricsCollectorSystem

func InitMetricsCollectorSystem(logger logrus.FieldLogger, currentNodeID string, ds *datastore.DataStore, kubeconfigPath string, proxyConnCounter util.Counter)

Types

type BackupCollector

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

func NewBackupCollector

func NewBackupCollector(
	logger logrus.FieldLogger,
	nodeID string,
	ds *datastore.DataStore) *BackupCollector

func (*BackupCollector) Collect

func (bc *BackupCollector) Collect(ch chan<- prometheus.Metric)

func (*BackupCollector) Describe

func (bc *BackupCollector) Describe(ch chan<- *prometheus.Desc)

type DiskCollector

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

func NewDiskCollector

func NewDiskCollector(
	logger logrus.FieldLogger,
	nodeID string,
	ds *datastore.DataStore) *DiskCollector

func (*DiskCollector) Collect

func (dc *DiskCollector) Collect(ch chan<- prometheus.Metric)

func (*DiskCollector) Describe

func (dc *DiskCollector) Describe(ch chan<- *prometheus.Desc)

type InstanceManagerCollector

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

func NewInstanceManagerCollector

func NewInstanceManagerCollector(
	logger logrus.FieldLogger,
	nodeID string,
	ds *datastore.DataStore,
	proxyConnCounter util.Counter,
	kubeMetricsClient *metricsclientset.Clientset,
	namespace string) *InstanceManagerCollector

func (*InstanceManagerCollector) Collect

func (imc *InstanceManagerCollector) Collect(ch chan<- prometheus.Metric)

func (*InstanceManagerCollector) Describe

func (imc *InstanceManagerCollector) Describe(ch chan<- *prometheus.Desc)

type ManagerCollector

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

func NewManagerCollector

func NewManagerCollector(
	logger logrus.FieldLogger,
	nodeID string,
	ds *datastore.DataStore,
	kubeMetricsClient *metricsclientset.Clientset,
	namespace string) *ManagerCollector

func (*ManagerCollector) Collect

func (mc *ManagerCollector) Collect(ch chan<- prometheus.Metric)

func (*ManagerCollector) Describe

func (mc *ManagerCollector) Describe(ch chan<- *prometheus.Desc)

type NodeCollector

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

func NewNodeCollector

func NewNodeCollector(
	logger logrus.FieldLogger,
	nodeID string,
	ds *datastore.DataStore,
	kubeMetricsClient *metricsclientset.Clientset) *NodeCollector

func (*NodeCollector) Collect

func (nc *NodeCollector) Collect(ch chan<- prometheus.Metric)

func (*NodeCollector) Describe

func (nc *NodeCollector) Describe(ch chan<- *prometheus.Desc)

type SnapshotCollector added in v1.5.4

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

func NewSnapshotCollector added in v1.5.4

func NewSnapshotCollector(
	logger logrus.FieldLogger,
	nodeID string,
	ds *datastore.DataStore) *SnapshotCollector

func (*SnapshotCollector) Collect added in v1.5.4

func (c *SnapshotCollector) Collect(ch chan<- prometheus.Metric)

func (*SnapshotCollector) Describe added in v1.5.4

func (c *SnapshotCollector) Describe(ch chan<- *prometheus.Desc)

type VolumeCollector

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

func NewVolumeCollector

func NewVolumeCollector(
	logger logrus.FieldLogger,
	nodeID string,
	ds *datastore.DataStore) *VolumeCollector

func (*VolumeCollector) Collect

func (vc *VolumeCollector) Collect(ch chan<- prometheus.Metric)

func (*VolumeCollector) Describe

func (vc *VolumeCollector) Describe(ch chan<- *prometheus.Desc)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL