diff options
author | guybe7 <guy.benoish@redislabs.com> | 2022-04-17 14:43:22 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-04-17 15:43:22 +0300 |
commit | f49ff156ecd62aee104cff9f88fb62948575e6b0 (patch) | |
tree | d7c5b09264550a2c5f17177b59182788318b24ec /src/cluster.h | |
parent | 789c94feceb7cb0b618dcb912c0151625d913887 (diff) | |
download | redis-f49ff156ecd62aee104cff9f88fb62948575e6b0.tar.gz |
Add RM_PublishMessageShard (#10543)
since PUBLISH and SPUBLISH use different dictionaries for channels and clients,
and we already have an API for PUBLISH, it only makes sense to have one for SPUBLISH
Add test coverage and unifying some test infrastructure.
Diffstat (limited to 'src/cluster.h')
-rw-r--r-- | src/cluster.h | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/cluster.h b/src/cluster.h index 90b775ca2..1349a7a92 100644 --- a/src/cluster.h +++ b/src/cluster.h @@ -384,8 +384,7 @@ void migrateCloseTimedoutSockets(void); int verifyClusterConfigWithData(void); unsigned long getClusterConnectionsCount(void); int clusterSendModuleMessageToTarget(const char *target, uint64_t module_id, uint8_t type, const char *payload, uint32_t len); -void clusterPropagatePublish(robj *channel, robj *message); -void clusterPropagatePublishShard(robj *channel, robj *message); +void clusterPropagatePublish(robj *channel, robj *message, int sharded); unsigned int keyHashSlot(char *key, int keylen); void slotToKeyAddEntry(dictEntry *entry, redisDb *db); void slotToKeyDelEntry(dictEntry *entry, redisDb *db); |