go-queue
go-queue copied to clipboard
feat: kq commitinorder support trace
Greptile Summary
Added OpenTelemetry tracing support to Kafka queue implementation, enabling distributed tracing across message processing with standardized context propagation.
- Added
kq/internal/trace.goimplementingMessageCarrierinterface for OpenTelemetry context handling - Added trace context injection in
PushWithKeymethod using OpenTelemetry propagator - Added trace context extraction in
extractCtxFromMsgfunction for consistent tracing - Enhanced error handling with context-aware logging in
consumeOnemethod - Updated dependencies in
go.modto support OpenTelemetry integration
💡 (1/5) You can manually trigger the bot by mentioning @greptileai in a comment!