com.bytex.snamp.supervision.def

Class DefaultElasticityManager

java.lang.Object

com.bytex.snamp.supervision.def.DefaultElasticityManager

All Implemented Interfaces:

com.bytex.snamp.connector.metrics.MetricsSupport, com.bytex.snamp.Stateful, com.bytex.snamp.supervision.elasticity.ElasticityManager, com.bytex.snamp.supervision.SupervisorAggregatedService, AutoCloseable, Iterable<com.bytex.snamp.connector.metrics.Metric>

public class DefaultElasticityManager
extends Object
implements com.bytex.snamp.supervision.elasticity.ElasticityManager, AutoCloseable

Represents eventual implementation of elasticity manager that can be used to make decisions only.

Real scaling logic should be implemented in the derived class.

Since:

2.0

Version:

2.0

Author:

Roman Sakno

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	DefaultElasticityManager.ScalingDecision Represents scaling decision.

Constructor Summary

Constructors

Constructor and Description
DefaultElasticityManager() Initializes a new elasticity manager.

Method Summary

Modifier and Type	Method and Description
void	addScalingPolicy(String policyName, ScalingPolicy voter) Adds a new voter to this manager.
void	close()
protected DefaultElasticityManager.ScalingDecision	decide(ScalingPolicyEvaluationContext context, Map<String,Double> ballotBox)
double	getCastingVoteWeight()
Duration	getCooldownTime()
int	getMaxClusterSize() Gets maximum number of resources in cluster.
com.bytex.snamp.connector.metrics.Metric	getMetric(String metricName) Gets metric by its name.
<M extends com.bytex.snamp.connector.metrics.Metric> Iterable<? extends M>	getMetrics(Class<M> metricType) Returns a set of supported metrics.
int	getMinClusterSize() Gets minimum number of resources in cluster.
com.google.common.collect.ImmutableMap<String,ScalingPolicy>	getPolicies() Gets read-only map of active scaling policies.
com.bytex.snamp.supervision.elasticity.ScalingMetrics	getScalingMetrics() Gets scaling metrics.
int	getScalingSize()
double	getVotesForScaleIn()
double	getVotesForScaleOut()
Iterator<com.bytex.snamp.connector.metrics.Metric>	iterator() Returns an iterator over elements of type T.
void	reset() Resets internal state of the object.
void	setCooldownTime(Duration value)
void	setMaxClusterSize(int value) Sets maximum size of a cluster.
void	setMinClusterSize(int value) Sets minimum size of a cluster.
void	setScalingSize(int value)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

DefaultElasticityManager

public DefaultElasticityManager()

Initializes a new elasticity manager.

Method Detail

addScalingPolicy

public final void addScalingPolicy(@Nonnull
                                   String policyName,
                                   @Nonnull
                                   ScalingPolicy voter)

Adds a new voter to this manager.

Parameters:

policyName - Name of the policy.

voter - A voter that will be used to compute decision about scaling.

decide

protected final DefaultElasticityManager.ScalingDecision decide(@Nonnull
                                                                ScalingPolicyEvaluationContext context,
                                                                @Nullable
                                                                Map<String,Double> ballotBox)

setMaxClusterSize

public final void setMaxClusterSize(int value)

Sets maximum size of a cluster.

Parameters:

value - Maximum size of a cluster. Cannot be less than 1.

setMinClusterSize

public final void setMinClusterSize(int value)

Sets minimum size of a cluster.

Parameters:

value - Minimum size of a cluster.

getMaxClusterSize

public final int getMaxClusterSize()

Gets maximum number of resources in cluster.

Specified by:

getMaxClusterSize in interface com.bytex.snamp.supervision.elasticity.ElasticityManager

Returns:

Maximum number of resources in cluster.

getMinClusterSize

public final int getMinClusterSize()

Gets minimum number of resources in cluster.

Specified by:

getMinClusterSize in interface com.bytex.snamp.supervision.elasticity.ElasticityManager

Returns:

Minimum number of resources in cluster.

setCooldownTime

public final void setCooldownTime(@Nonnull
                                  Duration value)

getCooldownTime

@Nonnull
public final Duration getCooldownTime()

Specified by:

getCooldownTime in interface com.bytex.snamp.supervision.elasticity.ElasticityManager

setScalingSize

public final void setScalingSize(int value)

getScalingSize

public final int getScalingSize()

Specified by:

getScalingSize in interface com.bytex.snamp.supervision.elasticity.ElasticityManager

getCastingVoteWeight

public final double getCastingVoteWeight()

Specified by:

getCastingVoteWeight in interface com.bytex.snamp.supervision.elasticity.ElasticityManager

getScalingMetrics

public final com.bytex.snamp.supervision.elasticity.ScalingMetrics getScalingMetrics()

Gets scaling metrics.

Specified by:

getScalingMetrics in interface com.bytex.snamp.supervision.elasticity.ElasticityManager

Returns:

Scaling metrics.

getMetrics

public <M extends com.bytex.snamp.connector.metrics.Metric> Iterable<? extends M> getMetrics(Class<M> metricType)

Returns a set of supported metrics.

Specified by:

getMetrics in interface com.bytex.snamp.connector.metrics.MetricsSupport

Parameters:

metricType - Type of the metrics.

Returns:

Immutable set of metrics.

getMetric

public com.bytex.snamp.connector.metrics.Metric getMetric(String metricName)

Gets metric by its name.

Specified by:

getMetric in interface com.bytex.snamp.connector.metrics.MetricsSupport

Parameters:

metricName - Name of the metric.

Returns:

An instance of metric; or null, if metrics doesn't exist.

iterator

@Nonnull
public Iterator<com.bytex.snamp.connector.metrics.Metric> iterator()

Returns an iterator over elements of type T.

Specified by:

iterator in interface Iterable<com.bytex.snamp.connector.metrics.Metric>

Returns:

an Iterator.

reset

public void reset()

Resets internal state of the object.

Specified by:

reset in interface com.bytex.snamp.connector.metrics.MetricsSupport

Specified by:

reset in interface com.bytex.snamp.Stateful

getVotesForScaleIn

public final double getVotesForScaleIn()

Specified by:

getVotesForScaleIn in interface com.bytex.snamp.supervision.elasticity.ElasticityManager

getVotesForScaleOut

public double getVotesForScaleOut()

Specified by:

getVotesForScaleOut in interface com.bytex.snamp.supervision.elasticity.ElasticityManager

getPolicies

public final com.google.common.collect.ImmutableMap<String,ScalingPolicy> getPolicies()

Gets read-only map of active scaling policies.

Specified by:

getPolicies in interface com.bytex.snamp.supervision.elasticity.ElasticityManager

Returns:

A map of scaling policies.

close

@OverridingMethodsMustInvokeSuper
public void close()
                                             throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception