metrics

Documentation

Index

• type Collector
  • func NewCollector() *Collector
  • func (c *Collector) Collect(ch chan<- prometheus.Metric)
  • func (c *Collector) Describe(ch chan<- *prometheus.Desc)
  • func (c *Collector) RecordDeliveryPerSubscription(subscriptionName, subscriptionNamespace, eventType, consumerName, sink string, ...)
  • func (c *Collector) RecordEventTypes(subscriptionName, subscriptionNamespace, eventType, consumer string)
  • func (c *Collector) RecordLatencyPerSubscription(duration time.Duration, ...)
  • func (c *Collector) RecordSubscriptionStatus(isActive bool, ...)
  • func (c *Collector) RegisterMetrics()
  • func (c *Collector) RemoveSubscriptionStatus(...)
  • func (c *Collector) ResetSubscriptionStatus()

Types

type Collector

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

Collector implements the prometheus.Collector interface.

func NewCollector

func NewCollector() *Collector

NewCollector a new instance of Collector.

func (*Collector) Collect

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

Collect implements the prometheus.Collector interface Collect method.

func (*Collector) Describe

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

Describe implements the prometheus.Collector interface Describe method.

func (*Collector) RecordDeliveryPerSubscription

func (c *Collector) RecordDeliveryPerSubscription(subscriptionName, subscriptionNamespace, eventType, consumerName, sink string, statusCode int)

RecordDeliveryPerSubscription records an eventing_ec_nats_delivery_per_subscription_total metric.

func (*Collector) RecordEventTypes

func (c *Collector) RecordEventTypes(subscriptionName, subscriptionNamespace, eventType, consumer string)

RecordEventTypes records a eventing_ec_event_type_subscribed_total metric.

func (*Collector) RecordLatencyPerSubscription

func (c *Collector) RecordLatencyPerSubscription(
	duration time.Duration,
	subscriptionName, subscriptionNamespace, eventType, consumerName, sink string,
	statusCode int,
)

RecordLatencyPerSubscription records an eventing_ec_nats_subscriber_dispatch_duration_seconds.

func (*Collector) RecordSubscriptionStatus

func (c *Collector) RecordSubscriptionStatus(isActive bool, subscriptionName,
	subscriptionNamespace, backendType, consumer, streamName string,
)

RecordSubscriptionStatus records an eventing_ec_subscription_status metric.

func (*Collector) RegisterMetrics

func (c *Collector) RegisterMetrics()

RegisterMetrics registers the metrics.

func (*Collector) RemoveSubscriptionStatus

func (c *Collector) RemoveSubscriptionStatus(subscriptionName, subscriptionNamespace,
	backendType, consumer, streamName string,
)

RemoveSubscriptionStatus removes an eventing_ec_subscription_status metric.

func (*Collector) ResetSubscriptionStatus

func (c *Collector) ResetSubscriptionStatus()