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

rmq

package

Go to main page

Versions in this module

v1

v1.0.78

Dec 17, 2024

v1.0.12

Dec 23, 2024

v1.0.10

Dec 22, 2024

v1.0.9

Dec 21, 2024

v1.0.8

Dec 17, 2024

v1.0.7

Dec 17, 2024

Changes in this version

+ const HeaderPre

+ const Hour1

+ const Hours2

+ const Minute1

+ const Minutes10

+ const Minutes2

+ const Minutes20

+ const Minutes3

+ const Minutes30

+ const Minutes4

+ const Minutes5

+ const Minutes6

+ const Minutes7

+ const Minutes8

+ const Minutes9

+ const Second

+ const Seconds10

+ const Seconds30

+ const Seconds5

+ var ErrRmqSvcAlreadyRegistered = fmt.Errorf("requested rmq service is already registered")

+ var ErrRmqSvcConfigInvalid = fmt.Errorf("requested rmq service is not correctly configured")

+ var ErrRmqSvcInvalidOperation = fmt.Errorf("requested rmq service is not suitable for current operation")

+ var ErrRmqSvcNotRegiestered = fmt.Errorf("requested rmq service is not registered")

+ func InitConsumer(config ConsumerConf) (err error)

+ func InitProducer(config ProducerConf) (err error)

+ func StartConsumer(g *gin.Engine, service string, callback MessageCallback) error

+ func StartProducer(service string) error

+ func StopConsumer(service string) error

+ func StopProducer(service string) error

+ func StopRmqConsume()

+ func StopRmqProduce()

+ type Auth struct

+ AccessKey string

+ SecretKey string

+ type ClientConf struct

+ Auth Auth

+ NameServer string

+ Service string

+ Topic string

+ Trace bool

+ TraceTopic string

+ func (conf *ClientConf) Check() error

+ type ConsumerConf struct

+ Batch int

+ Broadcast bool

+ Group string

+ Orderly bool

+ Retry int

+ RetryInterval time.Duration

+ Tags []string

+ func (conf *ConsumerConf) Check() error

+ type DelayLevel int

+ type Message interface

+ GetAllHeader func() map[string]string

+ GetContent func() []byte

+ GetHeader func(key string) string

+ GetID func() string

+ GetKey func() string

+ GetRetry func() int

+ GetShard func() string

+ GetTag func() string

+ GetTime func() time.Time

+ GetTopic func() string

+ Send func(ctx *gin.Context) (msgID string, err error)

+ SetProperty func(key string, value string) Message

+ SetTopic func(string) Message

+ WithDelay func(DelayLevel) Message

+ WithHeader func(key string, value string) Message

+ WithKey func(string) Message

+ WithShard func(string) Message

+ WithTag func(string) Message

+ func NewMessage(service string, content []byte) (Message, error)

+ type MessageBatch []Message

+ func (batch MessageBatch) Send(ctx *gin.Context) (msgID string, err error)

+ type MessageCallback func(ctx *gin.Context, msg Message) error

+ type NmqResponse struct

+ ErrNo int

+ ErrStr string

+ TransID uint64

+ type Producer struct

+ type ProducerConf struct

+ Retry int

+ Timeout time.Duration

+ func (conf *ProducerConf) Check() error

+ type RmqConfig struct

+ Consumer []ConsumerConf

+ Producer []ProducerConf

v1.0.6

Dec 16, 2024

v1.0.5

Dec 2, 2024

v1.0.3

Nov 30, 2024

v1.0.2

Nov 22, 2024