interceptor

Documentation

Index

• Variables
• func PrometheusInterceptor(next broker.Handler) broker.Handler
• func SubscriberLoggerInterceptor(next broker.Handler) broker.Handler
• func SubscriberMetadataInterceptor(next broker.Handler) broker.Handler

Variables

var (
	InboundGauge = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Name:        "amqp_inbound",
		Help:        "Increased on incoming deliveries, decreased on ack/nack",
		ConstLabels: nil,
	}, []string{"routing_key"})
	TransportErrorCounter = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name:        "amqp_transport_error",
		Help:        "Increased when a message could not be decoded",
		ConstLabels: nil,
	}, []string{"routing_key"})
	NackCounter = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name: "amqp_not_acknowledged",
		Help: "Incremented on every NACK",
	}, []string{"routing_key", "requeue"})
)

Functions

func PrometheusInterceptor

func PrometheusInterceptor(next broker.Handler) broker.Handler

func SubscriberLoggerInterceptor

func SubscriberLoggerInterceptor(next broker.Handler) broker.Handler

func SubscriberMetadataInterceptor

func SubscriberMetadataInterceptor(next broker.Handler) broker.Handler