otelcourier

Apr 26, 2024

Changes in this version

+ const MQTTClientID

+ func DefaultTopicAttributeTransformer(_ context.Context, topic string) string

+ type BucketBoundaries struct

+ Callback []float64

+ Publisher []float64

+ Subscriber []float64

+ Unsubscriber []float64

+ type OTel struct

+ func New(service string, opts ...Option) *OTel

+ func (t *OTel) ApplyMiddlewares(c UseMiddleware)

+ func (t *OTel) PublisherMiddleware(next courier.Publisher) courier.Publisher

+ func (t *OTel) SubscriberMiddleware(next courier.Subscriber) courier.Subscriber

+ func (t *OTel) UnsubscriberMiddleware(next courier.Unsubscriber) courier.Unsubscriber

type Option

+ func WithInfoHandlerFrom(c interface{ ... }) Option

+ func WithMeterProvider(provider metric.MeterProvider) Option

+ type TopicAttributeTransformer func(context.Context, string) string

+ type UseMiddleware interface

+ UsePublisherMiddleware func(mwf ...courier.PublisherMiddlewareFunc)

+ UseSubscriberMiddleware func(mwf ...courier.SubscriberMiddlewareFunc)

+ UseUnsubscriberMiddleware func(mwf ...courier.UnsubscriberMiddlewareFunc)

Nov 16, 2022

Changes in this version

type Option

+ func WithTextMapCarrierExtractFunc(fn func(context.Context) propagation.TextMapCarrier) Option

+ func WithTextMapPropagator(propagator propagation.TextMapPropagator) Option

type Tracer

+ func (t *Tracer) PublisherMiddleware(next courier.Publisher) courier.Publisher

+ func (t *Tracer) SubscriberMiddleware(next courier.Subscriber) courier.Subscriber

+ func (t *Tracer) UnsubscriberMiddleware(next courier.Unsubscriber) courier.Unsubscriber

Apr 12, 2022

Changes in this version

+ const MQTTQoS

+ const MQTTRetained

+ const MQTTTopic

+ const MQTTTopicWithQoS

+ func DisableCallbackTracing(opts *traceOptions)

+ func DisablePublisherTracing(opts *traceOptions)

+ func DisableSubscriberTracing(opts *traceOptions)

+ func DisableUnsubscriberTracing(opts *traceOptions)

+ type Option func(*traceOptions)

+ func WithTracerProvider(provider oteltrace.TracerProvider) Option

+ type Tracer struct

+ func NewTracer(service string, opts ...Option) *Tracer

+ func (t *Tracer) ApplyTraceMiddlewares(c *courier.Client)