Package akka.routing
Class DefaultOptimalSizeExploringResizer
- java.lang.Object
-
- akka.routing.DefaultOptimalSizeExploringResizer
-
- All Implemented Interfaces:
OptimalSizeExploringResizer
,Resizer
,java.io.Serializable
,scala.Equals
,scala.Product
,scala.Serializable
public class DefaultOptimalSizeExploringResizer extends java.lang.Object implements OptimalSizeExploringResizer, scala.Product, scala.Serializable
INTERNAL APILeave package accessible for testing purpose
- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface akka.routing.OptimalSizeExploringResizer
OptimalSizeExploringResizer.ResizeRecord, OptimalSizeExploringResizer.ResizeRecord$, OptimalSizeExploringResizer.UnderUtilizationStreak, OptimalSizeExploringResizer.UnderUtilizationStreak$
-
-
Constructor Summary
Constructors Constructor Description DefaultOptimalSizeExploringResizer(int lowerBound, int upperBound, double chanceOfScalingDownWhenFull, scala.concurrent.duration.Duration actionInterval, int numOfAdjacentSizesToConsiderDuringOptimization, double exploreStepSize, double downsizeRatio, scala.concurrent.duration.Duration downsizeAfterUnderutilizedFor, double explorationProbability, double weightOfLatestMetric)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static int
$lessinit$greater$default$1()
static double
$lessinit$greater$default$10()
static int
$lessinit$greater$default$2()
static double
$lessinit$greater$default$3()
static scala.concurrent.duration.Duration
$lessinit$greater$default$4()
static int
$lessinit$greater$default$5()
static double
$lessinit$greater$default$6()
static double
$lessinit$greater$default$7()
static scala.concurrent.duration.Duration
$lessinit$greater$default$8()
static double
$lessinit$greater$default$9()
scala.concurrent.duration.Duration
actionInterval()
static DefaultOptimalSizeExploringResizer
apply(int lowerBound, int upperBound, double chanceOfScalingDownWhenFull, scala.concurrent.duration.Duration actionInterval, int numOfAdjacentSizesToConsiderDuringOptimization, double exploreStepSize, double downsizeRatio, scala.concurrent.duration.Duration downsizeAfterUnderutilizedFor, double explorationProbability, double weightOfLatestMetric)
static int
apply$default$1()
static double
apply$default$10()
static int
apply$default$2()
static double
apply$default$3()
static scala.concurrent.duration.Duration
apply$default$4()
static int
apply$default$5()
static double
apply$default$6()
static double
apply$default$7()
static scala.concurrent.duration.Duration
apply$default$8()
static double
apply$default$9()
boolean
canEqual(java.lang.Object x$1)
double
chanceOfScalingDownWhenFull()
DefaultOptimalSizeExploringResizer
copy(int lowerBound, int upperBound, double chanceOfScalingDownWhenFull, scala.concurrent.duration.Duration actionInterval, int numOfAdjacentSizesToConsiderDuringOptimization, double exploreStepSize, double downsizeRatio, scala.concurrent.duration.Duration downsizeAfterUnderutilizedFor, double explorationProbability, double weightOfLatestMetric)
int
copy$default$1()
double
copy$default$10()
int
copy$default$2()
double
copy$default$3()
scala.concurrent.duration.Duration
copy$default$4()
int
copy$default$5()
double
copy$default$6()
double
copy$default$7()
scala.concurrent.duration.Duration
copy$default$8()
double
copy$default$9()
scala.concurrent.duration.Duration
downsizeAfterUnderutilizedFor()
double
downsizeRatio()
boolean
equals(java.lang.Object x$1)
double
explorationProbability()
double
exploreStepSize()
int
hashCode()
boolean
isTimeForResize(long messageCounter)
int
lowerBound()
int
numOfAdjacentSizesToConsiderDuringOptimization()
scala.collection.immutable.Map<java.lang.Object,scala.concurrent.duration.Duration>
performanceLog()
void
performanceLog_$eq(scala.collection.immutable.Map<java.lang.Object,scala.concurrent.duration.Duration> x$1)
int
productArity()
java.lang.Object
productElement(int x$1)
scala.collection.Iterator<java.lang.Object>
productIterator()
java.lang.String
productPrefix()
OptimalSizeExploringResizer.ResizeRecord
record()
INTERNAL APIvoid
record_$eq(OptimalSizeExploringResizer.ResizeRecord x$1)
void
reportMessageCount(scala.collection.immutable.IndexedSeq<Routee> currentRoutees, long messageCounter)
int
resize(scala.collection.immutable.IndexedSeq<Routee> currentRoutees)
Decide if the capacity of the router need to be changed.boolean
stopExploring()
INTERNAL APIvoid
stopExploring_$eq(boolean x$1)
java.lang.String
toString()
static scala.Option<scala.Tuple10<java.lang.Object,java.lang.Object,java.lang.Object,scala.concurrent.duration.Duration,java.lang.Object,java.lang.Object,java.lang.Object,scala.concurrent.duration.Duration,java.lang.Object,java.lang.Object>>
unapply(DefaultOptimalSizeExploringResizer x$0)
scala.Tuple2<scala.collection.immutable.Map<java.lang.Object,scala.concurrent.duration.Duration>,OptimalSizeExploringResizer.ResizeRecord>
updatedStats(scala.collection.immutable.IndexedSeq<Routee> currentRoutees, long messageCounter)
int
upperBound()
double
weightOfLatestMetric()
-
-
-
Constructor Detail
-
DefaultOptimalSizeExploringResizer
public DefaultOptimalSizeExploringResizer(int lowerBound, int upperBound, double chanceOfScalingDownWhenFull, scala.concurrent.duration.Duration actionInterval, int numOfAdjacentSizesToConsiderDuringOptimization, double exploreStepSize, double downsizeRatio, scala.concurrent.duration.Duration downsizeAfterUnderutilizedFor, double explorationProbability, double weightOfLatestMetric)
-
-
Method Detail
-
$lessinit$greater$default$1
public static int $lessinit$greater$default$1()
-
$lessinit$greater$default$2
public static int $lessinit$greater$default$2()
-
$lessinit$greater$default$3
public static double $lessinit$greater$default$3()
-
$lessinit$greater$default$4
public static scala.concurrent.duration.Duration $lessinit$greater$default$4()
-
$lessinit$greater$default$5
public static int $lessinit$greater$default$5()
-
$lessinit$greater$default$6
public static double $lessinit$greater$default$6()
-
$lessinit$greater$default$7
public static double $lessinit$greater$default$7()
-
$lessinit$greater$default$8
public static scala.concurrent.duration.Duration $lessinit$greater$default$8()
-
$lessinit$greater$default$9
public static double $lessinit$greater$default$9()
-
$lessinit$greater$default$10
public static double $lessinit$greater$default$10()
-
apply
public static DefaultOptimalSizeExploringResizer apply(int lowerBound, int upperBound, double chanceOfScalingDownWhenFull, scala.concurrent.duration.Duration actionInterval, int numOfAdjacentSizesToConsiderDuringOptimization, double exploreStepSize, double downsizeRatio, scala.concurrent.duration.Duration downsizeAfterUnderutilizedFor, double explorationProbability, double weightOfLatestMetric)
-
apply$default$1
public static int apply$default$1()
-
apply$default$10
public static double apply$default$10()
-
apply$default$2
public static int apply$default$2()
-
apply$default$3
public static double apply$default$3()
-
apply$default$4
public static scala.concurrent.duration.Duration apply$default$4()
-
apply$default$5
public static int apply$default$5()
-
apply$default$6
public static double apply$default$6()
-
apply$default$7
public static double apply$default$7()
-
apply$default$8
public static scala.concurrent.duration.Duration apply$default$8()
-
apply$default$9
public static double apply$default$9()
-
unapply
public static scala.Option<scala.Tuple10<java.lang.Object,java.lang.Object,java.lang.Object,scala.concurrent.duration.Duration,java.lang.Object,java.lang.Object,java.lang.Object,scala.concurrent.duration.Duration,java.lang.Object,java.lang.Object>> unapply(DefaultOptimalSizeExploringResizer x$0)
-
lowerBound
public int lowerBound()
-
upperBound
public int upperBound()
-
chanceOfScalingDownWhenFull
public double chanceOfScalingDownWhenFull()
-
actionInterval
public scala.concurrent.duration.Duration actionInterval()
-
numOfAdjacentSizesToConsiderDuringOptimization
public int numOfAdjacentSizesToConsiderDuringOptimization()
-
exploreStepSize
public double exploreStepSize()
-
downsizeRatio
public double downsizeRatio()
-
downsizeAfterUnderutilizedFor
public scala.concurrent.duration.Duration downsizeAfterUnderutilizedFor()
-
explorationProbability
public double explorationProbability()
-
weightOfLatestMetric
public double weightOfLatestMetric()
-
performanceLog
public scala.collection.immutable.Map<java.lang.Object,scala.concurrent.duration.Duration> performanceLog()
-
performanceLog_$eq
public void performanceLog_$eq(scala.collection.immutable.Map<java.lang.Object,scala.concurrent.duration.Duration> x$1)
-
record
public OptimalSizeExploringResizer.ResizeRecord record()
INTERNAL APILeave package accessible for testing purpose
- Returns:
- (undocumented)
-
record_$eq
public void record_$eq(OptimalSizeExploringResizer.ResizeRecord x$1)
-
stopExploring
public boolean stopExploring()
INTERNAL APILeave package accessible for testing purpose
- Returns:
- (undocumented)
-
stopExploring_$eq
public void stopExploring_$eq(boolean x$1)
-
isTimeForResize
public boolean isTimeForResize(long messageCounter)
- Specified by:
isTimeForResize
in interfaceResizer
-
reportMessageCount
public void reportMessageCount(scala.collection.immutable.IndexedSeq<Routee> currentRoutees, long messageCounter)
- Specified by:
reportMessageCount
in interfaceOptimalSizeExploringResizer
-
updatedStats
public scala.Tuple2<scala.collection.immutable.Map<java.lang.Object,scala.concurrent.duration.Duration>,OptimalSizeExploringResizer.ResizeRecord> updatedStats(scala.collection.immutable.IndexedSeq<Routee> currentRoutees, long messageCounter)
-
resize
public int resize(scala.collection.immutable.IndexedSeq<Routee> currentRoutees)
Description copied from interface:Resizer
Decide if the capacity of the router need to be changed. Will be invoked whenisTimeForResize
returns true and no other resize is in progress.Return the number of routees to add or remove. Negative value will remove that number of routees. Positive value will add that number of routees. 0 will not change the routees.
This method is invoked only in the context of the Router actor.
-
copy
public DefaultOptimalSizeExploringResizer copy(int lowerBound, int upperBound, double chanceOfScalingDownWhenFull, scala.concurrent.duration.Duration actionInterval, int numOfAdjacentSizesToConsiderDuringOptimization, double exploreStepSize, double downsizeRatio, scala.concurrent.duration.Duration downsizeAfterUnderutilizedFor, double explorationProbability, double weightOfLatestMetric)
-
copy$default$1
public int copy$default$1()
-
copy$default$10
public double copy$default$10()
-
copy$default$2
public int copy$default$2()
-
copy$default$3
public double copy$default$3()
-
copy$default$4
public scala.concurrent.duration.Duration copy$default$4()
-
copy$default$5
public int copy$default$5()
-
copy$default$6
public double copy$default$6()
-
copy$default$7
public double copy$default$7()
-
copy$default$8
public scala.concurrent.duration.Duration copy$default$8()
-
copy$default$9
public double copy$default$9()
-
productPrefix
public java.lang.String productPrefix()
- Specified by:
productPrefix
in interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArity
in interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElement
in interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIterator
in interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqual
in interfacescala.Equals
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object x$1)
- Specified by:
equals
in interfacescala.Equals
- Overrides:
equals
in classjava.lang.Object
-
-