com.bytex.snamp.supervision.elasticity.policies

Class AttributeBasedScalingPolicy

java.lang.Object

com.bytex.snamp.supervision.elasticity.policies.AbstractWeightedScalingPolicy

com.bytex.snamp.supervision.elasticity.policies.AttributeBasedScalingPolicy

All Implemented Interfaces:

ScriptletConfigurationSupport, com.bytex.snamp.Stateful, com.bytex.snamp.supervision.elasticity.AttributeBasedScalingPolicy, com.bytex.snamp.supervision.elasticity.ScalingPolicy, com.bytex.snamp.supervision.elasticity.WeightedScalingPolicy

public final class AttributeBasedScalingPolicy
extends AbstractWeightedScalingPolicy
implements com.bytex.snamp.supervision.elasticity.AttributeBasedScalingPolicy

Represents scaling policy based on value of attributes.

Since:

2.0

Version:

2.0

Author:

Roman Sakno

Field Summary

Fields inherited from interface com.bytex.snamp.supervision.elasticity.policies.ScalingPolicy

VOICELESS

Constructor Summary

Constructors

Constructor and Description
AttributeBasedScalingPolicy(String attributeName, double voteWeight, com.google.common.collect.Range<Double> operationalRange)
AttributeBasedScalingPolicy(String attributeName, double voteWeight, com.google.common.collect.Range<Double> operationalRange, Duration analysisDepth)
AttributeBasedScalingPolicy(String attributeName, double voteWeight, com.google.common.collect.Range<Double> operationalRange, Duration observationTime, com.bytex.snamp.moa.ReduceOperation aggregator, boolean incrementalWeight, Duration analysisDepth)

Method Summary

Modifier and Type	Method and Description
void	configureScriptlet(com.bytex.snamp.configuration.ScriptletConfiguration scriptlet)
double	evaluate(ScalingPolicyEvaluationContext context) Performs voting.
com.bytex.snamp.moa.ReduceOperation	getAggregator()
Duration	getAnalysisDepth()
String	getAttributeName()
com.google.common.collect.Range<Double>	getOperationalRange()
com.google.common.collect.Range<Double>	getRecommendation() Gets advice about more optimal operational range.
void	reset() Resets internal state of the object.

Methods inherited from class com.bytex.snamp.supervision.elasticity.policies.AbstractWeightedScalingPolicy

getObservationTime, getVoteWeight, isIncrementalVoteWeight

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.bytex.snamp.supervision.elasticity.WeightedScalingPolicy

getVoteWeight

Constructor Detail

AttributeBasedScalingPolicy

public AttributeBasedScalingPolicy(String attributeName,
                                   double voteWeight,
                                   com.google.common.collect.Range<Double> operationalRange,
                                   Duration observationTime,
                                   com.bytex.snamp.moa.ReduceOperation aggregator,
                                   boolean incrementalWeight,
                                   Duration analysisDepth)

AttributeBasedScalingPolicy

public AttributeBasedScalingPolicy(String attributeName,
                                   double voteWeight,
                                   com.google.common.collect.Range<Double> operationalRange,
                                   Duration analysisDepth)

AttributeBasedScalingPolicy

public AttributeBasedScalingPolicy(String attributeName,
                                   double voteWeight,
                                   com.google.common.collect.Range<Double> operationalRange)

Method Detail

getAnalysisDepth

public Duration getAnalysisDepth()

getRecommendation

@Nonnull
public com.google.common.collect.Range<Double> getRecommendation()

Gets advice about more optimal operational range.

Specified by:

getRecommendation in interface com.bytex.snamp.supervision.elasticity.AttributeBasedScalingPolicy

Returns:

More optimal operational range; or empty range if recommendation is not supported.

getAttributeName

@Nonnull
public String getAttributeName()

Specified by:

getAttributeName in interface com.bytex.snamp.supervision.elasticity.AttributeBasedScalingPolicy

getOperationalRange

@Nonnull
public com.google.common.collect.Range<Double> getOperationalRange()

Specified by:

getOperationalRange in interface com.bytex.snamp.supervision.elasticity.AttributeBasedScalingPolicy

getAggregator

@Nonnull
public com.bytex.snamp.moa.ReduceOperation getAggregator()

Specified by:

getAggregator in interface com.bytex.snamp.supervision.elasticity.AttributeBasedScalingPolicy

reset

public void reset()

Resets internal state of the object.

Specified by:

reset in interface com.bytex.snamp.Stateful

Overrides:

reset in class AbstractWeightedScalingPolicy

evaluate

public double evaluate(ScalingPolicyEvaluationContext context)

Performs voting.

Parameters:

context - An object containing all necessary data for voting by this voter.

Returns:

Vote weight: >0 - for scale-out; <0 - for scale-in

configureScriptlet

public void configureScriptlet(com.bytex.snamp.configuration.ScriptletConfiguration scriptlet)

Specified by:

configureScriptlet in interface ScriptletConfigurationSupport