exq
v0.19.0
v0.18.0
v0.17.0
v0.16.2
v0.16.1
v0.16.0
v0.15.0
v0.14.0
v0.13.5
v0.13.4
v0.13.3
v0.13.2
v0.13.1
v0.13.0
v0.12.2
v0.12.1
v0.12.0
v0.11.0
v0.10.1
v0.10.0
v0.9.1
v0.9.0
v0.8.7
v0.8.6
v0.8.5
v0.8.4
v0.8.3
v0.8.2
v0.8.1
v0.8.0
v0.7.3
v0.7.2
v0.7.1
v0.7.0
v0.6.5
v0.6.4
Pages
Modules
Mix Tasks
Exq
Top
Summary
Functions
child_spec/1
enqueue/4
enqueue/5
enqueue_all/2
enqueue_at/5
enqueue_at/6
enqueue_in/5
enqueue_in/6
start/2
start_link/1
subscribe/2
subscribe/3
subscriptions/1
unsubscribe/2
unsubscribe_all/1
whereis/1
worker_job/2
Exq.Adapters.Queue
Top
Sections
Example
Summary
Types
name/0
server/0
Callbacks
enqueue/5
enqueue_all/2
enqueue_at/6
enqueue_in/6
Exq.Adapters.Queue.Mock
Top
Summary
Functions
enqueue/5
enqueue_all/2
enqueue_at/6
enqueue_in/6
Exq.Adapters.Queue.Redis
Top
Summary
Functions
enqueue/5
enqueue_all/2
enqueue_at/6
enqueue_in/6
Exq.Api
Top
Summary
Functions
busy/1
clear_failed/1
clear_processes/1
clear_retries/1
clear_scheduled/1
dequeue_failed_jobs/2
dequeue_retry_jobs/2
dequeue_scheduled_jobs/2
failed/2
failed_size/1
find_failed/2
find_failed/4
find_job/3
find_retry/2
find_retry/4
find_scheduled/2
find_scheduled/4
jobs/1
jobs/3
nodes/1
processes/1
queue_size/1
queue_size/2
queues/1
realtime_stats/1
remove_enqueued_jobs/3
remove_failed/2
remove_failed_jobs/2
remove_job/3
remove_queue/2
remove_retry/2
remove_retry_jobs/2
remove_scheduled/2
remove_scheduled_jobs/2
retries/2
retry_job/2
retry_size/1
scheduled/2
scheduled_size/1
scheduled_with_scores/1
send_signal/3
start_link/1
stats/2
stats/3
Exq.Api.Server
Top
Summary
Functions
child_spec/1
init/1
server_name/1
start_link/1
Exq.Api.Server.State
Top
Exq.Backoff.Behaviour
Top
Summary
Callbacks
offset/1
Exq.Backoff.SidekiqDefault
Top
Summary
Functions
offset/1
Exq.Dequeue.Behaviour
Top
Summary
Callbacks
available?/1
dispatched/1
failed/1
init/2
processed/1
stop/1
Exq.Dequeue.Local
Top
Exq.Enqueuer
Top
Summary
Functions
enqueue/4
enqueue/5
enqueue_all/2
enqueue_at/5
enqueue_at/6
enqueue_in/5
enqueue_in/6
start_link/1
Exq.Enqueuer.EnqueueApi
Top
Exq.Enqueuer.Server
Top
Sections
Initialization:
Summary
Functions
child_spec/1
init/1
server_name/1
start_link/1
Exq.Enqueuer.Server.State
Top
Exq.Heartbeat.Monitor
Top
Summary
Functions
child_spec/1
init/1
start_link/1
Exq.Heartbeat.Monitor.State
Top
Exq.Heartbeat.Server
Top
Summary
Functions
child_spec/1
init/1
start_link/1
Exq.Heartbeat.Server.State
Top
Exq.Manager.Server
Top
Sections
Options
Redis Options (TODO - move to supervisor after refactor):
Job lifecycle
Retry / Schedule queue
Summary
Functions
available_queues/1
child_spec/1
dequeue_and_dispatch/1
dispatch_job/2
dispatch_job/3
handle_cast/2
init/1
job_terminated/3
server_name/1
start_link/1
Exq.Manager.Server.State
Top
Exq.Middleware.Behaviour
Top
Summary
Callbacks
after_failed_work/1
after_processed_work/1
before_work/1
Exq.Middleware.Job
Top
Summary
Functions
after_failed_work/1
after_processed_work/1
before_work/1
remove_job_from_backup/1
Exq.Middleware.Logger
Top
Summary
Functions
after_failed_work/1
after_processed_work/1
before_work/1
Exq.Middleware.Manager
Top
Summary
Functions
after_failed_work/1
after_processed_work/1
before_work/1
Exq.Middleware.Pipeline
Top
Summary
Functions
assign/3
assign_worker_state/2
chain/2
halt/1
terminate/1
Exq.Middleware.Server
Top
Summary
Functions
all/1
child_spec/1
init/1
push/2
server_name/1
start_link/1
Exq.Middleware.Stats
Top
Summary
Functions
after_failed_work/1
after_processed_work/1
before_work/1
Exq.Middleware.Telemetry
Top
Exq.Middleware.Unique
Top
Summary
Functions
after_failed_work/1
after_processed_work/1
before_work/1
Exq.Mock
Top
Summary
Functions
child_spec/1
jobs/0
set_mode/1
start_link/1
Exq.Node.Server
Top
Summary
Functions
child_spec/1
init/1
start_link/1
Exq.Node.Server.State
Top
Exq.NodeIdentifier.Behaviour
Top
Summary
Callbacks
node_id/0
Exq.NodeIdentifier.HostnameIdentifier
Top
Summary
Functions
node_id/0
Exq.Redis.Connection
Top
Summary
Functions
decr!/2
del!/3
expire!/3
flushdb!/1
get!/2
incr!/2
keys!/2
llen!/2
lpop/2
lpush!/3
lrange!/4
lrem!/5
q/3
qp/3
qp!/3
rpush!/3
sadd!/3
scan!/4
scard!/2
set!/3
sismember!/3
smembers!/2
srem!/3
zadd/5
zadd!/4
zcard!/2
zcount!/4
zrange!/4
zrangebyscore/4
zrangebyscore!/4
zrangebyscorewithlimit!/6
zrangebyscorewithscore/4
zrangebyscorewithscore!/4
zrangebyscorewithscoreandlimit!/6
zrem/3
zrem!/3
zrevrangebyscorewithlimit!/6
zrevrangebyscorewithscoreandlimit!/6
Exq.Redis.Heartbeat
Top
Summary
Functions
dead_nodes/4
re_enqueue_backup/5
register/3
unregister/3
Exq.Redis.JobQueue
Top
Summary
Functions
backup_queue_key/3
dead?/1
delete_queue/3
dequeue/4
dequeue_failed_jobs/3
dequeue_retry_jobs/3
dequeue_scheduled_jobs/3
do_enqueue_job_at/8
enqueue/6
enqueue_all/3
enqueue_at/7
enqueue_in/7
fail_job/4
failed/3
failed_queue_key/1
failed_size/2
find_job/4
find_job/5
full_key/2
jobs/2
jobs/4
list_queues/2
queue_key/2
queue_size/2
queue_size/3
re_enqueue_backup/4
remove_enqueued_jobs/4
remove_failed_jobs/3
remove_job/4
remove_job_from_backup/5
remove_retry/3
remove_retry_jobs/3
remove_scheduled/3
remove_scheduled_jobs/3
retry_job/3
retry_job/5
retry_or_fail_job/4
retry_queue_key/1
retry_size/2
schedule_queues/1
scheduled_jobs/4
scheduled_jobs_with_scores/4
scheduled_queue_key/1
scheduled_size/2
scheduler_dequeue/2
scheduler_dequeue/3
search_jobs/2
search_jobs/3
to_job_serialized/4
to_job_serialized/5
unique_key/2
unlock/3
Exq.Redis.JobStat
Top
Summary
Functions
add_process/4
add_process_commands/3
busy/2
cleanup_processes/3
clear_failed/2
clear_processes/2
decode_integer/1
find_failed/3
find_failed/5
find_retry/5
find_scheduled/5
get_count/3
get_counts/3
node_ids/2
node_ping/3
node_signal/4
nodes/2
processes/2
prune_dead_nodes/2
realtime_stats/2
record_failure/5
record_failure_commands/4
record_processed/4
record_processed_commands/3
remove_failed/3
remove_process/3
remove_process_commands/2
remove_queue/3
Exq.Redis.Script
Top
Summary
Functions
eval!/4
Exq.Redis.Script.Prepare
Top
Summary
Functions
script/1
Exq.Scheduler.Server
Top
Sections
Initialization:
Summary
Functions
child_spec/1
dequeue/1
init/1
server_name/1
start_link/1
start_timeout/1
Exq.Scheduler.Server.State
Top
Exq.Serializers.Behaviour
Top
Summary
Callbacks
decode/1
decode!/1
decode_job/1
decode_process/1
encode/1
encode!/1
encode_job/1
encode_process/1
Exq.Serializers.JsonSerializer
Top
Summary
Functions
decode/1
decode!/1
decode_job/1
decode_node/1
decode_process/1
encode/1
encode!/1
encode_job/1
encode_node/1
encode_process/1
Exq.Stats.Server
Top
Summary
Functions
add_process/6
child_spec/1
cleanup_host_stats/3
force_flush/1
generate_instructions/1
init/1
process_queue/4
process_terminated/3
record_failure/4
record_processed/3
server_name/1
start_link/1
Exq.Stats.Server.State
Top
Exq.Support.Binary
Top
Summary
Functions
take_prefix/2
Exq.Support.Config
Top
Summary
Functions
backoff/0
get/1
get/2
node_identifier/0
serializer/0
Exq.Support.Job
Top
Summary
Functions
decode/1
encode/1
Exq.Support.Mode
Top
Summary
Functions
children/1
children/2
Exq.Support.Node
Top
Summary
Functions
decode/1
encode/1
Exq.Support.Opts
Top
Summary
Functions
cast_concurrency/1
redis_client_name/1
redis_inspect_opts/1
redis_opts/1
redis_worker_opts/1
top_supervisor/1
Exq.Support.Process
Top
Summary
Functions
decode/1
encode/1
Exq.Support.Randomize
Top
Summary
Functions
random/1
Exq.Support.Redis
Top
Summary
Functions
rescue_timeout/2
with_retry_on_connection_error/2
Exq.Support.Time
Top
Summary
Functions
format_current_date/1
offset_from_now/1
time_to_score/1
unix_seconds/1
Exq.Worker.Metadata
Top
Summary
Functions
associate/3
child_spec/1
init/1
lookup/2
server_name/1
start_link/1
Exq.Worker.Server
Top
Sections
Initialization:
Summary
Functions
child_spec/1
dispatch_work/3
handle_cast/2
init/1
start_link/9
work/1
Exq.Worker.Server.State
Top
Exq.Worker.Supervisor
Top
Summary
Functions
child_spec/1
init/1
start_child/3
start_link/1
supervisor_name/1
workers/1
workers_count/1
Exq.WorkerDrainer.Server
Top
Summary
Functions
child_spec/1
init/1
server_name/1
start_link/1
Exq.NodeIdentifier.Behaviour
behaviour
(exq v0.19.0)
View Source
Link to this section
Summary
Callbacks
node_id()
Link to this section
Callbacks
Link to this callback
node_id()
View Source
Specs
node_id() ::
String.t
()
×