ottla.postgresql — com.joshuadavey/ottla 0.3.2

brin-index-template clj

column-types clj

commit-modes clj

commit-offset! clj

(commit-offset! {:keys [conn schema]} {:keys [topic group]} cursor)

connect-config clj

(connect-config config)

create-topic clj

(create-topic {:keys [conn schema]}
              topic
              &
              {:keys [key-type value-type]
               :as opts
               :or {key-type :bytea value-type :bytea}})

default-subscription-group clj

delete-topic clj

(delete-topic {:keys [conn schema]} topic)

deserializer-xf clj

(deserializer-xf config topic {:keys [deserialize-key deserialize-value]})

ensure-schema clj

(ensure-schema {:keys [conn schema]})

ensure-subscription clj

(ensure-subscription {:keys [conn schema]} {:keys [topic group]})

fetch-records! clj

(fetch-records! config selection)

fetch-records* clj

(fetch-records* {:keys [conn schema] :as config}
                {:keys [topic group commit-mode] :as selection})

fetch-topic clj

(fetch-topic {:keys [conn schema]} topic-name)

insert-records clj

(insert-records {:keys [conn conn-map schema] :as cfg}
                topic
                records
                &
                {:keys [serialize-key serialize-value] :as opts})

legal-identifier? clj

(legal-identifier? s)

normalize-selection clj

(normalize-selection selection)

normalize-topic-name clj

(normalize-topic-name topic)

reset-offset! clj

(reset-offset! {:keys [conn schema]} {:keys [topic group]} cursor)

selection-defaults clj

sql-entity clj

(sql-entity x)

topic-subscriptions clj

(topic-subscriptions {:keys [conn schema]})

topic-table-name clj

(topic-table-name topic)

trigger-function-name clj

(trigger-function-name schema)

trigger-function-template clj

trigger-template clj