package
2.0.2+incompatible
Repository: https://github.com/lambdaxs/rocketmq-client-go.git
Documentation: pkg.go.dev

# Functions

NewProducer create a new producer with config.
NewPushConsumer create a new consumer with config.
NewTransactionProducer create a new trasaction producer with config.
Version get go sdk version.

# Constants

MessageModel.
MessageModel.
ConsumerModel.
Different models.
ConsumerModel.
Different models.
Different models.

# Structs

ClientConfig save client config.
ProducerConfig define a producer.
PullConsumerConfig the configuration for the pull consumer.
PushConsumerConfig define a new consumer.
SendResult status for send.
SessionCredentials access config for client.

# Interfaces

Producer define interface.
PullConsumer consumer pulling the message.
PushConsumer apis for PushConsumer.
TransactionLocalListener local listener for transaction message.
TransactionProducer api for send transaction message.

# Type aliases

ConsumerModel CoCurrently or Orderly.
MessageModel Clustering or BroadCasting.
ProducerModel Common or orderly.