Package com.veertu.plugin.anka

Class AnkaMgmtCloud

java.lang.Object

hudson.model.AbstractModelObject

hudson.model.Actionable

hudson.slaves.Cloud

com.veertu.plugin.anka.AnkaMgmtCloud

All Implemented Interfaces:

ExtensionPoint, Describable<Cloud>, ModelObject, SearchableModelObject, SearchItem, AccessControlled, ModelObjectWithContextMenu

public class AnkaMgmtCloud
extends Cloud

Created by asafgur on 08/05/2017.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	AnkaMgmtCloud.DescriptorImpl

Nested classes/interfaces inherited from class hudson.slaves.Cloud

Cloud.CloudState

Nested classes/interfaces inherited from interface hudson.ExtensionPoint

ExtensionPoint.LegacyInstancesAreScopedToHudson

Nested classes/interfaces inherited from interface jenkins.model.ModelObjectWithContextMenu

ModelObjectWithContextMenu.ContextMenu, ModelObjectWithContextMenu.ContextMenuVisibility, ModelObjectWithContextMenu.MenuItem, ModelObjectWithContextMenu.MenuItemType

Field Summary

Fields

Modifier and Type	Field	Description
protected int	connectionKeepAliveSeconds
protected int	maxConnections

Fields inherited from class hudson.slaves.Cloud

ALL, name, PROVISION

Constructor Summary

Constructors

Constructor	Description
AnkaMgmtCloud(String ankaMgmtUrl, String cloudName, String credentialsId, String rootCA, boolean skipTLSVerification, List<AnkaCloudSlaveTemplate> templates, int cloudInstanceCap)

Method Summary

Modifier and Type	Method	Description
void	addDynamicTemplate(DynamicSlaveTemplate template)
boolean	canProvision(Cloud.CloudState state)
static AnkaMgmtCloud	get(String cloudName)
AnkaAPI	getAnkaApi()
static List<AnkaMgmtCloud>	getAnkaClouds()
String	getAnkaMgmtUrl()
int	getCloudCapacity()
int	getCloudInstanceCap()
String	getCloudName()
static AnkaMgmtCloud	getCloudThatHasImage(String masterVMID)
int	getConnectionKeepAliveSeconds()
String	getCredentialsId()
String	getDurabilityMode()
List<DynamicSlaveTemplate>	getDynamicTemplates()
Set<String>	getExistingGroupIds()
Set<String>	getExistingTags()
Set<String>	getExistingTemplateIds()
int	getLaunchRetryWaitTime()
int	getLaunchTimeout()
int	getMaxConnections()
int	getMaxLaunchRetries()
int	getMonitorRecurrenceMinutes()
List<NodeGroup>	getNodeGroups()
NodeCountResponse	getNumOfRunningNodesPerLabel(Label label)
String	getRootCA()
boolean	getSkipTLSVerification()
int	getSshLaunchDelaySeconds()
AnkaCloudSlaveTemplate	getTemplate(Label label)
List<AnkaCloudSlaveTemplate>	getTemplates()
List<String>	getTemplateTags(String masterVmId)
int	getVmIPAssignRetries()
int	getVmIPAssignWaitSeconds()
int	getVmPollTime()
boolean	hasMasterVm(String templateId)
boolean	isOnline()
Boolean	isPushSupported()
List<AnkaVmTemplate>	listVmTemplates()
static void	Log(Slave slave, TaskListener listener, String msg)
static void	Log(SlaveComputer slave, TaskListener listener, String format, Object... args)
static void	Log(String msg)
static void	Log(String format, Object... args)
static void	markFuture(AnkaMgmtCloud cloud, AbstractAnkaSlave abstractAnkaSlave)
Collection<NodeProvisioner.PlannedNode>	provision(Cloud.CloudState state, int excessWorkload)
protected Object	readResolve()
void	removeDynamicTemplate(AbstractSlaveTemplate template)
void	saveImage(AbstractAnkaSlave node)
void	setCloudInstanceCap(int val)
void	setConnectionKeepAliveSeconds(int connectionKeepAliveSeconds)
void	setDurabilityMode(String durabilityMode)
void	setLaunchRetryWaitTime(int launchRetryWaitTime)
void	setLaunchTimeout(int launchTimeout)
void	setMaxConnections(int maxConnections)
void	setMaxLaunchRetries(int maxLaunchRetries)
void	setMonitorRecurrenceMinutes(int minutes)
void	setSshLaunchDelaySeconds(int sshLaunchDelaySeconds)
void	setVmIPAssignRetries(int vmIPAssignRetries)
void	setVmIPAssignWaitSeconds(int vmIPAssignWaitSeconds)
void	setVmPollTime(int milliseconds)
AnkaVmInstance	showInstance(String id)
void	terminateVMInstance(String id)
void	terminateVMInstance(String id, AbstractAnkaSlave node)
void	updateInstance(String vmId, String name, String jenkinsNodeLink, String jobIdentifier)

Methods inherited from class hudson.slaves.Cloud

all, canProvision, getACL, getDescriptor, getDisplayName, getSearchUrl, getUrl, provision, registerPermissions

Methods inherited from class hudson.model.Actionable

addAction, addOrReplaceAction, doContextMenu, getAction, getAction, getActions, getActions, getAllActions, getDynamic, removeAction, removeActions, replaceAction, replaceActions

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, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface hudson.security.AccessControlled

checkAnyPermission, checkPermission, hasAnyPermission, hasPermission, hasPermission, hasPermission2

Field Details

maxConnections

protected int maxConnections

connectionKeepAliveSeconds

protected int connectionKeepAliveSeconds

Constructor Details

AnkaMgmtCloud

@DataBoundConstructor
public AnkaMgmtCloud(String ankaMgmtUrl,
 String cloudName,
 String credentialsId,
 String rootCA,
 boolean skipTLSVerification,
 List<AnkaCloudSlaveTemplate> templates,
 int cloudInstanceCap)

Method Details

markFuture

public static void markFuture(AnkaMgmtCloud cloud,
 AbstractAnkaSlave abstractAnkaSlave)

Log

public static void Log(String msg)

Log

public static void Log(String format,
 Object... args)

Log

public static void Log(Slave slave,
 TaskListener listener,
 String msg)

Log

public static void Log(SlaveComputer slave,
 TaskListener listener,
 String format,
 Object... args)

getAnkaClouds

public static List<AnkaMgmtCloud> getAnkaClouds()

getCloudThatHasImage

public static AnkaMgmtCloud getCloudThatHasImage(String masterVMID)

get

public static AnkaMgmtCloud get(String cloudName)

getLaunchTimeout

public int getLaunchTimeout()

setLaunchTimeout

@DataBoundSetter
public void setLaunchTimeout(int launchTimeout)

getMaxLaunchRetries

public int getMaxLaunchRetries()

setMaxLaunchRetries

@DataBoundSetter
public void setMaxLaunchRetries(int maxLaunchRetries)

getLaunchRetryWaitTime

public int getLaunchRetryWaitTime()

setLaunchRetryWaitTime

@DataBoundSetter
public void setLaunchRetryWaitTime(int launchRetryWaitTime)

getSshLaunchDelaySeconds

public int getSshLaunchDelaySeconds()

setSshLaunchDelaySeconds

@DataBoundSetter
public void setSshLaunchDelaySeconds(int sshLaunchDelaySeconds)

getVmIPAssignWaitSeconds

public int getVmIPAssignWaitSeconds()

setVmIPAssignWaitSeconds

@DataBoundSetter
public void setVmIPAssignWaitSeconds(int vmIPAssignWaitSeconds)

getVmIPAssignRetries

public int getVmIPAssignRetries()

setVmIPAssignRetries

@DataBoundSetter
public void setVmIPAssignRetries(int vmIPAssignRetries)

getDurabilityMode

public String getDurabilityMode()

setDurabilityMode

@DataBoundSetter
public void setDurabilityMode(String durabilityMode)

getMonitorRecurrenceMinutes

public int getMonitorRecurrenceMinutes()

setMonitorRecurrenceMinutes

@DataBoundSetter
public void setMonitorRecurrenceMinutes(int minutes)

getMaxConnections

public int getMaxConnections()

setMaxConnections

@DataBoundSetter
public void setMaxConnections(int maxConnections)

getConnectionKeepAliveSeconds

public int getConnectionKeepAliveSeconds()

setConnectionKeepAliveSeconds

@DataBoundSetter
public void setConnectionKeepAliveSeconds(int connectionKeepAliveSeconds)

readResolve

protected Object readResolve()

getCredentialsId

public String getCredentialsId()

getCloudName

public String getCloudName()

getAnkaMgmtUrl

public String getAnkaMgmtUrl()

getSkipTLSVerification

public boolean getSkipTLSVerification()

getRootCA

public String getRootCA()

getCloudInstanceCap

public int getCloudInstanceCap()

setCloudInstanceCap

public void setCloudInstanceCap(int val)

getCloudCapacity

public int getCloudCapacity()

getNumOfRunningNodesPerLabel

public NodeCountResponse getNumOfRunningNodesPerLabel(Label label)

listVmTemplates

public List<AnkaVmTemplate> listVmTemplates()

getTemplateTags

public List<String> getTemplateTags(String masterVmId)

getTemplates

public List<AnkaCloudSlaveTemplate> getTemplates()

getDynamicTemplates

public List<DynamicSlaveTemplate> getDynamicTemplates()

getNodeGroups

public List<NodeGroup> getNodeGroups()

provision

public Collection<NodeProvisioner.PlannedNode> provision(Cloud.CloudState state,
 int excessWorkload)

Overrides:

provision in class Cloud

getTemplate

public AnkaCloudSlaveTemplate getTemplate(Label label)

hasMasterVm

public boolean hasMasterVm(String templateId)

canProvision

public boolean canProvision(Cloud.CloudState state)

Overrides:

canProvision in class Cloud

getAnkaApi

public AnkaAPI getAnkaApi()

isOnline

public boolean isOnline()

isPushSupported

public Boolean isPushSupported()

removeDynamicTemplate

public void removeDynamicTemplate(AbstractSlaveTemplate template)

addDynamicTemplate

public void addDynamicTemplate(DynamicSlaveTemplate template)

saveImage

public void saveImage(AbstractAnkaSlave node)
               throws AnkaMgmtException

Throws:

AnkaMgmtException

updateInstance

public void updateInstance(String vmId,
 String name,
 String jenkinsNodeLink,
 String jobIdentifier)
                    throws AnkaMgmtException

Throws:

AnkaMgmtException

terminateVMInstance

public void terminateVMInstance(String id)
                         throws AnkaMgmtException

Throws:

AnkaMgmtException

terminateVMInstance

public void terminateVMInstance(String id,
 AbstractAnkaSlave node)
                         throws AnkaMgmtException

Throws:

AnkaMgmtException

showInstance

public AnkaVmInstance showInstance(String id)
                            throws AnkaMgmtException

Throws:

AnkaMgmtException

getVmPollTime

public int getVmPollTime()

setVmPollTime

@DataBoundSetter
public void setVmPollTime(int milliseconds)

getExistingTemplateIds

public Set<String> getExistingTemplateIds()

getExistingGroupIds

public Set<String> getExistingGroupIds()

getExistingTags

public Set<String> getExistingTags()