Function initRedisClient

packages/socket.io-redis-streams-emitter/test/util.ts:30–100

()

console.log(`[INFO] testing in ${mode} mode with ${lib}`);

export async function initRedisClient() {
  if (mode === "cluster") {
    if (lib === "ioredis") {
      return new Cluster([
        {
          host: "localhost",
          port: 7000,
        },
        {
          host: "localhost",
          port: 7001,
        },
        {
          host: "localhost",
          port: 7002,
        },
        {
          host: "localhost",
          port: 7003,
        },
        {
          host: "localhost",
          port: 7004,
        },
        {
          host: "localhost",
          port: 7005,
        },
      ]);
    } else {
      const redisClient = createCluster({
        rootNodes: [
          {
            url: "redis://localhost:7000",
          },
          {
            url: "redis://localhost:7001",
          },
          {
            url: "redis://localhost:7002",
          },
          {
            url: "redis://localhost:7003",
          },
          {
            url: "redis://localhost:7004",
          },
          {
            url: "redis://localhost:7005",
          },
        ],
      });

      await redisClient.connect();

      return redisClient;
    }
  } else {