X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/949d940b5f75114f86d381c347f0ba8f26b3e9b9..cd020c016106fbe844501c5f434c16f4def4e08d:/lib/dispatchcloud/scheduler/interfaces.go?ds=sidebyside diff --git a/lib/dispatchcloud/scheduler/interfaces.go b/lib/dispatchcloud/scheduler/interfaces.go index 59700c3935..307807e323 100644 --- a/lib/dispatchcloud/scheduler/interfaces.go +++ b/lib/dispatchcloud/scheduler/interfaces.go @@ -13,7 +13,8 @@ import ( ) // A ContainerQueue is a set of containers that need to be started or -// stopped. Implemented by container.Queue and test stubs. +// stopped. Implemented by container.Queue and test stubs. See +// container.Queue method documentation for details. type ContainerQueue interface { Entries() (entries map[string]container.QueueEnt, updated time.Time) Lock(uuid string) error @@ -28,16 +29,16 @@ type ContainerQueue interface { // A WorkerPool asynchronously starts and stops worker VMs, and starts // and stops containers on them. Implemented by worker.Pool and test -// stubs. +// stubs. See worker.Pool method documentation for details. type WorkerPool interface { Running() map[string]time.Time Unallocated() map[arvados.InstanceType]int CountWorkers() map[worker.State]int AtQuota() bool - Create(arvados.InstanceType) error + Create(arvados.InstanceType) bool Shutdown(arvados.InstanceType) bool StartContainer(arvados.InstanceType, arvados.Container) bool - KillContainer(uuid string) + KillContainer(uuid, reason string) Subscribe() <-chan struct{} Unsubscribe(<-chan struct{}) }