replikativ.core

Replication related pub-sub protocols.

commit-pub

(commit-pub S cold-store mem-store [user crdt-id] pub)

publish-in

(publish-in peer pub-ch bus-in out)
Synchronize downstream publications.

subscribe-in

(subscribe-in peer sub-ch out)
Adjust publication stream and propagate subscription requests.

subscribe-out

(subscribe-out S remote-pn remote-subs sub-out-ch out extend?)

wire

(wire [S peer [in out]])
Wire a peer to an output (response) channel and a publication by :type of the input.