Exq.Redis.JobStat (exq v0.19.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.

Link to this section 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)

Link to this section 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)