Exq.Stats.Server (exq v0.15.0) View Source

Stats process is responsible for recording all stats into Redis.

The stats format is compatible with the Sidekiq stats format, so that The Sidekiq UI can be also used to view Exq status as well, and Exq can run side by side with Sidekiq without breaking any of it's UI.

This includes job success/failure as well as in-progress jobs

Link to this section Summary

Functions

Returns a specification to start this module under a supervisor.

Cleanup stats on boot. This includes cleaning up busy workers.

Callback implementation for GenServer.init/1.

Remove in progress worker process

Record job as successfully processes

Link to this section Functions

Link to this function

add_process(stats, namespace, worker, host, job_serialized)

View Source

Add in progress worker process

Returns a specification to start this module under a supervisor.

See Supervisor.

Link to this function

cleanup_host_stats(stats, namespace, host)

View Source

Cleanup stats on boot. This includes cleaning up busy workers.

Link to this function

generate_instructions(arg)

View Source

Callback implementation for GenServer.init/1.

Link to this function

process_queue(queue, state, redis_batch, size \\ 0)

View Source
Link to this function

process_terminated(stats, namespace, process_info)

View Source

Remove in progress worker process

Link to this function

record_failure(stats, namespace, error, job)

View Source

Record job as failed

Link to this function

record_processed(stats, namespace, job)

View Source

Record job as successfully processes