MCPcopy Create free account
hub / github.com/acl-dev/acl / xrevrange

Function xrevrange

lib_acl_cpp/samples/redis/redis_stream/redis_stream.cpp:360–380  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

358}
359
360static void xrevrange(acl::redis_stream& redis, size_t count)
361{
362 acl::redis_stream_messages messages;
363
364 if (redis.xrevrange(messages, __key, "+", "-", count) == false) {
365 printf("xrevrange error=%s, key=%lu\r\n",
366 redis.result_error(), (unsigned long) count);
367 return;
368 }
369
370 printf("xrevrange ok, key=%s\r\n", __key.c_str());
371
372 const acl::string* req = redis.request_buf();
373 printf("request=[%s]\r\n", req ? req->c_str() : "NULL");
374
375 if (messages.empty()) {
376 printf("no messages\r\n");
377 } else {
378 show_messages(messages);
379 }
380}
381
382static void show_pending_consumer(const acl::redis_pending_consumer& consumer)
383{

Callers 1

mainFunction · 0.85

Calls 5

show_messagesFunction · 0.85
xrevrangeMethod · 0.80
result_errorMethod · 0.80
c_strMethod · 0.45
emptyMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…