otel

Documentation

Overview

Package otel is the implementation of instrumentation.Tracer for OpenTelemetry.

Index

• func Init() (instrumentation.Tracer, error)
• func ShutDown()
• type MessageCarrier
  • func NewMessageCarrier(msg *kafka.Message) *MessageCarrier
  • func (kc *MessageCarrier) Get(key string) string
  • func (kc *MessageCarrier) Keys() []string
  • func (kc *MessageCarrier) Set(key string, value string)

Functions

func Init

func Init() (instrumentation.Tracer, error)

Init initializes the global tracer provider and meter provider for OpenTelemetry.

func ShutDown

func ShutDown()

ShutDown shuts down the global tracer provider.

Types

type MessageCarrier

type MessageCarrier struct {
	*cKafka.Message
	// contains filtered or unexported fields
}

MessageCarrier implements the otel TextMapCarrier interface for kafka.Message.

func NewMessageCarrier

func NewMessageCarrier(msg *kafka.Message) *MessageCarrier

NewMessageCarrier creates a new MessageCarrier from the given kafka.Message.

func (*MessageCarrier) Get

func (kc *MessageCarrier) Get(key string) string

Get returns the value associated with the passed key.

func (*MessageCarrier) Keys

func (kc *MessageCarrier) Keys() []string

Keys lists the keys stored in this carrier.

func (*MessageCarrier) Set

func (kc *MessageCarrier) Set(key string, value string)

Set stores the key-value pair.