| 184 | } |
| 185 | |
| 186 | void persistenceCallback(RedisModuleCtx *ctx, RedisModuleEvent e, uint64_t sub, void *data) |
| 187 | { |
| 188 | REDISMODULE_NOT_USED(e); |
| 189 | REDISMODULE_NOT_USED(data); |
| 190 | |
| 191 | char *keyname = NULL; |
| 192 | switch (sub) { |
| 193 | case REDISMODULE_SUBEVENT_PERSISTENCE_RDB_START: keyname = "persistence-rdb-start"; break; |
| 194 | case REDISMODULE_SUBEVENT_PERSISTENCE_AOF_START: keyname = "persistence-aof-start"; break; |
| 195 | case REDISMODULE_SUBEVENT_PERSISTENCE_SYNC_RDB_START: keyname = "persistence-syncrdb-start"; break; |
| 196 | case REDISMODULE_SUBEVENT_PERSISTENCE_ENDED: keyname = "persistence-end"; break; |
| 197 | case REDISMODULE_SUBEVENT_PERSISTENCE_FAILED: keyname = "persistence-failed"; break; |
| 198 | } |
| 199 | /* modifying the keyspace from the fork child is not an option, using log instead */ |
| 200 | RedisModule_Log(ctx, "warning", "module-event-%s", keyname); |
| 201 | if (sub == REDISMODULE_SUBEVENT_PERSISTENCE_SYNC_RDB_START) |
| 202 | LogNumericEvent(ctx, keyname, 0); |
| 203 | } |
| 204 | |
| 205 | void loadingCallback(RedisModuleCtx *ctx, RedisModuleEvent e, uint64_t sub, void *data) |
| 206 | { |
nothing calls this directly
no test coverage detected