elastic

Documentation

Index

• type Elastc
  • func NewElastc(taddr string, saddr string) *Elastc
  • func (ec *Elastc) Cleanup(s sarama.ConsumerGroupSession) error
  • func (ec *Elastc) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (ec *Elastc) Setup(s sarama.ConsumerGroupSession) error
  • func (e *Elastc) Shudown()
  • func (ec *Elastc) Start() error

Types

type Elastc

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

ElastcConsumer 可关闭的带任务处理器的消费者

func NewElastc

func NewElastc(taddr string, saddr string) *Elastc

func (*Elastc) Cleanup

func (ec *Elastc) Cleanup(s sarama.ConsumerGroupSession) error

Cleanup 当退出时

func (*Elastc) ConsumeClaim

func (ec *Elastc) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

ConsumeClaim 消费日志

func (*Elastc) Setup

func (ec *Elastc) Setup(s sarama.ConsumerGroupSession) error

Setup 启动

func (*Elastc) Shudown

func (e *Elastc) Shudown()

func (*Elastc) Start

func (ec *Elastc) Start() error