Top Description Fields Constructors Methods

io.rsocket.loadbalance

pack-priv Class WeightedStatsRSocketProxy

Class Inheritance

extends RSocketProxy
implements WeightedStats

java.lang.Object
io.rsocket.util.RSocketProxy
io.rsocket.loadbalance.WeightedStatsRSocketProxy

All Implemented Interfaces

io.rsocket.loadbalance.WeightedStats

Imports

io.rsocket.RSocket, io.rsocket.util.RSocketProxy

Package private RSocketProxy used from WeightedStats#wrap(RSocket) to attach a WeightedStats instance to an RSocket.

Field Summary

Modifier and Type	Field and Description
private final WeightedStats	weightedStats

Inherited from io.rsocket.util.RSocketProxy:: source

Constructor Summary

Access	Constructor and Description
public	WeightedStatsRSocketProxy(RSocket source, WeightedStats weightedStats)

Method Summary

Modifier and Type	Method and Description
public WeightedStats	getDelegate()
public double	higherQuantileLatency() Implements io.rsocket.loadbalance.WeightedStats.higherQuantileLatency.
public double	lowerQuantileLatency() Implements io.rsocket.loadbalance.WeightedStats.lowerQuantileLatency.
public int	pending() Implements io.rsocket.loadbalance.WeightedStats.pending.
public double	predictedLatency() Implements io.rsocket.loadbalance.WeightedStats.predictedLatency.
public double	weightedAvailability() Implements io.rsocket.loadbalance.WeightedStats.weightedAvailability.

Inherited from io.rsocket.util.RSocketProxy:: availability dispose fireAndForget isDisposed metadataPush onClose requestChannel requestResponse requestStream

Field Detail

weightedStats	back to summary
private final WeightedStats weightedStats

Constructor Detail

WeightedStatsRSocketProxy	back to summary
public WeightedStatsRSocketProxy(RSocket source, WeightedStats weightedStats)

Method Detail

getDelegate	back to summary
public WeightedStats getDelegate()

higherQuantileLatency	back to summary
public double higherQuantileLatency() Implements io.rsocket.loadbalance.WeightedStats.higherQuantileLatency. Annotations @Override

higherQuantileLatency

back to summary

public double higherQuantileLatency()

Implements io.rsocket.loadbalance.WeightedStats.higherQuantileLatency.

Annotations

@Override

lowerQuantileLatency	back to summary
public double lowerQuantileLatency() Implements io.rsocket.loadbalance.WeightedStats.lowerQuantileLatency. Annotations @Override

lowerQuantileLatency

back to summary

public double lowerQuantileLatency()

Implements io.rsocket.loadbalance.WeightedStats.lowerQuantileLatency.

Annotations

@Override

pending	back to summary
public int pending() Implements io.rsocket.loadbalance.WeightedStats.pending. Annotations @Override

pending

back to summary

public int pending()

Implements io.rsocket.loadbalance.WeightedStats.pending.

Annotations

@Override

predictedLatency	back to summary
public double predictedLatency() Implements io.rsocket.loadbalance.WeightedStats.predictedLatency. Annotations @Override

predictedLatency

back to summary

public double predictedLatency()

Implements io.rsocket.loadbalance.WeightedStats.predictedLatency.

Annotations

@Override

weightedAvailability	back to summary
public double weightedAvailability() Implements io.rsocket.loadbalance.WeightedStats.weightedAvailability. Annotations @Override

weightedAvailability

back to summary

public double weightedAvailability()

Implements io.rsocket.loadbalance.WeightedStats.weightedAvailability.

Annotations

@Override