pulsarrequestid

package
v0.3.82-rc-0b8d5b9 Latest Latest
Warning

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

Go to latest
Published: Jul 12, 2023 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddToMessage

func AddToMessage(msg *pulsar.ProducerMessage, id string)

AddToMessage adds the provided request id in-place to the provided Pulsar message.

func FromMessage

func FromMessage(msg pulsar.Message) (string, bool)

FromMessage attempts to extract a request id embedded in a Pulsar message. The second return value is true if the operation was successful.

func FromMessageOrMissing

func FromMessageOrMissing(msg pulsar.Message) (requestId string)

FromMessageOrMissing attempts to extract a request id embedded in a Pulsar message, or "missing" if none could be found.

Types

This section is empty.

Jump to

Keyboard shortcuts

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