This is the psychiq Reference Manual, version 0.2.0, generated automatically by Declt version 4.0 beta 2 "William Riker" on Sun Dec 15 07:21:26 2024 GMT+0.
psychiq/psychiq.asd
psychiq/src/psychiq.lisp
psychiq/src/client.lisp
psychiq/src/launcher.lisp
psychiq/src/core/connection.lisp
psychiq/src/core/worker.lisp
psychiq/src/core/queue.lisp
psychiq/src/core/coder.lisp
psychiq/src/launcher-core/processor.lisp
psychiq/src/launcher-core/manager.lisp
psychiq/src/launcher-core/scheduled.lisp
psychiq/src/launcher-core/heartbeat.lisp
psychiq/src/middleware/retry-jobs.lisp
psychiq/src/middleware/logging.lisp
psychiq/src/util/util.lisp
psychiq/src/util/assoc.lisp
psychiq/src/util/redis.lisp
psychiq/src/util/concurrency.lisp
psychiq/src/specials.lisp
psychiq.specials
psychiq
psychiq.coder
psychiq.middleware.logging
psychiq.util.concurrency
psychiq.launcher.heartbeat
psychiq.launcher.scheduled
psychiq.launcher.manager
psychiq.util.redis
psychiq.launcher
psychiq.worker
psychiq.util.assoc
psychiq.queue
psychiq.client
psychiq.launcher.processor
psychiq.util
psychiq.middleware.retry-jobs
psychiq.connection
The main system appears first, followed by any subsystem dependency.
psychiq
Redis-backed job queueing system
Eitaro Fukamachi
LLGPL
0.2.0
cl-redis
(system).
jonathan
(system).
local-time
(system).
cl-reexport
(system).
bordeaux-threads
(system).
dissect
(system).
vom
(system).
uiop
(system).
alexandria
(system).
sb-posix
(system)., for feature :sbcl
src
(module).
src/specials.lisp
(file).
Modules are listed depth-first from the system components tree.
psychiq/src
src/specials.lisp
(file).
psychiq
(system).
psychiq.lisp
(file).
client.lisp
(file).
launcher.lisp
(file).
core
(module).
launcher-core
(module).
middleware
(module).
util
(module).
psychiq/src/core
util
(module).
src
(module).
connection.lisp
(file).
worker.lisp
(file).
queue.lisp
(file).
coder.lisp
(file).
psychiq/src/launcher-core
core
(module).
middleware
(module).
util
(module).
src
(module).
processor.lisp
(file).
manager.lisp
(file).
scheduled.lisp
(file).
heartbeat.lisp
(file).
psychiq/src/middleware
src
(module).
retry-jobs.lisp
(file).
logging.lisp
(file).
psychiq/src/util
src
(module).
util.lisp
(file).
assoc.lisp
(file).
redis.lisp
(file).
concurrency.lisp
(file).
Files are sorted by type and then listed depth-first from the systems components trees.
psychiq/psychiq.asd
psychiq/src/psychiq.lisp
psychiq/src/client.lisp
psychiq/src/launcher.lisp
psychiq/src/core/connection.lisp
psychiq/src/core/worker.lisp
psychiq/src/core/queue.lisp
psychiq/src/core/coder.lisp
psychiq/src/launcher-core/processor.lisp
psychiq/src/launcher-core/manager.lisp
psychiq/src/launcher-core/scheduled.lisp
psychiq/src/launcher-core/heartbeat.lisp
psychiq/src/middleware/retry-jobs.lisp
psychiq/src/middleware/logging.lisp
psychiq/src/util/util.lisp
psychiq/src/util/assoc.lisp
psychiq/src/util/redis.lisp
psychiq/src/util/concurrency.lisp
psychiq/src/specials.lisp
psychiq/src/psychiq.lisp
core
(module).
client.lisp
(file).
src
(module).
psychiq/src/client.lisp
core
(module).
src
(module).
all-dead-jobs
(function).
all-queues
(function).
all-retries
(function).
cleanup-processes
(function).
delete-queue
(function).
dequeue
(function).
enqueue
(function).
enqueue-bulk
(function).
enqueue-in-sec
(function).
peek-queue
(function).
queue-empty-p
(function).
queue-length
(function).
retry-length
(function).
slice-queue
(function).
stats
(function).
decode-objects
(function).
psychiq/src/launcher.lisp
core
(module).
launcher-core
(module).
src
(module).
kill
(function).
launcher
(structure).
launcher-status
(function).
print-object
(method).
run
(function).
start
(function).
stop
(function).
wait-for
(function).
%make-launcher
(function).
copy-launcher
(function).
launcher-heartbeat
(reader).
(setf launcher-heartbeat)
(writer).
launcher-manager
(reader).
(setf launcher-manager)
(writer).
launcher-p
(function).
launcher-scheduled
(reader).
(setf launcher-scheduled)
(writer).
make-launcher
(function).
psychiq/src/core/connection.lisp
core
(module).
*connection*
(special variable).
close-connection
(generic function).
connect
(function).
connect-toplevel
(function).
connectedp
(generic function).
connection
(class).
disconnect
(function).
disconnect-toplevel
(function).
ensure-connected
(function).
make-connection
(function).
open-connection
(generic function).
print-object
(method).
reconnect
(function).
with-connection
(macro).
redis-connection
(reader method).
(setf redis-connection)
(writer method).
psychiq/src/core/worker.lisp
core
(module).
decode-job
(function).
encode-job
(function).
perform
(generic function).
worker
(class).
worker-max-retries
(generic function).
worker-queue-name
(generic function).
worker-use-backtrace-p
(generic function).
worker-use-dead-queue-p
(generic function).
psychiq/src/core/queue.lisp
coder.lisp
(file).
core
(module).
dequeue-from-queue
(function).
enqueue-to-queue
(function).
enqueue-to-scheduled-queue
(function).
psychiq/src/core/coder.lisp
core
(module).
decode-object
(function).
encode-object
(function).
psychiq/src/launcher-core/processor.lisp
launcher-core
(module).
fetch-job
(generic function).
finalize
(generic function).
kill
(generic function).
make-processor
(function).
perform-job
(generic function).
print-object
(method).
process-job
(generic function).
processor
(structure).
processor-connection
(reader).
(setf processor-connection)
(writer).
processor-id
(reader).
(setf processor-id)
(writer).
processor-manager
(reader).
(setf processor-manager)
(writer).
processor-processing
(reader).
(setf processor-processing)
(writer).
processor-status
(reader).
(setf processor-status)
(writer).
processor-timeout
(reader).
(setf processor-timeout)
(writer).
run
(generic function).
start
(generic function).
stop
(generic function).
wait-for
(generic function).
%make-processor
(function).
copy-processor
(function).
processor-down
(reader).
(setf processor-down)
(writer).
processor-p
(function).
processor-queues
(reader).
(setf processor-queues)
(writer).
processor-thread
(reader).
(setf processor-thread)
(writer).
psychiq/src/launcher-core/manager.lisp
processor.lisp
(file).
launcher-core
(module).
finalize
(method).
kill
(method).
make-manager
(function).
manager
(structure).
manager-children
(reader).
(setf manager-children)
(writer).
manager-count
(reader).
(setf manager-count)
(writer).
manager-queues
(reader).
(setf manager-queues)
(writer).
manager-stat-failed
(reader).
(setf manager-stat-failed)
(writer).
manager-stat-processed
(reader).
(setf manager-stat-processed)
(writer).
manager-stopped-p
(reader).
(setf manager-stopped-p)
(writer).
process-job
(method).
run
(method).
start
(method).
stop
(method).
wait-for
(method).
%make-manager
(function).
copy-manager
(function).
make-child-processors
(function).
manager-db
(reader).
(setf manager-db)
(writer).
manager-host
(reader).
(setf manager-host)
(writer).
manager-lock
(reader).
(setf manager-lock)
(writer).
manager-make-processor-fn
(reader).
(setf manager-make-processor-fn)
(writer).
manager-p
(function).
manager-port
(reader).
(setf manager-port)
(writer).
processor-died
(function).
processor-stopped
(function).
psychiq/src/launcher-core/scheduled.lisp
launcher-core
(module).
kill
(function).
make-scheduled
(function).
scheduled
(structure).
scheduled-status
(reader).
(setf scheduled-status)
(writer).
scheduled-thread
(reader).
(setf scheduled-thread)
(writer).
start
(function).
stop
(function).
%make-scheduled
(function).
copy-scheduled
(function).
enqueue-jobs
(function).
scaled-poll-interval
(function).
scheduled-connection
(reader).
(setf scheduled-connection)
(writer).
scheduled-p
(function).
psychiq/src/launcher-core/heartbeat.lisp
manager.lisp
(file).
processor.lisp
(file).
launcher-core
(module).
clear-heartbeat
(function).
copy-heartbeat
(function).
heartbeat-db
(reader).
(setf heartbeat-db)
(writer).
heartbeat-host
(reader).
(setf heartbeat-host)
(writer).
heartbeat-manager
(reader).
(setf heartbeat-manager)
(writer).
heartbeat-p
(function).
heartbeat-port
(reader).
(setf heartbeat-port)
(writer).
heartbeat-stopped-p
(reader).
(setf heartbeat-stopped-p)
(writer).
heartbeat-thread
(reader).
(setf heartbeat-thread)
(writer).
run
(function).
psychiq/src/middleware/retry-jobs.lisp
middleware
(module).
*psychiq-middleware-retry-jobs*
(special variable).
*dead-max-jobs*
(special variable).
*dead-timeout-in-seconds*
(special variable).
attempt-retry
(function).
backtrace
(function).
delay-for
(function).
send-to-morgue
(function).
psychiq/src/middleware/logging.lisp
middleware
(module).
*psychiq-middleware-logging*
(special variable).
psychiq/src/util/util.lisp
assoc.lisp
(file).
redis.lisp
(file).
concurrency.lisp
(file).
util
(module).
generate-random-id
(function).
getpid
(function).
machine-identity
(function).
symbol-name-with-package
(function).
psychiq/src/util/assoc.lisp
util
(module).
aget
(function).
(setf aget)
(function).
psychiq/src/util/redis.lisp
util
(module).
omit-redis-prefix
(function).
redis-key
(function).
with-redis-transaction
(macro).
psychiq/src/util/concurrency.lisp
util
(module).
get-value
(function).
(setf get-value)
(function).
make-thread-safe-variable
(function).
reset-value
(function).
copy-thread-safe-variable
(function).
thread-safe-variable
(structure).
thread-safe-variable-initial-value
(reader).
(setf thread-safe-variable-initial-value)
(writer).
thread-safe-variable-lock
(reader).
(setf thread-safe-variable-lock)
(writer).
thread-safe-variable-p
(function).
thread-safe-variable-value
(reader).
(setf thread-safe-variable-value)
(writer).
psychiq/src/specials.lisp
psychiq
(system).
*default-max-retry-attempts*
(special variable).
*default-queue-name*
(special variable).
*default-redis-host*
(special variable).
*default-redis-port*
(special variable).
*psychiq-namespace*
(special variable).
Packages are listed by definition order.
psychiq.specials
psychiq
psychiq.coder
psychiq.middleware.logging
psychiq.util.concurrency
psychiq.launcher.heartbeat
psychiq.launcher.scheduled
psychiq.launcher.manager
psychiq.util.redis
psychiq.launcher
psychiq.worker
psychiq.util.assoc
psychiq.queue
psychiq.client
psychiq.launcher.processor
psychiq.util
psychiq.middleware.retry-jobs
psychiq.connection
psychiq.specials
common-lisp
.
*default-max-retry-attempts*
(special variable).
*default-queue-name*
(special variable).
*default-redis-host*
(special variable).
*default-redis-port*
(special variable).
*psychiq-namespace*
(special variable).
psychiq.coder
common-lisp
.
decode-object
(function).
encode-object
(function).
psychiq.middleware.logging
common-lisp
.
psychiq.util
.
*psychiq-middleware-logging*
(special variable).
psychiq.util.concurrency
common-lisp
.
get-value
(function).
(setf get-value)
(function).
make-thread-safe-variable
(function).
reset-value
(function).
copy-thread-safe-variable
(function).
thread-safe-variable
(structure).
thread-safe-variable-initial-value
(reader).
(setf thread-safe-variable-initial-value)
(writer).
thread-safe-variable-lock
(reader).
(setf thread-safe-variable-lock)
(writer).
thread-safe-variable-p
(function).
thread-safe-variable-value
(reader).
(setf thread-safe-variable-value)
(writer).
psychiq.launcher.heartbeat
common-lisp
.
psychiq.util
.
clear-heartbeat
(function).
copy-heartbeat
(function).
heartbeat-db
(reader).
(setf heartbeat-db)
(writer).
heartbeat-host
(reader).
(setf heartbeat-host)
(writer).
heartbeat-manager
(reader).
(setf heartbeat-manager)
(writer).
heartbeat-p
(function).
heartbeat-port
(reader).
(setf heartbeat-port)
(writer).
heartbeat-stopped-p
(reader).
(setf heartbeat-stopped-p)
(writer).
heartbeat-thread
(reader).
(setf heartbeat-thread)
(writer).
run
(function).
psychiq.launcher.scheduled
common-lisp
.
psychiq.specials
.
psychiq.util
.
kill
(function).
make-scheduled
(function).
scheduled
(structure).
scheduled-status
(reader).
(setf scheduled-status)
(writer).
scheduled-thread
(reader).
(setf scheduled-thread)
(writer).
start
(function).
stop
(function).
%make-scheduled
(function).
copy-scheduled
(function).
enqueue-jobs
(function).
scaled-poll-interval
(function).
scheduled-connection
(reader).
(setf scheduled-connection)
(writer).
scheduled-p
(function).
psychiq.launcher.manager
common-lisp
.
psychiq.launcher.processor
.
psychiq.specials
.
psychiq.util
.
make-manager
(function).
manager
(structure).
manager-children
(reader).
(setf manager-children)
(writer).
manager-count
(reader).
(setf manager-count)
(writer).
manager-queues
(reader).
(setf manager-queues)
(writer).
manager-stat-failed
(reader).
(setf manager-stat-failed)
(writer).
manager-stat-processed
(reader).
(setf manager-stat-processed)
(writer).
manager-stopped-p
(reader).
(setf manager-stopped-p)
(writer).
%make-manager
(function).
copy-manager
(function).
make-child-processors
(function).
manager-db
(reader).
(setf manager-db)
(writer).
manager-host
(reader).
(setf manager-host)
(writer).
manager-lock
(reader).
(setf manager-lock)
(writer).
manager-make-processor-fn
(reader).
(setf manager-make-processor-fn)
(writer).
manager-p
(function).
manager-port
(reader).
(setf manager-port)
(writer).
processor-died
(function).
processor-stopped
(function).
psychiq.util.redis
common-lisp
.
omit-redis-prefix
(function).
redis-key
(function).
with-redis-transaction
(macro).
psychiq.launcher
common-lisp
.
psychiq.specials
.
%make-launcher
(function).
copy-launcher
(function).
launcher-heartbeat
(reader).
(setf launcher-heartbeat)
(writer).
launcher-manager
(reader).
(setf launcher-manager)
(writer).
launcher-p
(function).
launcher-scheduled
(reader).
(setf launcher-scheduled)
(writer).
make-launcher
(function).
psychiq.worker
common-lisp
.
psychiq.specials
.
psychiq.util
.
decode-job
(function).
encode-job
(function).
perform
(generic function).
worker
(class).
worker-max-retries
(generic function).
worker-queue-name
(generic function).
worker-use-backtrace-p
(generic function).
worker-use-dead-queue-p
(generic function).
psychiq.util.assoc
common-lisp
.
aget
(function).
(setf aget)
(function).
psychiq.queue
common-lisp
.
psychiq.util
.
dequeue-from-queue
(function).
enqueue-to-queue
(function).
enqueue-to-scheduled-queue
(function).
psychiq.client
common-lisp
.
psychiq.specials
.
psychiq.util
.
all-dead-jobs
(function).
all-queues
(function).
all-retries
(function).
cleanup-processes
(function).
delete-queue
(function).
dequeue
(function).
enqueue
(function).
enqueue-bulk
(function).
enqueue-in-sec
(function).
peek-queue
(function).
queue-empty-p
(function).
queue-length
(function).
retry-length
(function).
slice-queue
(function).
stats
(function).
decode-objects
(function).
psychiq.launcher.processor
common-lisp
.
psychiq.specials
.
psychiq.util
.
fetch-job
(generic function).
finalize
(generic function).
kill
(generic function).
make-processor
(function).
perform-job
(generic function).
process-job
(generic function).
processor
(structure).
processor-connection
(reader).
(setf processor-connection)
(writer).
processor-id
(reader).
(setf processor-id)
(writer).
processor-manager
(reader).
(setf processor-manager)
(writer).
processor-processing
(reader).
(setf processor-processing)
(writer).
processor-status
(reader).
(setf processor-status)
(writer).
processor-timeout
(reader).
(setf processor-timeout)
(writer).
run
(generic function).
start
(generic function).
stop
(generic function).
wait-for
(generic function).
%make-processor
(function).
copy-processor
(function).
processor-down
(reader).
(setf processor-down)
(writer).
processor-p
(function).
processor-queues
(reader).
(setf processor-queues)
(writer).
processor-thread
(reader).
(setf processor-thread)
(writer).
psychiq.util
common-lisp
.
generate-random-id
(function).
getpid
(function).
machine-identity
(function).
symbol-name-with-package
(function).
psychiq.middleware.retry-jobs
common-lisp
.
psychiq.specials
.
psychiq.util
.
*psychiq-middleware-retry-jobs*
(special variable).
*dead-max-jobs*
(special variable).
*dead-timeout-in-seconds*
(special variable).
attempt-retry
(function).
backtrace
(function).
delay-for
(function).
send-to-morgue
(function).
psychiq.connection
common-lisp
.
psychiq.specials
.
*connection*
(special variable).
close-connection
(generic function).
connect
(function).
connect-toplevel
(function).
connectedp
(generic function).
connection
(slot).
connection
(class).
disconnect
(function).
disconnect-toplevel
(function).
ensure-connected
(function).
make-connection
(function).
open-connection
(generic function).
reconnect
(function).
with-connection
(macro).
redis-connection
(generic reader).
(setf redis-connection)
(generic writer).
Definitions are sorted by export status, category, package, and then by lexicographic order.
Redis removed support for this in v7.0. Set to "psychiq" for backwards compatibility.
Clean up dead processes recorded in Redis.
id
.
connection
)) ¶connection
)) ¶connection
)) ¶connection
) stream) ¶structure-object
.
(quote nil)
common-lisp
.
25
(quote nil)
(bt2:make-recursive-lock)
t
structure-object
.
fetch-job
.
finalize
.
finalize
.
kill
.
perform-job
.
print-object
.
process-job
.
process-job
.
run
.
run
.
start
.
stop
.
wait-for
.
(psychiq.util:generate-random-id 9)
psychiq.connection:connection
list
(quote nil)
:stopped
5
string
psychiq.specials:*default-redis-host*
:host
integer
psychiq.specials:*default-redis-port*
:port
(or integer null)
:db
(or redis:redis-connection null)
db
.
host
.
port
.
db
.
host
.
lock
.
port
.
down
.
lock
.
connection
)) ¶automatically generated reader method
connection
)) ¶automatically generated writer method
Jump to: | %
(
A B C D E F G H K L M O P Q R S T W |
---|
Jump to: | %
(
A B C D E F G H K L M O P Q R S T W |
---|
Jump to: | *
C D H I L M P Q R S T V |
---|
Jump to: | *
C D H I L M P Q R S T V |
---|
Jump to: | A C F H L M P Q R S T U W |
---|
Jump to: | A C F H L M P Q R S T U W |
---|