subscription

package
v0.0.0-...-ba2213e Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 21, 2019 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type SubscriptionGroupConfig

type SubscriptionGroupConfig struct {
	GroupName                    string `json:"groupName"`                    // 订阅组名
	ConsumeEnable                bool   `json:"consumeEnable"`                // 消费功能是否开启
	ConsumeFromMinEnable         bool   `json:"consumeFromMinEnable"`         // 是否允许从队列最小位置开始消费(线上默认会设置为false)
	ConsumeBroadcastEnable       bool   `json:"consumeBroadcastEnable"`       // 是否允许广播方式消费
	RetryQueueNums               int32  `json:"retryQueueNums"`               // 每个订阅组配置几个重试队列(消费失败的消息放到一个重试队列)
	RetryMaxTimes                int32  `json:"retryMaxTimes"`                // 重试消费最大次数(超过最大次数,则投递到死信队列并且不再投递,并报警)
	BrokerId                     int64  `json:"brokerId"`                     // 从哪个Broker开始消费
	WhichBrokerWhenConsumeSlowly int64  `json:"whichBrokerWhenConsumeSlowly"` // 发现消息堆积后,将Consumer的消费请求重定向到另外一台Slave机器
}

SubscriptionGroupConfig 订阅关系配置 Author gaoyanlei Since 2017/8/9

func NewSubscriptionGroupConfig

func NewSubscriptionGroupConfig() *SubscriptionGroupConfig

NewSubscriptionGroupConfig 初始化SubscriptionGroupConfig Author gaoyanlei Since 2017/8/9

func (*SubscriptionGroupConfig) ToString

func (self *SubscriptionGroupConfig) ToString() string

ToString 打印SubscriptionGroupConfig结构体数据 Author: tianyuliang Since: 2017/10/13

type SubscriptionGroupTable

type SubscriptionGroupTable struct {
	SubscriptionGroupTable map[string]*SubscriptionGroupConfig `json:"subscriptionGroupTable"` // key:group
	DataVersion            stgcommon.DataVersion               `json:"dataVersion"`
	sync.RWMutex           `json:"-"`
}

func NewSubscriptionGroupTable

func NewSubscriptionGroupTable() *SubscriptionGroupTable

func (*SubscriptionGroupTable) Clear

func (table *SubscriptionGroupTable) Clear()

Clear 清空 Author rongzhihong Since 2017/9/18

func (*SubscriptionGroupTable) ClearAndPutAll

func (table *SubscriptionGroupTable) ClearAndPutAll(offsetMap *syncmap.Map)

ClearAndPutAll 清空map,再PutAll Author rongzhihong Since 2017/9/18

func (*SubscriptionGroupTable) Foreach

func (table *SubscriptionGroupTable) Foreach(fn func(k string, v *SubscriptionGroupConfig))

func (*SubscriptionGroupTable) Get

func (*SubscriptionGroupTable) Put

func (*SubscriptionGroupTable) PutAll

func (table *SubscriptionGroupTable) PutAll(offsetMap *syncmap.Map)

syncTopicConfig 同步Topic配置文件 Author rongzhihong Since 2017/9/18

func (*SubscriptionGroupTable) Remove

func (*SubscriptionGroupTable) Size

func (table *SubscriptionGroupTable) Size() int

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL