tracing

Documentation

Overview

Package tracing provides helpers and bindings for distributed tracing of Apache Kafka consumers and producers.

As your infrastructure grows, it becomes important to be able to trace a request, as it travels through multiple services and back to the user. Package tracing provides endpoints and transport helpers and middlewares to capture and emit request-scoped information.

Index

• func ContextToTags(ctx context.Context) map[string]interface{}
• func MessageToContext(ctx context.Context, msg *kafka.Message) context.Context
• type KafkaContextKey

Functions

func ContextToTags

func ContextToTags(ctx context.Context) map[string]interface{}

ContextToTags returns new map of tags from ctx.

func MessageToContext

func MessageToContext(ctx context.Context, msg *kafka.Message) context.Context

MessageToContext returns new context with topic, partition and offset values from msg.

Types

type KafkaContextKey

type KafkaContextKey string

const (
	KeyTopic     KafkaContextKey = "kafka.topic"
	KeyPartition KafkaContextKey = "kafka.partition"
	KeyOffset    KafkaContextKey = "kafka.offset"
)