consumer

type Builder interface {
	Config() *Config
	Build(options ...BuilderOption) (Consumer, error)
}

type BuilderOption func(config *Config)

type Config struct {
	Id               string
	GroupId          string
	BootstrapServers []string
	MetricsReporter  metrics.Reporter
	Logger           log.Logger

	*sarama.Config
	// contains filtered or unexported fields
}

type Consumer interface {
	Consume(tps []string, handler ReBalanceHandler) (chan Partition, error)
	Errors() <-chan *Error
	Close() error
}

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

type Event interface {
	String() string
}

type MockConsumerBuilder struct {
	Builder
	// contains filtered or unexported fields
}

type MockPartitionConsumerBuilder struct {
	PartitionConsumerBuilder
	// contains filtered or unexported fields
}

type Offset int64

type Option func(*consumerOptions)

type Partition interface {
	Records() <-chan *data.Record
	Partition() TopicPartition
	MarkOffset(offset int64)
	CommitOffset(*data.Record) error
}

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

type PartitionConsumer interface {
	Consume(topic string, partition int32, offset Offset) (<-chan Event, error)
	Errors() <-chan *Error
	Close() error
	Id() string
}

type PartitionConsumerBuilder interface {
	Config() *Config
	Build(options ...BuilderOption) (PartitionConsumer, error)
}

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

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

type ReBalanceHandler interface {
	OnPartitionRevoked(ctx context.Context, revoked []TopicPartition) error
	OnPartitionAssigned(ctx context.Context, assigned []TopicPartition) error
}

type RecordUuidExtractFunc func(message *data.Record) uuid.UUID

type TopicPartition struct {
	Topic     string
	Partition int32
}