Exq.Worker.Server (exq v0.23.0)

View Source

Worker process is responsible for the parsing and execution of a Job.

It then broadcasts results to Stats / Manager.

Currently uses the terminate callback to track job success/failure.

Initialization:

  • job_serialized - Full JSON payload of the Job.
  • manager - Manager process pid.
  • queue - The queue the job came from.
  • stats - Stats process pid.
  • namespace - Redis namespace
  • host - Host name

Expects :work message after initialization to kickoff work.

Summary

Functions

cancel(pid)

Cancel the current job

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

dispatch_work(worker_module, job, metadata)
handle_cast(msg, state)

Kickoff work associated with worker.

init(arg)

Callback implementation for GenServer.init/1.

start_link(job_serialized, manager, queue, stats, namespace, host, redis, middleware, metadata)
work(pid)

Kickoff work associated with worker.

Functions

cancel(pid)

Cancel the current job

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

dispatch_work(worker_module, job, metadata)

handle_cast(msg, state)

Kickoff work associated with worker.

This step handles:

  • Parsing of JSON object
  • Preparation of target module

Calls :dispatch to then call target module.

init(arg)

Callback implementation for GenServer.init/1.

start_link(job_serialized, manager, queue, stats, namespace, host, redis, middleware, metadata)

work(pid)

Kickoff work associated with worker.