Documentation
¶
Index ¶
Constants ¶
View Source
const ( StartContainerDuration = 15 * time.Second ResourceMonitorDuration = 5 * time.Second )
View Source
const (
AvailabilityCheckSleepDuration = 5 * time.Second
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IControlPlane ¶
type IControlPlane interface {
Start()
GracefullyShutdown()
CheckTheDistributedTask()
}
func ProvideControlPlaneDaemon ¶
func ProvideControlPlaneDaemon( workerNodePool pool.WorkerNode, controlPlaneService handlerservice.IControlPlane, taskService service.Task, jobService service.Job, cpTaskWatcher service.CPTaskWatcher, config config.ControlPlaneConfigModel, ) (IControlPlane, func())
type WorkerNode ¶
type WorkerNode interface {
Start()
}
func ProvideWorkerNodeDaemon ¶
func ProvideWorkerNodeDaemon( dockerClient *client.Client, workerService handlerservice.IWorker, resourceMonitor service.IResourceMonitor, dynamicScaling service.IDynamicScaling, containerTakeDownLogic workerlogic.ContainerTakeDown, containerService service.IContainer, ) WorkerNode
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.