sweep

type Event struct {
	Type string
	Data interface{}
}

type Manager struct {
	Cancel context.CancelFunc
	// contains filtered or unexported fields
}

type Sweep[C any, R any] struct {
	Generator     func(config chan C, manager Manager)
	Worker        func(config C, results chan R, events chan Event, manager Manager)
	OnEvent       func(event WorkerEvent[C])
	GetWorkerName func(config C) string
	MaxWorkers    int
}

type WorkerDescription[C any] struct {
	ID        int
	Config    C
	Name      string
	StartTime time.Time
	EndTime   time.Time
}

type WorkerEvent[C any] struct {
	Description WorkerDescription[C]
	Event       Event
	Time        time.Time
}

type WorkerResult[C any, R any] struct {
	Description WorkerDescription[C]
	Result      R
	Time        time.Time
}