X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/de9d45e3a238df8e9f0b2833b86c5e54fec37c7a..5a33764685ef7fa9578b255e78ad2ed77abc1ded:/lib/dispatchcloud/scheduler/interfaces.go diff --git a/lib/dispatchcloud/scheduler/interfaces.go b/lib/dispatchcloud/scheduler/interfaces.go index e1b575c8a6..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,7 +29,7 @@ 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 @@ -37,7 +38,8 @@ type WorkerPool interface { 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{}) }