X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/0b0b4c7b23e96a6efb3cfd88b0ba7224158e9544..14d8cfa18f28586ad296e3e598d0a2a536be0613:/lib/crunchrun/executor.go diff --git a/lib/crunchrun/executor.go b/lib/crunchrun/executor.go index c773febe94..1ed460acd9 100644 --- a/lib/crunchrun/executor.go +++ b/lib/crunchrun/executor.go @@ -6,6 +6,7 @@ package crunchrun import ( "io" + "git.arvados.org/arvados.git/sdk/go/arvados" "golang.org/x/net/context" ) @@ -15,31 +16,29 @@ type bindmount struct { } type containerSpec struct { - Image string - VCPUs int - RAM int64 - WorkingDir string - Env map[string]string - BindMounts map[string]bindmount - Command []string - EnableNetwork bool - NetworkMode string // docker network mode, normally "default" - CgroupParent string - Stdin io.ReadCloser - Stdout io.WriteCloser - Stderr io.WriteCloser + Image string + VCPUs int + RAM int64 + WorkingDir string + Env map[string]string + BindMounts map[string]bindmount + Command []string + EnableNetwork bool + CUDADeviceCount int + NetworkMode string // docker network mode, normally "default" + CgroupParent string + Stdin io.Reader + Stdout io.Writer + Stderr io.Writer } // containerExecutor is an interface to a container runtime // (docker/singularity). type containerExecutor interface { - // ImageLoaded determines whether the given image is already - // available to use without calling ImageLoad. - ImageLoaded(imageID string) bool - // ImageLoad loads the image from the given tarball such that // it can be used to create/start a container. - LoadImage(filename string) error + LoadImage(imageID string, imageTarballPath string, container arvados.Container, keepMount string, + containerClient *arvados.Client) error // Wait for the container process to finish, and return its // exit code. If applicable, also remove the stopped container @@ -60,4 +59,9 @@ type containerExecutor interface { // Release resources (temp dirs, stopped containers) Close() + + // Name and version of runtime engine ("docker 20.10.16", "singularity-ce version 3.9.9") + Runtime() string + + GatewayTarget }