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

# Functions

GetLatestErrorMessage Get latest detailed error message from CPP-SDK.
GetVersion return go version strings.
NewProducer create a new producer with config.
NewPullConsumer creates a pull consumer.
NewPushConsumer create a new consumer with config.
NewTransactionProducer create a new trasaction producer with config.
Version get go sdk version.

# Constants

MessageModel.
MessageModel.
ConsumerModel.
TransactionStatus check the status if commit or rollback.
Different models.
ConsumeSuccess commit offset to broker.
This is error messages.
This is error messages.
This is error messages.
This is error messages.
This is error messages.
This is error messages.
This is error messages.
This is error messages.
This is error messages.
This is error messages.
This is error messages.
This is error messages.
GoClientVersion const strings for version.
predefined log level.
predefined log level.
predefined log level.
predefined log level.
predefined log level.
predefined log level.
predefined log level.
This is error messages.
ConsumerModel.
Different models.
predefined pull status.
predefined pull status.
predefined pull status.
predefined pull status.
predefined pull status.
ReConsumeLater it will be send back to broker.
TransactionStatus check the status if commit or rollback.
SendFlushDiskTimeout Failed because broker flush error.
SendFlushSlaveTimeout Failed because slave broker timeout.
SendOK OK.
SendSlaveNotAvailable Failed because slave broker error.
Different models.
TransactionStatus check the status if commit or rollback.

# Structs

ClientConfig save client config.
LogConfig the log configuration for the pull consumer.
Message used for send.
MessageExt used for consume.
MessageQueue the queue of the message.
ProducerConfig define a producer.
PullConsumerConfig the configuration for the pull consumer.
PullResult the pull result.
PushConsumerConfig define a new consumer.
SendResult status for send.
SessionCredentials access config for client.

# Interfaces

MessageQueueSelector select one message queue.
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.
ConsumeStatus the retern value for consumer.
LogLevel the log level.
MessageModel Clustering or BroadCasting.
ProducerModel Common or orderly.
PullStatus pull status.
SendStatus The Status for send result from C apis.
TransactionStatus check the status if commit or rollback.