Versions in this module Expand all Collapse all v1 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
Go to main page