Common Lisp Package: CL-GEARMAN

README:

FUNCTION

Public

Undocumented

LOG-DEBUG (MESSAGE &OPTIONAL (TAG ))

LOG-ERROR (MESSAGE &OPTIONAL (TAG ))

LOG-FATAL (MESSAGE &OPTIONAL (TAG ))

LOG-INFO (MESSAGE &OPTIONAL (TAG ))

LOG-WARN (MESSAGE &OPTIONAL (TAG ))

MAKE-CLIENT (SERVER-EXPS)

MAKE-WORKER (SERVER-EXPS)

Private

ENSURE-CONNECTION (CONN)

Ensure that CONN is open before doing anything with it.

REOPEN-CONNECTION (CONN)

Close and reopen CONN.

VECTOR-JOIN (SEP &REST VECTORS)

Join vectors. The first vector must be adjustable or contain enough space to append following vectors.

Undocumented

BIG-ENDIAN-OCTETS-TO-UINT32 (OCTETS)

DEFAULT-FORMATTER (MESSAGE &KEY TIMESTAMP LEVEL TAG)

LIST-TO-VECTOR (LIS)

MAKE-UID

MESSAGE-TO-OCTETS (MSG)

OPEN-CONNECTION-P (CONN)

READ-AS-VECTOR (SIZ STREAM &KEY (ELEMENT-TYPE T))

READ-MESSAGE (STREAM)

RECV-RESPONSE (CONN)

SEND-REQUEST (CONN MSG)

SPLIT-PAYLOADS (PAYLOADS)

UINT32-TO-BIG-ENDIAN-OCTETS (NUM)

WRITE-LOG (LEVEL TAG MESSAGE)

WRITE-MESSAGE (STREAM MESSAGE)

MACRO

Public

Undocumented

WITH-CLIENT ((VAR HOST) &BODY BODY)

WITH-WORKER ((VAR HOST) &BODY BODY)

Private

PROVIDE-RECONNECT-RESTART (EXPRESSION &BODY BODY)

When, during the execution of EXPRESSION, an error occurs that can break the connection socket, a condition of type GEARMAN-CONNECTION-ERROR is raised offering a :reconnect restart whose body is given by BODY.

SIGNAL-CONNECTION-ERROR-WITH-RECONNECT-RESTART (&KEY MESSAGE COMMENT RESTART)

Signal the condition of type GEARMAN-CONNECTION-ERROR denoted by the given MESSAGE and COMMENT offering a :reconnect restart given by RESTART.

WITH-RECONNECT-RESTART (CONN &BODY BODY)

When, inside BODY, an error occurs that breaks the socket of CONN, a condition of type REDIS-CONNECTION-ERROR is raised offering a :reconnect restart.

GENERIC-FUNCTION

Public

Undocumented

ADD-ABILITY (W NAME FUNC &KEY (TIMEOUT NIL))

CLOSE-CLIENT (C)

CLOSE-WORKER (W)

GET-JOB-STATUS (CLI J)

REMOVE-ABILITY (W NAME)

RESET-ABILITIES (W)

SUBMIT-BACKGROUND-JOB (CLI FUNC &KEY ARG PRIORITY)

SUBMIT-JOB (CLI FUNC &KEY ARG PRIORITY)

WORK (W)

Private

Undocumented

GM-CLOSE (CONN)

GM-CONNECT (CONN)

HANDLE-JOB-ASSIGN (W MSG)

JOB-ASSIGN-MESSAGE-TO-JOB (MSG)

JOB-CREATED-MESSAGE-TO-JOB (MSG &KEY NAME ARG UID)

MESSAGE-NAME? (MSG N)

RUN-JOB (W J)

SELECT-SERVER (CLI UID)

TELL-JOB-FAIL (W J)

TELL-JOB-SUCCESS (W J DATA)

SLOT-ACCESSOR

Private

Undocumented

DATA (OBJECT)

GM-STREAM (OBJECT)

SETFGM-STREAM (NEW-VALUE OBJECT)

HOST (OBJECT)

MAGIC (OBJECT)

NAME (OBJECT)

PORT (OBJECT)

SOCKET (OBJECT)

SETFSOCKET (NEW-VALUE OBJECT)

STATUS (OBJECT)

VARIABLE

Public

Undocumented

*LOGGER-FORMATTER*

*LOGGER-LEVEL*

*LOGGER-OUTPUT*

Private

Undocumented

*UID-RANDOM-STATE*

+NAME-TABLE+

+REQUEST-MAGIC+

+RESPONSE-MAGIC+

CLASS

Public

Undocumented

CLIENT

WORKER

Private

Undocumented

CONNECTION

JOB

MESSAGE

CONDITION

Private

Undocumented

GEARMAN-CONNECTION-ERROR

CONSTANT

Private

Undocumented

+DEBUG+

+ERROR+

+FATAL+

+INFO+

+WARN+

ALL_YOURS

CAN_DO

CAN_DO_TIMEOUT

CANT_DO

ECHO_REQ

ECHO_RES

GET_STATUS

GRAB_JOB

GRAB_JOB_UNIQ

JOB_ASSIGN

JOB_ASSIGN_UNIQ

JOB_CREATED

NO_JOB

NOOP

OPTION_REQ

OPTION_RES

PRE_SLEEP

RESET_ABILITIES

SET_CLIENT_ID

STATUS_RES

SUBMIT_JOB

SUBMIT_JOB_BG

SUBMIT_JOB_EPOCH

SUBMIT_JOB_HIGH

SUBMIT_JOB_HIGH_BG

SUBMIT_JOB_LOW

SUBMIT_JOB_LOW_BG

SUBMIT_JOB_SCHED

WORK_COMPLETE

WORK_DATA

WORK_EXCEPTION

WORK_FAIL

WORK_STATUS

WORK_WARNING