org.inria.myriads.snoozenode.groupmanager.monitoring

Class MonitoringFactory

java.lang.Object

org.inria.myriads.snoozenode.groupmanager.monitoring.MonitoringFactory

public final class MonitoringFactory
extends Object

Monitoring factory.

Author:

Eugen Feller

Method Summary

Methods

Modifier and Type	Method and Description
static GroupManagerMonitoringService	newGroupManagerMonitoringService(String groupManagerId, GroupManagerRepository repository, ResourceDemandEstimator estimator, DatabaseSettings databaseSettings, MonitoringSettings monitoringSettings, ExternalNotifierSettings monitoringExternalSettings) Creates a new group manager monitoring service.
static GroupManagerSummaryReceiver	newGroupManagerSummaryReceiver(org.inria.myriads.snoozecommon.communication.NetworkAddress networkAddress, int timeOut, GroupLeaderRepository repository) Creates a new group leader summary receiver.
static LocalControllerSummaryConsumer	newLocalControllerSummaryConsumer(BlockingQueue<LocalControllerDataTransporter> dataQueue, StateMachine stateMachine, GroupManagerRepository repository) Creates a new local controller summary information consumer.
static LocalControllerSummaryReceiver	newLocalControllerSummaryReceiver(org.inria.myriads.snoozecommon.communication.NetworkAddress networkAddress, int timeOut, BlockingQueue<LocalControllerDataTransporter> dataQueue, StateMachine stateMachine, GroupManagerRepository repository) Creates a new local controller monitoring data receiver.

Methods inherited from class java.lang.Object

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

Method Detail

newGroupManagerSummaryReceiver

public static GroupManagerSummaryReceiver newGroupManagerSummaryReceiver(org.inria.myriads.snoozecommon.communication.NetworkAddress networkAddress,
                                                         int timeOut,
                                                         GroupLeaderRepository repository)
                                                                  throws Exception

Creates a new group leader summary receiver.

Parameters:

networkAddress - The network address

timeOut - The time out

repository - The repository

Returns:

The group leader monitoring data receiver

Throws:

Exception

newLocalControllerSummaryReceiver

public static LocalControllerSummaryReceiver newLocalControllerSummaryReceiver(org.inria.myriads.snoozecommon.communication.NetworkAddress networkAddress,
                                                               int timeOut,
                                                               BlockingQueue<LocalControllerDataTransporter> dataQueue,
                                                               StateMachine stateMachine,
                                                               GroupManagerRepository repository)
                                                                        throws Exception

Creates a new local controller monitoring data receiver.

Parameters:

networkAddress - The network address

timeOut - The timeout

dataQueue - The data queue

stateMachine - The state machine

repository - The group manager repository

Returns:

The summary data receiver

Throws:

Exception

newLocalControllerSummaryConsumer

public static LocalControllerSummaryConsumer newLocalControllerSummaryConsumer(BlockingQueue<LocalControllerDataTransporter> dataQueue,
                                                               StateMachine stateMachine,
                                                               GroupManagerRepository repository)
                                                                        throws Exception

Creates a new local controller summary information consumer.

Parameters:

dataQueue - The data queue

stateMachine - The state machine

repository - The repository

Returns:

The local controller monitoring data consumer

Throws:

Exception

newGroupManagerMonitoringService

public static GroupManagerMonitoringService newGroupManagerMonitoringService(String groupManagerId,
                                                             GroupManagerRepository repository,
                                                             ResourceDemandEstimator estimator,
                                                             DatabaseSettings databaseSettings,
                                                             MonitoringSettings monitoringSettings,
                                                             ExternalNotifierSettings monitoringExternalSettings)
                                                                      throws Exception

Creates a new group manager monitoring service.

Parameters:

groupManagerId - The group manager id.

repository - The group manager repository.

estimator - The resource demand estimator.

databaseSettings - The database settings.

monitoringSettings - The monitoring settings.

monitoringExternalSettings - The monitoringExternalSettings.

Returns:

The group manager monitoring data sender.

Throws:

Exception - The exception