baseminer

Apr 11, 2024

Changes in this version

+ var ErrNilTask = errors.New("nil task")

+ var ErrParserTasksWasClosed = errors.New("tasks was closed")

+ var ErrSaverTasksWasClosed = errors.New("tasks was closed")

+ var ErrSrcDataClosed = errors.New("source of src data was closed")

+ var ErrSrcDataIsNil = errors.New("src data is nil")

+ type DataParser interface

+ Parse func(ctx context.Context, data *TSrcData) (*TPreSaverData, error)

+ type DataSource interface

+ Close func()

+ SrcData func() <-chan *TSrcData

+ type MHandler struct

+ func NewMHandler[TCheckPoint any, TSrcData any, TPreSaverData any, TSaverData any](ctx context.Context, stor Storage[TCheckPoint, TSaverData], ...) *MHandler[TCheckPoint, TSrcData, TPreSaverData, TSaverData]

+ func (mh *MHandler[TCheckPoint, TSrcData, TPreSaverData, TSaverData]) RunHandler(ctx context.Context) error

+ type PreSaver interface

+ PreSaveProcess func(ctx context.Context, prevChp *TCheckPoint, data []*TPreSaverData) (TCheckPoint, *TSaverData, error)

+ type Storage interface

+ FindCheckPoint func(ctx context.Context) (*TCheckPoint, bool, error)

+ Save func(ctx context.Context, chp TCheckPoint, data *TSaverData) (TCheckPoint, error)