plugin

type Config struct {
	Mock mock.Config `mapstructure:"mock"`
}

type Plugin interface {
	Exec(ctx context.Context, rec *record.Record, stream io.Reader) error
	Filter(recs []*record.Record) []*record.Record
	Batches(recs []*record.Record) []*batch.Batch
	UpgradeVersion(ctx context.Context, version int) error
	GetVersion(ctx context.Context) (int, error)
	Dispose(ctx context.Context) error
}