dais.postgres.streaming — infihis/dais 0.3.1

logical-decoding->value-streams clj

make-kv-pair clj

(make-kv-pair k v t)

start-data-stream clj

(start-data-stream streaming-proc {:keys [streaming-buffer] :as conf})

start-streaming-proc clj

(start-streaming-proc {:keys [host port database username password
                              recvlogical-exec replication-slot]
                       :as conf})

stop-data-stream clj

(stop-data-stream data-stream)

stop-streaming-proc clj

(stop-streaming-proc streaming-proc)