package
2.0.0+incompatible
Repository: https://github.com/swift9/rocketmq-client-go.git
Documentation: pkg.go.dev
# Functions
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
GetConsumerCtx get ConsumeMessageContext, only legal in PushConsumer.
No description provided by the author
GetMethod get call method name.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
WithConsumerCtx set ConsumeMessageContext in PushConsumer.
WithMethod set call method name.
No description provided by the author
No description provided by the author
No description provided by the author
# Constants
connect to Cloud service.
No description provided by the author
No description provided by the author
method name in consumer.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
connect to private IDC cluster.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
predefined pull Status.
predefined pull Status.
predefined pull Status.
predefined pull Status.
predefined pull Status.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
method name in producer.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
# Variables
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
# Structs
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
MessageQueue message queue.
No description provided by the author
PullResult the pull result.
SendResult RocketMQ send result.
config for message trace.
SendResult RocketMQ send result.
# Interfaces
No description provided by the author
# Type aliases
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Interceptor intercepts the invoke of a producer/consumer on messages.
Invoker finish a message invoke on producer/consumer.
No description provided by the author
No description provided by the author
No description provided by the author
PullStatus pull Status.
SendStatus of message.