pulsarrequestid

Documentation

Index

• func AddToMessage(msg *pulsar.ProducerMessage, id string)
• func FromMessage(msg pulsar.Message) (string, bool)
• func FromMessageOrMissing(msg pulsar.Message) (requestId string)

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.