LoadBalanceRSocket class
RSocket load balance
var rsocket = LoadBalanceRSocket();
await rsocket.refreshUrl(['tcp://127.0.0.1:42252']);
Constructors
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