tasks

type Buffer interface {
	Init() error
	Add(record *Record) error
	Flush() error
	Close() error
	Reset(dueTo error) error
	Records() []*Record
}

type BufferConfig struct {
	// Size defines the min num of records before the flush
	// starts(This includes messages in the state store changelogs).
	// Please note that this value has to be lesser than the
	// producer queue.buffering.max.messages
	// Deprecated no longer applicable
	Size int
	// FlushInterval defines minimum wait time before the flush starts
	FlushInterval time.Duration
}

type FailedMessageHandler func(err error, record kafka.Record)

type Generator struct{}

type OnFlush func(records []*Record) error

type Record struct {
	kafka.Record
	// contains filtered or unexported fields
}

type Task interface {
	ID() TaskID
	Init() error
	Restore() error
	Sync() error
	Ready() error
	Start(ctx context.Context, claim kafka.PartitionClaim, groupSession kafka.GroupSession)
	Store(name string) topology.StateStore
	Stop() error
}

type TaskAssignment []*TaskMapping

type TaskContext struct {
	context.Context
}

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

type TaskID interface {
	String() string
	UniqueID() string
	Partition() int32
	Topics() string
}

type TaskManager interface {
	NewTaskId(prefix string, tp kafka.TopicPartition) TaskID
	AddTask(ctx topology.BuilderContext, id TaskID, topology topology.SubTopologyBuilder, session kafka.GroupSession) (Task, error)
	AddGlobalTask(ctx topology.BuilderContext, id TaskID, topology topology.SubTopologyBuilder) (Task, error)
	RemoveTask(id TaskID) error
	Task(id TaskID) (Task, error)
	StoreInstances(name string) []topology.StateStore
}

type TaskMapping struct {
	TPs []kafka.TopicPartition
	// contains filtered or unexported fields
}

type TaskOpt func(*taskOptions)