/ size_t operations. */

Helper that calculates the bulk length given a certain string length. */

Send a message to all the nodes in the specified dictionary of nodes, that * are part of the cluster and have a connected link. * * It is guarantee

Force the receiver to acknowledge the job as delivered. */

Start an handshake with the specified address if there is not one * already in progress. Returns non-zero if the handshake was actually * started. O

Wrapper for configEnumGetName() returning "unknown" insetad of NULL if * there is no match. */

Create a string object with encoding OBJ_ENCODING_EMBSTR, that is * an object where the sds string is actually an unmodifiable string * allocated in

Deserialize a job serialized with serializeJob. Note that this only * deserializes the first job even if the input buffer contains multiple * jobs,

Expand or create the hash table */

Return the number of digits of 'v' when converted to string in radix 10. * See ll2string() for more information. */

Remove all the server state: jobs, queues, and everything else to start * like a fresh instance just rebooted. */

* This function represents a function used in the initialization * by init_by_array * @param x 32-bit integer * @return 32-bit integer */

This function returns the client peer id, by creating and caching it * if client->peerid is NULL, otherwise returning the cached value. * The Peer I

Return the mean of all the samples. */

Get a timeout value from an object and store it into 'timeout'. * The final timeout is always stored as milliseconds as a time where the * timeout w

This function is called when we detect the link with this node is lost. We set the node as no longer connected. The Cluster Cron will detect thi

/ API. */

Calculate the number of bytes needed to represent an integer as string. */

This function is used by the callback function registered by the user * in order to add completion options given the input string when the * user ty

Move cursor to the start of the line. */

Performs the operations needed to shutdown correctly the server, including * additional operations as specified by 'flags'. */

* Given a value p in [0..1] and Gamma distribution shape and scale parameters, * compute the upper limit on the definite integral from [0..z] that sa

Read a long long value starting at *s, under the assumption that it will be * terminated by \r\n. Ambiguously returns -1 for unexpected input. */

Rewrite the configuration file at "path". * If the configuration file already exists, we try at best to retain comments * and overall structure. *

Rewrite an enumeration option. It takes as usually state and option name, * and in addition the enumeration array and the default value for the * op

Write the long long 'bytes' value as a string in a way that is parsable * inside disque.conf. If possible uses the GB, MB, KB notation. */

Like sdscatprintf() but gets va_list instead of being variadic. */

Compare two sds strings s1 and s2 with memcmp(). * * Return value: * * positive if s1 > s2. * negative if s1 < s2. * 0 if s1 and s2

Compare two sds strings s1 and s2 with memcmp(). * * Return value: * * positive if s1 > s2. * negative if s1 < s2. * 0 if s1 and s2

Like sdscpylen() but 't' must be a null-termined string so that the length * of the string is obtained with strlen(). */

Remove the part of the string from left and from right composed just of * contiguous characters found in 'cset', that is a null terminted C string.

We use the server.jobs hash table in a space efficient way by storing the * job only at 'key' pointer, so the 'value' pointer is free to be used * f

Create a new skip list with the specified function used in order to * compare elements. The function return value is the same as strcmp(). */

If the skip list is empty, NULL is returned, otherwise the element * at head is removed and its pointed object returned. */

Add a sample to the operations per second array of samples. */

Try to garbage collect the job. */

Schedule a SIGALRM delivery after the specified period in milliseconds. * If a timer is already scheduled, this function will re-schedule it to the

Emit a DELJOB command into the AOF. This function is called in the following * two cases: * * 1) As a side effect of the job being acknowledged, wh

Helper function for the redisAsyncCommand* family of functions. Writes a * formatted command to the output buffer and registers the provided callback