consumer

type ConsumeConcurrentlyContext struct {
	MessageQueue *message.MessageQueue
	// 消费失败延迟消费级别
	DelayLevelWhenNextConsume int
	AckIndex                  int
}

type MQConsumerInner interface {
	// Set<SubscriptionData>
	Subscriptions() set.Set
	// Set<MessageQueue>
	UpdateTopicSubscribeInfo(topic string, info set.Set)
	// 组名称
	GroupName() string
	// 消息类型
	MessageModel() heartbeat.MessageModel
	// 消费类型
	ConsumeType() heartbeat.ConsumeType
	// 消费位置
	ConsumeFromWhere() heartbeat.ConsumeFromWhere
	IsUnitMode() bool
	// 是否需要更新
	IsSubscribeTopicNeedUpdate(topic string) bool
	// 持久化offset
	PersistConsumerOffset()
	// 负载
	DoRebalance()
}

type MQPullConsumer interface {
	// 开启
	Start()
	// 关闭
	Shutdown()
}

type MQPushConsumer interface {
	// 开启
	Start()
	// 关闭
	Shutdown()
}

type MessageListenerConcurrently interface {
	ConsumeMessage(msgs []*message.MessageExt, context *ConsumeConcurrentlyContext) listener.ConsumeConcurrentlyStatus
}

type ProcessQueue struct {
	Dropped           bool
	LastPullTimestamp int64
	PullMaxIdleTime   int64
	MsgCount          int64
	MsgTreeMap        *TreeMap
	QueueOffsetMax    int64
	Consuming         bool
	MsgAccCnt         int64
	// contains filtered or unexported fields
}

type PullRequest struct {
	ConsumerGroup string
	MessageQueue  *message.MessageQueue
	ProcessQueue  *ProcessQueue
	NextOffset    int64
}

type PullResult struct {
	PullStatus      PullStatus
	NextBeginOffset int64
	MinOffset       int64
	MaxOffset       int64
	MsgFoundList    []*message.MessageExt
}

type PullStatus int

type TreeMap struct {
	sync.RWMutex
	// contains filtered or unexported fields
}