MPIScheduler class

Implemented types

Constructors

MPIScheduler(InvocationHandler _h)

Properties

hashCode → int
The hash code for this object.
no setterinherited
runtimeType → Type
A representation of the runtime type of the object.
no setterinherited

Methods

cancel(String taskId, {Context? ctx}) → Future<bool?>
Cancel Attempts to cancel the {@link tech.firmer.mesh.types.Timeout} associated with this handle. If the task has been executed or cancelled already, it will return with no side effect.
override
cron(String cron, Topic topic, {Context? ctx}) → Future<String?>
Cron Schedules with the cron expression. "0 * * 1-3 * ? *"
override
dump({Context? ctx}) → Future<List<String>?>
Dump max is 1000 items Releases all resources acquired by this {@link Scheduler} and cancels all tasks which were scheduled but not executed yet.
override
emit(Topic topic, {Context? ctx}) → Future<void>
Emit the scheduler topic
override
ioc() → void
override
methods() → Map<String, Introspector>
override
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
period(Duration duration, Topic topic, {Context? ctx}) → Future<String?>
Period schedule with fixed duration.
override
shutdown(Duration duration, {Context? ctx}) → Future<void>
Shutdown the scheduler
override
stop(String taskId, {Context? ctx}) → Future<bool?>
Stop Attempts to stop the {@link tech.firmer.mesh.types.Timeout} associated with this handle. If the task has been executed or cancelled already, it will return with no side effect.
override
timeout(Timeout timeout, Duration duration, {Context? ctx}) → Future<String?>
Timeout Schedules the specified {@link Timeout} for one-time execution after the specified delay.
override
toString() → String
A string representation of this object.
inherited

Operators

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