gkc

type Consumer interface {

	// Name returns the name of this consumer group.
	Name() string

	// Topics returns the names of the topics being consumed.
	Topics() []string

	// Start starts the consumer
	Start() error
	// Stop stops the consumer
	Stop() error
	// Closed returns a channel which will be closed after this consumer is completely shutdown
	Closed() <-chan struct{}
	// Messages return the message channel for this consumer
	// Messages() <-chan Message
	Messages() <-chan *Message

	DisableLog()
}

type ConsumerConfig struct {
	// GroupName identifies your consumer group. Unless your application creates
	// multiple consumer groups (in which case it's suggested to have application name as
	// prefix of the group name), this should match your application name.
	GroupName string

	// Topic is the name of topic to consume from.
	Topics []string

	// Broker is the list of brokers in the kafka cluster to consume from.
	Broker string

	// Defines the logic after processing the kafka message
	MessageHook Hook

	// Defines the logic after processing the failed kafka message from DLQ
	ErrorHook Hook

	// Enable prometheus metrics
	ExposeMetrics bool

	// Prometheus address to export metrics on
	Address string
}

type Counter interface {
	UpdateTotal(float64)
	UpdateSuccess(float64)
	UpdateLatency(time.Duration)
}

type Hook interface {
	Execute(*Message) error
}

type HookFunc func(*Message) error

type Message struct {
	*kafka.Message
}

type Options struct {
	RcvBufferSize        int // aggregate message buffer size
	Concurrency          int // number of goroutines that will concurrently process messages
	OffsetCommitInterval time.Duration
	ConsumerGroupNumber  int // No of goroutines to run to consume from n different partitions
}