org.hobbit.controller.docker

Class ClusterManagerImpl

java.lang.Object

org.hobbit.controller.docker.ClusterManagerImpl

All Implemented Interfaces:

ClusterManager

public class ClusterManagerImpl
extends Object
implements ClusterManager

ClusterManager implementation

Author:

Ivan Ermilov (iermilov@informatik.uni-leipzig.de)

Field Summary

Fields

Modifier and Type	Field and Description
private com.spotify.docker.client.DockerClient	dockerClient Docker client instance
private Integer	expectedNumberOfNodes
private static org.slf4j.Logger	LOGGER
private String	SWARM_NODE_NUMBER

Constructor Summary

Constructors

Constructor and Description
ClusterManagerImpl()

Method Summary

Modifier and Type	Method and Description
com.spotify.docker.client.messages.Info	getClusterInfo() Get cluster info
Integer	getExpectedNumberOfNodes() Get expected number of nodes in the cluster Set externally by SWARM_NODE_NUMBER env variable
Integer	getNumberOfNodes() Get number of nodes in the cluster
Integer	getTaskHistoryLimit() Get task history limit for the swarm cluster
boolean	isClusterHealthy() Get the health status of the cluster
void	setTaskHistoryLimit(Integer taskHistoryLimit) Set task history limit for the swarm cluster For production history limit should be set to 0 Then the cluster will not keep containers after the services are removed

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

dockerClient

private com.spotify.docker.client.DockerClient dockerClient

Docker client instance

expectedNumberOfNodes

private Integer expectedNumberOfNodes

SWARM_NODE_NUMBER

private String SWARM_NODE_NUMBER

Constructor Detail

ClusterManagerImpl

public ClusterManagerImpl()
                   throws com.spotify.docker.client.exceptions.DockerCertificateException

Throws:

com.spotify.docker.client.exceptions.DockerCertificateException

Method Detail

getClusterInfo

public com.spotify.docker.client.messages.Info getClusterInfo()
                                                       throws com.spotify.docker.client.exceptions.DockerException,
                                                              InterruptedException

Description copied from interface: ClusterManager

Get cluster info

Specified by:

getClusterInfo in interface ClusterManager

Returns:

com.spotify.docker.client.messages.Info

Throws:

com.spotify.docker.client.exceptions.DockerException

InterruptedException

getNumberOfNodes

public Integer getNumberOfNodes()
                         throws com.spotify.docker.client.exceptions.DockerException,
                                InterruptedException

Description copied from interface: ClusterManager

Get number of nodes in the cluster

Specified by:

getNumberOfNodes in interface ClusterManager

Returns:

number of nodes

Throws:

com.spotify.docker.client.exceptions.DockerException

InterruptedException

isClusterHealthy

public boolean isClusterHealthy()
                         throws com.spotify.docker.client.exceptions.DockerException,
                                InterruptedException

Description copied from interface: ClusterManager

Get the health status of the cluster

Specified by:

isClusterHealthy in interface ClusterManager

Returns:

boolean (is cluster healthy?)

Throws:

com.spotify.docker.client.exceptions.DockerException

InterruptedException

getExpectedNumberOfNodes

public Integer getExpectedNumberOfNodes()

Description copied from interface: ClusterManager

Get expected number of nodes in the cluster Set externally by SWARM_NODE_NUMBER env variable

Specified by:

getExpectedNumberOfNodes in interface ClusterManager

Returns:

expected number of nodes

setTaskHistoryLimit

public void setTaskHistoryLimit(Integer taskHistoryLimit)
                         throws com.spotify.docker.client.exceptions.DockerException,
                                InterruptedException

Description copied from interface: ClusterManager

Set task history limit for the swarm cluster For production history limit should be set to 0 Then the cluster will not keep containers after the services are removed

Specified by:

setTaskHistoryLimit in interface ClusterManager

Throws:

com.spotify.docker.client.exceptions.DockerException

InterruptedException

getTaskHistoryLimit

public Integer getTaskHistoryLimit()
                            throws com.spotify.docker.client.exceptions.DockerException,
                                   InterruptedException

Description copied from interface: ClusterManager

Get task history limit for the swarm cluster

Specified by:

getTaskHistoryLimit in interface ClusterManager

Returns:

Integer (task history limit)

Throws:

com.spotify.docker.client.exceptions.DockerException

InterruptedException