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

package

Go to main page

Versions in this module

v1

v1.2.5

Mar 3, 2021

v1.2.4

Oct 22, 2019

Changes in this version

+ const CommitTransaction

+ const RollbackTransaction

+ const TransProducer

+ const UnknownTransaction

type Message

+ func (msg *Message) GetProperty(key string) string

type PushConsumerConfig

+ MaxCacheMessageSize int

+ MaxCacheMessageSizeInMB int

+ type TransactionLocalListener interface

+ Check func(m *MessageExt, arg interface{}) TransactionStatus

+ Execute func(m *Message, arg interface{}) TransactionStatus

+ type TransactionProducer interface

+ SendMessageTransaction func(msg *Message, arg interface{}) (*SendResult, error)

+ func NewTransactionProducer(config *ProducerConfig, listener TransactionLocalListener, arg interface{}) (TransactionProducer, error)

+ type TransactionStatus int

+ func (status TransactionStatus) String() string

v1.2.2

Sep 20, 2019

Changes in this version

+ const BroadCasting

+ const Clustering

+ const CoCurrently

+ const CommonProducer

+ const ConsumeSuccess

+ const ErrFetchMQFailed

+ const ErrFetchMessageFailed

+ const ErrMallocFailed

+ const ErrNullPoint

+ const ErrProducerStartFailed

+ const ErrPullConsumerStartFailed

+ const ErrPushConsumerStartFailed

+ const ErrSendOnewayFailed

+ const ErrSendOrderlyFailed

+ const ErrSendSyncFailed

+ const GoClientVersion

+ const LogLevelDebug

+ const LogLevelError

+ const LogLevelFatal

+ const LogLevelInfo

+ const LogLevelNum

+ const LogLevelTrace

+ const LogLevelWarn

+ const NIL

+ const Orderly

+ const OrderlyProducer

+ const PullBrokerTimeout

+ const PullFound

+ const PullNoMatchedMsg

+ const PullNoNewMsg

+ const PullOffsetIllegal

+ const ReConsumeLater

+ const SendFlushDiskTimeout

+ const SendFlushSlaveTimeout

+ const SendOK

+ const SendSlaveNotAvailable

+ func GetVersion() (version string)

+ func Version() (version string)

+ type ClientConfig struct

+ Credentials *SessionCredentials

+ GroupID string

+ GroupName string

+ InstanceName string

+ LogC *LogConfig

+ NameServer string

+ NameServerDomain string

+ func (config *ClientConfig) String() string

+ type ConsumeStatus int

+ func (status ConsumeStatus) String() string

+ type ConsumerModel int

+ func (mode ConsumerModel) String() string

+ type LogConfig struct

+ FileNum int

+ FileSize int64

+ Level LogLevel

+ Path string

+ func (lc *LogConfig) String() string

+ type LogLevel int

+ func (l LogLevel) String() string

+ type Message struct

+ Body string

+ DelayTimeLevel int

+ Keys string

+ Property map[string]string

+ Tags string

+ Topic string

+ func (msg *Message) String() string

+ type MessageExt struct

+ BornTimestamp int64

+ CommitLogOffset int64

+ MessageID string

+ PreparedTransactionOffset int64

+ QueueId int

+ QueueOffset int64

+ ReconsumeTimes int

+ StoreSize int

+ StoreTimestamp int64

+ func (msgExt *MessageExt) GetProperty(key string) string

+ func (msgExt *MessageExt) String() string

+ type MessageModel int

+ func (mode MessageModel) String() string

+ type MessageQueue struct

+ Broker string

+ ID int

+ Topic string

+ func (q *MessageQueue) String() string

+ type MessageQueueSelector interface

+ Select func(size int, m *Message, arg interface{}) int

+ type Producer interface

+ SendMessageOneway func(msg *Message) error

+ SendMessageOrderly func(msg *Message, selector MessageQueueSelector, arg interface{}, ...) (*SendResult, error)

+ SendMessageOrderlyByShardingKey func(msg *Message, shardingkey string) (*SendResult, error)

+ SendMessageSync func(msg *Message) (*SendResult, error)

+ func NewProducer(config *ProducerConfig) (Producer, error)

+ type ProducerConfig struct

+ CompressLevel int

+ MaxMessageSize int

+ ProducerModel ProducerModel

+ SendMsgTimeout int

+ func (config *ProducerConfig) String() string

+ type ProducerModel int

+ func (mode ProducerModel) String() string

+ type PullConsumer interface

+ FetchSubscriptionMessageQueues func(topic string) []MessageQueue

+ Pull func(mq MessageQueue, subExpression string, offset int64, maxNums int) PullResult

+ func NewPullConsumer(config *PullConsumerConfig) (PullConsumer, error)

+ type PullConsumerConfig struct

+ func (config *PullConsumerConfig) String() string

+ type PullResult struct

+ MaxOffset int64

+ Messages []*MessageExt

+ MinOffset int64

+ NextBeginOffset int64

+ Status PullStatus

+ func (pr *PullResult) String() string

+ type PullStatus int

+ func (ps PullStatus) String() string

+ type PushConsumer interface

+ Subscribe func(topic, expression string, consumeFunc func(msg *MessageExt) ConsumeStatus) error

+ func NewPushConsumer(config *PushConsumerConfig) (PushConsumer, error)

+ type PushConsumerConfig struct

+ ConsumerModel ConsumerModel

+ MessageBatchMaxSize int

+ Model MessageModel

+ ThreadCount int

+ func (config *PushConsumerConfig) String() string

+ type SendResult struct

+ MsgId string

+ Offset int64

+ Status SendStatus

+ func (result *SendResult) String() string

+ type SendStatus int

+ func (status SendStatus) String() string

+ type SessionCredentials struct

+ AccessKey string

+ Channel string

+ SecretKey string

+ func (session *SessionCredentials) String() string