consumer

Documentation

Index

• type V1ConsumerEvents
  • func V1ConsumerEventsHandler() *V1ConsumerEvents
  • func (consumer *V1ConsumerEvents) Consume(topics []string, signals chan os.Signal)
• type V1ConsumerEventsInterface

Types

type V1ConsumerEvents

type V1ConsumerEvents struct {
	Kafka  kafka.KafkaLibraryInterface
	Logger logger.LoggerInterface
}

V1ConsumerEvents ...

func V1ConsumerEventsHandler

func V1ConsumerEventsHandler() *V1ConsumerEvents

V1ConsumerEventsHandler ...

func (*V1ConsumerEvents) Consume

func (consumer *V1ConsumerEvents) Consume(topics []string, signals chan os.Signal)

Consume ...

type V1ConsumerEventsInterface

type V1ConsumerEventsInterface interface {
	Consume(topics []string, signals chan os.Signal)
}

V1ConsumerEventsInterface ...