LoadBalanceRSocket class

RSocket load balance

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

Inheritance

• Object
• RSocket
• LoadBalanceRSocket

Constructors

LoadBalanceRSocket()

Properties

activeRSockets ↔ Map<String, RSocket>

getter/setter pair

counter ↔ int

getter/setter pair

fireAndForget ↔ Future<void> Function(Payload?)?

getter/setter pair, override

hashCode → int

The hash code for this object.

no setter, inherited

healthCheckTimer ↔ Timer?

getter/setter pair

lastRefreshTimeStamp ↔ int

getter/setter pair

lastRSocketUrls ↔ List<String>

getter/setter pair

metadataPush ↔ Future<void> Function(Payload?)?

getter/setter pair, override

poolSize ↔ int

getter/setter pair

requestChannel ↔ Stream<Payload> Function(Stream<Payload>)?

getter/setter pair, override

requestResponse ↔ Future<Payload> Function(Payload?)?

getter/setter pair, override

requestStream ↔ Stream<Payload?> Function(Payload?)?

getter/setter pair, override

roundRobin ↔ List<RSocket>

getter/setter pair

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

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