Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ForwardIndexKafkaConsume ¶
ForwardIndexKafkaConsume 正排索引的消费建立
Types ¶
type ForwardIndexConsumer ¶
type ForwardIndexConsumer struct {
Ready chan bool
}
Consumer Sarama消费者群体的消费者
func (*ForwardIndexConsumer) Cleanup ¶
func (consumer *ForwardIndexConsumer) Cleanup(sarama.ConsumerGroupSession) error
Cleanup is run at the end of a session, once all ConsumeClaim goroutines have exited
func (*ForwardIndexConsumer) ConsumeClaim ¶
func (consumer *ForwardIndexConsumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
ConsumeClaim 必须启动 ConsumerGroupClaim 的 Messages() 消费者循环。 一旦 Messages() 通道关闭,处理程序必须完成其处理循环并退出。
func (*ForwardIndexConsumer) Setup ¶
func (consumer *ForwardIndexConsumer) Setup(sarama.ConsumerGroupSession) error
Setup is run at the beginning of a new session, before ConsumeClaim
type TrieTreeConsumer ¶
type TrieTreeConsumer struct {
Ready chan bool
}
TrieTreeConsumer Sarama消费者群体的消费者
func (*TrieTreeConsumer) Cleanup ¶
func (consumer *TrieTreeConsumer) Cleanup(sarama.ConsumerGroupSession) error
Cleanup is run at the end of a session, once all ConsumeClaim goroutines have exited
func (*TrieTreeConsumer) ConsumeClaim ¶
func (consumer *TrieTreeConsumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
ConsumeClaim 必须启动 ConsumerGroupClaim 的 Messages() 消费者循环。 一旦 Messages() 通道关闭,处理程序必须完成其处理循环并退出。
func (*TrieTreeConsumer) Setup ¶
func (consumer *TrieTreeConsumer) Setup(sarama.ConsumerGroupSession) error
Setup is run at the beginning of a new session, before ConsumeClaim
Click to show internal directories.
Click to hide internal directories.