![]() | 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.) |