116 struct RedisModuleCtx {  struct
136 typedef struct RedisModuleCtx RedisModuleCtx;  typedef
149     RedisModuleCtx *ctx;
177 typedef int (*RedisModuleCmdFunc) (RedisModuleCtx *ctx, void **argv, int argc);
178 typedef void (*RedisModuleDisconnectFunc) (RedisModuleCtx *ctx, struct RedisModuleBlockedClient *bc…
197     RedisModuleCtx *ctx;
222     void (*free_privdata)(RedisModuleCtx*,void*);/* privdata cleanup callback.*/
240 typedef int (*RedisModuleNotificationFunc) (RedisModuleCtx *ctx, int type, const char *event, Redis…
300 void autoMemoryCollect(RedisModuleCtx *ctx);
302 void moduleReplicateMultiIfNeeded(RedisModuleCtx *ctx);
305 void RM_FreeDict(RedisModuleCtx *ctx, RedisModuleDict *d);
349 void poolAllocRelease(RedisModuleCtx *ctx) {  in poolAllocRelease()
372 void *RM_PoolAlloc(RedisModuleCtx *ctx, size_t bytes) {  in RM_PoolAlloc()
500 void moduleFreeContext(RedisModuleCtx *ctx) {  in moduleFreeContext()
518 void moduleHandlePropagationAfterCommandCallback(RedisModuleCtx *ctx) {  in moduleHandlePropagationAfterCommandCallback()
538     RedisModuleCtx ctx = REDISMODULE_CTX_INIT;  in RedisModuleCommandDispatcher()
574     RedisModuleCtx ctx = REDISMODULE_CTX_INIT;  in moduleGetCommandKeysViaAPI()
589 int RM_IsKeysPositionRequest(RedisModuleCtx *ctx) {  in RM_IsKeysPositionRequest()
607 void RM_KeyAtPos(RedisModuleCtx *ctx, int pos) {  in RM_KeyAtPos()
697 int RM_CreateCommand(RedisModuleCtx *ctx, const char *name, RedisModuleCmdFunc cmdfunc, const char …  in RM_CreateCommand()
743 void RM_SetModuleAttribs(RedisModuleCtx *ctx, const char *name, int ver, int apiver) {  in RM_SetModuleAttribs()
781 void RM_AutoMemory(RedisModuleCtx *ctx) {  in RM_AutoMemory()
786 void autoMemoryAdd(RedisModuleCtx *ctx, int type, void *ptr) {  in autoMemoryAdd()
803 int autoMemoryFreed(RedisModuleCtx *ctx, int type, void *ptr) {  in autoMemoryFreed()
834 void autoMemoryCollect(RedisModuleCtx *ctx) {  in autoMemoryCollect()
871 RedisModuleString *RM_CreateString(RedisModuleCtx *ctx, const char *ptr, size_t len) {  in RM_CreateString()
885 RedisModuleString *RM_CreateStringPrintf(RedisModuleCtx *ctx, const char *fmt, ...) {  in RM_CreateStringPrintf()
908 RedisModuleString *RM_CreateStringFromLongLong(RedisModuleCtx *ctx, long long ll) {  in RM_CreateStringFromLongLong()
922 RedisModuleString *RM_CreateStringFromString(RedisModuleCtx *ctx, const RedisModuleString *str) {  in RM_CreateStringFromString()
940 void RM_FreeString(RedisModuleCtx *ctx, RedisModuleString *str) {  in RM_FreeString()
969 void RM_RetainString(RedisModuleCtx *ctx, RedisModuleString *str) {  in RM_RetainString()
1051 int RM_StringAppendBuffer(RedisModuleCtx *ctx, RedisModuleString *str, const char *buf, size_t len)…  in RM_StringAppendBuffer()
1076 int RM_WrongArity(RedisModuleCtx *ctx) {  in RM_WrongArity()
1097 client *moduleGetReplyClient(RedisModuleCtx *ctx) {  in moduleGetReplyClient()
1114 int RM_ReplyWithLongLong(RedisModuleCtx *ctx, long long ll) {  in RM_ReplyWithLongLong()
1124 int replyWithStatus(RedisModuleCtx *ctx, const char *msg, char *prefix) {  in replyWithStatus()
1148 int RM_ReplyWithError(RedisModuleCtx *ctx, const char *err) {  in RM_ReplyWithError()
1157 int RM_ReplyWithSimpleString(RedisModuleCtx *ctx, const char *msg) {  in RM_ReplyWithSimpleString()
1172 int RM_ReplyWithArray(RedisModuleCtx *ctx, long len) {  in RM_ReplyWithArray()
1213 void RM_ReplySetArrayLength(RedisModuleCtx *ctx, long len) {  in RM_ReplySetArrayLength()
1237 int RM_ReplyWithStringBuffer(RedisModuleCtx *ctx, const char *buf, size_t len) {  in RM_ReplyWithStringBuffer()
1247 int RM_ReplyWithString(RedisModuleCtx *ctx, RedisModuleString *str) {  in RM_ReplyWithString()
1258 int RM_ReplyWithNull(RedisModuleCtx *ctx) {  in RM_ReplyWithNull()
1271 int RM_ReplyWithCallReply(RedisModuleCtx *ctx, RedisModuleCallReply *reply) {  in RM_ReplyWithCallReply()
1285 int RM_ReplyWithDouble(RedisModuleCtx *ctx, double d) {  in RM_ReplyWithDouble()
1299 void moduleReplicateMultiIfNeeded(RedisModuleCtx *ctx) {  in moduleReplicateMultiIfNeeded()
1332 int RM_Replicate(RedisModuleCtx *ctx, const char *cmdname, const char *fmt, ...) {  in RM_Replicate()
1370 int RM_ReplicateVerbatim(RedisModuleCtx *ctx) {  in RM_ReplicateVerbatim()
1393 unsigned long long RM_GetClientId(RedisModuleCtx *ctx) {  in RM_GetClientId()
1399 int RM_GetSelectedDb(RedisModuleCtx *ctx) {  in RM_GetSelectedDb()
1440 int RM_GetContextFlags(RedisModuleCtx *ctx) {  in RM_GetContextFlags()
1499 int RM_SelectDb(RedisModuleCtx *ctx, int newid) {  in RM_SelectDb()
1518 void *RM_OpenKey(RedisModuleCtx *ctx, robj *keyname, int mode) {  in RM_OpenKey()
2453 RedisModuleCallReply *moduleCreateCallReplyFromProto(RedisModuleCtx *ctx, sds proto) {  in moduleCreateCallReplyFromProto()
2591     RedisModuleCtx *ctx = reply->ctx;  in RM_FreeCallReply()
2740 RedisModuleCallReply *RM_Call(RedisModuleCtx *ctx, const char *cmdname, const char *fmt, ...) {  in RM_Call()
3049 moduleType *RM_CreateDataType(RedisModuleCtx *ctx, const char *name, int encver, void *typemethods_…  in RM_CreateDataType()
3461 RedisModuleCtx *RM_GetContextFromIO(RedisModuleIO *io) {  in RM_GetContextFromIO()
3463     RedisModuleCtx ctxtemplate = REDISMODULE_CTX_INIT;  in RM_GetContextFromIO()
3464     io->ctx = zmalloc(sizeof(RedisModuleCtx));  in RM_GetContextFromIO()
3521 void RM_Log(RedisModuleCtx *ctx, const char *levelstr, const char *fmt, ...) {  in RM_Log()
3574         RedisModuleCtx ctx = REDISMODULE_CTX_INIT;  in unblockClientFromModule()
3606 …BlockClient(RedisModuleCtx *ctx, RedisModuleCmdFunc reply_callback, RedisModuleCmdFunc timeout_cal…  in RM_BlockClient()  argument
3721             RedisModuleCtx ctx = REDISMODULE_CTX_INIT;  in moduleHandleBlockedClients()
3734             RedisModuleCtx ctx = REDISMODULE_CTX_INIT;  in moduleHandleBlockedClients()
3785     RedisModuleCtx ctx = REDISMODULE_CTX_INIT;  in moduleBlockedClientTimedOut()
3800 int RM_IsBlockedReplyRequest(RedisModuleCtx *ctx) {  in RM_IsBlockedReplyRequest()
3806 int RM_IsBlockedTimeoutRequest(RedisModuleCtx *ctx) {  in RM_IsBlockedTimeoutRequest()
3811 void *RM_GetBlockedClientPrivateData(RedisModuleCtx *ctx) {  in RM_GetBlockedClientPrivateData()
3819 RedisModuleBlockedClient *RM_GetBlockedClientHandle(RedisModuleCtx *ctx) {  in RM_GetBlockedClientHandle()
3826 int RM_BlockedClientDisconnected(RedisModuleCtx *ctx) {  in RM_BlockedClientDisconnected()
3853 RedisModuleCtx *RM_GetThreadSafeContext(RedisModuleBlockedClient *bc) {  in RM_GetThreadSafeContext()
3854     RedisModuleCtx *ctx = zmalloc(sizeof(*ctx));  in RM_GetThreadSafeContext()
3855     RedisModuleCtx empty = REDISMODULE_CTX_INIT;  in RM_GetThreadSafeContext()
3875 void RM_FreeThreadSafeContext(RedisModuleCtx *ctx) {  in RM_FreeThreadSafeContext()
3883 void RM_ThreadSafeContextLock(RedisModuleCtx *ctx) {  in RM_ThreadSafeContextLock()
3889 void RM_ThreadSafeContextUnlock(RedisModuleCtx *ctx) {  in RM_ThreadSafeContextUnlock()
3956 int RM_SubscribeToKeyspaceEvents(RedisModuleCtx *ctx, int types, RedisModuleNotificationFunc callba…  in RM_SubscribeToKeyspaceEvents()
3986             RedisModuleCtx ctx = REDISMODULE_CTX_INIT;  in moduleNotifyKeyspaceEvent()
4021 typedef void (*RedisModuleClusterMessageReceiver)(RedisModuleCtx *ctx, const char *sender_id, uint8…
4049             RedisModuleCtx ctx = REDISMODULE_CTX_INIT;  in moduleCallClusterReceivers()
4066 void RM_RegisterClusterMessageReceiver(RedisModuleCtx *ctx, uint8_t type, RedisModuleClusterMessage…  in RM_RegisterClusterMessageReceiver()
4110 int RM_SendClusterMessage(RedisModuleCtx *ctx, char *target_id, uint8_t type, unsigned char *msg, u…  in RM_SendClusterMessage()
4141 char **RM_GetClusterNodesList(RedisModuleCtx *ctx, size_t *numnodes) {  in RM_GetClusterNodesList()
4209 int RM_GetClusterNodeInfo(RedisModuleCtx *ctx, const char *id, char *ip, char *master_id, int *port…  in RM_GetClusterNodeInfo()
4261 void RM_SetClusterFlags(RedisModuleCtx *ctx, uint64_t flags) {  in RM_SetClusterFlags()
4291 typedef void (*RedisModuleTimerProc)(RedisModuleCtx *ctx, void *data);
4321             RedisModuleCtx ctx = REDISMODULE_CTX_INIT;  in moduleTimerHandler()
4345 RedisModuleTimerID RM_CreateTimer(RedisModuleCtx *ctx, mstime_t period, RedisModuleTimerProc callba…  in RM_CreateTimer()
4393 int RM_StopTimer(RedisModuleCtx *ctx, RedisModuleTimerID id, void **data) {  in RM_StopTimer()
4409 int RM_GetTimerInfo(RedisModuleCtx *ctx, RedisModuleTimerID id, uint64_t *remaining, void **data) {  in RM_GetTimerInfo()
4443 RedisModuleDict *RM_CreateDict(RedisModuleCtx *ctx) {  in RM_CreateDict()
4453 void RM_FreeDict(RedisModuleCtx *ctx, RedisModuleDict *d) {  in RM_FreeDict()
4630 RedisModuleString *RM_DictNext(RedisModuleCtx *ctx, RedisModuleDictIter *di, void **dataptr) {  in RM_DictNext()
4640 RedisModuleString *RM_DictPrev(RedisModuleCtx *ctx, RedisModuleDictIter *di, void **dataptr) {  in RM_DictPrev()
4708 int RM_ExportSharedAPI(RedisModuleCtx *ctx, const char *apiname, void *func) {  in RM_ExportSharedAPI()
4752 void *RM_GetSharedAPI(RedisModuleCtx *ctx, const char *apiname) {  in RM_GetSharedAPI()
4885 RedisModuleCommandFilter *RM_RegisterCommandFilter(RedisModuleCtx *ctx, RedisModuleCommandFilterFun…  in RM_RegisterCommandFilter()
4898 int RM_UnregisterCommandFilter(RedisModuleCtx *ctx, RedisModuleCommandFilter *filter) {  in RM_UnregisterCommandFilter()
5144     RedisModuleCtx ctx = REDISMODULE_CTX_INIT;  in moduleLoad()