plugin

type Channel interface {
	Close() error
	Push(record element.Record) error
	Pull() (element.Record, error)
	Size() int
	IsClosed() bool
}

type ChannelFactory interface {
	CreateChannel(maxSize int) Channel
}

type PluginRegistry interface {
	RegisterReaderJob(name string, factory ReaderJobFactory) error
	RegisterReaderTask(name string, factory ReaderTaskFactory) error
	RegisterWriterJob(name string, factory WriterJobFactory) error
	RegisterWriterTask(name string, factory WriterTaskFactory) error

	GetReaderJob(name string) (ReaderJobFactory, error)
	GetReaderTask(name string) (ReaderTaskFactory, error)
	GetWriterJob(name string) (WriterJobFactory, error)
	GetWriterTask(name string) (WriterTaskFactory, error)

	ListReaderPlugins() []string
	ListWriterPlugins() []string
}

type PluginType int

type Reader interface {
	Init(config config.Configuration) error
	Destroy() error
}

type ReaderJob interface {
	Reader
	Split(adviceNumber int) ([]config.Configuration, error)
	Post() error
}

type ReaderJobFactory interface {
	CreateReaderJob() ReaderJob
}

type ReaderTask interface {
	Reader
	StartRead(recordSender RecordSender) error
	Post() error
}

type ReaderTaskFactory interface {
	CreateReaderTask() ReaderTask
}

type ReaderTaskWithContext interface {
	ReaderTask
	StartReadWithContext(recordSender RecordSender, ctx context.Context) error
}

type RecordReceiver interface {
	GetFromReader() (element.Record, error)
	Shutdown() error
}

type RecordSender interface {
	SendRecord(record element.Record) error
	Flush() error
	Terminate() error
	Shutdown() error
}

type SenderReceiverFactory interface {
	CreateRecordSender(channel Channel) RecordSender
	CreateRecordReceiver(channel Channel) RecordReceiver
}

type Writer interface {
	Init(config config.Configuration) error
	Destroy() error
}

type WriterJob interface {
	Writer
	Split(mandatoryNumber int) ([]config.Configuration, error)
	Post() error
	Prepare() error
}

type WriterJobFactory interface {
	CreateWriterJob() WriterJob
}

type WriterTask interface {
	Writer
	StartWrite(recordReceiver RecordReceiver) error
	Post() error
	Prepare() error
}

type WriterTaskFactory interface {
	CreateWriterTask() WriterTask
}

type WriterTaskWithContext interface {
	WriterTask
	StartWriteWithContext(recordReceiver RecordReceiver, ctx context.Context) error
}