internal

package
v0.0.0-...-6e77d46 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 19, 2021 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func KafkaConsumerGroupID

func KafkaConsumerGroupID(consumerGroupID string) attribute.KeyValue

func KafkaDestinationTopic

func KafkaDestinationTopic(topic string) attribute.KeyValue

func KafkaMessageHeaders

func KafkaMessageHeaders(headers []kafka.Header) []attribute.KeyValue

func KafkaMessageKey

func KafkaMessageKey(messageID string) attribute.KeyValue

func KafkaOperation

func KafkaOperation(operationName Operation) attribute.KeyValue

func KafkaSystemKey

func KafkaSystemKey() attribute.KeyValue

Types

type Operation

type Operation string
const (
	OperationProduce Operation = "produce"
	OperationConsume Operation = "consume"

	MessagingSystemKeyValue = "kafka"
)

Jump to

Keyboard shortcuts

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