processlog

Documentation

Index

• type Consumer
  • func NewConsumer(grpc *grpc.ClientConn, wg *sync.WaitGroup) *Consumer
  • func (c *Consumer) Cleanup(sarama.ConsumerGroupSession) error
  • func (c *Consumer) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (c *Consumer) Setup(sarama.ConsumerGroupSession) error

Types

type Consumer

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

func NewConsumer

func NewConsumer(grpc *grpc.ClientConn, wg *sync.WaitGroup) *Consumer

func (*Consumer) Cleanup

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

func (*Consumer) ConsumeClaim

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

func (*Consumer) Setup

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