verbo.sokka.task — net.clojars.sathyavijayan/sokka-core 0.0.1-SNAPSHOT

task-allowed-status-transitions clj

task-statuses clj

TaskService clj protocol

create-task! clj

(create-task! this task)

Creates a new task.

fail! clj

(fail! this task-id pid error)

terminate! clj

(terminate! this task-id pid)

task clj

(task this task-id)

Returns task for the specified task-id combination. Returns nil if task-id not found.

reserve-task! clj

(reserve-task! this topic pid)

Attempts to reserve the next available task. Tasks that are not owned by any process and whose lease expired are available to be reserved. Throws exceptions in the following scenarios: :no-task-found - No task available to be picked up.

snooze! clj

(snooze! this task-id pid snooze-time)

tasks clj

(tasks this task-group-id)

Returns tasks for the specified task-group-id

list-tasks clj

(list-tasks this
            topic
            {:keys [from to sub-topic] :as filters}
            {:keys [limit] :as cursor})

List all tasks

extend-lease! clj

(extend-lease! this task-id pid)

Attempts to extend lease of the specified task. :no-task-found - Task not found. :already-done - Task terminated. :wrong-owner - Attempted to extend lease of a task owned by another process. :lease-expired - Attempted to extend lease of a task whose lease already expired.