Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ExtractRemoteParentSpanContext ¶
func ExtractRemoteParentSpanContext() message.HandlerMiddleware
ExtractRemoteParentSpanContext defines a middleware that will extract trace/span id from the message metadata and creates a child span for the message.
func ExtractRemoteParentSpanContextHandler ¶
func ExtractRemoteParentSpanContextHandler(h message.HandlerFunc) message.HandlerFunc
ExtractRemoteParentSpanContextHandler decorates a watermill HandlerFunc to extract trace/span id from the metadata when a message is received and set a child span context.
Types ¶
type TracePropagatingPublisherDecorator ¶
type TracePropagatingPublisherDecorator struct {
// contains filtered or unexported fields
}
Decorator that adds trace/span id to the message metadata, so the subscriber(s) can extract this.
func (*TracePropagatingPublisherDecorator) Close ¶
func (p *TracePropagatingPublisherDecorator) Close() error
Source Files
Click to show internal directories.
Click to hide internal directories.