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)
Click to show internal directories.
Click to hide internal directories.