pubsub

Documentation

Index

• func ContextFromMessage(msg *message.Message) context.Context
• func InjectContext(ctx context.Context, msg *message.Message)
• func NewMessage(ctx context.Context, payload []byte) *message.Message

Functions

func ContextFromMessage

func ContextFromMessage(msg *message.Message) context.Context

ContextFromMessage returns a new Context which may include OpenTelemetry tracing data.

func InjectContext

func InjectContext(ctx context.Context, msg *message.Message)

InjectContext adds OpenTelemetry tracing data to the message header (if available).

func NewMessage

func NewMessage(ctx context.Context, payload []byte) *message.Message

NewMessage creates a new message which may include OpenTelemetry tracing data in the header.