scheduler

package

v0.1.1 Latest Latest Go to latest Published: May 14, 2026 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Scheduler manages the worker pool and task distribution

func New(cfg *config.Config) *Scheduler

New creates a new Scheduler instance

func (s *Scheduler) GetResults() []map[string]interface{}

GetResults returns the collected results after processing

func (s *Scheduler) Start(ctx context.Context)

Start spins up the worker pool and begins processing tasks

func (s *Scheduler) Wait()

Wait blocks until all workers finish