Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

rocketmq_client

package module

Go to main page

Versions in this module

v1

v1.0.1

Jul 29, 2024

Changes in this version

+ var NewFilterExpression = func(expression string) *FilterExpression

+ var NewFilterExpressionWithType = func(expression string, expressionType rmq_client.FilterExpressionType) *FilterExpression

+ var SUB_ALL = NewFilterExpression("*")

type Config

+ FlowColor *string

+ FlowColorBase *bool

+ type FilterExpression struct

+ Expression string

+ ExpressionType rmq_client.FilterExpressionType

type TopicType

+ const FlowColor

v1.0.0

Jun 21, 2024

Changes in this version

+ func IsNoNewMessage(err error) bool

+ func IsTooManyRequest(err error) bool

+ func Send(ctx context.Context, cfg *Config, producer rmq_client.Producer, ...) (resp []*rmq_client.SendReceipt, err error)

+ func SendAsync(ctx context.Context, cfg *Config, producer rmq_client.Producer, ...) (err error)

+ func SendTransaction(ctx context.Context, cfg *Config, producer rmq_client.Producer, ...) (resp []*rmq_client.SendReceipt, err error)

+ func SimpleConsume(ctx context.Context, cfg *Config, consumeFunc ConsumeFunc, ...) (stopFunc func(), err error)

+ func SimpleConsume4Gf(ctx context.Context, cfg *Config, consumeFunc ConsumeFunc, ...) (stopFunc func(), err error)

+ type Config struct

+ AccessKey string

+ AccessSecret string

+ ConsumerGroup string

+ Debug bool

+ DebugHandlerFunc debugHandlerFunc

+ Endpoint string

+ LogPath string

+ LogStdout bool

+ NameSpace string

+ type ConfirmFunc func(msg Message, resp []*rmq_client.SendReceipt) bool

+ type ConsumeFunc func(ctx context.Context, msg *rmq_client.MessageView, consumer Consumer) error

+ type Consumer interface

+ Ack func(ctx context.Context) error

+ ChangeInvisibleDuration func(invisibleDuration time.Duration) error

+ ChangeInvisibleDurationAsync func(invisibleDuration time.Duration)

+ type ConsumerOptionFunc func(options *ConsumerOptions)

+ func WithConsumerOptionAwaitDuration(AwaitDuration time.Duration) ConsumerOptionFunc

+ func WithConsumerOptionInvisibleDuration(InvisibleDuration time.Duration) ConsumerOptionFunc

+ func WithConsumerOptionMaxMessageNum(MaxMessageNum int32) ConsumerOptionFunc

+ func WithConsumerOptionSubExpressions(SubExpressions map[string]*rmq_client.FilterExpression) ConsumerOptionFunc

+ type ConsumerOptions struct

+ AwaitDuration time.Duration

+ InvisibleDuration time.Duration

+ MaxMessageNum int32

+ SubExpressions map[string]*rmq_client.FilterExpression

+ type Message struct

+ Body string

+ DeliveryTimestamp time.Time

+ Keys []string

+ MessageGroup string

+ Properties map[string]string

+ Tag string

+ Topic string

+ type Producer interface

+ Send func(ctx context.Context, topicType TopicType, msg Message) (resp []*rmq_client.SendReceipt, err error)

+ SendAsync func(ctx context.Context, topicType TopicType, msg Message, ...) error

+ SendTransaction func(ctx context.Context, message Message, confirmFunc ConfirmFunc) error

+ Stop func() error

+ func GetGfProducer(cfg *Config, oFunc ...ProducerOptionFunc) (producer Producer, err error)

+ func GetProducer(cfg *Config, oFunc ...ProducerOptionFunc) (producer Producer, err error)

+ type ProducerOptionFunc func(options *ProducerOptions)

+ func WithProducerOptionMaxAttempts(maxAttempts int32) ProducerOptionFunc

+ func WithProducerOptionTopics(Topics ...string) ProducerOptionFunc

+ func WithProducerOptionTransactionChecker(transactionChecker SendTransactionCheckerFunc) ProducerOptionFunc

+ type ProducerOptions struct

+ MaxAttempts int32

+ Topics []string

+ type SendAsyncDealFunc func(ctx context.Context, msg Message, resp []*rmq_client.SendReceipt, err error)

+ type SendTransactionCheckerFunc func(msg *rmq_client.MessageView) rmq_client.TransactionResolution

+ type TopicType string

+ const TopicDelay

+ const TopicFIFO

+ const TopicNormal

+ const TopicTransaction