metrics

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, eventType, sink string, statusCode int)

RecordDeliveryPerSubscription records a 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, eventType, sink string,
	statusCode int)

RecordLatencyPerSubscription records a 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()