Top Description Methods
io.rsocket.loadbalance

public Interface WeightedStats

Known Direct Implementers
io.rsocket.loadbalance.WeightedStatsRSocketProxy, io.rsocket.loadbalance.BaseWeightedStats
Imports
io.rsocket.RSocket
Contract to expose the stats required in WeightedLoadbalanceStrategy to calculate an algorithmic weight for an RSocket. The weight helps to select an RSocket for load-balancing.
Since
1.1

Method Summary

Modifier and TypeMethod and Description
public double
higherQuantileLatency()

public double
lowerQuantileLatency()

public int
pending()

public double
predictedLatency()

public double
weightedAvailability()

public default RSocket

Returns:

the wrapped RSocket
wrap(RSocket
the RSocket to wrap
rsocket)

Create a proxy for the given RSocket that attaches the stats contained in this instance and exposes them as WeightedStats.

Method Detail

higherQuantileLatencyback to summary
public double higherQuantileLatency()
lowerQuantileLatencyback to summary
public double lowerQuantileLatency()
pendingback to summary
public int pending()
predictedLatencyback to summary
public double predictedLatency()
weightedAvailabilityback to summary
public double weightedAvailability()
wrapback to summary
public default RSocket wrap(RSocket rsocket)

Create a proxy for the given RSocket that attaches the stats contained in this instance and exposes them as WeightedStats.

Parameters
rsocket:RSocket

the RSocket to wrap

Returns:RSocket

the wrapped RSocket

Since
1.1.1