Exq.Redis.JobStat (exq v0.23.0)

View Source

The JobStat module encapsulates storing system-wide stats on top of Redis It aims to be compatible with the Sidekiq stats format.

Summary

Functions

add_process(redis, namespace, process_info, serialized_process \\ nil)
add_process_commands(namespace, process_info, serialized_process \\ nil)
busy(redis, namespace)
cleanup_processes(redis, namespace, host)
clear_failed(redis, namespace)
clear_processes(redis, namespace)
decode_integer(count)
find_failed(redis, namespace, jid)
find_failed(redis, namespace, score, jid, options)
find_retry(redis, namespace, score, jid, options)
find_scheduled(redis, namespace, score, jid, options)
get_count(redis, namespace, key)
get_counts(redis, namespace, keys)
node_ids(redis, namespace)
node_ping(redis, namespace, node)
node_signal(redis, namespace, node_id, signal_name)
nodes(redis, namespace)
processes(redis, namespace)
prune_dead_nodes(redis, namespace)
realtime_stats(redis, namespace)
record_failure(redis, namespace, error, job, current_date \\ DateTime.utc_now())
record_failure_commands(namespace, error, job, current_date \\ DateTime.utc_now())
record_processed(redis, namespace, job, current_date \\ DateTime.utc_now())
record_processed_commands(namespace, job, current_date \\ DateTime.utc_now())
remove_failed(redis, namespace, jid)
remove_process(redis, namespace, process_info)
remove_process_commands(namespace, process_info)
remove_queue(redis, namespace, queue)

Functions

add_process(redis, namespace, process_info, serialized_process \\ nil)

add_process_commands(namespace, process_info, serialized_process \\ nil)

busy(redis, namespace)

cleanup_processes(redis, namespace, host)

clear_failed(redis, namespace)

clear_processes(redis, namespace)

decode_integer(count)

find_failed(redis, namespace, jid)

find_failed(redis, namespace, score, jid, options)

find_retry(redis, namespace, score, jid, options)

find_scheduled(redis, namespace, score, jid, options)

get_count(redis, namespace, key)

get_counts(redis, namespace, keys)

node_ids(redis, namespace)

node_ping(redis, namespace, node)

node_signal(redis, namespace, node_id, signal_name)

nodes(redis, namespace)

processes(redis, namespace)

prune_dead_nodes(redis, namespace)

realtime_stats(redis, namespace)

record_failure(redis, namespace, error, job, current_date \\ DateTime.utc_now())

record_failure_commands(namespace, error, job, current_date \\ DateTime.utc_now())

record_processed(redis, namespace, job, current_date \\ DateTime.utc_now())

record_processed_commands(namespace, job, current_date \\ DateTime.utc_now())

remove_failed(redis, namespace, jid)

remove_process(redis, namespace, process_info)

remove_process_commands(namespace, process_info)

remove_queue(redis, namespace, queue)