Versions in this module Expand all Collapse all v0 v0.6.12 Dec 12, 2023 Changes in this version + func CreateSpanFromMessage(cm *pulsar.ConsumerMessage, tracer opentracing.Tracer, label string) opentracing.Span + func ExtractSpanContextFromConsumerMessage(message pulsar.ConsumerMessage) opentracing.SpanContext + func ExtractSpanContextFromProducerMessage(message *pulsar.ProducerMessage) opentracing.SpanContext + func InjectConsumerMessageSpanContext(ctx context.Context, message pulsar.ConsumerMessage) + func InjectProducerMessageSpanContext(ctx context.Context, message *pulsar.ProducerMessage) + type ConsumerInterceptor struct + func (t *ConsumerInterceptor) BeforeConsume(message pulsar.ConsumerMessage) + func (t *ConsumerInterceptor) OnAcknowledge(consumer pulsar.Consumer, msgID pulsar.MessageID) + func (t *ConsumerInterceptor) OnNegativeAcksSend(consumer pulsar.Consumer, msgIDs []pulsar.MessageID) + type ConsumerMessageExtractAdapter struct + func (a *ConsumerMessageExtractAdapter) ForeachKey(handler func(key, val string) error) error + func (a *ConsumerMessageExtractAdapter) Set(key, val string) + type ConsumerMessageInjectAdapter struct + func (a *ConsumerMessageInjectAdapter) ForeachKey(handler func(key, val string) error) error + func (a *ConsumerMessageInjectAdapter) Set(key, val string) + type ProducerInterceptor struct + func (t *ProducerInterceptor) BeforeSend(producer pulsar.Producer, message *pulsar.ProducerMessage) + func (t *ProducerInterceptor) OnSendAcknowledgement(producer pulsar.Producer, message *pulsar.ProducerMessage, ...) + type ProducerMessageExtractAdapter struct + func (a *ProducerMessageExtractAdapter) ForeachKey(handler func(key, val string) error) error + func (a *ProducerMessageExtractAdapter) Set(key, val string) + type ProducerMessageInjectAdapter struct + func (a *ProducerMessageInjectAdapter) ForeachKey(handler func(key, val string) error) error + func (a *ProducerMessageInjectAdapter) Set(key, val string)
Go to main page