com.elastisys.scale.cloudadapters.splitter

Class Splitter

java.lang.Object

com.elastisys.scale.cloudadapters.splitter.Splitter

All Implemented Interfaces:

CloudAdapter

public class Splitter
extends Object
implements CloudAdapter

A cloud adapter that splits up the MachinePool to a number of configured CloudAdapters. It communicates with the underlying CloudAdapters via their REST protocol endpoints.

Cloud adapters are prioritized by a number between [0, 100]. The sums of these priorities must equal 100, to ensure that we have an unambiguous configuration. The splitter adapter will instruct its underlying adapters to obtain the correct number of instances based on the priorities (in case of a tie, e.g., two adapters each configured to handle 50% of the machine demand, the first in the configuration file will win).

The following is an example of what a configuration document for the Splitter could look like:

 {
   "poolSizeCalculator": "STRICT",
   "adapters": [
     {
       "priority": 40,
       "cloudAdapterHost": "cloudadapter-host-1",
       "cloudAdapterPort": 8443
     },
     {
       "priority": 40,
       "cloudAdapterHost": "cloudadapter-host-2",
       "cloudAdapterPort": 8443,
       "basicCredentials": {
         "username": "admin",
         "password": "adminpassword"
       }
     },
     {
       "priority": 20,
       "cloudAdapterHost": "cloudadapter-host-3",
       "cloudAdapterPort": 8443,
       "certificateCredentials": {
         "keystorePath": "/path/to/keystore/goes/here",
         "keystorePassword": "keystorepassword",
         "keystoreType": "PKCS12"
       }
     }
   ],
   "poolUpdatePeriod": 60
 }
 

Field Summary

Fields

Modifier and Type	Field and Description
static com.google.gson.JsonObject	CONFIG_SCHEMA JSON Schema describing valid configurations for the cloud adapter.

Constructor Summary

Constructors

Constructor and Description
Splitter() Constructs a Splitter in an unconfigured state.
Splitter(RequestFactory requestFactory) Constructs a Splitter with a specific RequestFactory.

Method Summary

Methods

Modifier and Type	Method and Description
void	attachMachine(String machineId)
protected Map<PrioritizedCloudAdapter,Integer>	calculatePoolSizes()
void	configure(com.google.gson.JsonObject configuration)
void	detachMachine(String machineId, boolean decrementDesiredSize)
com.google.common.base.Optional<com.google.gson.JsonObject>	getConfiguration()
com.google.common.base.Optional<com.google.gson.JsonObject>	getConfigurationSchema()
MachinePool	getMachinePool()
PoolSizeSummary	getPoolSize()
void	setDesiredSize(int desiredSize)
void	setServiceState(String machineId, ServiceState serviceState)
void	terminateMachine(String machineId, boolean decrementDesiredSize)
void	updateMachinePool() Updates the child pools according to the desired size and the configured priorities in a thread-safe manner.

Methods inherited from class java.lang.Object

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

Field Detail

CONFIG_SCHEMA

public static final com.google.gson.JsonObject CONFIG_SCHEMA

JSON Schema describing valid configurations for the cloud adapter.

Constructor Detail

Splitter

public Splitter()

Constructs a Splitter in an unconfigured state.

Splitter

public Splitter(RequestFactory requestFactory)

Constructs a Splitter with a specific RequestFactory. Useful during testing.

Parameters:

requestFactory -

Method Detail

getConfigurationSchema

public com.google.common.base.Optional<com.google.gson.JsonObject> getConfigurationSchema()

Specified by:

getConfigurationSchema in interface CloudAdapter

configure

public void configure(com.google.gson.JsonObject configuration)
               throws IllegalArgumentException,
                      CloudAdapterException

Specified by:

configure in interface CloudAdapter

Throws:

IllegalArgumentException

CloudAdapterException

getConfiguration

public com.google.common.base.Optional<com.google.gson.JsonObject> getConfiguration()

Specified by:

getConfiguration in interface CloudAdapter

getMachinePool

public MachinePool getMachinePool()
                           throws CloudAdapterException

Specified by:

getMachinePool in interface CloudAdapter

Throws:

CloudAdapterException

getPoolSize

public PoolSizeSummary getPoolSize()
                            throws CloudAdapterException

Specified by:

getPoolSize in interface CloudAdapter

Throws:

CloudAdapterException

setDesiredSize

public void setDesiredSize(int desiredSize)
                    throws IllegalArgumentException,
                           CloudAdapterException

Specified by:

setDesiredSize in interface CloudAdapter

Throws:

IllegalArgumentException

CloudAdapterException

terminateMachine

public void terminateMachine(String machineId,
                    boolean decrementDesiredSize)
                      throws NotFoundException,
                             CloudAdapterException

Specified by:

terminateMachine in interface CloudAdapter

Throws:

NotFoundException

CloudAdapterException

setServiceState

public void setServiceState(String machineId,
                   ServiceState serviceState)
                     throws NotFoundException,
                            CloudAdapterException

Specified by:

setServiceState in interface CloudAdapter

Throws:

NotFoundException

CloudAdapterException

attachMachine

public void attachMachine(String machineId)
                   throws NotFoundException,
                          CloudAdapterException

Specified by:

attachMachine in interface CloudAdapter

Throws:

NotFoundException

CloudAdapterException

detachMachine

public void detachMachine(String machineId,
                 boolean decrementDesiredSize)
                   throws NotFoundException,
                          CloudAdapterException

Specified by:

detachMachine in interface CloudAdapter

Throws:

NotFoundException

CloudAdapterException

updateMachinePool

public void updateMachinePool()

Updates the child pools according to the desired size and the configured priorities in a thread-safe manner.

calculatePoolSizes

protected Map<PrioritizedCloudAdapter,Integer> calculatePoolSizes()