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

create-table clj

(create-table config)

Creates the tables for the DurableQueue and all necessary indexes

ddb-rec->m clj

(ddb-rec->m r)

converts form a dynamo record representation to a clojure map

DEFAULT-CONFIG clj

DEFAULT_LEASE_TIME clj

dyn-taskq clj

(dyn-taskq config)

DynamoTaskQ clj

DynamoTaskQWrapper clj

list-tasks* clj

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

m->ddb-rec clj

(m->ddb-rec r)

converts form a Clojure map to a dynamo record representation

status-flags* clj