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 API
Leave 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 API
`void`	`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 API
`void`	`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()`

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

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 API
Leave package accessible for testing purpose

Returns:

(undocumented)

record_$eq

public void record_$eq(OptimalSizeExploringResizer.ResizeRecord x$1)

stopExploring
```
public boolean stopExploring()
```
INTERNAL API
Leave 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 interface Resizer

reportMessageCount

public void reportMessageCount(scala.collection.immutable.IndexedSeq<Routee> currentRoutees,
                               long messageCounter)

Specified by:: reportMessageCount in interface OptimalSizeExploringResizer

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 when isTimeForResize 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.

Specified by:

resize in interface Resizer

Parameters:

currentRoutees - (undocumented)

Returns:

(undocumented)

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 interface scala.Product

productArity
```
public int productArity()
```
Specified by:

productArity in interface scala.Product

productElement
```
public java.lang.Object productElement(int x$1)
```
Specified by:

productElement in interface scala.Product

productIterator

public scala.collection.Iterator<java.lang.Object> productIterator()

Specified by:: productIterator in interface scala.Product

canEqual
```
public boolean canEqual(java.lang.Object x$1)
```
Specified by:

canEqual in interface scala.Equals

hashCode
```
public int hashCode()
```
Overrides:

hashCode in class java.lang.Object

toString
```
public java.lang.String toString()
```
Overrides:

toString in class java.lang.Object

equals
```
public boolean equals(java.lang.Object x$1)
```
Specified by:

equals in interface scala.Equals

Overrides:

equals in class java.lang.Object

Class DefaultOptimalSizeExploringResizer

Nested Class Summary

Nested classes/interfaces inherited from interface akka.routing.OptimalSizeExploringResizer

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

DefaultOptimalSizeExploringResizer

Method Detail

$lessinit$greater$default$1

$lessinit$greater$default$2

$lessinit$greater$default$3

$lessinit$greater$default$4

$lessinit$greater$default$5

$lessinit$greater$default$6

$lessinit$greater$default$7

$lessinit$greater$default$8

$lessinit$greater$default$9

$lessinit$greater$default$10

apply

apply$default$1

apply$default$10

apply$default$2

apply$default$3

apply$default$4

apply$default$5

apply$default$6

apply$default$7

apply$default$8

apply$default$9

unapply

lowerBound

upperBound

chanceOfScalingDownWhenFull

actionInterval

numOfAdjacentSizesToConsiderDuringOptimization

exploreStepSize

downsizeRatio

downsizeAfterUnderutilizedFor

explorationProbability

weightOfLatestMetric

performanceLog

performanceLog_$eq

record

record_$eq

stopExploring

stopExploring_$eq

isTimeForResize

reportMessageCount

updatedStats

resize

copy

copy$default$1

copy$default$10

copy$default$2

copy$default$3

copy$default$4

copy$default$5

copy$default$6

copy$default$7

copy$default$8

copy$default$9

productPrefix

productArity

productElement

productIterator

canEqual

hashCode

toString

equals