orchestrator

Documentation

Index

• type ScheduledTask
• type TaskScheduler
  • func (ts *TaskScheduler) Schedule(ctx context.Context, task *ProcessingTask, priority TaskPriority) (*ScheduledTask, error)

Types

type ScheduledTask

type ScheduledTask struct {
	Task           *ProcessingTask
	Priority       TaskPriority
	ScheduledTime  time.Time
	EstimatedStart time.Time
	Resources      ResourceRequirements
}

type TaskScheduler

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

func (*TaskScheduler) Schedule

func (ts *TaskScheduler) Schedule(
	ctx context.Context,
	task *ProcessingTask,
	priority TaskPriority,
) (*ScheduledTask, error)