X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/dfb9598282b677ead60f91c14f5e96405735d42f..98db65de63c9e2acfeae6636ccc619171635bda0:/lib/dispatchcloud/dispatcher.go?ds=sidebyside diff --git a/lib/dispatchcloud/dispatcher.go b/lib/dispatchcloud/dispatcher.go index 19c8f6e0b4..02b6c976ae 100644 --- a/lib/dispatchcloud/dispatcher.go +++ b/lib/dispatchcloud/dispatcher.go @@ -82,6 +82,11 @@ func (disp *dispatcher) CheckHealth() error { return disp.pool.CheckHealth() } +// Done implements service.Handler. +func (disp *dispatcher) Done() <-chan struct{} { + return disp.stopped +} + // Stop dispatching containers and release resources. Typically used // in tests. func (disp *dispatcher) Close() { @@ -148,7 +153,7 @@ func (disp *dispatcher) initialize() { } else { mux := httprouter.New() mux.HandlerFunc("GET", "/arvados/v1/dispatch/containers", disp.apiContainers) - mux.HandlerFunc("POST", "/arvados/v1/dispatch/containers/kill", disp.apiInstanceKill) + mux.HandlerFunc("POST", "/arvados/v1/dispatch/containers/kill", disp.apiContainerKill) mux.HandlerFunc("GET", "/arvados/v1/dispatch/instances", disp.apiInstances) mux.HandlerFunc("POST", "/arvados/v1/dispatch/instances/hold", disp.apiInstanceHold) mux.HandlerFunc("POST", "/arvados/v1/dispatch/instances/drain", disp.apiInstanceDrain)