Package com.veertu.ankaMgmtSdk

Class AnkaMgmtCommunicator

java.lang.Object

com.veertu.ankaMgmtSdk.AnkaMgmtCommunicator

Direct Known Subclasses:

AnkaMgmtClientCertAuthCommunicator, AnkaMgmtOpenIdCommunicator, AnkaMgmtUakCommunicator

public class AnkaMgmtCommunicator
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static enum	AnkaMgmtCommunicator.RequestMethod

Field Summary

Fields

Modifier and Type	Field	Description
protected int	connectionKeepAliveSeconds
protected org.apache.http.client.CredentialsProvider	credentialsProvider
protected org.apache.http.impl.client.CloseableHttpClient	httpClient
protected int	maxConnections
protected final int	maxRetries
protected URL	mgmtUrl
protected String	rootCA
protected RoundRobin	roundRobin
protected boolean	skipTLSVerification
protected final int	timeout

Constructor Summary

Constructors

Constructor	Description
AnkaMgmtCommunicator(String url)
AnkaMgmtCommunicator(String mgmtURL, boolean skipTLSVerification)
AnkaMgmtCommunicator(String mgmtUrl, boolean skipTLSVerification, String rootCA)
AnkaMgmtCommunicator(String mgmtUrl, String rootCA)
AnkaMgmtCommunicator(List<String> mgmtURLS, boolean skipTLSVerification, String rootCA)

Method Summary

Modifier and Type	Method	Description
protected void	addHeaders(org.apache.http.client.methods.HttpRequestBase request)
protected org.json.JSONObject	doRequest(AnkaMgmtCommunicator.RequestMethod method, String path, org.json.JSONObject requestBody)
protected org.json.JSONObject	doRequest(AnkaMgmtCommunicator.RequestMethod method, String path, org.json.JSONObject requestBody, int reqTimeout)
int	getConnectionKeepAliveSeconds()
protected org.apache.http.impl.client.CloseableHttpClient	getHttpClient()
List<org.json.JSONObject>	getImageRequests()
protected KeyStore	getKeyStore()
int	getMaxConections()
List<NodeGroup>	getNodeGroups()
List<AnkaNode>	getNodes()
String	getSaveImageStatus(String reqId)
protected SSLContext	getSSLContext(KeyStore keystore)
List<String>	getTemplateTags(String templateId)
protected org.apache.http.ssl.TrustStrategy	getTrustStrategy()
List<AnkaVmInstance>	list()
List<AnkaVmTemplate>	listTemplates()
protected org.apache.http.impl.client.CloseableHttpClient	makeHttpClient()
protected org.apache.http.client.config.RequestConfig	makeRequestConfig(int reqTimeout, String host)
protected StringBuffer	readHttpEntity(org.apache.http.HttpEntity entity)
void	revertRegistryVM(String templateID)
String	saveImage(String instanceId, String targetVMId, String newTemplateName, String tag, String description, Boolean suspend, String shutdownScript, Boolean revertBeforePush, String revertTag, Boolean doSuspendTest)
protected org.apache.http.client.methods.HttpRequestBase	setBody(org.apache.http.client.methods.HttpEntityEnclosingRequestBase request, org.json.JSONObject requestBody)
void	setConnectionKeepAliveSeconds(int connectionKeepAliveSeconds)
void	setMaxConections(int maxConections)
AnkaVmInstance	showVm(String sessionId)
String	startVm(String templateId, String tag, String nameTemplate, String startUpScript, String groupId, int priority, String name, String externalId, int vcpu, int vram)
AnkaCloudStatus	status()
boolean	terminateVm(String sessionId)
void	updateVM(String id, String name, String jenkinsNodeLink, String jobIdentifier)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

timeout

protected final int timeout

See Also:

• Constant Field Values

maxRetries

protected final int maxRetries

See Also:

• Constant Field Values

mgmtUrl

protected URL mgmtUrl

skipTLSVerification

protected boolean skipTLSVerification

rootCA

protected String rootCA

roundRobin

protected transient RoundRobin roundRobin

maxConnections

protected int maxConnections

credentialsProvider

protected org.apache.http.client.CredentialsProvider credentialsProvider

connectionKeepAliveSeconds

protected int connectionKeepAliveSeconds

httpClient

protected transient org.apache.http.impl.client.CloseableHttpClient httpClient

Constructor Details

AnkaMgmtCommunicator

public AnkaMgmtCommunicator(String url)

AnkaMgmtCommunicator

public AnkaMgmtCommunicator(String mgmtURL,
 boolean skipTLSVerification)

AnkaMgmtCommunicator

public AnkaMgmtCommunicator(String mgmtUrl,
 String rootCA)

AnkaMgmtCommunicator

public AnkaMgmtCommunicator(String mgmtUrl,
 boolean skipTLSVerification,
 String rootCA)

AnkaMgmtCommunicator

public AnkaMgmtCommunicator(List<String> mgmtURLS,
 boolean skipTLSVerification,
 String rootCA)

Method Details

getMaxConections

public int getMaxConections()

setMaxConections

public void setMaxConections(int maxConections)

getConnectionKeepAliveSeconds

public int getConnectionKeepAliveSeconds()

setConnectionKeepAliveSeconds

public void setConnectionKeepAliveSeconds(int connectionKeepAliveSeconds)

listTemplates

public List<AnkaVmTemplate> listTemplates()
                                   throws AnkaMgmtException

Throws:

AnkaMgmtException

getTemplateTags

public List<String> getTemplateTags(String templateId)
                             throws AnkaMgmtException

Throws:

AnkaMgmtException

getNodeGroups

public List<NodeGroup> getNodeGroups()
                              throws AnkaMgmtException

Throws:

AnkaMgmtException

startVm

public String startVm(String templateId,
 String tag,
 String nameTemplate,
 String startUpScript,
 String groupId,
 int priority,
 String name,
 String externalId,
 int vcpu,
 int vram)
               throws AnkaMgmtException

Throws:

AnkaMgmtException

showVm

public AnkaVmInstance showVm(String sessionId)
                      throws AnkaMgmtException

Throws:

AnkaMgmtException

terminateVm

public boolean terminateVm(String sessionId)
                    throws AnkaMgmtException

Throws:

AnkaMgmtException

list

public List<AnkaVmInstance> list()
                          throws AnkaMgmtException

Throws:

AnkaMgmtException

status

public AnkaCloudStatus status()
                       throws AnkaMgmtException

Throws:

AnkaMgmtException

saveImage

public String saveImage(String instanceId,
 String targetVMId,
 String newTemplateName,
 String tag,
 String description,
 Boolean suspend,
 String shutdownScript,
 Boolean revertBeforePush,
 String revertTag,
 Boolean doSuspendTest)
                 throws AnkaMgmtException

Throws:

AnkaMgmtException

getSaveImageStatus

public String getSaveImageStatus(String reqId)
                          throws AnkaMgmtException

Throws:

AnkaMgmtException

revertRegistryVM

public void revertRegistryVM(String templateID)
                      throws AnkaMgmtException

Throws:

AnkaMgmtException

getImageRequests

public List<org.json.JSONObject> getImageRequests()
                                           throws AnkaMgmtException

Throws:

AnkaMgmtException

updateVM

public void updateVM(String id,
 String name,
 String jenkinsNodeLink,
 String jobIdentifier)
              throws AnkaMgmtException

Throws:

AnkaMgmtException

getNodes

public List<AnkaNode> getNodes()
                        throws AnkaMgmtException

Throws:

AnkaMgmtException

addHeaders

protected void addHeaders(org.apache.http.client.methods.HttpRequestBase request)
                   throws AnkaMgmtException,
ClientException

Throws:

AnkaMgmtException

ClientException

doRequest

protected org.json.JSONObject doRequest(AnkaMgmtCommunicator.RequestMethod method,
 String path,
 org.json.JSONObject requestBody)
                                 throws IOException,
AnkaMgmtException

Throws:

IOException

AnkaMgmtException

doRequest

protected org.json.JSONObject doRequest(AnkaMgmtCommunicator.RequestMethod method,
 String path,
 org.json.JSONObject requestBody,
 int reqTimeout)
                                 throws IOException,
AnkaMgmtException

Throws:

IOException

AnkaMgmtException

readHttpEntity

protected StringBuffer readHttpEntity(org.apache.http.HttpEntity entity)
                               throws IOException

Throws:

IOException

getHttpClient

protected org.apache.http.impl.client.CloseableHttpClient getHttpClient()
                                                                 throws CertificateException,
UnrecoverableKeyException,
NoSuchAlgorithmException,
KeyStoreException,
KeyManagementException,
IOException

Throws:

CertificateException

UnrecoverableKeyException

NoSuchAlgorithmException

KeyStoreException

KeyManagementException

IOException

makeRequestConfig

protected org.apache.http.client.config.RequestConfig makeRequestConfig(int reqTimeout,
 String host)

makeHttpClient

protected org.apache.http.impl.client.CloseableHttpClient makeHttpClient()
                                                                  throws KeyStoreException,
NoSuchAlgorithmException,
KeyManagementException,
CertificateException,
IOException,
UnrecoverableKeyException

Throws:

KeyStoreException

NoSuchAlgorithmException

KeyManagementException

CertificateException

IOException

UnrecoverableKeyException

getSSLContext

protected SSLContext getSSLContext(KeyStore keystore)
                            throws KeyStoreException,
NoSuchAlgorithmException,
KeyManagementException,
UnrecoverableKeyException

Throws:

KeyStoreException

NoSuchAlgorithmException

KeyManagementException

UnrecoverableKeyException

getKeyStore

protected KeyStore getKeyStore()
                        throws CertificateException,
NoSuchAlgorithmException,
KeyStoreException,
IOException

Throws:

CertificateException

NoSuchAlgorithmException

KeyStoreException

IOException

getTrustStrategy

protected org.apache.http.ssl.TrustStrategy getTrustStrategy()

setBody

protected org.apache.http.client.methods.HttpRequestBase setBody(org.apache.http.client.methods.HttpEntityEnclosingRequestBase request,
 org.json.JSONObject requestBody)
                                                          throws UnsupportedEncodingException

Throws:

UnsupportedEncodingException