consumer

Documentation

Index

• func FinishConsumerSpan(span trace.Span, err error) error
• func StartConsumerSpan(ctx context.Context, meta *metadata.Metadata, payload string, ...) (context.Context, trace.Span)
• type ConsumerTracingOptions

Functions

func FinishConsumerSpan

func FinishConsumerSpan(span trace.Span, err error) error

func StartConsumerSpan

func StartConsumerSpan(
	ctx context.Context,
	meta *metadata.Metadata,
	payload string,
	consumerTracingOptions *ConsumerTracingOptions,
) (context.Context, trace.Span)

Types

type ConsumerTracingOptions

type ConsumerTracingOptions struct {
	MessagingSystem string
	DestinationKind string
	Destination     string
	OtherAttributes []attribute.KeyValue
}