org.jenkinsci.plugins.mesos

Class MesosJenkinsAgent

java.lang.Object

hudson.model.AbstractModelObject

hudson.model.Node

hudson.model.Slave

hudson.slaves.AbstractCloudSlave

org.jenkinsci.plugins.mesos.MesosJenkinsAgent

All Implemented Interfaces:

hudson.ExtensionPoint, hudson.model.Describable<hudson.model.Node>, hudson.model.ModelObject, hudson.model.ReconfigurableDescribable<hudson.model.Node>, hudson.model.Saveable, hudson.search.SearchableModelObject, hudson.search.SearchItem, hudson.security.AccessControlled, hudson.slaves.EphemeralNode, java.io.Serializable, jenkins.util.io.OnMaster

public class MesosJenkinsAgent
extends hudson.slaves.AbstractCloudSlave
implements hudson.slaves.EphemeralNode

Representation of a Jenkins node on Mesos.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class hudson.model.Slave

hudson.model.Slave.JnlpJar, hudson.model.Slave.SlaveDescriptor

Nested classes/interfaces inherited from class hudson.model.Node

hudson.model.Node.InternalComputerListener, hudson.model.Node.Mode

Nested classes/interfaces inherited from interface hudson.ExtensionPoint

hudson.ExtensionPoint.LegacyInstancesAreScopedToHudson

Field Summary

Fields inherited from class hudson.model.Slave

name, remoteFS

Fields inherited from class hudson.model.Node

holdOffLaunchUntilSave, SKIP_BUILD_CHECK_ON_FLYWEIGHTS

Fields inherited from interface hudson.model.Saveable

NOOP

Constructor Summary

Constructors

Constructor and Description
MesosJenkinsAgent(MesosApi api, java.lang.String name, MesosAgentSpecTemplate spec, java.lang.String nodeDescription, java.net.URL jenkinsUrl, java.lang.Integer idleTerminationInMinutes, boolean reusable, java.util.List<? extends hudson.slaves.NodeProperty<?>> nodeProperties, java.time.Duration agentTimeout)

Method Summary

Modifier and Type	Method and Description
protected void	_terminate(hudson.model.TaskListener listener)
hudson.model.Node	asNode()
hudson.slaves.AbstractCloudComputer	createComputer()
java.lang.String	getPodId() get the podId tied to this task.
boolean	getReusable()
boolean	isKilled()
boolean	isOnline()
boolean	isPending()
boolean	isRunning()
boolean	isTerminalOrUnreachable()
void	update(com.mesosphere.usi.core.models.PodStatusUpdatedEvent event) Updates the state of the slave and takes action on certain events.
java.util.concurrent.CompletableFuture<hudson.model.Node>	waitUntilOnlineAsync(akka.stream.ActorMaterializer materializer) Polls the agent until it is online.

Methods inherited from class hudson.slaves.AbstractCloudSlave

terminate

Methods inherited from class hudson.model.Slave

createLauncher, equals, getClockDifferenceCallable, getComputer, getDescriptor, getLabelString, getLauncher, getMode, getNodeDescription, getNodeName, getNodeProperties, getNumExecutors, getRemoteFS, getRetentionStrategy, getRootPath, getUserId, getWorkspaceFor, getWorkspaceRoot, hashCode, readResolve, setLabelString, setLauncher, setMode, setNodeDescription, setNodeName, setNodeProperties, setNumExecutors, setRetentionStrategy, setUserId, toString

Methods inherited from class hudson.model.Node

canTake, canTake, createPath, getACL, getAssignedLabels, getChannel, getClockDifference, getDisplayName, getFileSystemProvisioner, getLabelCloud, getNodeProperty, getNodeProperty, getNodePropertyDescriptors, getSearchUrl, getSelfLabel, isAcceptingTasks, isHoldOffLaunchUntilSave, reconfigure, save, toComputer

Methods inherited from class hudson.model.AbstractModelObject

getSearch, getSearchIndex, getSearchName, makeSearchIndex, requirePOST, sendError, sendError, sendError, sendError, sendError

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface hudson.security.AccessControlled

checkPermission, hasPermission, hasPermission

Constructor Detail

MesosJenkinsAgent

public MesosJenkinsAgent(MesosApi api,
                         java.lang.String name,
                         MesosAgentSpecTemplate spec,
                         java.lang.String nodeDescription,
                         java.net.URL jenkinsUrl,
                         java.lang.Integer idleTerminationInMinutes,
                         boolean reusable,
                         java.util.List<? extends hudson.slaves.NodeProperty<?>> nodeProperties,
                         java.time.Duration agentTimeout)
                  throws hudson.model.Descriptor.FormException,
                         java.io.IOException

Throws:

hudson.model.Descriptor.FormException

java.io.IOException

Method Detail

waitUntilOnlineAsync

public java.util.concurrent.CompletableFuture<hudson.model.Node> waitUntilOnlineAsync(akka.stream.ActorMaterializer materializer)

Polls the agent until it is online. Note: This is a non-blocking call in contrast to the blocking Computer.waitUntilOnline().

Returns:

The future agent that will come online.

isRunning

public boolean isRunning()

Returns:

whether the agent is running or not.

isKilled

public boolean isKilled()

Returns:

whether the agent is killed or not.

isTerminalOrUnreachable

public boolean isTerminalOrUnreachable()

Returns:

whether the agent is terminal or unreachable.

isOnline

public boolean isOnline()

Returns:

whether the Jenkins agent connected and is online.

isPending

public boolean isPending()

Returns:

whether the agent is launching and not connected yet.

update

public void update(com.mesosphere.usi.core.models.PodStatusUpdatedEvent event)

Updates the state of the slave and takes action on certain events.

Parameters:

event - The state event from USI which informs about the task status.

asNode

public hudson.model.Node asNode()

Specified by:

asNode in interface hudson.slaves.EphemeralNode

createComputer

public hudson.slaves.AbstractCloudComputer createComputer()

Overrides:

createComputer in class hudson.slaves.AbstractCloudSlave

_terminate

protected void _terminate(hudson.model.TaskListener listener)

Specified by:

_terminate in class hudson.slaves.AbstractCloudSlave

getReusable

public boolean getReusable()

getPodId

public java.lang.String getPodId()

get the podId tied to this task.