Function attachClient

server/modules/runtimeCache.js:276–303

()

    const resolvedEnvPrefix = runtimeRedisOverridesEnabled ? RUNTIME_REDIS_ENV_PREFIX : "CB_REDIS";
    let redisClient;
    const attachClient = () => {
      redisClient.on("error", (error) => {
        console.error("[runtime-cache] Redis client error", error); // oxlint-disable-line no-console
      });

      return {
        backend: clusterConfig?.cluster?.nodes?.length > 0 ? "redis-cluster" : "redis",
        envPrefix: resolvedEnvPrefix,
        get: (...args) => redisClient.get(...args),
        set: (key, value, ttlMs = 0) => {
          if (ttlMs > 0) {
            return redisClient.set(key, value, "PX", ttlMs);
          }
          return redisClient.set(key, value);
        },
        del: (...args) => redisClient.del(...args),
        hset: (...args) => redisClient.hset(...args),
        hget: (...args) => redisClient.hget(...args),
        hgetall: (...args) => redisClient.hgetall(...args),
        hdel: (...args) => redisClient.hdel(...args),
        zscore: (...args) => redisClient.zscore(...args),
        zincrby: (...args) => redisClient.zincrby(...args),
        zrevrange: (...args) => redisClient.zrevrange(...args),
        zrem: (...args) => redisClient.zrem(...args),
        zcard: (...args) => redisClient.zcard(...args),
        zremrangebyrank: (...args) => redisClient.zremrangebyrank(...args),
      };
    };

    const createMemoryStore = () => {
      const memoryStore = new InMemoryRuntimeStore();