Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from https://pkg.go.dev/github.com/dnwe/otelsarama below:

otelsarama package - github.com/dnwe/otelsarama - Go Packages

Package otelsarama instruments the github.com/IBM/sarama package.

The consumer's span will be created as a child of the producer's span.

Context propagation only works on Kafka versions higher than 0.11.0.0 which supports record headers. (https://archive.apache.org/dist/kafka/0.11.0.0/RELEASE_NOTES.html)

Based on: https://github.com/DataDog/dd-trace-go/tree/main/contrib/IBM/sarama.v1

• func SemVersion() stringdeprecated
• func Version() string
• func WrapAsyncProducer(saramaConfig *sarama.Config, p sarama.AsyncProducer, opts ...Option) sarama.AsyncProducer
• func WrapConsumer(c sarama.Consumer, opts ...Option) sarama.Consumer
• func WrapConsumerGroupHandler(handler sarama.ConsumerGroupHandler, opts ...Option) sarama.ConsumerGroupHandler
• func WrapPartitionConsumer(pc sarama.PartitionConsumer, opts ...Option) sarama.PartitionConsumer
• func WrapSyncProducer(saramaConfig *sarama.Config, producer sarama.SyncProducer, opts ...Option) sarama.SyncProducer
• type ConsumerMessageCarrier
• • func NewConsumerMessageCarrier(msg *sarama.ConsumerMessage) ConsumerMessageCarrier
• • func (c ConsumerMessageCarrier) Get(key string) string
  • func (c ConsumerMessageCarrier) Keys() []string
  • func (c ConsumerMessageCarrier) Set(key, val string)
• type Option
• • func WithPropagators(propagators propagation.TextMapPropagator) Option
  • func WithTracerProvider(provider trace.TracerProvider) Option
• type ProducerMessageCarrier
• • func NewProducerMessageCarrier(msg *sarama.ProducerMessage) ProducerMessageCarrier
• • func (c ProducerMessageCarrier) Get(key string) string
  • func (c ProducerMessageCarrier) Keys() []string
  • func (c ProducerMessageCarrier) Set(key, val string)

This section is empty.

This section is empty.

SemVersion is the semantic version to be supplied to tracer/meter creation.

Deprecated: Use Version instead.

Version is the current release version of the sarama instrumentation.

WrapAsyncProducer wraps a sarama.AsyncProducer so that all produced messages are traced. It requires the underlying sarama Config, so we can know whether or not successes will be returned.

If `Return.Successes` is false, there is no way to know partition and offset of the message.

WrapConsumer wraps a sarama.Consumer wrapping any PartitionConsumer created via Consumer.ConsumePartition.

WrapConsumerGroupHandler wraps a sarama.ConsumerGroupHandler causing each received message to be traced.

WrapPartitionConsumer wraps a sarama.PartitionConsumer causing each received message to be traced.

WrapSyncProducer wraps a sarama.SyncProducer so that all produced messages are traced.

type ConsumerMessageCarrier struct {
	
}

ConsumerMessageCarrier injects and extracts traces from a sarama.ConsumerMessage.

NewConsumerMessageCarrier creates a new ConsumerMessageCarrier.

Get retrieves a single value for a given key.

Keys returns a slice of all key identifiers in the carrier.

type Option interface {
	
}

Option interface used for setting optional config properties.

WithPropagators specifies propagators to use for extracting information from the HTTP requests. If none are specified, global ones will be used.

WithTracerProvider specifies a tracer provider to use for creating a tracer. If none is specified, the global provider is used.

type ProducerMessageCarrier struct {
	
}

ProducerMessageCarrier injects and extracts traces from a sarama.ProducerMessage.

NewProducerMessageCarrier creates a new ProducerMessageCarrier.

Get retrieves a single value for a given key.

Keys returns a slice of all key identifiers in the carrier.

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4