Package grpc provides a gRPC service to effectively run task instances on multiple workers.

NewDispatcher creates and initialises a new Dispatcher with this amount of workers.

NewRunnable creates a new runnable and populates it with the concrete task implementation found with action.ID, if such an implementation is found.

NewSubscriber creates a multiplexer for tasks managements and messages by maintaining a map of dispatcher, one for each job definition.

NewTaskFromEvent creates a task based on incoming job and event.

NewWorker creates and configures a new worker.

DefaultMaximumWorkers is set to 20.

Dispatcher orchestrates the jobs by dispatching work to available workers.

Runnable represents the runnable instance of a given task.

Subscriber handles incoming events, applies selectors if any and generates all ActionMessage to trigger actions.

Worker represents the worker that executes the jobs.