Documentation ¶
Overview ¶
*
- builtin interceptor
Index ¶
- Variables
- func MarshalMessageBatch(msgs ...*primitive.Message) []byte
- func NewDefaultProducer(opts ...Option) (*defaultProducer, error)
- func NewTransactionProducer(listener primitive.TransactionListener, opts ...Option) (*transactionProducer, error)
- type Option
- func WithCompressLevel(level int) Option
- func WithCompressMsgBodyOverHowmuch(threshold int) Option
- func WithCreateTopicKey(topic string) Option
- func WithCredentials(c primitive.Credentials) Option
- func WithDefaultTopicQueueNums(queueNum int) Option
- func WithGroupName(group string) Option
- func WithInstanceName(name string) Option
- func WithInterceptor(f ...primitive.Interceptor) Option
- func WithNameServer(nameServers primitive.NamesrvAddr) Option
- func WithNameServerDomain(nameServerUrl string) Option
- func WithNamespace(namespace string) Option
- func WithNsResolver(resolver primitive.NsResolver) Option
- func WithQueueSelector(s QueueSelector) Option
- func WithRetry(retries int) Option
- func WithSendMsgTimeout(duration time.Duration) Option
- func WithTrace(traceCfg *primitive.TraceConfig) Option
- func WithVIPChannel(enable bool) Option
- type QueueSelector
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func MarshalMessageBatch ¶
func NewDefaultProducer ¶
func NewTransactionProducer ¶
func NewTransactionProducer(listener primitive.TransactionListener, opts ...Option) (*transactionProducer, error)
TODO: checkLocalTransaction
Types ¶
type Option ¶
type Option func(*producerOptions)
func WithCompressLevel ¶
WithCompressLevel set compress level (0~9) 0 stands for best speed 9 stands for best compression ratio
func WithCompressMsgBodyOverHowmuch ¶
WithCompressMsgBodyOverHowmuch set compression threshold
func WithCreateTopicKey ¶
func WithCredentials ¶
func WithCredentials(c primitive.Credentials) Option
func WithInstanceName ¶
func WithInterceptor ¶
func WithInterceptor(f ...primitive.Interceptor) Option
func WithNameServer ¶
func WithNameServer(nameServers primitive.NamesrvAddr) Option
WithNameServer set NameServer address, only support one NameServer cluster in alpha2
func WithNameServerDomain ¶
WithNameServerDomain set NameServer domain
func WithNamespace ¶
WithNamespace set the namespace of producer
func WithNsResolver ¶
func WithNsResolver(resolver primitive.NsResolver) Option
WithNsResolver set nameserver resolver to fetch nameserver addr
func WithQueueSelector ¶
func WithQueueSelector(s QueueSelector) Option
func WithRetry ¶
WithRetry return a Option that specifies the retry times when send failed. TODO: use retry middleware instead
func WithSendMsgTimeout ¶
func WithTrace ¶
func WithTrace(traceCfg *primitive.TraceConfig) Option
WithTrace support rocketmq trace: https://github.com/apache/rocketmq/wiki/RIP-6-Message-Trace.
func WithVIPChannel ¶
type QueueSelector ¶
type QueueSelector interface {
Select(*primitive.Message, []*primitive.MessageQueue) *primitive.MessageQueue
}
func NewHashQueueSelector ¶
func NewHashQueueSelector() QueueSelector
func NewManualQueueSelector ¶
func NewManualQueueSelector() QueueSelector
func NewRandomQueueSelector ¶
func NewRandomQueueSelector() QueueSelector
func NewRoundRobinQueueSelector ¶
func NewRoundRobinQueueSelector() QueueSelector
Click to show internal directories.
Click to hide internal directories.