consumer

Documentation

Index

• func CancelDelaySleep()
• func NewConsumerGroup(addrs []string, consumer *Consumer) error
• type Consumer
  • func NewConsumer(group, topic string, num int) *Consumer
  • func (s *Consumer) Cleanup(session sarama.ConsumerGroupSession) error
  • func (s *Consumer) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (s *Consumer) Setup(sarama.ConsumerGroupSession) error
• type PayloadDelay
  • func NewDefaultDelayPayload(payload string, topic string) PayloadDelay

Functions

func CancelDelaySleep

func CancelDelaySleep()

CancelDelaySleep 触发退出

func NewConsumerGroup

func NewConsumerGroup(addrs []string, consumer *Consumer) error

Types

type Consumer

type Consumer struct {
	Group   string
	Topic   string
	PartNum int
}

func NewConsumer

func NewConsumer(group, topic string, num int) *Consumer

func (*Consumer) Cleanup

func (s *Consumer) Cleanup(session sarama.ConsumerGroupSession) error

func (*Consumer) ConsumeClaim

func (s *Consumer) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

mvcc、token、去重表

func (*Consumer) Setup

func (s *Consumer) Setup(sarama.ConsumerGroupSession) error

type PayloadDelay

type PayloadDelay struct {
	PushUnix int64  `json:"pushUnix"` // 秒
	PushTime string `json:"pushTime"` // 2021-3-11 16:14:17
	Payload  string `json:"payload"`  //
	Topic    string `json:"topic"`    // 到期之后放入的队列
}

PayloadDelay 延迟队列数据

func NewDefaultDelayPayload

func NewDefaultDelayPayload(payload string, topic string) PayloadDelay

NewDefaultDelayPayload 默认