com.bytex.snamp.supervision.def

Class DefaultSupervisor

java.lang.Object

com.bytex.snamp.AbstractAggregator

com.bytex.snamp.core.AbstractFrameworkServiceTracker<S,C>

com.bytex.snamp.core.AbstractStatefulFrameworkServiceTracker<com.bytex.snamp.connector.ManagedResourceConnector,com.bytex.snamp.connector.ManagedResourceConnectorClient,com.bytex.snamp.configuration.SupervisorInfo>

com.bytex.snamp.supervision.AbstractSupervisor

com.bytex.snamp.supervision.def.DefaultSupervisor

All Implemented Interfaces:

com.bytex.snamp.Aggregator, com.bytex.snamp.core.FrameworkService, com.bytex.snamp.core.StatefulFrameworkService, ScalingPolicyEvaluationContext, HealthStatusTrigger, com.bytex.snamp.supervision.Supervisor, Closeable, AutoCloseable, EventListener, org.osgi.framework.ServiceListener

public class DefaultSupervisor
extends com.bytex.snamp.supervision.AbstractSupervisor
implements HealthStatusTrigger, ScalingPolicyEvaluationContext

Represents default supervisor with health check support and without elasticity management.

Since:

2.0

Version:

2.0

Author:

Roman Sakno

Nested Class Summary

Nested classes/interfaces inherited from class com.bytex.snamp.core.AbstractStatefulFrameworkServiceTracker

com.bytex.snamp.core.AbstractStatefulFrameworkServiceTracker.InternalState<C extends Map<String,?>>

Nested classes/interfaces inherited from class com.bytex.snamp.AbstractAggregator

com.bytex.snamp.AbstractAggregator.Aggregation, com.bytex.snamp.AbstractAggregator.AggregationBuilder

Field Summary

Fields

Modifier and Type	Field and Description
protected com.bytex.snamp.core.ClusterMember	clusterMember Gets a reference to the current member in SNAMP cluster.

Fields inherited from class com.bytex.snamp.supervision.AbstractSupervisor

groupName, supervisorType

Fields inherited from class com.bytex.snamp.core.AbstractFrameworkServiceTracker

trackedServices

Fields inherited from interface com.bytex.snamp.supervision.health.triggers.HealthStatusTrigger

NO_OP

Fields inherited from interface com.bytex.snamp.Aggregator

EMPTY

Fields inherited from interface com.bytex.snamp.supervision.Supervisor

CAPABILITY_NAMESPACE, EMPTY_CONFIGURATION, TYPE_CAPABILITY_ATTRIBUTE

Fields inherited from interface com.bytex.snamp.core.FrameworkService

CATEGORY_PROPERTY

Constructor Summary

Constructors

Constructor and Description
DefaultSupervisor(String groupName)

Method Summary

Modifier and Type	Method and Description
protected DefaultSupervisorConfigurationDescriptionProvider	getDescriptionProvider()
protected void	maxClusterSizeReached(Map<String,Double> policyEvaluation)
protected void	overrideCheckerFactory(AttributeCheckerFactory value)
protected void	overrideDiscoveryService(DefaultResourceDiscoveryService value)
protected void	overrideElasticityManager(DefaultElasticityManager value)
protected void	overrideHealthStatusProvider(DefaultHealthStatusProvider value)
protected void	overrideScalingPolicyFactory(ScalingPolicyFactory value)
protected void	overrideTriggerFactory(TriggerFactory value)
protected void	removeResource(String resourceName, com.bytex.snamp.connector.ManagedResourceConnector connector)
protected void	scaleIn(Map<String,Double> policyEvaluation)
protected void	scaleOut(Map<String,Double> policyEvaluation)
protected void	start(com.bytex.snamp.configuration.SupervisorInfo configuration) Starts the tracking resources.
void	statusChanged(com.bytex.snamp.supervision.health.ResourceGroupHealthStatus previousStatus, com.bytex.snamp.supervision.health.ResourceGroupHealthStatus newStatus)
protected void	stop() Stops tracking resources.
protected void	supervise() Executes automatically using scheduling time.

Methods inherited from class com.bytex.snamp.supervision.AbstractSupervisor

addResource, addService, addSupervisionEventListener, addSupervisionEventListener, close, createClient, createServiceFilter, getResources, getServiceId, healthStatusChanged, removeService, removeSupervisionEventListener, scalingHappens, toString

Methods inherited from class com.bytex.snamp.core.AbstractStatefulFrameworkServiceTracker

getServiceFilter, getState, started, stopped, update

Methods inherited from class com.bytex.snamp.core.AbstractFrameworkServiceTracker

getBundleContext, getLogger, serviceChanged

Methods inherited from class com.bytex.snamp.AbstractAggregator

builder, clearCache, compose, queryObject, queryObject

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.bytex.snamp.supervision.elasticity.policies.ScalingPolicyEvaluationContext

getConfiguration, getResources

Methods inherited from interface com.bytex.snamp.Aggregator

compose, queryObject

Methods inherited from interface com.bytex.snamp.supervision.Supervisor

getSupervisorType, getSupervisorType, isSupervisorBundle, queryObject

Methods inherited from interface com.bytex.snamp.core.StatefulFrameworkService

getState

Field Detail

clusterMember

protected final com.bytex.snamp.core.ClusterMember clusterMember

Gets a reference to the current member in SNAMP cluster.

Constructor Detail

DefaultSupervisor

public DefaultSupervisor(@Nonnull
                         String groupName)

Method Detail

overrideElasticityManager

protected final void overrideElasticityManager(@Nonnull
                                               DefaultElasticityManager value)

overrideScalingPolicyFactory

protected final void overrideScalingPolicyFactory(@Nonnull
                                                  ScalingPolicyFactory value)

overrideCheckerFactory

protected final void overrideCheckerFactory(@Nonnull
                                            AttributeCheckerFactory value)

overrideTriggerFactory

protected final void overrideTriggerFactory(@Nonnull
                                            TriggerFactory value)

overrideHealthStatusProvider

protected final void overrideHealthStatusProvider(@Nonnull
                                                  DefaultHealthStatusProvider value)

overrideDiscoveryService

protected final void overrideDiscoveryService(@Nonnull
                                              DefaultResourceDiscoveryService value)

statusChanged

public final void statusChanged(com.bytex.snamp.supervision.health.ResourceGroupHealthStatus previousStatus,
                                com.bytex.snamp.supervision.health.ResourceGroupHealthStatus newStatus)

Specified by:

statusChanged in interface HealthStatusTrigger

supervise

protected void supervise()

Executes automatically using scheduling time.

removeResource

@OverridingMethodsMustInvokeSuper
protected void removeResource(String resourceName,
                                                                com.bytex.snamp.connector.ManagedResourceConnector connector)

Overrides:

removeResource in class com.bytex.snamp.supervision.AbstractSupervisor

stop

@OverridingMethodsMustInvokeSuper
protected void stop()
                                               throws Exception

Stops tracking resources.

This method will be called by SNAMP infrastructure automatically.

Specified by:

stop in class com.bytex.snamp.core.AbstractStatefulFrameworkServiceTracker<com.bytex.snamp.connector.ManagedResourceConnector,com.bytex.snamp.connector.ManagedResourceConnectorClient,com.bytex.snamp.configuration.SupervisorInfo>

Throws:

Exception - Unable to stop tracking resources.

scaleIn

protected final void scaleIn(Map<String,Double> policyEvaluation)

scaleOut

protected final void scaleOut(Map<String,Double> policyEvaluation)

maxClusterSizeReached

protected final void maxClusterSizeReached(Map<String,Double> policyEvaluation)

getDescriptionProvider

protected DefaultSupervisorConfigurationDescriptionProvider getDescriptionProvider()

start

@OverridingMethodsMustInvokeSuper
protected void start(com.bytex.snamp.configuration.SupervisorInfo configuration)
                                                throws Exception

Starts the tracking resources.

This method will be called by SNAMP infrastructure automatically.

Specified by:

start in class com.bytex.snamp.core.AbstractStatefulFrameworkServiceTracker<com.bytex.snamp.connector.ManagedResourceConnector,com.bytex.snamp.connector.ManagedResourceConnectorClient,com.bytex.snamp.configuration.SupervisorInfo>

Parameters:

configuration - Tracker startup parameters.

Throws:

Exception - Unable to start tracking.