service

Documentation

Index

• Constants
• func Init(brokerList string, topicPrefix string, centerIp string, rpcPort int64)
• func InitKafkaConf(brokerList string, topicPrefix string) *entity.KafkaConfig
• type CenterConsumer
  • func (this *CenterConsumer) ConsumerDelayMsg(req message.Request, res *message.Response) error
• type Consumer
  • func (consumer *Consumer) Cleanup(sarama.ConsumerGroupSession) error
  • func (consumer *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (consumer *Consumer) Setup(sarama.ConsumerGroupSession) error
• type ICenterService
  • func NewCenterService(brokerList string, topicPrefix string, rpcPort int64, centerIp string) ICenterService

Constants

const (
	WORKER_ADDRESS_EXPIRE                  = 60  //60秒重新取worker address
	PULL_OFFLINE_WORKER_MSG_NUM_EVERY_TIME = 500 //每次拉取下线worker消息个数
	MAX_REQ_CNT                            = 3   //每个消息请求worker最大次数
)

Functions

func Init

func Init(brokerList string, topicPrefix string, centerIp string, rpcPort int64)

func InitKafkaConf

func InitKafkaConf(brokerList string, topicPrefix string) *entity.KafkaConfig

Types

type CenterConsumer

type CenterConsumer struct {
}

func (*CenterConsumer) ConsumerDelayMsg

func (this *CenterConsumer) ConsumerDelayMsg(req message.Request, res *message.Response) error

延时消息消费

type Consumer

type Consumer struct {
	// contains filtered or unexported fields
}

func (*Consumer) Cleanup

func (consumer *Consumer) Cleanup(sarama.ConsumerGroupSession) error

func (*Consumer) ConsumeClaim

func (consumer *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (*Consumer) Setup

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

type ICenterService

type ICenterService interface {
	Start()
	Stop()
	// contains filtered or unexported methods
}

var CenterService ICenterService

func NewCenterService

func NewCenterService(brokerList string, topicPrefix string, rpcPort int64, centerIp string) ICenterService