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

create-table clj

(create-table config)

Creates the tables for the DurableQueue and all necessary indexes

DEFAULT-CONFIG clj

DEFAULT_LEASE_TIME clj

dyn-task-service clj

(dyn-task-service config)

DynamoTaskService clj

list-tasks* clj

(list-tasks* {:keys [creds tasks-table task-scan-index] :as cfg}
             {:keys [topic sub-topic status from to] :as filters}
             {:keys [inner-cursor limit next-period] :as cursor})

status-flags* clj

update-status! clj

(update-status! this
                task-id
                target-status
                pid
                {:keys [snooze-time error] :as opts})