metrics

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

type LabelComputeValueFn func(msgCtx context.Context) string

type MetricLabel struct {
	Label          string
	ComputeValueFn LabelComputeValueFn
}

type PrometheusMetricsBuilder struct {
	// PrometheusRegistry may be filled with a pre-existing Prometheus registry, or left empty for the default registry.
	PrometheusRegistry prometheus.Registerer

	Namespace string
	Subsystem string
	// PublishBuckets defines the histogram buckets for publish time histogram, defaulted if nil.
	PublishBuckets []float64
	// HandlerBuckets defines the histogram buckets for handle execution time histogram, defaulted to watermill's default.
	HandlerBuckets []float64
	// contains filtered or unexported fields
}

type PrometheusMetricsBuilderConfig struct {
	Namespace        string
	Subsystem        string
	AdditionalLabels []MetricLabel
}

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

type SubscriberPrometheusMetricsDecorator struct {
	message.Subscriber
	// contains filtered or unexported fields
}