scheduler

type ScheduleTaskResult struct {
	TaskID        string
	CorrelationID string
	Driver        string
	ResourceURI   string
	ScheduleTime  time.Time
}

type Service struct {
	Scheduler       TaskScheduler
	StateRepository state.Repository
	FactoryID       factory.Identifier
}

type TaskScheduler interface {
	Schedule(ctx context.Context, tasks []boltzmann.Task) ([]ScheduleTaskResult, error)
}

type TaskSchedulerDefault struct {
	AgentRegistry   agent.Registry
	QueueService    queue.Queue
	StateRepository state.Repository
}