package
0.0.0-20201113072945-941bdb3e51a3
Repository: https://github.com/tuyainc/pulsar-client-go.git
Documentation: pkg.go.dev
# Functions
DecodeBatchMessage decode message if num_messages_in_batch exist and bigger than 0.
DecodeBatchPayload parses the payload of the batch type If the producer uses the batch function, msg.Payload will be a SingleMessage array structure.
# Structs
Message represents a received MESSAGE from the Pulsar server.
MonotonicID handles unique id generation.
SingleMessage represents one of the elements of the batch type payload.