DefaultResizer Class |
Namespace: Akka.Routing
The DefaultResizer type exposes the following members.
Name | Description | |
---|---|---|
DefaultResizer |
Initializes a new instance of the DefaultResizer class.
|
Name | Description | |
---|---|---|
BackoffRate |
Fraction of routees to be removed when the resizer reaches the
backoffThreshold.
For example, 0.1 would decrease 10% (rounded up), i.e. if current
capacity is 9 it will request an decrease of 1 routee.
| |
BackoffThreshold |
Minimum fraction of busy routees before backing off.
For example, if this is 0.3, then we'll remove some routees only when
less than 30% of routees are busy, i.e. if current capacity is 10 and
3 are busy then the capacity is unchanged, but if 2 or less are busy
the capacity is decreased.
Use 0.0 or negative to avoid removal of routees.
| |
LowerBound |
The fewest number of routees the router should ever have.
| |
MessagesPerResize |
Number of messages between resize operation.
Use 1 to resize before each message.
| |
PressureThreshold |
* Threshold to evaluate if routee is considered to be busy (under pressure).
Implementation depends on this value (default is 1).
| |
RampupRate |
Percentage to increase capacity whenever all routees are busy.
For example, 0.2 would increase 20% (rounded up), i.e. if current
capacity is 6 it will request an increase of 2 more routees.
| |
UpperBound |
The most number of routees the router should ever have.
Must be greater than or equal to `lowerBound`.
|
Name | Description | |
---|---|---|
Backoff |
Computes a proposed negative (or zero) capacity delta using
the configured `backoffThreshold` and `backoffRate`
| |
Capacity |
Returns the overall desired change in resizer capacity. Positive value will
add routees to the resizer. Negative value will remove routees from the
resizer
| |
Equals(Object) | Determines whether the specified object is equal to the current object. (Overrides ObjectEquals(Object).) | |
Equals(DefaultResizer) | Indicates whether the current object is equal to another object of the same type. | |
Filter |
This method can be used to smooth the capacity delta by considering
the current pressure and current capacity.
| |
Finalize | Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection. (Inherited from Object.) | |
FromConfig |
TBD
| |
GetHashCode | Serves as the default hash function. (Overrides ObjectGetHashCode.) | |
GetType | Gets the Type of the current instance. (Inherited from Object.) | |
IsTimeForResize |
TBD
(Overrides ResizerIsTimeForResize(Int64).) | |
MemberwiseClone | Creates a shallow copy of the current Object. (Inherited from Object.) | |
Pressure |
Number of routees considered busy, or above 'pressure level'.
Implementation depends on the value of `pressureThreshold`
(default is 1).
| |
Rampup |
Computes a proposed positive (or zero) capacity delta using
the configured `rampupRate`.
| |
Resize |
TBD
(Overrides ResizerResize(IEnumerableRoutee).) | |
ToString | Returns a string that represents the current object. (Inherited from Object.) |
Name | Description | |
---|---|---|
AsInstanceOfT |
TBD
(Defined by Extensions.) | |
Match | Overloaded.
Matches the specified target.
(Defined by PatternMatch.) | |
MatchT | Overloaded.
Matches the specified target and return a result of target processing.
(Defined by PatternMatch.) |