kafka

Documentation

Index

• type Queue
  • func (q *Queue) Consume(ctx context.Context) error
  • func (q *Queue) ConsumeWithHandler(ctx context.Context, handler abstract.ConsumeHandler) error
  • func (q *Queue) Errors() chan error
  • func (q *Queue) Events() chan *event.Entity
  • func (q *Queue) SyncProduce(_ context.Context, event *event.Entity) error

Types

type Queue

type Queue struct {
	Kafka     *kafka.Entity
	EventChan chan *event.Entity
	ErrorChan chan error
}

func (*Queue) Consume

func (q *Queue) Consume(ctx context.Context) error

* 仅支持以 consumer group 的方式获取kafka的数据

func (*Queue) ConsumeWithHandler

func (q *Queue) ConsumeWithHandler(ctx context.Context, handler abstract.ConsumeHandler) error

func (*Queue) Errors

func (q *Queue) Errors() chan error

func (*Queue) Events

func (q *Queue) Events() chan *event.Entity

func (*Queue) SyncProduce

func (q *Queue) SyncProduce(_ context.Context, event *event.Entity) error