Function streamLookupCG

src/t_stream.cpp:2291–2296

Lookup the consumer group in the specified stream and returns its * pointer, otherwise if there is no such group, NULL is returned. */

/* Lookup the consumer group in the specified stream and returns its
 * pointer, otherwise if there is no such group, NULL is returned. */
streamCG *streamLookupCG(stream *s, sds groupname) {
    if (s->cgroups == NULL) return NULL;
    streamCG *cg = (streamCG*)raxFind(s->cgroups,(unsigned char*)groupname,
                           sdslen(groupname));
    return (cg == raxNotFound) ? NULL : cg;
}

/* Lookup the consumer with the specified name in the group 'cg': if the
 * consumer does not exist it is created unless SLC_NOCREAT flag was specified.