@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(); }
@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(); }
@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; }
@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); }
@Test public void testClusterHardReset() { String nodeId = JedisClusterTestUtil.getNodeId(node1.clusterNodes()); node1.clusterReset(Reset.HARD); String newNodeId = JedisClusterTestUtil.getNodeId(node1.clusterNodes()); assertNotEquals(nodeId, newNodeId); }
@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); }
@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(); } }
public void clusterReset(Reset resetType) { cluster(Protocol.CLUSTER_RESET, resetType.toString()); }
@AfterClass public static void removeSlots() throws InterruptedException { node1.clusterReset(Reset.SOFT); node2.clusterReset(Reset.SOFT); }
public String clusterReset(final Reset resetType) { checkIsInMultiOrPipeline(); client.clusterReset(resetType); return client.getStatusCodeReply(); }
@Override public String clusterReset(Reset resetType) { return jedis.clusterReset(resetType); }
@Override public String clusterReset(final Reset resetType) { checkIsInMultiOrPipeline(); client.clusterReset(resetType); return client.getStatusCodeReply(); }
public String clusterReset(final Reset resetType) { checkIsInMulti(); client.clusterReset(resetType); return client.getStatusCodeReply(); }
String clusterReset(Reset resetType);