watermillext

README

Watermill Extension

watermill.io extensions and middleware

OpenTelemetryMiddleware

OpenTelemetry middlewre to track metrics and inject tracinf spans into message context.

Metrics tracked:

Metric	Type
watermill_kafka_subscriber_offset	counter
watermill_kafka_subscriber_lag_ms	histogram
watermill_kafka_publish_ms	histogram
watermill_processing_ms	histogram

KafkaDeadlineMiddleware

Middleware to ignore message from kafka older then duration specified.

Documentation

Index

• func KafkaDeadlineMiddleware(fromPublish time.Duration) func(message.HandlerFunc) message.HandlerFunc
• func OpenTelemetryMiddleware(h message.HandlerFunc) message.HandlerFunc

Functions

func KafkaDeadlineMiddleware

func KafkaDeadlineMiddleware(fromPublish time.Duration) func(message.HandlerFunc) message.HandlerFunc

KafkaDeadlineMiddleware short-circuits message processing without an error, if message was in kafka for longer, then duration provided

func OpenTelemetryMiddleware

func OpenTelemetryMiddleware(h message.HandlerFunc) message.HandlerFunc

OpenTelemetryMiddleware collects metrics and injects tracing data into context If trace propagation is configured will extract or inject tracing data into metadata for watermill to pass it on the wire, If metrics are enabled collects them