LoadBalanceRSocket class

RSocket load balance

var rsocket = LoadBalanceRSocket();
await rsocket.refreshUrl(['tcp://127.0.0.1:42252']);
Inheritance

Constructors

LoadBalanceRSocket()

Properties

activeRSockets Map<String, RSocket>
getter/setter pair
counter int
getter/setter pair
fireAndForget ↔ (Future<void> Function(Payload?)?)
getter/setter pairoverride
hashCode int
The hash code for this object.
no setterinherited
healthCheckTimer Timer?
getter/setter pair
lastRefreshTimeStamp int
getter/setter pair
lastRSocketUrls List<String>
getter/setter pair
metadataPush ↔ (Future<void> Function(Payload?)?)
getter/setter pairoverride
poolSize int
getter/setter pair
requestChannel ↔ (Stream<Payload> Function(Stream<Payload>)?)
getter/setter pairoverride
requestResponse ↔ (Future<Payload> Function(Payload?)?)
getter/setter pairoverride
requestStream ↔ (Stream<Payload?> Function(Payload?)?)
getter/setter pairoverride
roundRobin List<RSocket>
getter/setter pair
runtimeType Type
A representation of the runtime type of the object.
no setterinherited
unHealthyUrls List<String>
getter/setter pair

Methods

availability() double
override
checkActiveRSockets() → void
checkUnhealthyUris() → void
close() → void
override
closeStales(Map<String, RSocket> staleRSockets) Future<void>
connect(String url) Future<RSocket>
getRandomRSocket() RSocket?
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
refreshUrl(List<String> urls) Future<void>
toString() String
A string representation of this object.
inherited

Operators

operator ==(Object other) bool
The equality operator.
inherited

Static Properties

healthCheckIntervalSeconds Duration
final