Categorygithub.com/apache/rocketmq-client-go/v2primitive
package
2.1.2
Repository: https://github.com/apache/rocketmq-client-go.git
Documentation: pkg.go.dev
Versions
1
Dependencies
19
Dependents
248
Files
1.1k SLOC

# Functions

GetConsumerCtx get ConsumeMessageContext, only legal in PushConsumer.
GetMethod get call method name.
WithConsumerCtx set ConsumeMessageContext in PushConsumer.
WithMethod set call method name.

# Constants

connect to Cloud service.
method name in consumer.
connect to private IDC cluster.
predefined pull Status.
predefined pull Status.
predefined pull Status.
predefined pull Status.
predefined pull Status.
method name in producer.

# Variables

# Structs

MessageQueue message queue.
PullResult the pull result.
SendResult RocketMQ send result.
config for message trace.
TransactionSendResult RocketMQ send result.

# Interfaces

resolver for nameserver, monitor change of nameserver and notify client consul or domain is common.

# Type aliases

Interceptor intercepts the invoke of a producer/consumer on messages.
Invoker finish a message invoke on producer/consumer.
PullStatus pull Status.
SendStatus of message.