groupHandler

Documentation

Index

• type AnalysisConsumerGroupHandler
  • func NewAnalysisConsumerGroupHandler(scanner *scanner.Scanner, producer *producer.IProducer, ...) *AnalysisConsumerGroupHandler
  • func NewAnalysisConsumerGroupHandlerDefault(scanner *scanner.Scanner, producer *producer.IProducer) *AnalysisConsumerGroupHandler
  • func (h *AnalysisConsumerGroupHandler) Cleanup(session sarama.ConsumerGroupSession) error
  • func (h *AnalysisConsumerGroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (h *AnalysisConsumerGroupHandler) Setup(session sarama.ConsumerGroupSession) error

Types

type AnalysisConsumerGroupHandler

type AnalysisConsumerGroupHandler struct {
	Topics      []string
	TopicsError []string
	Log         logservice.ILogger
	// contains filtered or unexported fields
}

func NewAnalysisConsumerGroupHandler

func NewAnalysisConsumerGroupHandler(scanner *scanner.Scanner, producer *producer.IProducer, topics, topicsError []string, logService logservice.ILogger) *AnalysisConsumerGroupHandler

func NewAnalysisConsumerGroupHandlerDefault

func NewAnalysisConsumerGroupHandlerDefault(scanner *scanner.Scanner, producer *producer.IProducer) *AnalysisConsumerGroupHandler

func (*AnalysisConsumerGroupHandler) Cleanup

func (h *AnalysisConsumerGroupHandler) Cleanup(session sarama.ConsumerGroupSession) error

func (*AnalysisConsumerGroupHandler) ConsumeClaim

func (h *AnalysisConsumerGroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (*AnalysisConsumerGroupHandler) Setup

func (h *AnalysisConsumerGroupHandler) Setup(session sarama.ConsumerGroupSession) error