metricscollector

Documentation

Index

• func InitMetricsCollectorSystem(logger logrus.FieldLogger, currentNodeID string, ds *datastore.DataStore, ...)
• type BackupCollector
  • func NewBackupCollector(logger logrus.FieldLogger, nodeID string, ds *datastore.DataStore) *BackupCollector
  • func (vc *BackupCollector) Collect(ch chan<- prometheus.Metric)
  • func (vc *BackupCollector) Describe(ch chan<- *prometheus.Desc)
• type DiskCollector
  • func NewDiskCollector(logger logrus.FieldLogger, nodeID string, ds *datastore.DataStore) *DiskCollector
  • func (dc *DiskCollector) Collect(ch chan<- prometheus.Metric)
  • func (dc *DiskCollector) Describe(ch chan<- *prometheus.Desc)
• type InstanceManagerCollector
  • func NewInstanceManagerCollector(logger logrus.FieldLogger, nodeID string, ds *datastore.DataStore, ...) *InstanceManagerCollector
  • func (imc *InstanceManagerCollector) Collect(ch chan<- prometheus.Metric)
  • func (imc *InstanceManagerCollector) Describe(ch chan<- *prometheus.Desc)
• type ManagerCollector
  • func NewManagerCollector(logger logrus.FieldLogger, nodeID string, ds *datastore.DataStore, ...) *ManagerCollector
  • func (mc *ManagerCollector) Collect(ch chan<- prometheus.Metric)
  • func (mc *ManagerCollector) Describe(ch chan<- *prometheus.Desc)
• type NodeCollector
  • func NewNodeCollector(logger logrus.FieldLogger, nodeID string, ds *datastore.DataStore, ...) *NodeCollector
  • func (nc *NodeCollector) Collect(ch chan<- prometheus.Metric)
  • func (nc *NodeCollector) Describe(ch chan<- *prometheus.Desc)
• type VolumeCollector
  • func NewVolumeCollector(logger logrus.FieldLogger, nodeID string, ds *datastore.DataStore) *VolumeCollector
  • func (vc *VolumeCollector) Collect(ch chan<- prometheus.Metric)
  • func (vc *VolumeCollector) Describe(ch chan<- *prometheus.Desc)

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 (vc *BackupCollector) Collect(ch chan<- prometheus.Metric)

func (*BackupCollector) Describe

func (vc *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 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)