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

Link to this section Functions

Link to this function

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

View Source
Link to this function

add_process_commands(namespace, process_info, serialized_process \\ nil)

View Source
Link to this function

cleanup_processes(redis, namespace, host)

View Source
Link to this function

clear_failed(redis, namespace)

View Source
Link to this function

clear_processes(redis, namespace)

View Source
Link to this function

find_failed(redis, namespace, jid)

View Source
Link to this function

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

View Source
Link to this function

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

View Source
Link to this function

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

View Source
Link to this function

get_count(redis, namespace, key)

View Source
Link to this function

get_counts(redis, namespace, keys)

View Source
Link to this function

node_ids(redis, namespace)

View Source
Link to this function

node_ping(redis, namespace, node)

View Source
Link to this function

node_signal(redis, namespace, node_id, signal_name)

View Source
Link to this function

processes(redis, namespace)

View Source
Link to this function

prune_dead_nodes(redis, namespace)

View Source
Link to this function

realtime_stats(redis, namespace)

View Source
Link to this function

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

View Source
Link to this function

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

View Source
Link to this function

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

View Source
Link to this function

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

View Source
Link to this function

remove_failed(redis, namespace, jid)

View Source
Link to this function

remove_process(redis, namespace, process_info)

View Source
Link to this function

remove_process_commands(namespace, process_info)

View Source
Link to this function

remove_queue(redis, namespace, queue)

View Source