Versions in this module Expand all Collapse all v1 v1.0.1 Aug 7, 2020 Changes in this version + func NewTransactionProducer(listener primitive.TransactionListener, opts ...Option) (*transactionProducer, error) type Option + func WithInstanceName(name string) Option + func WithNamespace(namespace string) Option + func WithSendMsgTimeout(duration time.Duration) Option type QueueSelector + func NewHashQueueSelector() QueueSelector v1.0.0 Mar 17, 2020 Changes in this version + var ErrMessageEmpty = errors.New("message is nil") + var ErrNotRunning = errors.New("producer not started") + var ErrTopicEmpty = errors.New("topic is nil") + func NewDefaultProducer(opts ...Option) (*defaultProducer, error) + type Option func(*producerOptions) + func WithCredentials(c primitive.Credentials) Option + func WithGroupName(group string) Option + func WithInterceptor(f ...primitive.Interceptor) Option + func WithNameServer(nameServers []string) Option + func WithQueueSelector(s QueueSelector) Option + func WithRetry(retries int) Option + func WithTrace(traceCfg *primitive.TraceConfig) Option + func WithVIPChannel(enable bool) Option + type QueueSelector interface + Select func(*primitive.Message, int) int + func NewManualQueueSelector() QueueSelector + func NewRandomQueueSelector() QueueSelector + func NewRoundRobinQueueSelector() QueueSelector Incompatible versions in this module v2.0.0+incompatible Aug 7, 2020