scheduler

Documentation

Index

• type Clock
  • func NewClock() Clock
• type ScheduledBuild
• type Scheduler
  • func NewScheduler(l lager.Logger, b builder.Builder, clock Clock) Scheduler

Types

type Clock

type Clock interface {
	CurrentTime() time.Time
}

func NewClock

func NewClock() Clock

type ScheduledBuild

type ScheduledBuild struct {
	Build     turbine.Build
	Status    turbine.Status
	ProcessID uint32
	EventHub  *event.Hub
	// contains filtered or unexported fields
}

type Scheduler

type Scheduler interface {
	Start(turbine.Build)
	Restore(ScheduledBuild)
	Abort(guid string)
	Hijack(guid string, process gapi.ProcessSpec, io gapi.ProcessIO) (gapi.Process, error)
	Subscribe(guid string, from uint) (<-chan event.Event, chan<- struct{}, error)
	Delete(guid string)

	Drain() []ScheduledBuild
}

func NewScheduler

func NewScheduler(
	l lager.Logger,
	b builder.Builder,
	clock Clock,
) Scheduler