Java 类redis.clients.jedis.JedisCluster.Reset 实例源码

项目：JRediClients 文件：JedisClusterTest.java

@Test
public void testReadonly() throws Exception {
  node1.clusterMeet(localHost, nodeInfoSlave2.getPort());
  JedisClusterTestUtil.waitForClusterReady(node1, node2, node3, nodeSlave2);

  for (String nodeInfo : node2.clusterNodes().split("\n")) {
    if (nodeInfo.contains("myself")) {
      nodeSlave2.clusterReplicate(nodeInfo.split(" ")[0]);
      break;
    }
  }
  try {
    nodeSlave2.get("test");
    fail();
  } catch (JedisMovedDataException e) {
  }
  nodeSlave2.readonly();
  nodeSlave2.get("test");

  nodeSlave2.clusterReset(Reset.SOFT);
  nodeSlave2.flushDB();
}

项目：cachecloud 文件：JedisClusterTest.java

@Test
public void testReadonly() throws Exception {
  node1.clusterMeet(localHost, nodeInfoSlave2.getPort());
  JedisClusterTestUtil.waitForClusterReady(node1, node2, node3, nodeSlave2);

  ClusterNodeInformationParser nodeInfoParser = new ClusterNodeInformationParser();
  for (String nodeInfo : node2.clusterNodes().split("\n")) {
    if (nodeInfo.contains("myself")) {
      nodeSlave2.clusterReplicate(nodeInfo.split(" ")[0]);
      break;
    }
  }
  try {
    nodeSlave2.get("test");
    fail();
  } catch (JedisMovedDataException e) {
  }
  nodeSlave2.readonly();
  nodeSlave2.get("test");

  nodeSlave2.clusterReset(Reset.SOFT);
  nodeSlave2.flushDB();
}

项目：Jedis 文件：JedisClusterTest.java

@Test
public void testReadonly() throws Exception {
  node1.clusterMeet(localHost, nodeInfoSlave2.getPort());
  JedisClusterTestUtil.waitForClusterReady(node1, node2, node3, nodeSlave2);

  ClusterNodeInformationParser nodeInfoParser = new ClusterNodeInformationParser();
  for (String nodeInfo : node2.clusterNodes().split("\n")) {
    if (nodeInfo.contains("myself")) {
      nodeSlave2.clusterReplicate(nodeInfo.split(" ")[0]);
      break;
    }
  }
  try {
    nodeSlave2.get("test");
    fail();
  } catch (JedisMovedDataException e) {
  }
  nodeSlave2.readonly();
  nodeSlave2.get("test");

  nodeSlave2.clusterReset(Reset.SOFT);
  nodeSlave2.flushDB();
}

项目：JRediClients 文件：Jedis.java

@Override
public String clusterReset(final Reset resetType) {
    checkIsInMultiOrPipeline();
    client.clusterReset(resetType);
    String reply = client.getStatusCodeReply();
    if (!"OK".equalsIgnoreCase(reply)) {
        logger.error("Send CLUSTER CLUSTER_RESET Command Error! reply={}" , reply);
    }
    return reply;
}

项目：JRediClients 文件：ClusterCommandsTest.java

@Test
public void testClusterSoftReset() {
  node1.clusterMeet("127.0.0.1", nodeInfo2.getPort());
  assertTrue(node1.clusterNodes().split("\n").length > 1);
  node1.clusterReset(Reset.SOFT);
  assertEquals(1, node1.clusterNodes().split("\n").length);
}

项目：JRediClients 文件：ClusterCommandsTest.java

@Test
public void testClusterHardReset() {
  String nodeId = JedisClusterTestUtil.getNodeId(node1.clusterNodes());
  node1.clusterReset(Reset.HARD);
  String newNodeId = JedisClusterTestUtil.getNodeId(node1.clusterNodes());
  assertNotEquals(nodeId, newNodeId);
}

项目：JRediClients 文件：JedisClusterTest.java

@AfterClass
public static void cleanUp() {
  node1.flushDB();
  node2.flushDB();
  node3.flushDB();
  node4.flushDB();
  node1.clusterReset(Reset.SOFT);
  node2.clusterReset(Reset.SOFT);
  node3.clusterReset(Reset.SOFT);
  node4.clusterReset(Reset.SOFT);
}

项目：java-redis-client 文件：TracingJedis.java

@Override
public String clusterReset(Reset resetType) {
  Span span = helper.buildSpan("clusterReset");
  span.setTag("resetType", resetType.name());
  try {
    return super.clusterReset(resetType);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}

项目：cachecloud 文件：ClusterCommandsTest.java

@Test
public void testClusterSoftReset() {
  node1.clusterMeet("127.0.0.1", nodeInfo2.getPort());
  assertTrue(node1.clusterNodes().split("\n").length > 1);
  node1.clusterReset(Reset.SOFT);
  assertEquals(1, node1.clusterNodes().split("\n").length);
}

项目：cachecloud 文件：ClusterCommandsTest.java

@Test
public void testClusterHardReset() {
  String nodeId = JedisClusterTestUtil.getNodeId(node1.clusterNodes());
  node1.clusterReset(Reset.HARD);
  String newNodeId = JedisClusterTestUtil.getNodeId(node1.clusterNodes());
  assertNotEquals(nodeId, newNodeId);
}

项目：cachecloud 文件：JedisClusterTest.java

@AfterClass
public static void cleanUp() {
  node1.flushDB();
  node2.flushDB();
  node3.flushDB();
  node4.flushDB();
  node1.clusterReset(Reset.SOFT);
  node2.clusterReset(Reset.SOFT);
  node3.clusterReset(Reset.SOFT);
  node4.clusterReset(Reset.SOFT);
}

项目：Jedis 文件：ClusterCommandsTest.java

@Test
public void testClusterSoftReset() {
  node1.clusterMeet("127.0.0.1", nodeInfo2.getPort());
  assertTrue(node1.clusterNodes().split("\n").length > 1);
  node1.clusterReset(Reset.SOFT);
  assertEquals(1, node1.clusterNodes().split("\n").length);
}

项目：Jedis 文件：ClusterCommandsTest.java

@Test
public void testClusterHardReset() {
  String nodeId = JedisClusterTestUtil.getNodeId(node1.clusterNodes());
  node1.clusterReset(Reset.HARD);
  String newNodeId = JedisClusterTestUtil.getNodeId(node1.clusterNodes());
  assertNotEquals(nodeId, newNodeId);
}

项目：Jedis 文件：JedisClusterTest.java

@AfterClass
public static void cleanUp() {
  node1.flushDB();
  node2.flushDB();
  node3.flushDB();
  node4.flushDB();
  node1.clusterReset(Reset.SOFT);
  node2.clusterReset(Reset.SOFT);
  node3.clusterReset(Reset.SOFT);
  node4.clusterReset(Reset.SOFT);
}

项目：JRediClients 文件：Client.java

public void clusterReset(Reset resetType) {
    cluster(Protocol.CLUSTER_RESET, resetType.toString());
}

项目：JRediClients 文件：ClusterCommandsTest.java

@AfterClass
public static void removeSlots() throws InterruptedException {
  node1.clusterReset(Reset.SOFT);
  node2.clusterReset(Reset.SOFT);
}

项目：x7 文件：Jedis.java

public String clusterReset(final Reset resetType) {
  checkIsInMultiOrPipeline();
  client.clusterReset(resetType);
  return client.getStatusCodeReply();
}

项目：x7 文件：Client.java

public void clusterReset(Reset resetType) {
  cluster(Protocol.CLUSTER_RESET, resetType.toString());
}

项目：leopard 文件：Jedis.java

@Override
public String clusterReset(Reset resetType) {

    return jedis.clusterReset(resetType);
}

项目：leopard 文件：JedisWrapper.java

@Override
public String clusterReset(Reset resetType) {

    return jedis.clusterReset(resetType);
}

项目：cachecloud 文件：Jedis.java

@Override
public String clusterReset(final Reset resetType) {
  checkIsInMultiOrPipeline();
  client.clusterReset(resetType);
  return client.getStatusCodeReply();
}

项目：cachecloud 文件：Client.java

public void clusterReset(Reset resetType) {
  cluster(Protocol.CLUSTER_RESET, resetType.toString());
}

项目：cachecloud 文件：ClusterCommandsTest.java

@AfterClass
public static void removeSlots() throws InterruptedException {
  node1.clusterReset(Reset.SOFT);
  node2.clusterReset(Reset.SOFT);
}

项目：Jedis 文件：Jedis.java

@Override
public String clusterReset(final Reset resetType) {
  checkIsInMultiOrPipeline();
  client.clusterReset(resetType);
  return client.getStatusCodeReply();
}

项目：Jedis 文件：Client.java

public void clusterReset(Reset resetType) {
  cluster(Protocol.CLUSTER_RESET, resetType.toString());
}

项目：Jedis 文件：ClusterCommandsTest.java

@AfterClass
public static void removeSlots() throws InterruptedException {
  node1.clusterReset(Reset.SOFT);
  node2.clusterReset(Reset.SOFT);
}

项目：leopard-data 文件：Jedis.java

@Override
public String clusterReset(Reset resetType) {

    return jedis.clusterReset(resetType);
}

项目：leopard-data 文件：JedisWrapper.java

@Override
public String clusterReset(Reset resetType) {

    return jedis.clusterReset(resetType);
}

项目：jedis-sr 文件：Jedis.java

public String clusterReset(final Reset resetType) {
    checkIsInMulti();
    client.clusterReset(resetType);
    return client.getStatusCodeReply();
}

项目：jedis-sr 文件：Client.java

public void clusterReset(Reset resetType) {
    cluster(Protocol.CLUSTER_RESET, resetType.toString());
}

项目：JRediClients 文件：ClusterCommands.java

String clusterReset(Reset resetType);

项目：x7 文件：ClusterCommands.java

String clusterReset(Reset resetType);

项目：cachecloud 文件：ClusterCommands.java

String clusterReset(Reset resetType);

项目：Jedis 文件：ClusterCommands.java

String clusterReset(Reset resetType);

项目：jedis-sr 文件：ClusterCommands.java

String clusterReset(Reset resetType);