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

Function createObjectFromStreamID

src/t_stream.cpp:1360–1363  ·  view source on GitHub ↗

Similar to the above function, but just creates an object, usually useful * for replication purposes to create arguments. */

Source from the content-addressed store, hash-verified

1358/* Similar to the above function, but just creates an object, usually useful
1359 * for replication purposes to create arguments. */
1360robj *createObjectFromStreamID(streamID *id) {
1361 return createObject(OBJ_STRING, sdscatfmt(sdsempty(),"%U-%U",
1362 id->ms,id->seq));
1363}
1364
1365/* As a result of an explicit XCLAIM or XREADGROUP command, new entries
1366 * are created in the pending list of the stream and consumers. We need

Callers 7

streamPropagateXCLAIMFunction · 0.85
streamPropagateGroupIDFunction · 0.85
streamReplyWithRangeFunction · 0.85
xaddCommandFunction · 0.85
xautoclaimCommandFunction · 0.85

Calls 3

createObjectFunction · 0.85
sdscatfmtFunction · 0.85
sdsemptyFunction · 0.85

Tested by

no test coverage detected