Namespace Azos.Sky.Workers

Classes

Extends Todo toallow for correlation of multiple instances on SysCorrelationKey. This is used for example to aggregate various asynchronous events together. Example: batch frequent email notifications into one

FinalizeSignal

FinishSignal

MongoWorkersException

Thrown to indicate mongo-related workers problems

OkSignal

Process

Represents a context for units of work (like Todos) executing in the distributed system. Processes are controlled via SkySystem.ProcessManager implementation

ProcessAttribute

Provides information about the decorated Process type: assignes a globally-unique immutable type id

ProcessManager

ProcessManagerBase

ResultSignal

Signal

SignalAttribute

Provides information about the decorated Signal type: assignes a globally-unique immutable type id

TerminateSignal

Todo

Represents a unit of abstract work that is dispatched to a remote worker in an asynchronous fashion. Todos are essentially a form of a queueable asynchronous one-way command object (Execute() does not return business object). Todos are dequeued in the order of submission and SysStartDate constraint, processed sequentially or in-parallel depending on a SysParallelKey

TodoQueueAttribute

Provides information about the decorated Todo type: Queue name and assignes a globally-unique immutable type id

UnknownSignal

WorkersException

Thrown to indicate workers related problems

Structs

PID

Represents a globally-unique process identifier. The pids are allocated of SkySystem.ProcessManager

ProcessDescriptor

Provides process status information snapshot

ProcessFrame

Provides an efficient data vector for marshalling and storage of process. This type obviates the need of extra serialization for teleportation and storage of Process instances. Special-purposed Glue binding is used to teleport ProcessFrames and directly store them without unnecessary intermediate serialization steps

SignalFrame

Todo.ExecuteState

Denotes states of Todo execution state machine

TodoFrame

Provides an efficient data vector for marshalling and storage of todo's in queues. This type obviates the need of extra serialization for teleportation and storage of Todo instances. Special-purposed Glue binding is used to teleport TodoFrames and directly store them in queue without unnecessary intermediate serialization steps