Worker class abstract
Base worker class.
This base class takes care of creating the Channel and firing up the worker. Typically, derived classes should add proxy methods sending WorkerRequests to the worker.
- Implemented types
Constructors
Properties
- args → List
-
The Worker's start arguments.
final
- channel → Channel?
-
Channel to communicate with the worker.
no setter
- hashCode → int
-
The hash code for this object.
no setterinherited
- idleTime → Duration
-
Idle time.
no setter
- isStopped → bool
-
Indicates if the Worker has been stopped.
no setter
- maxWorkload → int
-
Maximum acceptable workload.
no setter
-
operations
→ Map<
int, CommandHandler> -
Workers do not need an operations map.
no setteroverride
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
- stats → WorkerStat
-
Worker statistics.
no setter
- status → String
-
Worker status.
no setter
- totalErrors → int
-
Total errors.
no setter
- totalWorkload → int
-
Total processed workload.
no setter
- upTime → Duration
-
Up time.
no setter
- workerId → String
-
Worker ID
final
- workload → int
-
Current workload.
no setter
Methods
-
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
send<
T> (int command, {List args = const [], CancellationToken? token, bool inspectRequest = false, bool inspectResponse = false}) → Future< T> - Sends a workload to the worker.
-
start(
) → Future< Channel> -
Creates a Channel and starts the worker using the
_entryPoint. -
stop(
) → void - Stops this worker.
-
stream<
T> (int command, {List args = const [], CancellationToken? token, bool inspectRequest = false, bool inspectResponse = false}) → Stream< T> - Sends a streaming workload to the worker.
-
toString(
) → String -
A string representation of this object.
inherited
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited