processmanager

type FirecrackerProcessManager struct {
	// contains filtered or unexported fields
}

type ProcessDelegate interface {
	// Indicates that an agent process with the given id has been started and is ready to be "prepared" for workload deployment
	OnProcessStarted(id string)
}

type ProcessInfo struct {
	DeployRequest *agentapi.DeployRequest
	ID            string
	Name          string
	Namespace     string
}

type ProcessManager interface {
	// Returns a list of agent processes in an implementation-agnostic format
	ListProcesses() ([]ProcessInfo, error)

	// Lookup a deploy request by id. Returns nil when attempting to lookup an "unprepared" workload
	Lookup(id string) (*agentapi.DeployRequest, error)

	// Associate a deploy request with the given workload id, and perform any
	// just in time initialization of resources if necessary
	PrepareWorkload(id string, request *agentapi.DeployRequest) error

	// Start the process manager and allocate a pool of agents based on an implementation-specific
	// strategy, delegating callbacks to the given delegate
	Start(delegate ProcessDelegate) error

	// Stop the process manager and gracefully shutdown all agents in the pool
	Stop() error

	// Terminate a running agent process with the given ID
	StopProcess(id string) error

	// Notifies the process manager that the node is in lame duck mode, so that the processes
	// can be treated differerently (if applicable)
	EnterLameDuck() error
}

type SpawningProcessManager struct {
	// contains filtered or unexported fields
}