MCPcopy Create free account
hub / github.com/F-Stack/f-stack / createObjectFromStreamID

Function createObjectFromStreamID

app/redis-6.2.6/src/t_stream.c:1362–1365  ·  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

1360/* Similar to the above function, but just creates an object, usually useful
1361 * for replication purposes to create arguments. */
1362robj *createObjectFromStreamID(streamID *id) {
1363 return createObject(OBJ_STRING, sdscatfmt(sdsempty(),"%U-%U",
1364 id->ms,id->seq));
1365}
1366
1367/* As a result of an explicit XCLAIM or XREADGROUP command, new entries
1368 * 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