collectors

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: Mar 25, 2020 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

View Source
const AggregateNodeID = "aggregate"
View Source
const MetricNamePrefix = "nifi_"

Variables

This section is empty.

Functions

This section is empty.

Types

type ConnectionsCollector

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

ConnectionsCollector holds the metrics for each connection

func NewConnectionsCollector

func NewConnectionsCollector(api *client.Client, labels map[string]string) *ConnectionsCollector

NewConnectionsCollector initialises a collector

func (*ConnectionsCollector) Collect

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

Collect retrieves the data that for the metrics

func (*ConnectionsCollector) Describe

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

Describe makes the metrics descriptions available to Prometheus

type CountersCollector

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

func NewCountersCollector

func NewCountersCollector(api *client.Client, labels map[string]string) *CountersCollector

func (*CountersCollector) Collect

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

func (*CountersCollector) Describe

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

type DiagnosticsCollector

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

func NewDiagnosticsCollector

func NewDiagnosticsCollector(api *client.Client, labels map[string]string) *DiagnosticsCollector

func (*DiagnosticsCollector) Collect

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

func (*DiagnosticsCollector) Describe

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

type ProcessGroupsCollector

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

func NewProcessGroupsCollector

func NewProcessGroupsCollector(api *client.Client, labels map[string]string) *ProcessGroupsCollector

func (*ProcessGroupsCollector) Collect

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

func (*ProcessGroupsCollector) Describe

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

Jump to

Keyboard shortcuts

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