MCPcopy Create free account
hub / github.com/Snapchat/KeyDB / clusterPropagatePublish

Function clusterPropagatePublish

src/cluster.cpp:2896–2898  ·  view source on GitHub ↗

----------------------------------------------------------------------------- * CLUSTER Pub/Sub support * * For now we do very little, just propagating PUBLISH messages across the whole * cluster. In the future we'll try to get smarter and avoiding propagating those * messages to hosts without receives for a given channel. * -------------------------------------------------------------------

Source from the content-addressed store, hash-verified

2894 * messages to hosts without receives for a given channel.
2895 * -------------------------------------------------------------------------- */
2896void clusterPropagatePublish(robj *channel, robj *message) {
2897 clusterSendPublish(NULL, channel, message);
2898}
2899
2900/* -----------------------------------------------------------------------------
2901 * SLAVE node specific functions

Callers 2

publishCommandFunction · 0.85
RM_PublishMessageFunction · 0.85

Calls 1

clusterSendPublishFunction · 0.85

Tested by

no test coverage detected