kafka_zipkin_interceptor

package module

v0.0.0-...-38a3273 Latest Latest Go to latest Published: Jun 10, 2021 License: Apache-2.0 Imports: 6 Imported by: 2

README ¶

kafka-zipkin-interceptor

Kafka zipkin interceptor

Documentation ¶

Index ¶

Variables
func ExtractTraceInfo(m kafka.Message, key string, topic string, clientId string, groupId string, ...) zipkin.Span
func WrapInSpan(key string, topic string, clientId string, groupId string, ctx context.Context, ...) ([]kafka.Header, context.Context)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	REMOTE_SERVICE_NAME_DEFAULT = "kafka"
	KAFKA_TOPIC                 = "kafka.topic"
	KAFKA_KEY                   = "kafka.key"
	KAFKA_CLIENT_ID             = "kafka.client.id"
	KAFKA_GROUP_ID              = "kafka.group.id"
	SPAN_NAME_SEND              = "send"
	SPAN_NAME_POLL              = "poll"
)

Functions ¶

func ExtractTraceInfo ¶

func ExtractTraceInfo(m kafka.Message, key string, topic string, clientId string, groupId string, t *zipkin.Tracer) zipkin.Span

func WrapInSpan ¶

func WrapInSpan(key string, topic string, clientId string, groupId string, ctx context.Context, t *zipkin.Tracer) ([]kafka.Header, context.Context)

Types ¶

This section is empty.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL