Exq.Stats.Server (exq v0.19.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

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

Add in progress worker process

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

cleanup_host_stats(stats, namespace, host)

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

force_flush(stats)

generate_instructions(arg)

init(opts)

Callback implementation for GenServer.init/1.

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

process_terminated(stats, namespace, process_info)

Remove in progress worker process

record_failure(stats, namespace, error, job)

Record job as failed

record_processed(stats, namespace, job)

Record job as successfully processes

server_name(name)

start_link(opts \\ [])

Link to this section Functions