monitoring

Documentation

Index

• func Handler() http.Handler
• func InitMonitoringSystem(logger logrus.FieldLogger, currentNodeID string, ds *datastore.DataStore, ...)
• func Register(collector prometheus.Collector) error
• 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 Handler

func Handler() http.Handler

Handler returns an http.Handler for longhornCustomRegistry, using default HandlerOpts

func InitMonitoringSystem

func InitMonitoringSystem(logger logrus.FieldLogger, currentNodeID string, ds *datastore.DataStore, kubeconfigPath string)

func Register

func Register(collector prometheus.Collector) error

Register registers the provided Collector with the longhornCustomRegistry

Types

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,
	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)