collectors

package
v1.12.2 Latest Latest
Warning

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

 Go to latest Published: Oct 7, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ControllerCollector 

type ControllerCollector interface {
	SetIngresses(ingressType string, count int)
	SetVirtualServers(count int)
	SetVirtualServerRoutes(count int)
	Register(registry *prometheus.Registry) error
}

ControllerCollector is an interface for the metrics of the Controller

type ControllerFakeCollector 

type ControllerFakeCollector struct{}

ControllerFakeCollector is a fake collector that implements the ControllerCollector interface

func NewControllerFakeCollector 

func NewControllerFakeCollector() *ControllerFakeCollector

NewControllerFakeCollector creates a fake collector that implements the ControllerCollector interface

func (*ControllerFakeCollector) Register 

func (cc *ControllerFakeCollector) Register(registry *prometheus.Registry) error

Register implements a fake Register

func (*ControllerFakeCollector) SetIngresses added in v1.6.0 

func (cc *ControllerFakeCollector) SetIngresses(ingressType string, count int)

SetIngresses implements a fake SetIngresses

func (*ControllerFakeCollector) SetVirtualServerRoutes added in v1.6.0 

func (cc *ControllerFakeCollector) SetVirtualServerRoutes(count int)

SetVirtualServerRoutes implements a fake SetVirtualServerRoutes

func (*ControllerFakeCollector) SetVirtualServers added in v1.6.0 

func (cc *ControllerFakeCollector) SetVirtualServers(count int)

SetVirtualServers implements a fake SetVirtualServers

type ControllerMetricsCollector 

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

ControllerMetricsCollector implements the ControllerCollector interface and prometheus.Collector interface

func NewControllerMetricsCollector 

func NewControllerMetricsCollector(crdsEnabled bool, constLabels map[string]string) *ControllerMetricsCollector

NewControllerMetricsCollector creates a new ControllerMetricsCollector

func (*ControllerMetricsCollector) Collect 

func (cc *ControllerMetricsCollector) Collect(ch chan<- prometheus.Metric)

Collect implements the prometheus.Collector interface Collect method

func (*ControllerMetricsCollector) Describe 

func (cc *ControllerMetricsCollector) Describe(ch chan<- *prometheus.Desc)

Describe implements prometheus.Collector interface Describe method

func (*ControllerMetricsCollector) Register 

func (cc *ControllerMetricsCollector) Register(registry *prometheus.Registry) error

Register registers all the metrics of the collector

func (*ControllerMetricsCollector) SetIngresses added in v1.6.0 

func (cc *ControllerMetricsCollector) SetIngresses(ingressType string, count int)

SetIngresses sets the value of the ingress resources gauge for a given type

func (*ControllerMetricsCollector) SetVirtualServerRoutes added in v1.6.0 

func (cc *ControllerMetricsCollector) SetVirtualServerRoutes(count int)

SetVirtualServerRoutes sets the value of the VirtualServerRoute resources gauge

func (*ControllerMetricsCollector) SetVirtualServers added in v1.6.0 

func (cc *ControllerMetricsCollector) SetVirtualServers(count int)

SetVirtualServers sets the value of the VirtualServer resources gauge

type LatencyCollector added in v1.9.0 

type LatencyCollector interface {
	RecordLatency(string)
	UpdateUpstreamServerLabels(map[string][]string)
	DeleteUpstreamServerLabels([]string)
	UpdateUpstreamServerPeerLabels(map[string][]string)
	DeleteUpstreamServerPeerLabels([]string)
	DeleteMetrics([]string)
	Register(*prometheus.Registry) error
}

LatencyCollector is an interface for latency metrics

type LatencyFakeCollector added in v1.9.0 

type LatencyFakeCollector struct{}

LatencyFakeCollector is a fake collector that implements the LatencyCollector interface

func NewLatencyFakeCollector added in v1.9.0 

func NewLatencyFakeCollector() *LatencyFakeCollector

NewLatencyFakeCollector creates a fake collector that implements the LatencyCollector interface

func (*LatencyFakeCollector) DeleteMetrics added in v1.9.0 

func (l *LatencyFakeCollector) DeleteMetrics([]string)

DeleteMetrics implements a fake DeleteMetrics

func (*LatencyFakeCollector) DeleteUpstreamServerLabels added in v1.9.0 

func (l *LatencyFakeCollector) DeleteUpstreamServerLabels([]string)

DeleteUpstreamServerLabels implements a fake DeleteUpstreamServerLabels

func (*LatencyFakeCollector) DeleteUpstreamServerPeerLabels added in v1.9.0 

func (l *LatencyFakeCollector) DeleteUpstreamServerPeerLabels([]string)

DeleteUpstreamServerPeerLabels implements a fake DeleteUpstreamServerPeerLabels

func (*LatencyFakeCollector) RecordLatency added in v1.9.0 

func (l *LatencyFakeCollector) RecordLatency(_ string)

RecordLatency implements a fake RecordLatency

func (*LatencyFakeCollector) Register added in v1.9.0 

func (l *LatencyFakeCollector) Register(_ *prometheus.Registry) error

Register implements a fake Register

func (*LatencyFakeCollector) UpdateUpstreamServerLabels added in v1.9.0 

func (l *LatencyFakeCollector) UpdateUpstreamServerLabels(map[string][]string)

UpdateUpstreamServerLabels implements a fake UpdateUpstreamServerLabels

func (*LatencyFakeCollector) UpdateUpstreamServerPeerLabels added in v1.9.0 

func (l *LatencyFakeCollector) UpdateUpstreamServerPeerLabels(map[string][]string)

UpdateUpstreamServerPeerLabels implements a fake UpdateUpstreamServerPeerLabels

type LatencyMetricsCollector added in v1.9.0 

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

LatencyMetricsCollector implements the LatencyCollector interface and prometheus.Collector interface

func NewLatencyMetricsCollector added in v1.9.0 

func NewLatencyMetricsCollector(
	constLabels map[string]string,
	upstreamServerLabelNames []string,
	upstreamServerPeerLabelNames []string,
) *LatencyMetricsCollector

NewLatencyMetricsCollector creates a new LatencyMetricsCollector

func (*LatencyMetricsCollector) Collect added in v1.9.0 

func (l *LatencyMetricsCollector) Collect(ch chan<- prometheus.Metric)

Collect implements the prometheus.Collector interface Collect method

func (*LatencyMetricsCollector) DeleteMetrics added in v1.9.0 

func (l *LatencyMetricsCollector) DeleteMetrics(upstreamServerPeerNames []string)

DeleteMetrics deletes all metrics published associated with the given upstream server peer names.

func (*LatencyMetricsCollector) DeleteUpstreamServerLabels added in v1.9.0 

func (l *LatencyMetricsCollector) DeleteUpstreamServerLabels(upstreamNames []string)

DeleteUpstreamServerLabels deletes upstream server labels

func (*LatencyMetricsCollector) DeleteUpstreamServerPeerLabels added in v1.9.0 

func (l *LatencyMetricsCollector) DeleteUpstreamServerPeerLabels(peers []string)

DeleteUpstreamServerPeerLabels deletes the Upstream Server Peer Labels

func (*LatencyMetricsCollector) Describe added in v1.9.0 

func (l *LatencyMetricsCollector) Describe(ch chan<- *prometheus.Desc)

Describe implements prometheus.Collector interface Describe method

func (*LatencyMetricsCollector) RecordLatency added in v1.9.0 

func (l *LatencyMetricsCollector) RecordLatency(syslogMsg string)

RecordLatency parses a syslog message and records latency

func (*LatencyMetricsCollector) Register added in v1.9.0 

func (l *LatencyMetricsCollector) Register(registry *prometheus.Registry) error

Register registers all the metrics of the collector

func (*LatencyMetricsCollector) UpdateUpstreamServerLabels added in v1.9.0 

func (l *LatencyMetricsCollector) UpdateUpstreamServerLabels(newLabelValues map[string][]string)

UpdateUpstreamServerLabels updates the upstream server label map

func (*LatencyMetricsCollector) UpdateUpstreamServerPeerLabels added in v1.9.0 

func (l *LatencyMetricsCollector) UpdateUpstreamServerPeerLabels(upstreamServerPeerLabels map[string][]string)

UpdateUpstreamServerPeerLabels updates the Upstream Server Peer Labels

type LocalManagerMetricsCollector 

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

LocalManagerMetricsCollector implements NginxManagerCollector interface and prometheus.Collector interface

func NewLocalManagerMetricsCollector 

func NewLocalManagerMetricsCollector(constLabels map[string]string) *LocalManagerMetricsCollector

NewLocalManagerMetricsCollector creates a new LocalManagerMetricsCollector

func (*LocalManagerMetricsCollector) Collect 

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

Collect implements the prometheus.Collector interface Collect method

func (*LocalManagerMetricsCollector) Describe 

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

Describe implements prometheus.Collector interface Describe method

func (*LocalManagerMetricsCollector) IncNginxReloadCount 

func (nc *LocalManagerMetricsCollector) IncNginxReloadCount(isEndPointUpdate bool)

IncNginxReloadCount increments the counter of successful NGINX reloads and sets the last reload status to true

func (*LocalManagerMetricsCollector) IncNginxReloadErrors 

func (nc *LocalManagerMetricsCollector) IncNginxReloadErrors()

IncNginxReloadErrors increments the counter of NGINX reload errors and sets the last reload status to false

func (*LocalManagerMetricsCollector) Register 

func (nc *LocalManagerMetricsCollector) Register(registry *prometheus.Registry) error

Register registers all the metrics of the collector

func (*LocalManagerMetricsCollector) UpdateLastReloadTime 

func (nc *LocalManagerMetricsCollector) UpdateLastReloadTime(duration time.Duration)

UpdateLastReloadTime updates the last NGINX reload time

type ManagerCollector 

type ManagerCollector interface {
	IncNginxReloadCount(isEndPointUpdate bool)
	IncNginxReloadErrors()
	UpdateLastReloadTime(ms time.Duration)
	Register(registry *prometheus.Registry) error
}

ManagerCollector is an interface for the metrics of the Nginx Manager

type ManagerFakeCollector 

type ManagerFakeCollector struct{}

ManagerFakeCollector is a fake collector that will implement ManagerCollector interface

func NewManagerFakeCollector 

func NewManagerFakeCollector() *ManagerFakeCollector

NewManagerFakeCollector creates a fake collector that implements ManagerCollector interface

func (*ManagerFakeCollector) IncNginxReloadCount 

func (nc *ManagerFakeCollector) IncNginxReloadCount(isEndPointUpdate bool)

IncNginxReloadCount implements a fake IncNginxReloadCount

func (*ManagerFakeCollector) IncNginxReloadErrors 

func (nc *ManagerFakeCollector) IncNginxReloadErrors()

IncNginxReloadErrors implements a fake IncNginxReloadErrors

func (*ManagerFakeCollector) Register 

func (nc *ManagerFakeCollector) Register(registry *prometheus.Registry) error

Register implements a fake Register

func (*ManagerFakeCollector) UpdateLastReloadTime 

func (nc *ManagerFakeCollector) UpdateLastReloadTime(ms time.Duration)

UpdateLastReloadTime implements a fake UpdateLastReloadTime

type NginxProcessesMetricsCollector added in v1.9.0 

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

NginxProcessesMetricsCollector implements prometheus.Collector interface

func NewNginxProcessesMetricsCollector added in v1.9.0 

func NewNginxProcessesMetricsCollector(constLabels map[string]string) *NginxProcessesMetricsCollector

NewNginxProcessesMetricsCollector creates a new NginxProcessMetricsCollector

func (*NginxProcessesMetricsCollector) Collect added in v1.9.0 

func (pc *NginxProcessesMetricsCollector) Collect(ch chan<- prometheus.Metric)

Collect implements the prometheus.Collector interface Collect method

func (*NginxProcessesMetricsCollector) Describe added in v1.9.0 

func (pc *NginxProcessesMetricsCollector) Describe(ch chan<- *prometheus.Desc)

Describe implements prometheus.Collector interface Describe method

func (*NginxProcessesMetricsCollector) Register added in v1.9.0 

func (pc *NginxProcessesMetricsCollector) Register(registry *prometheus.Registry) error

Register registers all the metrics of the collector

type WorkQueueMetricsCollector added in v1.10.0 

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

WorkQueueMetricsCollector collects the metrics about the work queue, which the Ingress Controller uses to process changes to the resources in the cluster. implements the prometheus.Collector interface

func NewWorkQueueMetricsCollector added in v1.10.0 

func NewWorkQueueMetricsCollector(constLabels map[string]string) *WorkQueueMetricsCollector

NewWorkQueueMetricsCollector creates a new WorkQueueMetricsCollector

func (*WorkQueueMetricsCollector) Collect added in v1.10.0 

func (wqc *WorkQueueMetricsCollector) Collect(ch chan<- prometheus.Metric)

Collect implements the prometheus.Collector interface Collect method

func (*WorkQueueMetricsCollector) Describe added in v1.10.0 

func (wqc *WorkQueueMetricsCollector) Describe(ch chan<- *prometheus.Desc)

Describe implements the prometheus.Collector interface Describe method

func (*WorkQueueMetricsCollector) NewAddsMetric added in v1.10.0 

func (*WorkQueueMetricsCollector) NewAddsMetric(string) workqueue.CounterMetric

NewAddsMetric implements the workqueue.MetricsProvider interface NewAddsMetric method

func (*WorkQueueMetricsCollector) NewDepthMetric added in v1.10.0 

func (wqc *WorkQueueMetricsCollector) NewDepthMetric(name string) workqueue.GaugeMetric

NewDepthMetric implements the workqueue.MetricsProvider interface NewDepthMetric method

func (*WorkQueueMetricsCollector) NewLatencyMetric added in v1.10.0 

func (wqc *WorkQueueMetricsCollector) NewLatencyMetric(name string) workqueue.HistogramMetric

NewLatencyMetric implements the workqueue.MetricsProvider interface NewLatencyMetric method

func (*WorkQueueMetricsCollector) NewLongestRunningProcessorSecondsMetric added in v1.10.0 

func (*WorkQueueMetricsCollector) NewLongestRunningProcessorSecondsMetric(string) workqueue.SettableGaugeMetric

NewLongestRunningProcessorSecondsMetric implements the workqueue.MetricsProvider interface NewLongestRunningProcessorSecondsMetric method

func (*WorkQueueMetricsCollector) NewRetriesMetric added in v1.10.0 

func (*WorkQueueMetricsCollector) NewRetriesMetric(string) workqueue.CounterMetric

NewRetriesMetric implements the workqueue.MetricsProvider interface NewRetriesMetric method

func (*WorkQueueMetricsCollector) NewUnfinishedWorkSecondsMetric added in v1.10.0 

func (*WorkQueueMetricsCollector) NewUnfinishedWorkSecondsMetric(string) workqueue.SettableGaugeMetric

NewUnfinishedWorkSecondsMetric implements the workqueue.MetricsProvider interface NewUnfinishedWorkSecondsMetric method

func (*WorkQueueMetricsCollector) NewWorkDurationMetric added in v1.10.0 

func (wqc *WorkQueueMetricsCollector) NewWorkDurationMetric(name string) workqueue.HistogramMetric

NewWorkDurationMetric implements the workqueue.MetricsProvider interface NewWorkDurationMetric method

func (*WorkQueueMetricsCollector) Register added in v1.10.0 

func (wqc *WorkQueueMetricsCollector) Register(registry *prometheus.Registry) error

Register registers all the metrics of the collector

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.