producer

Documentation

Index

• func FinishProducerSpan(span trace.Span, err error) error
• func StartProducerSpan(ctx context.Context, message types.IMessage, meta *metadata.Metadata, ...) (context.Context, trace.Span)
• type ProducerTracingOptions

Functions

func FinishProducerSpan

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

func StartProducerSpan

func StartProducerSpan(
	ctx context.Context,
	message types.IMessage,
	meta *metadata.Metadata,
	payload string,
	producerTracingOptions *ProducerTracingOptions,
) (context.Context, trace.Span)

Types

type ProducerTracingOptions

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