ottla.postgresql — com.joshuadavey/ottla 0.1.1

brin-index-template clj

column-types clj

commit-cursor! clj

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

commit-modes clj

connect-config clj

(connect-config config)

create-topic clj

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

default-subscription-group clj

delete-topic clj

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

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]
                 :or {serialize-key identity serialize-value identity}
                 :as opts})

normalize-selection clj

(normalize-selection selection)

normalize-topic-name clj

(normalize-topic-name topic)

selection-defaults clj

sql-entity clj

(sql-entity x)

topic-table-name clj

(topic-table-name topic)

trigger-function-name clj

(trigger-function-name schema)

trigger-function-template clj

trigger-template clj