Searched refs:streamPropagateGroupID (Results 1 – 2 of 2) sorted by relevance
837 void streamPropagateGroupID(client *c, robj *key, streamCG *group, robj *groupname) { in streamPropagateGroupID() function989 streamPropagateGroupID(c,spi->keyname,group,spi->groupname); in streamReplyWithRange()2305 streamPropagateGroupID(c,c->argv[1],group,c->argv[2]); in xclaimCommand()
1075 Streams: use propagate_last_id itself as streamPropagateGroupID trigger.