org.inria.myriads.snoozenode.database.api.impl.cassandra

Class GroupLeaderCassandraRepository

java.lang.Object

org.inria.myriads.snoozenode.database.api.impl.cassandra.CassandraRepository

org.inria.myriads.snoozenode.database.api.impl.cassandra.GroupLeaderCassandraRepository

All Implemented Interfaces:

GroupLeaderRepository

public class GroupLeaderCassandraRepository
extends CassandraRepository
implements GroupLeaderRepository

GroupLeader cassandra repository.

Author:

msimonin

Constructor Summary

Constructors

Constructor and Description
GroupLeaderCassandraRepository(org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription groupLeaderDescription, String[] virtualMachineSubnets, int ttlGroupManager, int ttlVirtualMachine, String hosts) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	addGroupManagerDescription(org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription description) Adds a group manager description.
void	addGroupManagerSummaryInformation(String groupManagerId, org.inria.myriads.snoozecommon.communication.groupmanager.summary.GroupManagerSummaryInformation summary) Adds group manager data.
boolean	addIpAddress(String ipAddress) Adds the IP address.
boolean	dropGroupManager(String groupManagerId) Drops a group manager.
protected List<String>	generateAddressPool(String[] virtualMachineSubnets) Generates the address pool.
org.inria.myriads.snoozecommon.communication.localcontroller.AssignedGroupManager	getAssignedGroupManager(org.inria.myriads.snoozecommon.communication.NetworkAddress contactInformation) Gets the group manager assigned to the localcontroller identified by its contact information.
String	getFreeIpAddress() Get the next free IP address.
org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription	getGroupManagerDescription(String groupManagerId, int numberOfBacklogEntries) Returns the group manager description.
ArrayList<org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription>	getGroupManagerDescriptions(int numberOfBacklogEntries) Returns the group manager descriptions.
org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription	getLocalControllerDescription(String localControllerId) Gets the localController description.
ArrayList<org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription>	getLocalControllerList() Returns the local controllers list.
protected void	populateAddressPool(List<String> ipAddress) Populates all the ips.
boolean	removeIpAddress(String ipAddress) Removes IP address from the pool.
protected void	unassignNodes() Unassign all nodes.
boolean	updateLocation(org.inria.myriads.snoozecommon.communication.virtualcluster.submission.VirtualMachineLocation location) Given a local controller location updates the location with the proper groupmanager.

Methods inherited from class org.inria.myriads.snoozenode.database.api.impl.cassandra.CassandraRepository

addAggregatedMonitoringDataCassandra, addGroupManagerDescriptionCassandra, addGroupManagerSummaryInformationCassandra, addLocalControllerDescriptionCassandra, addVirtualMachineCassandra, clear, dropGroupManager, fillGroupManagerSummaryInformation, fillVirtualMachineMonitoringData, fillWithLocalControllers, fillWithVirtualMachines, fillWithVirtualMachines, fillWithVirtualMachines, getCluster, getGroupManagerDescription, getGroupManagerDescriptionCassandra, getGroupManagerDescriptionOnly, getGroupManagerDescriptionsOnly, getKeyspace, getLocalControllerDescription, getLocalControllerDescriptionCassandra, getLocalControllerDescriptionOnly, getLocalControllerDescriptionsCassandra, getLocalControllerDescriptionsOnly, getLocalControllerId, getVirtualMachineDescriptionOnly, getVirtualMachineDescriptionOnly, getVirtualMachineDescriptionsOnly, getVirtualMachineMetaDataCassandra

Methods inherited from class java.lang.Object

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

Constructor Detail

GroupLeaderCassandraRepository

public GroupLeaderCassandraRepository(org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription groupLeaderDescription,
                              String[] virtualMachineSubnets,
                              int ttlGroupManager,
                              int ttlVirtualMachine,
                              String hosts)

Constructor.

Parameters:

groupLeaderDescription - The group manager description.

virtualMachineSubnets - The virtual machine subnets.

ttlGroupManager - The ttl for group manager monitoring.

ttlVirtualMachine - The ttl for virtual machines monitoring.

hosts - The cassandra hosts to connect to.

Method Detail

unassignNodes

protected void unassignNodes()

Unassign all nodes.

addGroupManagerDescription

public boolean addGroupManagerDescription(org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription description)

Adds a group manager description.

Specified by:

addGroupManagerDescription in interface GroupLeaderRepository

Parameters:

description - The group manager description

Returns:

true if added, false otherwise

getGroupManagerDescriptions

public ArrayList<org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription> getGroupManagerDescriptions(int numberOfBacklogEntries)

Returns the group manager descriptions.

Specified by:

getGroupManagerDescriptions in interface GroupLeaderRepository

Parameters:

numberOfBacklogEntries - The number of backlog entries

Returns:

The group manager descriptions

getGroupManagerDescription

public org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription getGroupManagerDescription(String groupManagerId,
                                                                                                           int numberOfBacklogEntries)

Returns the group manager description.

Specified by:

getGroupManagerDescription in interface GroupLeaderRepository

Parameters:

groupManagerId - The group manager id

numberOfBacklogEntries - The number of backlog entries

Returns:

The group manager description

addGroupManagerSummaryInformation

public void addGroupManagerSummaryInformation(String groupManagerId,
                                     org.inria.myriads.snoozecommon.communication.groupmanager.summary.GroupManagerSummaryInformation summary)

Adds group manager data.

Specified by:

addGroupManagerSummaryInformation in interface GroupLeaderRepository

Parameters:

groupManagerId - The group manager identifier

summary - The group manager summary information

dropGroupManager

public boolean dropGroupManager(String groupManagerId)

Drops a group manager.

Specified by:

dropGroupManager in interface GroupLeaderRepository

Parameters:

groupManagerId - The group manager identifier

Returns:

true if everything ok, false otherwise

addIpAddress

public boolean addIpAddress(String ipAddress)

Adds the IP address.

Specified by:

addIpAddress in interface GroupLeaderRepository

Parameters:

ipAddress - The ip address

Returns:

true if everything ok, false otherwise

removeIpAddress

public boolean removeIpAddress(String ipAddress)

Removes IP address from the pool.

Specified by:

removeIpAddress in interface GroupLeaderRepository

Parameters:

ipAddress - The ip address

Returns:

true if everything ok, false otherwise

getFreeIpAddress

public String getFreeIpAddress()

Get the next free IP address.

Specified by:

getFreeIpAddress in interface GroupLeaderRepository

Returns:

The next free ip address

getLocalControllerList

public ArrayList<org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription> getLocalControllerList()

Returns the local controllers list.

Specified by:

getLocalControllerList in interface GroupLeaderRepository

Returns:

The local controllers list (unused).

getAssignedGroupManager

public org.inria.myriads.snoozecommon.communication.localcontroller.AssignedGroupManager getAssignedGroupManager(org.inria.myriads.snoozecommon.communication.NetworkAddress contactInformation)

Gets the group manager assigned to the localcontroller identified by its contact information.

Specified by:

getAssignedGroupManager in interface GroupLeaderRepository

Parameters:

contactInformation - the contact address/port of the local controller.

Returns:

The assigned group manager or null if none is found.

updateLocation

public boolean updateLocation(org.inria.myriads.snoozecommon.communication.virtualcluster.submission.VirtualMachineLocation location)

Given a local controller location updates the location with the proper groupmanager.

Specified by:

updateLocation in interface GroupLeaderRepository

Parameters:

location - The location.

Returns:

True if everything is ok.

getLocalControllerDescription

public org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription getLocalControllerDescription(String localControllerId)

Gets the localController description.

Specified by:

getLocalControllerDescription in interface GroupLeaderRepository

Parameters:

localControllerId - The local controller id.

Returns:

The local controller description.

generateAddressPool

protected List<String> generateAddressPool(String[] virtualMachineSubnets)

Generates the address pool.

Parameters:

virtualMachineSubnets - The virtual machine subnet

Returns:

The list of IP addresses

populateAddressPool

protected void populateAddressPool(List<String> ipAddress)

Populates all the ips.

Parameters:

ipAddress - The ip Address to populate.