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

Class CassandraRepository

java.lang.Object

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

Direct Known Subclasses:

BootstrapCassandraRepository, CassandraGroupManagerDataSender, CassandraVirtualMachineDataSender, GroupLeaderCassandraRepository, GroupManagerCassandraRepository

public class CassandraRepository
extends Object

Cassandra Repository.

Author:

msimonin

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	log_ Logger.

Constructor Summary

Constructors

Constructor and Description
CassandraRepository(String hosts) Constructor.
CassandraRepository(String hosts, int ttlGroupManager, int ttlVirtualMachine) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
protected void	addAggregatedMonitoringDataCassandra(String localControllerId, List<AggregatedVirtualMachineData> aggregatedData) Adds aggregated monitoring data to Cassandra.
protected boolean	addGroupManagerDescriptionCassandra(org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription description, boolean isGroupLeader, boolean isAssigned) Add (serialize) a group manager to cassandra.
protected void	addGroupManagerSummaryInformationCassandra(String groupManagerId, org.inria.myriads.snoozecommon.communication.groupmanager.summary.GroupManagerSummaryInformation summary) Add a groupmanager summary information into cassandra.
protected boolean	addLocalControllerDescriptionCassandra(String groupManagerId, org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription description) Add (serialize) a local controller to cassandra.
protected boolean	addVirtualMachineCassandra(org.inria.myriads.snoozecommon.communication.virtualcluster.VirtualMachineMetaData virtualMachineMetaData) Add (serialize) virtual machine to cassandra.
protected void	clear() Clear to repository.
protected boolean	dropGroupManager(String groupManagerId, boolean withLocalControllers, boolean withVirtualMachines) Drop a group manager from the cassandra cluster.
protected void	fillGroupManagerSummaryInformation(org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription groupManagerDescription, int numberOfBacklogEntries) Fills group manager description with summary information.
protected void	fillVirtualMachineMonitoringData(org.inria.myriads.snoozecommon.communication.virtualcluster.VirtualMachineMetaData virtualMachine, int numberOfMonitoringEntries) Fills the virtual machine meta data with monitoring datas.
protected void	fillWithLocalControllers(org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription groupManager, boolean isActiveOnly, int numberOfMonitoringEntries) Fill the group manager description with the associated localcontrollers.
protected void	fillWithVirtualMachines(org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription groupManager, int numberOfMonitoringEntries) Fills the group manager description with the associated virtual machines.
protected void	fillWithVirtualMachines(org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription localController, int numberOfMonitoringEntries) Fills the localcontroller with its virtual machines.
protected void	fillWithVirtualMachines(String groupManagerId, ArrayList<org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription> localControllers, int numberOfMonitoringEntries) Fills the hashmap with virtualmachines.
me.prettyprint.hector.api.Cluster	getCluster()
protected org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription	getGroupManagerDescription(me.prettyprint.hector.api.beans.Row<String,String,String> row) Gets the groupManagerDescription from a row.
protected org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription	getGroupManagerDescriptionCassandra(String groupManagerId, int numberOfbacklogEntries, boolean withLocalControllers, boolean isActiveOnly, boolean withVirtualMachines, int numberOfMonitoringEntries) Gets the groupManagerDescription.
protected org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription	getGroupManagerDescriptionOnly(String groupManagerId, int numberOfBacklogEntries) Gets the groupManager description.
protected ArrayList<org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription>	getGroupManagerDescriptionsOnly(String firstGroupManagerId, int limit, boolean assignedOnly, int numberOfBacklogEntries, List<String> toExclude) Gets the groupmanager descriptions.
me.prettyprint.hector.api.Keyspace	getKeyspace()
protected org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription	getLocalControllerDescription(me.prettyprint.hector.api.beans.Row<String,String,String> row) Gets local controller from a cassandra row.
protected org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription	getLocalControllerDescriptionCassandra(String localControllerId, int numberOfHostMonitoringEntries, boolean withVirtualMachines, int numberOfMonitoringEntries) Gets local controller description.
protected org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription	getLocalControllerDescriptionOnly(String localControllerId, int numberOfMonitoringEntries) Gets the localcontroller only (without virtual machines).
protected ArrayList<org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription>	getLocalControllerDescriptionsCassandra(String groupManagerId, int numberOfMonitoringEntries, boolean isActiveOnly, boolean withVirtualMachines) Gets the localcontroller descriptions from the cassandra cluster.
protected ArrayList<org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription>	getLocalControllerDescriptionsOnly(String groupManagerId, String localControllerStart, int limit, int numberOfMonitoringEntries, boolean isActiveOnly, boolean onlyAssigned) Returns the local controller descriptions of a given group manager.
protected String	getLocalControllerId(org.inria.myriads.snoozecommon.communication.NetworkAddress contactInformation) Gets the local controller id from the mapping column family.
protected org.inria.myriads.snoozecommon.communication.virtualcluster.VirtualMachineMetaData	getVirtualMachineDescriptionOnly(me.prettyprint.hector.api.beans.Row<String,String,String> row) Gets the virtual machine meta data from a cassandra row.
protected org.inria.myriads.snoozecommon.communication.virtualcluster.VirtualMachineMetaData	getVirtualMachineDescriptionOnly(String virtualMachineId, int numberOfMonitoringEntries) Gets the virtual machine descriptions.
protected ArrayList<org.inria.myriads.snoozecommon.communication.virtualcluster.VirtualMachineMetaData>	getVirtualMachineDescriptionsOnly(String groupManagerId, String localControllerId, String virtualMachineStart, int limit, int numberOfMonitoringEntries, boolean onlyAssigned) Gets virtual machine metadatas from cassandra cluster.
protected org.inria.myriads.snoozecommon.communication.virtualcluster.VirtualMachineMetaData	getVirtualMachineMetaDataCassandra(String virtualMachineId, int numberOfMonitoringEntries) Get a virtual machine.

Methods inherited from class java.lang.Object

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

Field Detail

log_

protected static final org.slf4j.Logger log_

Logger.

Constructor Detail

CassandraRepository

public CassandraRepository(String hosts,
                   int ttlGroupManager,
                   int ttlVirtualMachine)

Constructor.

Parameters:

hosts - List of hosts to connect to.

ttlGroupManager - ttl for groupManager monitoring.

ttlVirtualMachine - ttl for virtualMachine monitoring.

CassandraRepository

public CassandraRepository(String hosts)

Constructor.

Parameters:

hosts - List of hosts to connect to.

Method Detail

getGroupManagerDescriptionOnly

protected org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription getGroupManagerDescriptionOnly(String groupManagerId,
                                                                                                               int numberOfBacklogEntries)

Gets the groupManager description. Without localcontrollers and virtual machines.

Parameters:

groupManagerId - The groupmanager id.

numberOfBacklogEntries - The number of wanted monitoring values.

Returns:

The groupmanager description or null

getGroupManagerDescriptionCassandra

protected org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription getGroupManagerDescriptionCassandra(String groupManagerId,
                                                                                                                    int numberOfbacklogEntries,
                                                                                                                    boolean withLocalControllers,
                                                                                                                    boolean isActiveOnly,
                                                                                                                    boolean withVirtualMachines,
                                                                                                                    int numberOfMonitoringEntries)

Gets the groupManagerDescription. Fill it with specific details (monitoring, lc, virtualmachines).

Parameters:

groupManagerId - The group manager id to retrieve.

numberOfbacklogEntries - The number of wanted monitoring values.

withLocalControllers - True if it must fill with associated localcontrollers.

isActiveOnly - True if wanted only active local controllers

withVirtualMachines - True if it must fill with associated virtual machines.

numberOfMonitoringEntries - Number of monitoring entries for the virtualmachines

Returns:

The groupmanager description or null.

getLocalControllerDescriptionCassandra

protected org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription getLocalControllerDescriptionCassandra(String localControllerId,
                                                                                                                             int numberOfHostMonitoringEntries,
                                                                                                                             boolean withVirtualMachines,
                                                                                                                             int numberOfMonitoringEntries)

Gets local controller description.

Parameters:

localControllerId - The local controller description.

numberOfHostMonitoringEntries - number of monitoring entries (host).

withVirtualMachines - with virtualmachines.

numberOfMonitoringEntries - number of monitoring entries (vms)

Returns:

The local controller description.

getLocalControllerDescriptionOnly

protected org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription getLocalControllerDescriptionOnly(String localControllerId,
                                                                                                                        int numberOfMonitoringEntries)

Gets the localcontroller only (without virtual machines).

Parameters:

localControllerId - The local controller Id.

numberOfMonitoringEntries - Number of monitoring entries.

Returns:

The local controller description.

getLocalControllerDescription

protected org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription getLocalControllerDescription(me.prettyprint.hector.api.beans.Row<String,String,String> row)

Gets local controller from a cassandra row.

Parameters:

row - the cassandra row

Returns:

the deserialized local controller description.

fillGroupManagerSummaryInformation

protected void fillGroupManagerSummaryInformation(org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription groupManagerDescription,
                                      int numberOfBacklogEntries)

Fills group manager description with summary information.

Parameters:

groupManagerDescription - The group manager description to fill.

numberOfBacklogEntries - The number of monitoring entries to use.

getGroupManagerDescription

protected org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription getGroupManagerDescription(me.prettyprint.hector.api.beans.Row<String,String,String> row)

Gets the groupManagerDescription from a row.

Parameters:

row - The cassandra row.

Returns:

The deserialized groupmanager.

fillWithLocalControllers

protected void fillWithLocalControllers(org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription groupManager,
                            boolean isActiveOnly,
                            int numberOfMonitoringEntries)

Fill the group manager description with the associated localcontrollers.

Parameters:

groupManager - The group manager description to fill

isActiveOnly - True if only active requested.

numberOfMonitoringEntries - The number of monitoring entries

fillWithVirtualMachines

protected void fillWithVirtualMachines(String groupManagerId,
                           ArrayList<org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription> localControllers,
                           int numberOfMonitoringEntries)

Fills the hashmap with virtualmachines.

Parameters:

groupManagerId - The group manager id.

localControllers - The localcontrollers.

numberOfMonitoringEntries - The number of monitoring entries.

fillWithVirtualMachines

protected void fillWithVirtualMachines(org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription groupManager,
                           int numberOfMonitoringEntries)

Fills the group manager description with the associated virtual machines.

Parameters:

groupManager - GroupManager description to fill.

numberOfMonitoringEntries - Number of Monitoring entries.

fillWithVirtualMachines

protected void fillWithVirtualMachines(org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription localController,
                           int numberOfMonitoringEntries)

Fills the localcontroller with its virtual machines.

Parameters:

localController - The localcontroller description.

numberOfMonitoringEntries - Number of monitoring entries.

getLocalControllerDescriptionsCassandra

protected ArrayList<org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription> getLocalControllerDescriptionsCassandra(String groupManagerId,
                                                                                                                                         int numberOfMonitoringEntries,
                                                                                                                                         boolean isActiveOnly,
                                                                                                                                         boolean withVirtualMachines)

Gets the localcontroller descriptions from the cassandra cluster.

Parameters:

groupManagerId - The groupmanager id.

numberOfMonitoringEntries - The number of monitoring entries.

isActiveOnly - True if only active requested.

withVirtualMachines - True if localcontrollers should be filled with its virtualmachines

Returns:

the list of localcontrollers.

getLocalControllerDescriptionsOnly

protected ArrayList<org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription> getLocalControllerDescriptionsOnly(String groupManagerId,
                                                                                                                                    String localControllerStart,
                                                                                                                                    int limit,
                                                                                                                                    int numberOfMonitoringEntries,
                                                                                                                                    boolean isActiveOnly,
                                                                                                                                    boolean onlyAssigned)

Returns the local controller descriptions of a given group manager.

Parameters:

groupManagerId - The group manager Id

localControllerStart - The local Controller start key (for range)

limit - The total number to fetch

numberOfMonitoringEntries - Number of monitoring entries to fecth

isActiveOnly - Only gets ACTIVE localController

onlyAssigned - Only gets Assigned localcontroller

Returns:

The list of localcontroller description.

fillVirtualMachineMonitoringData

protected void fillVirtualMachineMonitoringData(org.inria.myriads.snoozecommon.communication.virtualcluster.VirtualMachineMetaData virtualMachine,
                                    int numberOfMonitoringEntries)

Fills the virtual machine meta data with monitoring datas.

Parameters:

virtualMachine - The virtual machine meta data to fill

numberOfMonitoringEntries - the number of monitoring entries to fecth.

getVirtualMachineDescriptionOnly

protected org.inria.myriads.snoozecommon.communication.virtualcluster.VirtualMachineMetaData getVirtualMachineDescriptionOnly(me.prettyprint.hector.api.beans.Row<String,String,String> row)

Gets the virtual machine meta data from a cassandra row.

Parameters:

row - cassandra row.

Returns:

the deserialized virtual machine meta data.

dropGroupManager

protected boolean dropGroupManager(String groupManagerId,
                       boolean withLocalControllers,
                       boolean withVirtualMachines)

Drop a group manager from the cassandra cluster.

Parameters:

groupManagerId - The group manager id to drop

withLocalControllers - True if assigned LocalController must be dropped

withVirtualMachines - True if assigned virtualMachines must be dropped

Returns:

true iff the group manager has been dropped.

addVirtualMachineCassandra

protected boolean addVirtualMachineCassandra(org.inria.myriads.snoozecommon.communication.virtualcluster.VirtualMachineMetaData virtualMachineMetaData)

Add (serialize) virtual machine to cassandra.

Parameters:

virtualMachineMetaData - The virtual machine meta data to serialize.

Returns:

True iff everything is ok.

addAggregatedMonitoringDataCassandra

protected void addAggregatedMonitoringDataCassandra(String localControllerId,
                                        List<AggregatedVirtualMachineData> aggregatedData)

Adds aggregated monitoring data to Cassandra.

Parameters:

localControllerId - The localControllerId.

aggregatedData - The aggregated datas.

addLocalControllerDescriptionCassandra

protected boolean addLocalControllerDescriptionCassandra(String groupManagerId,
                                             org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription description)

Add (serialize) a local controller to cassandra.

Parameters:

groupManagerId - The group manager Id.

description - The local controller description.

Returns:

true iff everything is ok.

addGroupManagerDescriptionCassandra

protected boolean addGroupManagerDescriptionCassandra(org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription description,
                                          boolean isGroupLeader,
                                          boolean isAssigned)

Add (serialize) a group manager to cassandra.

Parameters:

description - The group manager description.

isGroupLeader - True iff it is the group leader.

isAssigned - True iff it is assigned

Returns:

True iff is ok.

addGroupManagerSummaryInformationCassandra

protected void addGroupManagerSummaryInformationCassandra(String groupManagerId,
                                              org.inria.myriads.snoozecommon.communication.groupmanager.summary.GroupManagerSummaryInformation summary)

Add a groupmanager summary information into cassandra.

Parameters:

groupManagerId - The groupManager Id.

summary - The summary to add.

getVirtualMachineMetaDataCassandra

protected org.inria.myriads.snoozecommon.communication.virtualcluster.VirtualMachineMetaData getVirtualMachineMetaDataCassandra(String virtualMachineId,
                                                                                                                    int numberOfMonitoringEntries)

Get a virtual machine.

Parameters:

virtualMachineId - The virtual machine id.

numberOfMonitoringEntries - The number of monitoring entries to fetch.

Returns:

The virtual machine meta data.

getGroupManagerDescriptionsOnly

protected ArrayList<org.inria.myriads.snoozecommon.communication.groupmanager.GroupManagerDescription> getGroupManagerDescriptionsOnly(String firstGroupManagerId,
                                                                                                                           int limit,
                                                                                                                           boolean assignedOnly,
                                                                                                                           int numberOfBacklogEntries,
                                                                                                                           List<String> toExclude)

Gets the groupmanager descriptions.

Parameters:

firstGroupManagerId - First groupmanager to fetch.

limit - Limit.

assignedOnly - True will return assigned group manager only.

numberOfBacklogEntries - Number of Back log entries to fetch.

toExclude - id to exclude.

Returns:

List of group manager description.

getVirtualMachineDescriptionOnly

protected org.inria.myriads.snoozecommon.communication.virtualcluster.VirtualMachineMetaData getVirtualMachineDescriptionOnly(String virtualMachineId,
                                                                                                                  int numberOfMonitoringEntries)

Gets the virtual machine descriptions.

Parameters:

virtualMachineId - The virtualMachine Id.

numberOfMonitoringEntries - The number of monitoring entries to fecth.

Returns:

The virtual machine meta data.

getVirtualMachineDescriptionsOnly

protected ArrayList<org.inria.myriads.snoozecommon.communication.virtualcluster.VirtualMachineMetaData> getVirtualMachineDescriptionsOnly(String groupManagerId,
                                                                                                                              String localControllerId,
                                                                                                                              String virtualMachineStart,
                                                                                                                              int limit,
                                                                                                                              int numberOfMonitoringEntries,
                                                                                                                              boolean onlyAssigned)

Gets virtual machine metadatas from cassandra cluster.

Parameters:

groupManagerId - The groupmanager id.

localControllerId - The localcontroller id.

virtualMachineStart - The first virtual machine to fecth

limit - Limit.

numberOfMonitoringEntries - Number Of monitoring entries to fetch.

onlyAssigned - True if only assigned requested.

Returns:

The virtual machine meta datas list.

getLocalControllerId

protected String getLocalControllerId(org.inria.myriads.snoozecommon.communication.NetworkAddress contactInformation)

Gets the local controller id from the mapping column family.

Parameters:

contactInformation - the network address

Returns:

the local controller id.

clear

protected void clear()

Clear to repository.

getKeyspace

public me.prettyprint.hector.api.Keyspace getKeyspace()

Returns:

the keyspace_

getCluster

public me.prettyprint.hector.api.Cluster getCluster()

Returns:

the cluster