jpe42

final Node node = Node.create("127.0.0.1", 6379);
final String channel = "jedipus";

final RedisClientFactory.Builder clientFactory = RedisClientFactory.startBuilding();

final ElementRetryDelay<Node> nodeRetryDelay =
    ElementRetryDelay.startBuilding().withMaxDelay(Duration.ofSeconds(30)).create();
    
final RedisClientExecutor clientExecutor = RedisClientExecutor.startBuilding()
    .withClientFactory(clientFactory)

jpe42

private static int runWithJedipus(final IntStream keys) {

  int count = 0; 

  try (final RedisClient client =
      RedisClientFactory.startBuilding().create(Node.create("127.0.0.1", 6379))) {

    client.sendCmd(Cmds.FLUSHALL);
    
    final long start = System.currentTimeMillis();

jpe42

Keybase proof

I hereby claim:

• I am jpe42 on github.
• I am jamespedwards42 (https://keybase.io/jamespedwards42) on keybase.
• I have a public key whose fingerprint is 6898 5D15 3F6F 6890 ADA1 F473 30CE 9FFF 6EDE 7CAF

To claim this, I am signing this object:

jpe42

// BITFIELD command taken from http://redis.io/commands/BITFIELD 

// BITFIELD mykey INCRBY i5 100 1 GET u4 0
final CmdByteArray<long[]> bitfieldCmd = CmdByteArray.startBuilding(Cmds.BITFIELD, 9)
  .addSlotKey("mykey")
  .addSubCmd(Cmds.BITFIELD_INCRBY, "i5", "100", "1")
  .addSubCmd(Cmds.BITFIELD_GET, "u4", "0").create();

try (final RedisClient client =
  RedisClientFactory.startBuilding().create(Node.create("localhost", 6379))) {

jpe42

final Map<Node, Node> nodeMappings = new HashMap<>(3);

nodeMappings.put(Node.create("internal1", 7001), Node.create("public1", 7001));
nodeMappings.put(Node.create("internal1", 7002), Node.create("public2", 7002));
nodeMappings.put(Node.create("internal1", 7003), Node.create("public3", 7003));

final Collection<Node> discoveryNodes = Collections.singleton(Node.create("public1", 7001));

// Static mapper, could easily be something dynamic as well.
final NodeMapper nodeMapper =