package collectors

import "github.com/goodrain/rainbond/gateway/metric/collectors"

Index ¶

• Variables
• type Controller
• func NewController() *Controller
• func (cm Controller) Collect(ch chan<- prometheus.Metric)
• func (cm Controller) Describe(ch chan<- *prometheus.Desc)
• func (cm *Controller) SetServerNum(httpNum, tcpNum int)
• type NginxCmdMetric
• func (n *NginxCmdMetric) Collect(ch chan<- prometheus.Metric)
• func (n *NginxCmdMetric) Describe(ch chan<- *prometheus.Desc)
• type SocketCollector
• func NewSocketCollector(gatewayHost string, metricsPerHost bool) (*SocketCollector, error)
• func (sc SocketCollector) Collect(ch chan<- prometheus.Metric)
• func (sc SocketCollector) Describe(ch chan<- *prometheus.Desc)
• func (sc *SocketCollector) RemoveMetrics(hosts []string, registry prometheus.Gatherer)
• func (sc *SocketCollector) SetHosts(hosts sets.String)
• func (sc *SocketCollector) Start()
• func (sc *SocketCollector) Stop()

Package Files ¶

controller.go gateway.go nginx_status.go socket_message.go

Variables ¶

var PrometheusNamespace = "gateway"

PrometheusNamespace default metric namespace

type Controller ¶ Uses

type Controller struct {
    prometheus.Collector
    // contains filtered or unexported fields
}

Controller defines base metrics about the rbd-gateway

func NewController ¶ Uses

func NewController() *Controller

NewController creates a new prometheus collector for the gateway controller operations

func (Controller) Collect ¶ Uses

func (cm Controller) Collect(ch chan<- prometheus.Metric)

Collect implements the prometheus.Collector interface.

func (Controller) Describe ¶ Uses

func (cm Controller) Describe(ch chan<- *prometheus.Desc)

Describe implements prometheus.Collector

func (*Controller) SetServerNum ¶ Uses

func (cm *Controller) SetServerNum(httpNum, tcpNum int)

SetServerNum sets the number of active domain

type NginxCmdMetric ¶ Uses

type NginxCmdMetric struct {
}

NginxCmdMetric -

func (*NginxCmdMetric) Collect ¶ Uses

func (n *NginxCmdMetric) Collect(ch chan<- prometheus.Metric)

Collect -

func (*NginxCmdMetric) Describe ¶ Uses

func (n *NginxCmdMetric) Describe(ch chan<- *prometheus.Desc)

Describe -

type SocketCollector ¶ Uses

type SocketCollector struct {
    prometheus.Collector
    // contains filtered or unexported fields
}

SocketCollector stores prometheus metrics and ingress meta-data

func NewSocketCollector ¶ Uses

func NewSocketCollector(gatewayHost string, metricsPerHost bool) (*SocketCollector, error)

NewSocketCollector creates a new SocketCollector instance using the ingress watch namespace and class used by the controller

func (SocketCollector) Collect ¶ Uses

func (sc SocketCollector) Collect(ch chan<- prometheus.Metric)

Collect implements the prometheus.Collector interface.

func (SocketCollector) Describe ¶ Uses

func (sc SocketCollector) Describe(ch chan<- *prometheus.Desc)

Describe implements prometheus.Collector

func (*SocketCollector) RemoveMetrics ¶ Uses

func (sc *SocketCollector) RemoveMetrics(hosts []string, registry prometheus.Gatherer)

RemoveMetrics deletes prometheus metrics from prometheus for hosts and host that are not available anymore. Ref: https://godoc.org/github.com/prometheus/client_golang/prometheus#CounterVec.Delete

func (*SocketCollector) SetHosts ¶ Uses

func (sc *SocketCollector) SetHosts(hosts sets.String)

SetHosts sets the hostnames that are being served by the ingress controller This set of hostnames is used to filter the metrics to be exposed

func (*SocketCollector) Start ¶ Uses

func (sc *SocketCollector) Start()

Start listen for connections in the unix socket and spawns a goroutine to process the content

func (*SocketCollector) Stop ¶ Uses

func (sc *SocketCollector) Stop()

Stop stops unix listener