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 ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.