everest.pg.handler.store — sundbp/everest.pg 0.4.0-alpha4

delete! clj

(delete! db {:pg.handler/keys [id]})

get-all-states clj

(get-all-states db)

(get-all-states db handler-type)

Gets all of the #:handler{:position, :state, :id, :type} for the given handler-type or for all types if not specified.

get-state clj

(get-state db handler-id)

Gets the {:position, :state} map of the handler identified by the handler-id.

get-state* clj

(get-state* conn handler-id)

subscribe clj

(subscribe source db stream-id handler-id opts)

update! clj

(update! db {:pg.handler/keys [type id position state]})

upsert!* clj

(upsert!* conn handler-type handler-id new-position state)