tech.queue.protocols — techascent/tech.queue 1.0

default-create-options clj

PResourceLimit clj protocol

resource-map clj

(resource-map this msg initial-resource-map)

Resources this task needs. Map may be empty, or may contain whatever resources are defined in the resource manager. Default resources would be (resource-limit/default-resource-map): {:num-cores (integer) :system-memory-MB (integer}

QueueProcessor clj protocol

msg->log-context clj

(msg->log-context this msg)

Given a message return a map of context that should be included with every log message

msg-ready? clj

(msg-ready? this msg)

Boolean as to whether the system is ready to process this message. Defaults to (constantly true)

process! clj

(process! this msg)

Process this message. Errors are captured and logged and the message will be retried until its ttl is up. This must return a map that contains: {:status - one of :error, :not-ready? :success :msg - an updated message. }

retire! clj

(retire! this msg last-attempt-result)

Return a message. If the last time the system attempted to process this message then the error returned is captured in last-exception. last-attempt-result: { :status - :not-ready? or :error :error - last error returned due to processing }

QueueProtocol clj protocol

complete! clj

(complete! this task options)

put! clj

(put! this msg options)

stats clj

(stats this options)

take! clj

(take! this options)

take should return the value :timeout if the receive has timed out. Else it should return the next task in the queue

task->msg clj

(task->msg this task)

QueueProvider clj protocol

delete-queue! clj

(delete-queue! this queue-name options)

get-or-create-queue! clj

(get-or-create-queue! this queue-name options)

url-parts->provider clj multimethod