scheduler

package

v1.5.7 Latest Latest Go to latest Published: Sep 2, 2024 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Scheduler struct {
	*logger.Logger

	Tasks []types.ITask
	// contains filtered or unexported fields
}

func NewScheduler(
	ctx context.Context,
	log *logger.Logger,
	tasks []types.ITask,
	ss common.ServiceStatus,
	numOfConcurrencies int,
) *Scheduler

func (r *Scheduler) Interrupt()

func (r *Scheduler) Release() ([]types.ITask, error)

func (r *Scheduler) Run(ctx context.Context) error

func (r *Scheduler) SetIgnore(t types.ITask)