Return the client object the `RM_Reply*` functions should target. * Normally this is just `ctx->client`, that is the client that called * the module

Compare entry pointer to by 'p' with 'sstr' of length 'slen'. */ Return 1 if equal. */

Copy constructor.

This function aborts a non blocking replication attempt if there is one * in progress, by canceling the non-blocking connect attempt or * the initia

Get last error code. */

/ Internal implementation. */

/ Internal implementation. */

Validate the integrity of a single listpack entry and move to the next one. * The input argument 'pp' is a reference to the current record and is adv

Release iterator. * If we still have a valid current node, then re-encode current node. */

Enlarge the free space at the end of the sds string so that the caller * is sure that after calling this function can overwrite up to addlen * bytes

Master lookup by name */

This is the reverse of streamEncodeID(): the decoded ID will be stored * in the 'id' structure passed by reference. The buffer 'buf' must point * to

Convert a string into a long. Returns 1 if the string could be parsed into a * (non-overflowing) long, 0 otherwise. The value will be set to the pars

* Compute usable size that would result from allocating an object with the * specified size and alignment. */

Unblock a client calling the right function depending on the kind * of operation the client is blocking for. */

Delete a single entry from the ziplist, pointed to by *p. * Also update *p in place, to be able to iterate over the * ziplist, while deleting entrie

Return the required encoding for the provided value. */

Concatenate a string representing the state of a client in a human * readable format, into the sds string 's'. */

Likewise: with ctl mutex synchronization, reading is simple. */

Return the number of elements in a hash. */

Disconnect a hiredis connection in the context of an instance link. */

Rewrite the command vector of the client. All the new objects ref count * is incremented. The old command vector is freed, and the old objects * ref

Return the size consumed from the allocator, for the specified SDS string, * including internal fragmentation. This function is used in order to comp

Split 's' with separator in 'sep'. An array * of sds strings is returned. *count will be set * by reference to the number of tokens returned. * *

This function uses the config rewriting Redis engine in order to persist * the state of the Sentinel in the current configuration file. * * Before

This function is used in order to send commands to Redis instances: the * commands we send from Sentinel may be renamed, a common case is a master *

Stop the stream iterator. The only cleanup we need is to free the rax * iterator, since the stream iterator itself is supposed to be stack * allocat

* Compute usable size that would result from allocating an object with the * specified size and alignment. */

Return ziplist blob size in bytes. */

A null array is a concept that no longer exists in RESP3. However * RESP2 had it, so API-wise we have this call, that will emit the correct * RESP2

Add the SDS 's' string to the client output buffer, as a side effect * the SDS string is freed. */

Emit a reply in the client output buffer by formatting a Stream ID * in the standard <ms>-<seq> format, using the simple string protocol * of REPL.

Register a write handler, to be called when the connection is writable. * If NULL, the existing handler is removed. */

Create an empty (zero length) hisds string. Even in this case the string * always has an implicit null term. */

Create a new hisds string starting from a null terminated C string. */

Remove all the elements from the list without destroying the list itself. */