trace

Documentation

Index

• Constants
• func ConsumeInterceptor(ctx context.Context, msg *sarama.ConsumerMessage, handler kafka.ConsumeHandler) error
• func ProducerInterceptor(ctx context.Context, msg *sarama.ProducerMessage, ...) (int32, int64, error)
• 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 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)

Constants

const Name = "kafka-go"

const (
	VersionCodeKey = "VersionCode"
)

Functions

func ConsumeInterceptor

func ConsumeInterceptor(ctx context.Context, msg *sarama.ConsumerMessage, handler kafka.ConsumeHandler) error

func ProducerInterceptor

func ProducerInterceptor(ctx context.Context, msg *sarama.ProducerMessage, handler kafka.ProducerHandler) (int32, int64, error)

Types

type ConsumerMessageCarrier

type ConsumerMessageCarrier struct {
	// contains filtered or unexported fields
}

ConsumerMessageCarrier injects and extracts traces from a sarama.ConsumerMessage.

func NewConsumerMessageCarrier

func NewConsumerMessageCarrier(msg *sarama.ConsumerMessage) ConsumerMessageCarrier

NewConsumerMessageCarrier creates a new ConsumerMessageCarrier.

func (ConsumerMessageCarrier) Get

func (c ConsumerMessageCarrier) Get(key string) string

Get retrieves a single value for a given key.

func (ConsumerMessageCarrier) Keys

func (c ConsumerMessageCarrier) Keys() []string

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

func (ConsumerMessageCarrier) Set

func (c ConsumerMessageCarrier) Set(key, val string)

Set sets a header.

type ProducerMessageCarrier

type ProducerMessageCarrier struct {
	// contains filtered or unexported fields
}

ProducerMessageCarrier injects and extracts traces from a sarama.ProducerMessage.

func NewProducerMessageCarrier

func NewProducerMessageCarrier(msg *sarama.ProducerMessage) ProducerMessageCarrier

NewProducerMessageCarrier creates a new ProducerMessageCarrier.

func (ProducerMessageCarrier) Get

func (c ProducerMessageCarrier) Get(key string) string

Get retrieves a single value for a given key.

func (ProducerMessageCarrier) Keys

func (c ProducerMessageCarrier) Keys() []string

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

func (ProducerMessageCarrier) Set

func (c ProducerMessageCarrier) Set(key, val string)

Set sets a header.