docker-runner/dev.ust.zinc.grader.virtualization.docker/DaemonHost

DaemonHost

abstract class DaemonHost

The internal representation of a DockerDaemon.

Inheritors

EngineTrackedDaemonHost

LocallyTrackedDaemonHost

Constructors

DaemonHost

constructor()

Types

Companion

object Companion

TrackedRunner

abstract class TrackedRunner

Properties

cpuFree

abstract val cpuFree: Double

The current amount of unallocated CPU.

cpuOvercommitRatio

protected val cpuOvercommitRatio: Double

daemon

abstract val daemon: DockerDaemon

Encapsulated Docker daemon.

gpuAllocation

open val gpuAllocation: Map<GpuDevice, Boolean>

Mapping of all GPUs on the host system to its occupancy status.

gpuCapabilities

abstract val gpuCapabilities: Map<GpuDevice, Runner?>

Mapping of all GPUs on the host system to the allocated Runner.

hostReservedCpu

protected val hostReservedCpu: Double

hostReservedMem

protected val hostReservedMem: Long

isConnected

val isConnected: Boolean

Whether this daemon is connected to the Docker Engine.

isDispatchable

open val isDispatchable: Boolean

Whether this daemon can be used for dispatched.

isInitialized

abstract val isInitialized: Boolean

Whether this daemon is initialized.

isMainHost

abstract val isMainHost: Boolean

Whether to treat this daemon host as a main host, i.e. reserve more resources for the host OS and its services.

managedRunners

open val managedRunners: List<Runner>

A List of all runners managed by this DaemonHost.

maxCpuAlloc

abstract val maxCpuAlloc: Double

The maximum amount of allocatable CPU by runners.

maxMemAlloc

abstract val maxMemAlloc: Long

The maximum amount of allocatable memory by runners.

memFree

abstract val memFree: Long

The current amount of unallocated memory.

memOvercommitRatio

protected val memOvercommitRatio: Double

trackedRunners

abstract val trackedRunners: List<DaemonHost.TrackedRunner>

A List of all runners tracked by this DaemonHost, stored as instances of TrackedRunner.

Functions

addRunnerInstance

abstract fun addRunnerInstance(runner: Runner)

Binds runner to this Docker daemon.

canSatisfyCpuLimit

fun canSatisfyCpuLimit(context: DockerContext): Boolean

canSatisfyGpuRequest

fun canSatisfyGpuRequest(context: DockerContext): Boolean

canSatisfyMemLimit

fun canSatisfyMemLimit(context: DockerContext): Boolean

canSatisfyWithMaxResource

fun canSatisfyWithMaxResource(context: DockerContext): Boolean

containsRunner

fun containsRunner(runner: Runner): Boolean

getAllocatedGpu

abstract fun getAllocatedGpu(runner: Runner): GpuDevice?

getOutputFromContainer

private fun getOutputFromContainer(cmd: String, timeout: Duration, containerConfig: CreateContainerCmd.() -> Unit = {}): String

Wrapper for getting the stdout output from a container using the given cmd.

queryGpuCapabilities

protected fun queryGpuCapabilities(): List<GpuDevice>

Queries the list of GPUs present on this daemon host.

removeRunnerInstance

abstract fun removeRunnerInstance(runner: Runner)

Unbinds runner to this Docker daemon.

updateEngineInfo

abstract fun updateEngineInfo()

Tries to update the information of the engine from the daemon.