scheduler

Documentation

Index

• type Scheduler
  • func New(e Scheduler) *Scheduler
  • func (e *Scheduler) CleanTarget(target *graph.Target, async bool) error
  • func (e *Scheduler) Run(ctx context.Context, rr targetrun.Request, iocfg sandbox.IOConfig, ...) error
  • func (e *Scheduler) RunWithSpan(ctx context.Context, rr targetrun.Request, iocfg sandbox.IOConfig, ...) (rerr error)
  • func (e *Scheduler) ScheduleGenPass(ctx context.Context, genTargets []*graph.Target) (_ worker2.Dep, rerr error)
  • func (e *Scheduler) ScheduleTargetRRsWithDeps(octx context.Context, rrs targetrun.Requests, skip []specs.Specer) (*WaitGroupMap, *worker2.RunningTracker, error)
  • func (e *Scheduler) ScheduleTargetsWithDeps(ctx context.Context, targets []*graph.Target, pullCache bool, ...) (*WaitGroupMap, *worker2.RunningTracker, error)
• type WaitGroupMap
  • func (wgm *WaitGroupMap) All() worker2.Dep
  • func (wgm *WaitGroupMap) Get(s string) worker2.Dep
  • func (wgm *WaitGroupMap) List() []worker2.Dep

Types

type Scheduler

type Scheduler struct {
	Cwd               string
	Root              *hroot.State
	Config            *config.Config
	Observability     *observability.Observability
	GetFlowID         func() string
	LocalCache        *lcache.LocalCacheState
	RemoteCache       *rcache.RemoteCache
	RemoteCacheHints  *rcache.HintStore
	Packages          *packages.Registry
	BuildFilesState   *buildfiles.State
	Graph             *graph.State
	Pool              *worker2.Engine
	BackgroundTracker *worker2.RunningTracker
	Finalizers        *finalizers.Finalizers
	Runner            *targetrun.Runner
	GitStatus         *gitstatus.GitStatus
	// contains filtered or unexported fields
}

func New

func New(e Scheduler) *Scheduler

func (*Scheduler) CleanTarget

func (e *Scheduler) CleanTarget(target *graph.Target, async bool) error

func (*Scheduler) Run

func (e *Scheduler) Run(ctx context.Context, rr targetrun.Request, iocfg sandbox.IOConfig, tracker *worker2.RunningTracker) error

func (*Scheduler) RunWithSpan

func (e *Scheduler) RunWithSpan(ctx context.Context, rr targetrun.Request, iocfg sandbox.IOConfig, tracker *worker2.RunningTracker) (rerr error)

func (*Scheduler) ScheduleGenPass

func (e *Scheduler) ScheduleGenPass(ctx context.Context, genTargets []*graph.Target) (_ worker2.Dep, rerr error)

func (*Scheduler) ScheduleTargetRRsWithDeps

func (e *Scheduler) ScheduleTargetRRsWithDeps(octx context.Context, rrs targetrun.Requests, skip []specs.Specer) (*WaitGroupMap, *worker2.RunningTracker, error)

func (*Scheduler) ScheduleTargetsWithDeps

func (e *Scheduler) ScheduleTargetsWithDeps(ctx context.Context, targets []*graph.Target, pullCache bool, skip []specs.Specer) (*WaitGroupMap, *worker2.RunningTracker, error)

type WaitGroupMap

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

func (*WaitGroupMap) All

func (wgm *WaitGroupMap) All() worker2.Dep

func (*WaitGroupMap) Get

func (wgm *WaitGroupMap) Get(s string) worker2.Dep

func (*WaitGroupMap) List

func (wgm *WaitGroupMap) List() []worker2.Dep