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

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 \\ [])

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.

See 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 \\ [])