The psychiq Reference Manual

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.

Table of Contents


1 Introduction


2 Systems

The main system appears first, followed by any subsystem dependency.


2.1 psychiq

Redis-backed job queueing system

Author

Eitaro Fukamachi

License

LLGPL

Version

0.2.0

Dependencies
  • 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
Source

psychiq.asd.

Child Components

3 Modules

Modules are listed depth-first from the system components tree.


3.1 psychiq/src

Dependency

src/specials.lisp (file).

Source

psychiq.asd.

Parent Component

psychiq (system).

Child Components

3.2 psychiq/src/core

Dependency

util (module).

Source

psychiq.asd.

Parent Component

src (module).

Child Components

3.3 psychiq/src/launcher-core

Dependencies
Source

psychiq.asd.

Parent Component

src (module).

Child Components

3.4 psychiq/src/middleware

Dependencies
Source

psychiq.asd.

Parent Component

src (module).

Child Components

3.5 psychiq/src/util

Source

psychiq.asd.

Parent Component

src (module).

Child Components

4 Files

Files are sorted by type and then listed depth-first from the systems components trees.


4.1 Lisp


4.1.1 psychiq/psychiq.asd

Source

psychiq.asd.

Parent Component

psychiq (system).

ASDF Systems

psychiq.


4.1.2 psychiq/src/psychiq.lisp

Dependencies
Source

psychiq.asd.

Parent Component

src (module).

Packages

psychiq.


4.1.3 psychiq/src/client.lisp

Dependency

core (module).

Source

psychiq.asd.

Parent Component

src (module).

Packages

psychiq.client.

Public Interface
Internals

decode-objects (function).


4.1.4 psychiq/src/launcher.lisp

Dependencies
Source

psychiq.asd.

Parent Component

src (module).

Packages

psychiq.launcher.

Public Interface
Internals

4.1.5 psychiq/src/core/connection.lisp

Source

psychiq.asd.

Parent Component

core (module).

Packages

psychiq.connection.

Public Interface
Internals

4.1.6 psychiq/src/core/worker.lisp

Source

psychiq.asd.

Parent Component

core (module).

Packages

psychiq.worker.

Public Interface

4.1.7 psychiq/src/core/queue.lisp

Dependency

coder.lisp (file).

Source

psychiq.asd.

Parent Component

core (module).

Packages

psychiq.queue.

Public Interface

4.1.8 psychiq/src/core/coder.lisp

Source

psychiq.asd.

Parent Component

core (module).

Packages

psychiq.coder.

Public Interface

4.1.9 psychiq/src/launcher-core/processor.lisp

Source

psychiq.asd.

Parent Component

launcher-core (module).

Packages

psychiq.launcher.processor.

Public Interface
Internals

4.1.10 psychiq/src/launcher-core/manager.lisp

Dependency

processor.lisp (file).

Source

psychiq.asd.

Parent Component

launcher-core (module).

Packages

psychiq.launcher.manager.

Public Interface
Internals

4.1.11 psychiq/src/launcher-core/scheduled.lisp

Source

psychiq.asd.

Parent Component

launcher-core (module).

Packages

psychiq.launcher.scheduled.

Public Interface
Internals

4.1.12 psychiq/src/launcher-core/heartbeat.lisp

Dependencies
Source

psychiq.asd.

Parent Component

launcher-core (module).

Packages

psychiq.launcher.heartbeat.

Public Interface
Internals

4.1.13 psychiq/src/middleware/retry-jobs.lisp

Source

psychiq.asd.

Parent Component

middleware (module).

Packages

psychiq.middleware.retry-jobs.

Public Interface

*psychiq-middleware-retry-jobs* (special variable).

Internals

4.1.14 psychiq/src/middleware/logging.lisp

Source

psychiq.asd.

Parent Component

middleware (module).

Packages

psychiq.middleware.logging.

Public Interface

*psychiq-middleware-logging* (special variable).


4.1.15 psychiq/src/util/util.lisp

Dependencies
Source

psychiq.asd.

Parent Component

util (module).

Packages

psychiq.util.

Public Interface

4.1.16 psychiq/src/util/assoc.lisp

Source

psychiq.asd.

Parent Component

util (module).

Packages

psychiq.util.assoc.

Public Interface

4.1.17 psychiq/src/util/redis.lisp

Source

psychiq.asd.

Parent Component

util (module).

Packages

psychiq.util.redis.

Public Interface

4.1.18 psychiq/src/util/concurrency.lisp

Source

psychiq.asd.

Parent Component

util (module).

Packages

psychiq.util.concurrency.

Public Interface
Internals

4.1.19 psychiq/src/specials.lisp

Source

psychiq.asd.

Parent Component

psychiq (system).

Packages

psychiq.specials.

Public Interface

5 Packages

Packages are listed by definition order.


5.1 psychiq.specials

Source

src/specials.lisp.

Use List

common-lisp.

Used By List
Public Interface

5.2 psychiq

Source

psychiq.lisp.

Nickname

psy

Use List

common-lisp.


5.3 psychiq.coder

Source

coder.lisp.

Use List

common-lisp.

Public Interface

5.4 psychiq.middleware.logging

Source

logging.lisp.

Use List
Public Interface

*psychiq-middleware-logging* (special variable).


5.5 psychiq.util.concurrency

Source

concurrency.lisp.

Use List

common-lisp.

Public Interface
Internals

5.6 psychiq.launcher.heartbeat

Source

heartbeat.lisp.

Use List
Public Interface
Internals

5.7 psychiq.launcher.scheduled

Source

scheduled.lisp.

Use List
Public Interface
Internals

5.8 psychiq.launcher.manager

Source

manager.lisp.

Use List
Public Interface
Internals

5.9 psychiq.util.redis

Source

redis.lisp.

Use List

common-lisp.

Public Interface

5.10 psychiq.launcher

Source

launcher.lisp.

Use List
Public Interface
Internals

5.11 psychiq.worker

Source

worker.lisp.

Use List
Public Interface

5.12 psychiq.util.assoc

Source

assoc.lisp.

Use List

common-lisp.

Public Interface

5.13 psychiq.queue

Source

queue.lisp.

Use List
Public Interface

5.14 psychiq.client

Source

client.lisp.

Use List
Public Interface
Internals

decode-objects (function).


5.15 psychiq.launcher.processor

Source

processor.lisp.

Use List
Used By List

psychiq.launcher.manager.

Public Interface
Internals

5.17 psychiq.middleware.retry-jobs

Source

retry-jobs.lisp.

Use List
Public Interface

*psychiq-middleware-retry-jobs* (special variable).

Internals

5.18 psychiq.connection

Source

connection.lisp.

Use List
Public Interface
Internals

6 Definitions

Definitions are sorted by export status, category, package, and then by lexicographic order.


6.1 Public Interface


6.1.1 Special variables

Special Variable: *connection*
Package

psychiq.connection.

Source

connection.lisp.

Special Variable: *default-max-retry-attempts*
Package

psychiq.specials.

Source

src/specials.lisp.

Special Variable: *default-queue-name*
Package

psychiq.specials.

Source

src/specials.lisp.

Special Variable: *default-redis-host*
Package

psychiq.specials.

Source

src/specials.lisp.

Special Variable: *default-redis-port*
Package

psychiq.specials.

Source

src/specials.lisp.

Special Variable: *psychiq-middleware-logging*
Package

psychiq.middleware.logging.

Source

logging.lisp.

Special Variable: *psychiq-middleware-retry-jobs*
Package

psychiq.middleware.retry-jobs.

Source

retry-jobs.lisp.

Special Variable: *psychiq-namespace*

Redis removed support for this in v7.0. Set to "psychiq" for backwards compatibility.

Package

psychiq.specials.

Source

src/specials.lisp.


6.1.2 Macros

Macro: with-connection (conn &body body)
Package

psychiq.connection.

Source

connection.lisp.

Macro: with-redis-transaction (&body body)
Package

psychiq.util.redis.

Source

redis.lisp.


6.1.3 Ordinary functions

Function: aget (alist key &key test)
Package

psychiq.util.assoc.

Source

assoc.lisp.

Function: (setf aget) (alist key &key test)
Package

psychiq.util.assoc.

Source

assoc.lisp.

Function: all-dead-jobs ()
Package

psychiq.client.

Source

client.lisp.

Function: all-queues ()
Package

psychiq.client.

Source

client.lisp.

Function: all-retries ()
Package

psychiq.client.

Source

client.lisp.

Function: cleanup-processes ()

Clean up dead processes recorded in Redis.

Package

psychiq.client.

Source

client.lisp.

Function: connect (&rest initargs &key host port db)
Package

psychiq.connection.

Source

connection.lisp.

Function: connect-toplevel (&rest initargs &key host port db)
Package

psychiq.connection.

Source

connection.lisp.

Function: decode-job (job-info)
Package

psychiq.worker.

Source

worker.lisp.

Function: decode-object (payload)
Package

psychiq.coder.

Source

coder.lisp.

Function: delete-queue (queue)
Package

psychiq.client.

Source

client.lisp.

Function: dequeue (&optional queue-or-queues timeout)
Package

psychiq.client.

Source

client.lisp.

Function: dequeue-from-queue (queue-or-queues &key timeout)
Package

psychiq.queue.

Source

queue.lisp.

Function: disconnect (conn)
Package

psychiq.connection.

Source

connection.lisp.

Function: disconnect-toplevel ()
Package

psychiq.connection.

Source

connection.lisp.

Function: encode-job (worker-class args)
Package

psychiq.worker.

Source

worker.lisp.

Function: encode-object (object)
Package

psychiq.coder.

Source

coder.lisp.

Function: enqueue (worker-class &optional args)
Package

psychiq.client.

Source

client.lisp.

Function: enqueue-bulk (worker-class job-args &rest more-job-args)
Package

psychiq.client.

Source

client.lisp.

Function: enqueue-in-sec (interval worker-class &optional args)
Package

psychiq.client.

Source

client.lisp.

Function: enqueue-to-queue (queue job-info)
Package

psychiq.queue.

Source

queue.lisp.

Function: enqueue-to-scheduled-queue (job-info at)
Package

psychiq.queue.

Source

queue.lisp.

Function: ensure-connected (conn)
Package

psychiq.connection.

Source

connection.lisp.

Function: generate-random-id (&optional length)
Package

psychiq.util.

Source

util.lisp.

Function: get-value (var)
Package

psychiq.util.concurrency.

Source

concurrency.lisp.

Function: (setf get-value) (var)
Package

psychiq.util.concurrency.

Source

concurrency.lisp.

Function: getpid ()
Package

psychiq.util.

Source

util.lisp.

Function: heartbeat (heartbeat machine-identity json)
Package

psychiq.launcher.heartbeat.

Source

heartbeat.lisp.

Function: kill (heartbeat)
Package

psychiq.launcher.heartbeat.

Source

heartbeat.lisp.

Function: kill (scheduled)
Package

psychiq.launcher.scheduled.

Source

scheduled.lisp.

Function: kill (launcher)
Package

psychiq.launcher.

Source

launcher.lisp.

Function: launcher-status (launcher)
Package

psychiq.launcher.

Source

launcher.lisp.

Function: machine-identity ()
Package

psychiq.util.

Source

util.lisp.

Function: make-connection (&rest initargs &key host port db)
Package

psychiq.connection.

Source

connection.lisp.

Function: make-heartbeat (&key host port db thread stopped-p manager)
Package

psychiq.launcher.heartbeat.

Source

heartbeat.lisp.

Function: make-manager (&key host port db queues count timeout)
Package

psychiq.launcher.manager.

Source

manager.lisp.

Function: make-processor (&key host port db queues manager timeout)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Function: make-scheduled (&key host port db)
Package

psychiq.launcher.scheduled.

Source

scheduled.lisp.

Function: make-thread-safe-variable (initial-value &key lock)
Package

psychiq.util.concurrency.

Source

concurrency.lisp.

Reader: manager-children (instance)
Writer: (setf manager-children) (instance)
Package

psychiq.launcher.manager.

Source

manager.lisp.

Target Slot

children.

Reader: manager-count (instance)
Writer: (setf manager-count) (instance)
Package

psychiq.launcher.manager.

Source

manager.lisp.

Target Slot

count.

Reader: manager-queues (instance)
Writer: (setf manager-queues) (instance)
Package

psychiq.launcher.manager.

Source

manager.lisp.

Target Slot

queues.

Reader: manager-stat-failed (instance)
Writer: (setf manager-stat-failed) (instance)
Package

psychiq.launcher.manager.

Source

manager.lisp.

Target Slot

stat-failed.

Reader: manager-stat-processed (instance)
Writer: (setf manager-stat-processed) (instance)
Package

psychiq.launcher.manager.

Source

manager.lisp.

Target Slot

stat-processed.

Reader: manager-stopped-p (instance)
Writer: (setf manager-stopped-p) (instance)
Package

psychiq.launcher.manager.

Source

manager.lisp.

Target Slot

stopped-p.

Function: omit-redis-prefix (key &rest prefixes)
Package

psychiq.util.redis.

Source

redis.lisp.

Function: peek-queue (queue &optional start count)
Package

psychiq.client.

Source

client.lisp.

Reader: processor-connection (instance)
Writer: (setf processor-connection) (instance)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Target Slot

connection.

Reader: processor-id (instance)
Writer: (setf processor-id) (instance)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Target Slot

id.

Reader: processor-manager (instance)
Writer: (setf processor-manager) (instance)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Target Slot

manager.

Reader: processor-processing (instance)
Writer: (setf processor-processing) (instance)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Target Slot

processing.

Reader: processor-status (instance)
Writer: (setf processor-status) (instance)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Target Slot

status.

Reader: processor-timeout (instance)
Writer: (setf processor-timeout) (instance)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Target Slot

timeout.

Function: queue-empty-p (queue)
Package

psychiq.client.

Source

client.lisp.

Function: queue-length (queue)
Package

psychiq.client.

Source

client.lisp.

Function: reconnect (conn)
Package

psychiq.connection.

Source

connection.lisp.

Function: redis-key (&rest keys)
Package

psychiq.util.redis.

Source

redis.lisp.

Function: reset-value (var)
Package

psychiq.util.concurrency.

Source

concurrency.lisp.

Function: retry-length ()
Package

psychiq.client.

Source

client.lisp.

Function: run (&rest initargs &key host port db concurrency queue)
Package

psychiq.launcher.

Source

launcher.lisp.

Reader: scheduled-status (instance)
Writer: (setf scheduled-status) (instance)
Package

psychiq.launcher.scheduled.

Source

scheduled.lisp.

Target Slot

status.

Reader: scheduled-thread (instance)
Writer: (setf scheduled-thread) (instance)
Package

psychiq.launcher.scheduled.

Source

scheduled.lisp.

Target Slot

thread.

Function: slice-queue (queue start &optional end)
Package

psychiq.client.

Source

client.lisp.

Function: start (heartbeat)
Package

psychiq.launcher.heartbeat.

Source

heartbeat.lisp.

Function: start (scheduled)
Package

psychiq.launcher.scheduled.

Source

scheduled.lisp.

Function: start (launcher)
Package

psychiq.launcher.

Source

launcher.lisp.

Function: stats ()
Package

psychiq.client.

Source

client.lisp.

Function: stop (heartbeat)
Package

psychiq.launcher.heartbeat.

Source

heartbeat.lisp.

Function: stop (scheduled)
Package

psychiq.launcher.scheduled.

Source

scheduled.lisp.

Function: stop (launcher)
Package

psychiq.launcher.

Source

launcher.lisp.

Function: symbol-name-with-package (symbol)
Package

psychiq.util.

Source

util.lisp.

Function: wait-for (launcher)
Package

psychiq.launcher.

Source

launcher.lisp.


6.1.4 Generic functions

Generic Function: close-connection (conn)
Package

psychiq.connection.

Source

connection.lisp.

Methods
Method: close-connection ((conn connection))
Generic Function: connectedp (conn)
Package

psychiq.connection.

Source

connection.lisp.

Methods
Method: connectedp ((conn connection))
Generic Function: fetch-job (processor)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Methods
Method: fetch-job ((processor processor))
Generic Function: finalize (processor)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Methods
Method: finalize :after ((processor processor))
Source

manager.lisp.

Method: finalize ((processor processor))
Generic Function: kill (processor)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Methods
Method: kill ((manager manager))
Source

manager.lisp.

Method: kill ((processor processor))
Generic Function: open-connection (conn)
Package

psychiq.connection.

Source

connection.lisp.

Methods
Method: open-connection ((conn connection))
Generic Function: perform (worker &rest args)
Package

psychiq.worker.

Source

worker.lisp.

Methods
Method: perform ((worker worker) &rest args)
Generic Function: perform-job (processor queue worker &rest args)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Methods
Method: perform-job ((processor processor) queue worker &rest args)
Generic Function: process-job (processor queue job-info)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Methods
Method: process-job :around ((processor processor) queue job-info)
Source

manager.lisp.

Method: process-job ((processor processor) queue job-info)
Generic Function: run (processor)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Methods
Method: run :around ((processor processor))
Source

manager.lisp.

Method: run ((processor processor))
Generic Function: start (processor)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Methods
Method: start ((manager manager))
Source

manager.lisp.

Method: start ((processor processor))
Generic Function: stop (processor)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Methods
Method: stop ((manager manager))
Source

manager.lisp.

Method: stop ((processor processor))
Generic Function: wait-for (object)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Methods
Method: wait-for ((manager manager))
Source

manager.lisp.

Method: wait-for ((processor processor))
Generic Function: worker-max-retries (worker)
Package

psychiq.worker.

Source

worker.lisp.

Methods
Method: worker-max-retries ((worker worker))
Generic Function: worker-queue-name (worker)
Package

psychiq.worker.

Source

worker.lisp.

Methods
Method: worker-queue-name ((worker worker))
Generic Function: worker-use-backtrace-p (worker)
Package

psychiq.worker.

Source

worker.lisp.

Methods
Method: worker-use-backtrace-p ((worker worker))
Generic Function: worker-use-dead-queue-p (worker)
Package

psychiq.worker.

Source

worker.lisp.

Methods
Method: worker-use-dead-queue-p ((worker worker))

6.1.5 Standalone methods

Method: print-object ((launcher launcher) stream)
Source

launcher.lisp.

Method: print-object ((processor processor) stream)
Source

processor.lisp.

Method: print-object ((conn connection) stream)
Source

connection.lisp.


6.1.6 Structures

Structure: heartbeat
Package

psychiq.launcher.heartbeat.

Source

heartbeat.lisp.

Direct superclasses

structure-object.

Direct slots
Slot: host
Readers

heartbeat-host.

Writers

(setf heartbeat-host).

Slot: port
Readers

heartbeat-port.

Writers

(setf heartbeat-port).

Slot: db
Readers

heartbeat-db.

Writers

(setf heartbeat-db).

Slot: thread
Readers

heartbeat-thread.

Writers

(setf heartbeat-thread).

Slot: stopped-p
Initform

t

Readers

heartbeat-stopped-p.

Writers

(setf heartbeat-stopped-p).

Slot: manager
Readers

heartbeat-manager.

Writers

(setf heartbeat-manager).

Structure: launcher
Package

psychiq.launcher.

Source

launcher.lisp.

Direct superclasses

structure-object.

Direct methods

print-object.

Direct slots
Slot: manager
Readers

launcher-manager.

Writers

(setf launcher-manager).

Slot: scheduled
Readers

launcher-scheduled.

Writers

(setf launcher-scheduled).

Slot: heartbeat
Readers

launcher-heartbeat.

Writers

(setf launcher-heartbeat).

Structure: manager
Package

psychiq.launcher.manager.

Source

manager.lisp.

Direct superclasses

structure-object.

Direct methods
Direct slots
Slot: host
Readers

manager-host.

Writers

(setf manager-host).

Slot: port
Readers

manager-port.

Writers

(setf manager-port).

Slot: db
Readers

manager-db.

Writers

(setf manager-db).

Slot: queues
Initform

(quote nil)

Readers

manager-queues.

Writers

(setf manager-queues).

Slot: count
Package

common-lisp.

Initform

25

Readers

manager-count.

Writers

(setf manager-count).

Slot: children
Initform

(quote nil)

Readers

manager-children.

Writers

(setf manager-children).

Slot: lock
Initform

(bt2:make-recursive-lock)

Readers

manager-lock.

Writers

(setf manager-lock).

Slot: stopped-p
Initform

t

Readers

manager-stopped-p.

Writers

(setf manager-stopped-p).

Slot: stat-processed
Readers

manager-stat-processed.

Writers

(setf manager-stat-processed).

Slot: stat-failed
Readers

manager-stat-failed.

Writers

(setf manager-stat-failed).

Slot: make-processor-fn
Readers

manager-make-processor-fn.

Writers

(setf manager-make-processor-fn).

Structure: processor
Package

psychiq.launcher.processor.

Source

processor.lisp.

Direct superclasses

structure-object.

Direct methods
Direct slots
Slot: id
Initform

(psychiq.util:generate-random-id 9)

Readers

processor-id.

Writers

(setf processor-id).

Slot: connection
Package

psychiq.connection.

Type

psychiq.connection:connection

Readers

processor-connection.

Writers

(setf processor-connection).

Slot: queues
Type

list

Initform

(quote nil)

Readers

processor-queues.

Writers

(setf processor-queues).

Slot: manager
Readers

processor-manager.

Writers

(setf processor-manager).

Slot: thread
Readers

processor-thread.

Writers

(setf processor-thread).

Slot: status
Initform

:stopped

Readers

processor-status.

Writers

(setf processor-status).

Slot: timeout
Initform

5

Readers

processor-timeout.

Writers

(setf processor-timeout).

Slot: down
Readers

processor-down.

Writers

(setf processor-down).

Slot: processing
Readers

processor-processing.

Writers

(setf processor-processing).

Structure: scheduled
Package

psychiq.launcher.scheduled.

Source

scheduled.lisp.

Direct superclasses

structure-object.

Direct slots
Slot: connection
Readers

scheduled-connection.

Writers

(setf scheduled-connection).

Slot: thread
Readers

scheduled-thread.

Writers

(setf scheduled-thread).

Slot: status
Initform

:stopped

Readers

scheduled-status.

Writers

(setf scheduled-status).


6.1.7 Classes

Class: connection
Package

psychiq.connection.

Source

connection.lisp.

Direct methods
Direct slots
Slot: host
Type

string

Initform

psychiq.specials:*default-redis-host*

Initargs

:host

Slot: port
Type

integer

Initform

psychiq.specials:*default-redis-port*

Initargs

:port

Slot: db
Type

(or integer null)

Initargs

:db

Slot: redis
Type

(or redis:redis-connection null)

Readers

redis-connection.

Writers

(setf redis-connection).

Class: worker
Package

psychiq.worker.

Source

worker.lisp.

Direct methods

6.2 Internals


6.2.1 Special variables

Special Variable: *dead-max-jobs*
Package

psychiq.middleware.retry-jobs.

Source

retry-jobs.lisp.

Special Variable: *dead-timeout-in-seconds*
Package

psychiq.middleware.retry-jobs.

Source

retry-jobs.lisp.


6.2.2 Ordinary functions

Function: %make-launcher (&key manager scheduled heartbeat)
Package

psychiq.launcher.

Source

launcher.lisp.

Function: %make-manager (&key host port db queues count lock)
Package

psychiq.launcher.manager.

Source

manager.lisp.

Function: %make-processor (&key id connection queues manager thread status timeout down processing)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Function: %make-scheduled (&key connection thread status)
Package

psychiq.launcher.scheduled.

Source

scheduled.lisp.

Function: attempt-retry (queue worker job-info e)
Package

psychiq.middleware.retry-jobs.

Source

retry-jobs.lisp.

Function: backtrace (&optional count-to-remove)
Package

psychiq.middleware.retry-jobs.

Source

retry-jobs.lisp.

Function: clear-heartbeat (heartbeat)
Package

psychiq.launcher.heartbeat.

Source

heartbeat.lisp.

Function: copy-heartbeat (instance)
Package

psychiq.launcher.heartbeat.

Source

heartbeat.lisp.

Function: copy-launcher (instance)
Package

psychiq.launcher.

Source

launcher.lisp.

Function: copy-manager (instance)
Package

psychiq.launcher.manager.

Source

manager.lisp.

Function: copy-processor (instance)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Function: copy-scheduled (instance)
Package

psychiq.launcher.scheduled.

Source

scheduled.lisp.

Function: copy-thread-safe-variable (instance)
Package

psychiq.util.concurrency.

Source

concurrency.lisp.

Function: decode-objects (objects)
Package

psychiq.client.

Source

client.lisp.

Function: delay-for (retry-count)
Package

psychiq.middleware.retry-jobs.

Source

retry-jobs.lisp.

Function: enqueue-jobs (now)
Package

psychiq.launcher.scheduled.

Source

scheduled.lisp.

Reader: heartbeat-db (instance)
Writer: (setf heartbeat-db) (instance)
Package

psychiq.launcher.heartbeat.

Source

heartbeat.lisp.

Target Slot

db.

Reader: heartbeat-host (instance)
Writer: (setf heartbeat-host) (instance)
Package

psychiq.launcher.heartbeat.

Source

heartbeat.lisp.

Target Slot

host.

Reader: heartbeat-manager (instance)
Writer: (setf heartbeat-manager) (instance)
Package

psychiq.launcher.heartbeat.

Source

heartbeat.lisp.

Target Slot

manager.

Function: heartbeat-p (object)
Package

psychiq.launcher.heartbeat.

Source

heartbeat.lisp.

Reader: heartbeat-port (instance)
Writer: (setf heartbeat-port) (instance)
Package

psychiq.launcher.heartbeat.

Source

heartbeat.lisp.

Target Slot

port.

Reader: heartbeat-stopped-p (instance)
Writer: (setf heartbeat-stopped-p) (instance)
Package

psychiq.launcher.heartbeat.

Source

heartbeat.lisp.

Target Slot

stopped-p.

Reader: heartbeat-thread (instance)
Writer: (setf heartbeat-thread) (instance)
Package

psychiq.launcher.heartbeat.

Source

heartbeat.lisp.

Target Slot

thread.

Reader: launcher-heartbeat (instance)
Writer: (setf launcher-heartbeat) (instance)
Package

psychiq.launcher.

Source

launcher.lisp.

Target Slot

heartbeat.

Reader: launcher-manager (instance)
Writer: (setf launcher-manager) (instance)
Package

psychiq.launcher.

Source

launcher.lisp.

Target Slot

manager.

Function: launcher-p (object)
Package

psychiq.launcher.

Source

launcher.lisp.

Reader: launcher-scheduled (instance)
Writer: (setf launcher-scheduled) (instance)
Package

psychiq.launcher.

Source

launcher.lisp.

Target Slot

scheduled.

Function: make-child-processors (manager)
Package

psychiq.launcher.manager.

Source

manager.lisp.

Function: make-launcher (&key host port db concurrency queue interval)
Package

psychiq.launcher.

Source

launcher.lisp.

Reader: manager-db (instance)
Writer: (setf manager-db) (instance)
Package

psychiq.launcher.manager.

Source

manager.lisp.

Target Slot

db.

Reader: manager-host (instance)
Writer: (setf manager-host) (instance)
Package

psychiq.launcher.manager.

Source

manager.lisp.

Target Slot

host.

Reader: manager-lock (instance)
Writer: (setf manager-lock) (instance)
Package

psychiq.launcher.manager.

Source

manager.lisp.

Target Slot

lock.

Reader: manager-make-processor-fn (instance)
Writer: (setf manager-make-processor-fn) (instance)
Package

psychiq.launcher.manager.

Source

manager.lisp.

Target Slot

make-processor-fn.

Function: manager-p (object)
Package

psychiq.launcher.manager.

Source

manager.lisp.

Reader: manager-port (instance)
Writer: (setf manager-port) (instance)
Package

psychiq.launcher.manager.

Source

manager.lisp.

Target Slot

port.

Function: processor-died (manager processor e)
Package

psychiq.launcher.manager.

Source

manager.lisp.

Reader: processor-down (instance)
Writer: (setf processor-down) (instance)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Target Slot

down.

Function: processor-p (object)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Reader: processor-queues (instance)
Writer: (setf processor-queues) (instance)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Target Slot

queues.

Function: processor-stopped (manager processor)
Package

psychiq.launcher.manager.

Source

manager.lisp.

Reader: processor-thread (instance)
Writer: (setf processor-thread) (instance)
Package

psychiq.launcher.processor.

Source

processor.lisp.

Target Slot

thread.

Function: run (heartbeat)
Package

psychiq.launcher.heartbeat.

Source

heartbeat.lisp.

Function: scaled-poll-interval ()
Package

psychiq.launcher.scheduled.

Source

scheduled.lisp.

Reader: scheduled-connection (instance)
Writer: (setf scheduled-connection) (instance)
Package

psychiq.launcher.scheduled.

Source

scheduled.lisp.

Target Slot

connection.

Function: scheduled-p (object)
Package

psychiq.launcher.scheduled.

Source

scheduled.lisp.

Function: send-to-morgue (job-info)
Package

psychiq.middleware.retry-jobs.

Source

retry-jobs.lisp.

Reader: thread-safe-variable-initial-value (instance)
Writer: (setf thread-safe-variable-initial-value) (instance)
Package

psychiq.util.concurrency.

Source

concurrency.lisp.

Target Slot

initial-value.

Reader: thread-safe-variable-lock (instance)
Writer: (setf thread-safe-variable-lock) (instance)
Package

psychiq.util.concurrency.

Source

concurrency.lisp.

Target Slot

lock.

Function: thread-safe-variable-p (object)
Package

psychiq.util.concurrency.

Source

concurrency.lisp.

Reader: thread-safe-variable-value (instance)
Writer: (setf thread-safe-variable-value) (instance)
Package

psychiq.util.concurrency.

Source

concurrency.lisp.

Target Slot

value.


6.2.3 Generic functions

Generic Reader: redis-connection (object)
Package

psychiq.connection.

Methods
Reader Method: redis-connection ((connection connection))

automatically generated reader method

Source

connection.lisp.

Target Slot

redis.

Generic Writer: (setf redis-connection) (object)
Package

psychiq.connection.

Methods
Writer Method: (setf redis-connection) ((connection connection))

automatically generated writer method

Source

connection.lisp.

Target Slot

redis.


6.2.4 Structures

Structure: thread-safe-variable
Package

psychiq.util.concurrency.

Source

concurrency.lisp.

Direct superclasses

structure-object.

Direct slots
Slot: initial-value
Readers

thread-safe-variable-initial-value.

Writers

(setf thread-safe-variable-initial-value).

Slot: value
Readers

thread-safe-variable-value.

Writers

(setf thread-safe-variable-value).

Slot: lock
Initform

(bt2:make-recursive-lock)

Readers

thread-safe-variable-lock.

Writers

(setf thread-safe-variable-lock).


Appendix A Indexes


A.1 Concepts


A.2 Functions

Jump to:   %   (  
A   B   C   D   E   F   G   H   K   L   M   O   P   Q   R   S   T   W  
Index Entry  Section

%
%make-launcher: Private ordinary functions
%make-manager: Private ordinary functions
%make-processor: Private ordinary functions
%make-scheduled: Private ordinary functions

(
(setf aget): Public ordinary functions
(setf get-value): Public ordinary functions
(setf heartbeat-db): Private ordinary functions
(setf heartbeat-host): Private ordinary functions
(setf heartbeat-manager): Private ordinary functions
(setf heartbeat-port): Private ordinary functions
(setf heartbeat-stopped-p): Private ordinary functions
(setf heartbeat-thread): Private ordinary functions
(setf launcher-heartbeat): Private ordinary functions
(setf launcher-manager): Private ordinary functions
(setf launcher-scheduled): Private ordinary functions
(setf manager-children): Public ordinary functions
(setf manager-count): Public ordinary functions
(setf manager-db): Private ordinary functions
(setf manager-host): Private ordinary functions
(setf manager-lock): Private ordinary functions
(setf manager-make-processor-fn): Private ordinary functions
(setf manager-port): Private ordinary functions
(setf manager-queues): Public ordinary functions
(setf manager-stat-failed): Public ordinary functions
(setf manager-stat-processed): Public ordinary functions
(setf manager-stopped-p): Public ordinary functions
(setf processor-connection): Public ordinary functions
(setf processor-down): Private ordinary functions
(setf processor-id): Public ordinary functions
(setf processor-manager): Public ordinary functions
(setf processor-processing): Public ordinary functions
(setf processor-queues): Private ordinary functions
(setf processor-status): Public ordinary functions
(setf processor-thread): Private ordinary functions
(setf processor-timeout): Public ordinary functions
(setf redis-connection): Private generic functions
(setf redis-connection): Private generic functions
(setf scheduled-connection): Private ordinary functions
(setf scheduled-status): Public ordinary functions
(setf scheduled-thread): Public ordinary functions
(setf thread-safe-variable-initial-value): Private ordinary functions
(setf thread-safe-variable-lock): Private ordinary functions
(setf thread-safe-variable-value): Private ordinary functions

A
aget: Public ordinary functions
all-dead-jobs: Public ordinary functions
all-queues: Public ordinary functions
all-retries: Public ordinary functions
attempt-retry: Private ordinary functions

B
backtrace: Private ordinary functions

C
cleanup-processes: Public ordinary functions
clear-heartbeat: Private ordinary functions
close-connection: Public generic functions
close-connection: Public generic functions
connect: Public ordinary functions
connect-toplevel: Public ordinary functions
connectedp: Public generic functions
connectedp: Public generic functions
copy-heartbeat: Private ordinary functions
copy-launcher: Private ordinary functions
copy-manager: Private ordinary functions
copy-processor: Private ordinary functions
copy-scheduled: Private ordinary functions
copy-thread-safe-variable: Private ordinary functions

D
decode-job: Public ordinary functions
decode-object: Public ordinary functions
decode-objects: Private ordinary functions
delay-for: Private ordinary functions
delete-queue: Public ordinary functions
dequeue: Public ordinary functions
dequeue-from-queue: Public ordinary functions
disconnect: Public ordinary functions
disconnect-toplevel: Public ordinary functions

E
encode-job: Public ordinary functions
encode-object: Public ordinary functions
enqueue: Public ordinary functions
enqueue-bulk: Public ordinary functions
enqueue-in-sec: Public ordinary functions
enqueue-jobs: Private ordinary functions
enqueue-to-queue: Public ordinary functions
enqueue-to-scheduled-queue: Public ordinary functions
ensure-connected: Public ordinary functions

F
fetch-job: Public generic functions
fetch-job: Public generic functions
finalize: Public generic functions
finalize: Public generic functions
finalize: Public generic functions
Function, %make-launcher: Private ordinary functions
Function, %make-manager: Private ordinary functions
Function, %make-processor: Private ordinary functions
Function, %make-scheduled: Private ordinary functions
Function, (setf aget): Public ordinary functions
Function, (setf get-value): Public ordinary functions
Function, (setf heartbeat-db): Private ordinary functions
Function, (setf heartbeat-host): Private ordinary functions
Function, (setf heartbeat-manager): Private ordinary functions
Function, (setf heartbeat-port): Private ordinary functions
Function, (setf heartbeat-stopped-p): Private ordinary functions
Function, (setf heartbeat-thread): Private ordinary functions
Function, (setf launcher-heartbeat): Private ordinary functions
Function, (setf launcher-manager): Private ordinary functions
Function, (setf launcher-scheduled): Private ordinary functions
Function, (setf manager-children): Public ordinary functions
Function, (setf manager-count): Public ordinary functions
Function, (setf manager-db): Private ordinary functions
Function, (setf manager-host): Private ordinary functions
Function, (setf manager-lock): Private ordinary functions
Function, (setf manager-make-processor-fn): Private ordinary functions
Function, (setf manager-port): Private ordinary functions
Function, (setf manager-queues): Public ordinary functions
Function, (setf manager-stat-failed): Public ordinary functions
Function, (setf manager-stat-processed): Public ordinary functions
Function, (setf manager-stopped-p): Public ordinary functions
Function, (setf processor-connection): Public ordinary functions
Function, (setf processor-down): Private ordinary functions
Function, (setf processor-id): Public ordinary functions
Function, (setf processor-manager): Public ordinary functions
Function, (setf processor-processing): Public ordinary functions
Function, (setf processor-queues): Private ordinary functions
Function, (setf processor-status): Public ordinary functions
Function, (setf processor-thread): Private ordinary functions
Function, (setf processor-timeout): Public ordinary functions
Function, (setf scheduled-connection): Private ordinary functions
Function, (setf scheduled-status): Public ordinary functions
Function, (setf scheduled-thread): Public ordinary functions
Function, (setf thread-safe-variable-initial-value): Private ordinary functions
Function, (setf thread-safe-variable-lock): Private ordinary functions
Function, (setf thread-safe-variable-value): Private ordinary functions
Function, aget: Public ordinary functions
Function, all-dead-jobs: Public ordinary functions
Function, all-queues: Public ordinary functions
Function, all-retries: Public ordinary functions
Function, attempt-retry: Private ordinary functions
Function, backtrace: Private ordinary functions
Function, cleanup-processes: Public ordinary functions
Function, clear-heartbeat: Private ordinary functions
Function, connect: Public ordinary functions
Function, connect-toplevel: Public ordinary functions
Function, copy-heartbeat: Private ordinary functions
Function, copy-launcher: Private ordinary functions
Function, copy-manager: Private ordinary functions
Function, copy-processor: Private ordinary functions
Function, copy-scheduled: Private ordinary functions
Function, copy-thread-safe-variable: Private ordinary functions
Function, decode-job: Public ordinary functions
Function, decode-object: Public ordinary functions
Function, decode-objects: Private ordinary functions
Function, delay-for: Private ordinary functions
Function, delete-queue: Public ordinary functions
Function, dequeue: Public ordinary functions
Function, dequeue-from-queue: Public ordinary functions
Function, disconnect: Public ordinary functions
Function, disconnect-toplevel: Public ordinary functions
Function, encode-job: Public ordinary functions
Function, encode-object: Public ordinary functions
Function, enqueue: Public ordinary functions
Function, enqueue-bulk: Public ordinary functions
Function, enqueue-in-sec: Public ordinary functions
Function, enqueue-jobs: Private ordinary functions
Function, enqueue-to-queue: Public ordinary functions
Function, enqueue-to-scheduled-queue: Public ordinary functions
Function, ensure-connected: Public ordinary functions
Function, generate-random-id: Public ordinary functions
Function, get-value: Public ordinary functions
Function, getpid: Public ordinary functions
Function, heartbeat: Public ordinary functions
Function, heartbeat-db: Private ordinary functions
Function, heartbeat-host: Private ordinary functions
Function, heartbeat-manager: Private ordinary functions
Function, heartbeat-p: Private ordinary functions
Function, heartbeat-port: Private ordinary functions
Function, heartbeat-stopped-p: Private ordinary functions
Function, heartbeat-thread: Private ordinary functions
Function, kill: Public ordinary functions
Function, kill: Public ordinary functions
Function, kill: Public ordinary functions
Function, launcher-heartbeat: Private ordinary functions
Function, launcher-manager: Private ordinary functions
Function, launcher-p: Private ordinary functions
Function, launcher-scheduled: Private ordinary functions
Function, launcher-status: Public ordinary functions
Function, machine-identity: Public ordinary functions
Function, make-child-processors: Private ordinary functions
Function, make-connection: Public ordinary functions
Function, make-heartbeat: Public ordinary functions
Function, make-launcher: Private ordinary functions
Function, make-manager: Public ordinary functions
Function, make-processor: Public ordinary functions
Function, make-scheduled: Public ordinary functions
Function, make-thread-safe-variable: Public ordinary functions
Function, manager-children: Public ordinary functions
Function, manager-count: Public ordinary functions
Function, manager-db: Private ordinary functions
Function, manager-host: Private ordinary functions
Function, manager-lock: Private ordinary functions
Function, manager-make-processor-fn: Private ordinary functions
Function, manager-p: Private ordinary functions
Function, manager-port: Private ordinary functions
Function, manager-queues: Public ordinary functions
Function, manager-stat-failed: Public ordinary functions
Function, manager-stat-processed: Public ordinary functions
Function, manager-stopped-p: Public ordinary functions
Function, omit-redis-prefix: Public ordinary functions
Function, peek-queue: Public ordinary functions
Function, processor-connection: Public ordinary functions
Function, processor-died: Private ordinary functions
Function, processor-down: Private ordinary functions
Function, processor-id: Public ordinary functions
Function, processor-manager: Public ordinary functions
Function, processor-p: Private ordinary functions
Function, processor-processing: Public ordinary functions
Function, processor-queues: Private ordinary functions
Function, processor-status: Public ordinary functions
Function, processor-stopped: Private ordinary functions
Function, processor-thread: Private ordinary functions
Function, processor-timeout: Public ordinary functions
Function, queue-empty-p: Public ordinary functions
Function, queue-length: Public ordinary functions
Function, reconnect: Public ordinary functions
Function, redis-key: Public ordinary functions
Function, reset-value: Public ordinary functions
Function, retry-length: Public ordinary functions
Function, run: Public ordinary functions
Function, run: Private ordinary functions
Function, scaled-poll-interval: Private ordinary functions
Function, scheduled-connection: Private ordinary functions
Function, scheduled-p: Private ordinary functions
Function, scheduled-status: Public ordinary functions
Function, scheduled-thread: Public ordinary functions
Function, send-to-morgue: Private ordinary functions
Function, slice-queue: Public ordinary functions
Function, start: Public ordinary functions
Function, start: Public ordinary functions
Function, start: Public ordinary functions
Function, stats: Public ordinary functions
Function, stop: Public ordinary functions
Function, stop: Public ordinary functions
Function, stop: Public ordinary functions
Function, symbol-name-with-package: Public ordinary functions
Function, thread-safe-variable-initial-value: Private ordinary functions
Function, thread-safe-variable-lock: Private ordinary functions
Function, thread-safe-variable-p: Private ordinary functions
Function, thread-safe-variable-value: Private ordinary functions
Function, wait-for: Public ordinary functions

G
generate-random-id: Public ordinary functions
Generic Function, (setf redis-connection): Private generic functions
Generic Function, close-connection: Public generic functions
Generic Function, connectedp: Public generic functions
Generic Function, fetch-job: Public generic functions
Generic Function, finalize: Public generic functions
Generic Function, kill: Public generic functions
Generic Function, open-connection: Public generic functions
Generic Function, perform: Public generic functions
Generic Function, perform-job: Public generic functions
Generic Function, process-job: Public generic functions
Generic Function, redis-connection: Private generic functions
Generic Function, run: Public generic functions
Generic Function, start: Public generic functions
Generic Function, stop: Public generic functions
Generic Function, wait-for: Public generic functions
Generic Function, worker-max-retries: Public generic functions
Generic Function, worker-queue-name: Public generic functions
Generic Function, worker-use-backtrace-p: Public generic functions
Generic Function, worker-use-dead-queue-p: Public generic functions
get-value: Public ordinary functions
getpid: Public ordinary functions

H
heartbeat: Public ordinary functions
heartbeat-db: Private ordinary functions
heartbeat-host: Private ordinary functions
heartbeat-manager: Private ordinary functions
heartbeat-p: Private ordinary functions
heartbeat-port: Private ordinary functions
heartbeat-stopped-p: Private ordinary functions
heartbeat-thread: Private ordinary functions

K
kill: Public ordinary functions
kill: Public ordinary functions
kill: Public ordinary functions
kill: Public generic functions
kill: Public generic functions
kill: Public generic functions

L
launcher-heartbeat: Private ordinary functions
launcher-manager: Private ordinary functions
launcher-p: Private ordinary functions
launcher-scheduled: Private ordinary functions
launcher-status: Public ordinary functions

M
machine-identity: Public ordinary functions
Macro, with-connection: Public macros
Macro, with-redis-transaction: Public macros
make-child-processors: Private ordinary functions
make-connection: Public ordinary functions
make-heartbeat: Public ordinary functions
make-launcher: Private ordinary functions
make-manager: Public ordinary functions
make-processor: Public ordinary functions
make-scheduled: Public ordinary functions
make-thread-safe-variable: Public ordinary functions
manager-children: Public ordinary functions
manager-count: Public ordinary functions
manager-db: Private ordinary functions
manager-host: Private ordinary functions
manager-lock: Private ordinary functions
manager-make-processor-fn: Private ordinary functions
manager-p: Private ordinary functions
manager-port: Private ordinary functions
manager-queues: Public ordinary functions
manager-stat-failed: Public ordinary functions
manager-stat-processed: Public ordinary functions
manager-stopped-p: Public ordinary functions
Method, (setf redis-connection): Private generic functions
Method, close-connection: Public generic functions
Method, connectedp: Public generic functions
Method, fetch-job: Public generic functions
Method, finalize: Public generic functions
Method, finalize: Public generic functions
Method, kill: Public generic functions
Method, kill: Public generic functions
Method, open-connection: Public generic functions
Method, perform: Public generic functions
Method, perform-job: Public generic functions
Method, print-object: Public standalone methods
Method, print-object: Public standalone methods
Method, print-object: Public standalone methods
Method, process-job: Public generic functions
Method, process-job: Public generic functions
Method, redis-connection: Private generic functions
Method, run: Public generic functions
Method, run: Public generic functions
Method, start: Public generic functions
Method, start: Public generic functions
Method, stop: Public generic functions
Method, stop: Public generic functions
Method, wait-for: Public generic functions
Method, wait-for: Public generic functions
Method, worker-max-retries: Public generic functions
Method, worker-queue-name: Public generic functions
Method, worker-use-backtrace-p: Public generic functions
Method, worker-use-dead-queue-p: Public generic functions

O
omit-redis-prefix: Public ordinary functions
open-connection: Public generic functions
open-connection: Public generic functions

P
peek-queue: Public ordinary functions
perform: Public generic functions
perform: Public generic functions
perform-job: Public generic functions
perform-job: Public generic functions
print-object: Public standalone methods
print-object: Public standalone methods
print-object: Public standalone methods
process-job: Public generic functions
process-job: Public generic functions
process-job: Public generic functions
processor-connection: Public ordinary functions
processor-died: Private ordinary functions
processor-down: Private ordinary functions
processor-id: Public ordinary functions
processor-manager: Public ordinary functions
processor-p: Private ordinary functions
processor-processing: Public ordinary functions
processor-queues: Private ordinary functions
processor-status: Public ordinary functions
processor-stopped: Private ordinary functions
processor-thread: Private ordinary functions
processor-timeout: Public ordinary functions

Q
queue-empty-p: Public ordinary functions
queue-length: Public ordinary functions

R
reconnect: Public ordinary functions
redis-connection: Private generic functions
redis-connection: Private generic functions
redis-key: Public ordinary functions
reset-value: Public ordinary functions
retry-length: Public ordinary functions
run: Public ordinary functions
run: Public generic functions
run: Public generic functions
run: Public generic functions
run: Private ordinary functions

S
scaled-poll-interval: Private ordinary functions
scheduled-connection: Private ordinary functions
scheduled-p: Private ordinary functions
scheduled-status: Public ordinary functions
scheduled-thread: Public ordinary functions
send-to-morgue: Private ordinary functions
slice-queue: Public ordinary functions
start: Public ordinary functions
start: Public ordinary functions
start: Public ordinary functions
start: Public generic functions
start: Public generic functions
start: Public generic functions
stats: Public ordinary functions
stop: Public ordinary functions
stop: Public ordinary functions
stop: Public ordinary functions
stop: Public generic functions
stop: Public generic functions
stop: Public generic functions
symbol-name-with-package: Public ordinary functions

T
thread-safe-variable-initial-value: Private ordinary functions
thread-safe-variable-lock: Private ordinary functions
thread-safe-variable-p: Private ordinary functions
thread-safe-variable-value: Private ordinary functions

W
wait-for: Public ordinary functions
wait-for: Public generic functions
wait-for: Public generic functions
wait-for: Public generic functions
with-connection: Public macros
with-redis-transaction: Public macros
worker-max-retries: Public generic functions
worker-max-retries: Public generic functions
worker-queue-name: Public generic functions
worker-queue-name: Public generic functions
worker-use-backtrace-p: Public generic functions
worker-use-backtrace-p: Public generic functions
worker-use-dead-queue-p: Public generic functions
worker-use-dead-queue-p: Public generic functions


A.3 Variables

Jump to:   *  
C   D   H   I   L   M   P   Q   R   S   T   V  
Index Entry  Section

*
*connection*: Public special variables
*dead-max-jobs*: Private special variables
*dead-timeout-in-seconds*: Private special variables
*default-max-retry-attempts*: Public special variables
*default-queue-name*: Public special variables
*default-redis-host*: Public special variables
*default-redis-port*: Public special variables
*psychiq-middleware-logging*: Public special variables
*psychiq-middleware-retry-jobs*: Public special variables
*psychiq-namespace*: Public special variables

C
children: Public structures
connection: Public structures
connection: Public structures
count: Public structures

D
db: Public structures
db: Public structures
db: Public classes
down: Public structures

H
heartbeat: Public structures
host: Public structures
host: Public structures
host: Public classes

I
id: Public structures
initial-value: Private structures

L
lock: Public structures
lock: Private structures

M
make-processor-fn: Public structures
manager: Public structures
manager: Public structures
manager: Public structures

P
port: Public structures
port: Public structures
port: Public classes
processing: Public structures

Q
queues: Public structures
queues: Public structures

R
redis: Public classes

S
scheduled: Public structures
Slot, children: Public structures
Slot, connection: Public structures
Slot, connection: Public structures
Slot, count: Public structures
Slot, db: Public structures
Slot, db: Public structures
Slot, db: Public classes
Slot, down: Public structures
Slot, heartbeat: Public structures
Slot, host: Public structures
Slot, host: Public structures
Slot, host: Public classes
Slot, id: Public structures
Slot, initial-value: Private structures
Slot, lock: Public structures
Slot, lock: Private structures
Slot, make-processor-fn: Public structures
Slot, manager: Public structures
Slot, manager: Public structures
Slot, manager: Public structures
Slot, port: Public structures
Slot, port: Public structures
Slot, port: Public classes
Slot, processing: Public structures
Slot, queues: Public structures
Slot, queues: Public structures
Slot, redis: Public classes
Slot, scheduled: Public structures
Slot, stat-failed: Public structures
Slot, stat-processed: Public structures
Slot, status: Public structures
Slot, status: Public structures
Slot, stopped-p: Public structures
Slot, stopped-p: Public structures
Slot, thread: Public structures
Slot, thread: Public structures
Slot, thread: Public structures
Slot, timeout: Public structures
Slot, value: Private structures
Special Variable, *connection*: Public special variables
Special Variable, *dead-max-jobs*: Private special variables
Special Variable, *dead-timeout-in-seconds*: Private special variables
Special Variable, *default-max-retry-attempts*: Public special variables
Special Variable, *default-queue-name*: Public special variables
Special Variable, *default-redis-host*: Public special variables
Special Variable, *default-redis-port*: Public special variables
Special Variable, *psychiq-middleware-logging*: Public special variables
Special Variable, *psychiq-middleware-retry-jobs*: Public special variables
Special Variable, *psychiq-namespace*: Public special variables
stat-failed: Public structures
stat-processed: Public structures
status: Public structures
status: Public structures
stopped-p: Public structures
stopped-p: Public structures

T
thread: Public structures
thread: Public structures
thread: Public structures
timeout: Public structures

V
value: Private structures


A.4 Data types

Jump to:   A   C   F   H   L   M   P   Q   R   S   T   U   W  
Index Entry  Section

A
assoc.lisp: The psychiq/src/util/assoc․lisp file

C
Class, connection: Public classes
Class, worker: Public classes
client.lisp: The psychiq/src/client․lisp file
coder.lisp: The psychiq/src/core/coder․lisp file
concurrency.lisp: The psychiq/src/util/concurrency․lisp file
connection: Public classes
connection.lisp: The psychiq/src/core/connection․lisp file
core: The psychiq/src/core module

F
File, assoc.lisp: The psychiq/src/util/assoc․lisp file
File, client.lisp: The psychiq/src/client․lisp file
File, coder.lisp: The psychiq/src/core/coder․lisp file
File, concurrency.lisp: The psychiq/src/util/concurrency․lisp file
File, connection.lisp: The psychiq/src/core/connection․lisp file
File, heartbeat.lisp: The psychiq/src/launcher-core/heartbeat․lisp file
File, launcher.lisp: The psychiq/src/launcher․lisp file
File, logging.lisp: The psychiq/src/middleware/logging․lisp file
File, manager.lisp: The psychiq/src/launcher-core/manager․lisp file
File, processor.lisp: The psychiq/src/launcher-core/processor․lisp file
File, psychiq.asd: The psychiq/psychiq․asd file
File, psychiq.lisp: The psychiq/src/psychiq․lisp file
File, queue.lisp: The psychiq/src/core/queue․lisp file
File, redis.lisp: The psychiq/src/util/redis․lisp file
File, retry-jobs.lisp: The psychiq/src/middleware/retry-jobs․lisp file
File, scheduled.lisp: The psychiq/src/launcher-core/scheduled․lisp file
File, src/specials.lisp: The psychiq/src/specials․lisp file
File, util.lisp: The psychiq/src/util/util․lisp file
File, worker.lisp: The psychiq/src/core/worker․lisp file

H
heartbeat: Public structures
heartbeat.lisp: The psychiq/src/launcher-core/heartbeat․lisp file

L
launcher: Public structures
launcher-core: The psychiq/src/launcher-core module
launcher.lisp: The psychiq/src/launcher․lisp file
logging.lisp: The psychiq/src/middleware/logging․lisp file

M
manager: Public structures
manager.lisp: The psychiq/src/launcher-core/manager․lisp file
middleware: The psychiq/src/middleware module
Module, core: The psychiq/src/core module
Module, launcher-core: The psychiq/src/launcher-core module
Module, middleware: The psychiq/src/middleware module
Module, src: The psychiq/src module
Module, util: The psychiq/src/util module

P
Package, psychiq: The psychiq package
Package, psychiq.client: The psychiq․client package
Package, psychiq.coder: The psychiq․coder package
Package, psychiq.connection: The psychiq․connection package
Package, psychiq.launcher: The psychiq․launcher package
Package, psychiq.launcher.heartbeat: The psychiq․launcher․heartbeat package
Package, psychiq.launcher.manager: The psychiq․launcher․manager package
Package, psychiq.launcher.processor: The psychiq․launcher․processor package
Package, psychiq.launcher.scheduled: The psychiq․launcher․scheduled package
Package, psychiq.middleware.logging: The psychiq․middleware․logging package
Package, psychiq.middleware.retry-jobs: The psychiq․middleware․retry-jobs package
Package, psychiq.queue: The psychiq․queue package
Package, psychiq.specials: The psychiq․specials package
Package, psychiq.util: The psychiq․util package
Package, psychiq.util.assoc: The psychiq․util․assoc package
Package, psychiq.util.concurrency: The psychiq․util․concurrency package
Package, psychiq.util.redis: The psychiq․util․redis package
Package, psychiq.worker: The psychiq․worker package
processor: Public structures
processor.lisp: The psychiq/src/launcher-core/processor․lisp file
psychiq: The psychiq system
psychiq: The psychiq package
psychiq.asd: The psychiq/psychiq․asd file
psychiq.client: The psychiq․client package
psychiq.coder: The psychiq․coder package
psychiq.connection: The psychiq․connection package
psychiq.launcher: The psychiq․launcher package
psychiq.launcher.heartbeat: The psychiq․launcher․heartbeat package
psychiq.launcher.manager: The psychiq․launcher․manager package
psychiq.launcher.processor: The psychiq․launcher․processor package
psychiq.launcher.scheduled: The psychiq․launcher․scheduled package
psychiq.lisp: The psychiq/src/psychiq․lisp file
psychiq.middleware.logging: The psychiq․middleware․logging package
psychiq.middleware.retry-jobs: The psychiq․middleware․retry-jobs package
psychiq.queue: The psychiq․queue package
psychiq.specials: The psychiq․specials package
psychiq.util: The psychiq․util package
psychiq.util.assoc: The psychiq․util․assoc package
psychiq.util.concurrency: The psychiq․util․concurrency package
psychiq.util.redis: The psychiq․util․redis package
psychiq.worker: The psychiq․worker package

Q
queue.lisp: The psychiq/src/core/queue․lisp file

R
redis.lisp: The psychiq/src/util/redis․lisp file
retry-jobs.lisp: The psychiq/src/middleware/retry-jobs․lisp file

S
scheduled: Public structures
scheduled.lisp: The psychiq/src/launcher-core/scheduled․lisp file
src: The psychiq/src module
src/specials.lisp: The psychiq/src/specials․lisp file
Structure, heartbeat: Public structures
Structure, launcher: Public structures
Structure, manager: Public structures
Structure, processor: Public structures
Structure, scheduled: Public structures
Structure, thread-safe-variable: Private structures
System, psychiq: The psychiq system

T
thread-safe-variable: Private structures

U
util: The psychiq/src/util module
util.lisp: The psychiq/src/util/util․lisp file

W
worker: Public classes
worker.lisp: The psychiq/src/core/worker․lisp file