verbo.sokka.task
Protocols and constants to implement a task queue.
Protocols and constants to implement a task queue.
LeaseSupervisioncljprotocol
Protocol for backends (usually stores that dont support db level locks) that require special supervision of leased tasks to prevent issues caused by clock skew.
Protocol for backends (usually stores that dont support db level locks) that require special supervision of leased tasks to prevent issues caused by clock skew.
list-leased-tasksclj
(list-leased-tasks this topic cursor)List all running / snoozed tasks
List all running / snoozed tasks
task-allowed-status-transitionsclj
List of possible task statuses mapped to statuses they can transition to
List of possible task statuses mapped to statuses they can transition to
task-statusesclj
List of possible statuses for a task
List of possible statuses for a task
TaskStorecljprotocol
Protocol for a task store with functions to manage the life-cycle of
a task.
Protocol for a task store with functions to manage the life-cycle of a `task`.
create-task!clj
(create-task! this task)Create and returns a new task.
Create and returns a new task.
fail!clj
(fail! this task-id pid error)Updates the status of the task to :failed. An optional
error-message can be passed.
Updates the status of the task to `:failed`. An optional error-message can be passed.
terminate!clj
(terminate! this task-id pid)Updates the status to :terminated. This means the task has been
executed successfully.
Updates the status to `:terminated`. This means the task has been executed successfully.
taskclj
(task this task-id)Get task by task-id. Returns nil when no task is found.
Get task by `task-id`. Returns nil when no task is found.
revoke-lease!clj
(revoke-lease! this task-id record-ver)Forcefully revoke the lease held for the specified task-id. The
record-ver from the last time the task was read must be
supplied. This is used to implement MVCC to ensure that the task
wasn't updated by another process concurrently.
Forcefully revoke the lease held for the specified `task-id`. The `record-ver` from the last time the task was read must be supplied. This is used to implement MVCC to ensure that the task wasn't updated by another process concurrently.
reserve-task!clj
(reserve-task! this topic pid)Attempts to reserve the next available task for execution by obtaining a lease for configured amount of time (implementation specific). Returns nil when there is no task is available for reservation.
Attempts to reserve the next available task for execution by obtaining a lease for configured amount of time (implementation specific). Returns nil when there is no task is available for reservation.
snooze!clj
(snooze! this task-id pid snooze-time)Temporarily pause the task for snooze-time
milliseconds. Updates the status to :snoozed.
Temporarily pause the task for `snooze-time` milliseconds. Updates the status to `:snoozed`.
tasksclj
(tasks this task-group-id)Get tasks for a given task-group-id. Returns nil when no tasks
are found for the supplied input.
Get tasks for a given `task-group-id`. Returns nil when no tasks are found for the supplied input.
list-tasksclj
(list-tasks this
{:keys [from to sub-topic] :as filters}
{:keys [limit] :as cursor})List all tasks
List all tasks
extend-lease!clj
(extend-lease! this task-id pid)Attempts to extend lease of the specified task. Throws the following exceptions: :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.
Attempts to extend lease of the specified task. Throws the following exceptions: :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.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close