Versions in this module Expand all Collapse all v0 v0.1.7 Jan 5, 2026 v0.1.6 Jan 1, 2026 Changes in this version + type Store interface + PersistData func(ctx context.Context, data *schemas.ResultEnvelope) error + type TaskEngine struct + func New(cfg config.Interface, logger *zap.Logger, storeService Store, worker Worker, ...) (*TaskEngine, error) + func (e *TaskEngine) Start(ctx context.Context, taskChan <-chan schemas.Task) + func (e *TaskEngine) Stop() + type Worker interface + ProcessTask func(ctx context.Context, analysisCtx *core.AnalysisContext) error
Go to main page