X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/e8f99cfef7cfbfcf1a1485d69250f24ced3fd609..5a33764685ef7fa9578b255e78ad2ed77abc1ded:/lib/dispatchcloud/scheduler/interfaces.go diff --git a/lib/dispatchcloud/scheduler/interfaces.go b/lib/dispatchcloud/scheduler/interfaces.go index 59700c3935..78f8c804e2 100644 --- a/lib/dispatchcloud/scheduler/interfaces.go +++ b/lib/dispatchcloud/scheduler/interfaces.go @@ -7,13 +7,14 @@ package scheduler import ( "time" - "git.curoverse.com/arvados.git/lib/dispatchcloud/container" - "git.curoverse.com/arvados.git/lib/dispatchcloud/worker" - "git.curoverse.com/arvados.git/sdk/go/arvados" + "git.arvados.org/arvados.git/lib/dispatchcloud/container" + "git.arvados.org/arvados.git/lib/dispatchcloud/worker" + "git.arvados.org/arvados.git/sdk/go/arvados" ) // 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,17 @@ 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) bool + ForgetContainer(uuid string) Subscribe() <-chan struct{} Unsubscribe(<-chan struct{}) }