package
0.0.0-20210318030624-2c99a816287b
Repository: https://github.com/tuya/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.