Java 类org.apache.hadoop.hbase.util.ChaosMonkey.RestartRandomRs 实例源码

@Before
public void setUp() throws Exception {
  super.setUp(SERVER_COUNT);
  ChaosMonkey.Action[] actions = new ChaosMonkey.Action[] {
      new RestartRandomRs(60000),
      new BatchRestartRs(5000, 0.5f),
      new RestartActiveMaster(5000),
      new RollingBatchRestartRs(5000, 1.0f),
      new RestartRsHoldingMeta(35000),
      new RestartRsHoldingRoot(35000)
  };
  monkey = new ChaosMonkey(util, new ChaosMonkey.CompositeSequentialPolicy(
          new ChaosMonkey.DoActionsOncePolicy(CHAOS_EVERY_MS, actions),
          new ChaosMonkey.PeriodicRandomActionPolicy(CHAOS_EVERY_MS, actions)));
  monkey.start();
}

@Before
public void setUp() throws Exception {
  super.setUp(SERVER_COUNT);
  ChaosMonkey.Action[] actions = new ChaosMonkey.Action[] {
      new RestartRandomRs(60000),
      new BatchRestartRs(5000, 0.5f),
      new RestartActiveMaster(5000),
      new RollingBatchRestartRs(5000, 1.0f),
      new RestartRsHoldingMeta(35000),
      new RestartRsHoldingRoot(35000)
  };
  monkey = new ChaosMonkey(util, new ChaosMonkey.CompositeSequentialPolicy(
          new ChaosMonkey.DoActionsOncePolicy(CHAOS_EVERY_MS, actions),
          new ChaosMonkey.PeriodicRandomActionPolicy(CHAOS_EVERY_MS, actions)));
  monkey.start();
}

@Before
public void setUp() throws Exception {
  super.setUp(SERVER_COUNT);
  ChaosMonkey.Action[] actions = new ChaosMonkey.Action[] {
      new RestartRandomRs(60000),
      new BatchRestartRs(5000, 0.5f),
      new RestartActiveMaster(5000),
      new RollingBatchRestartRs(5000, 1.0f),
      new RestartRsHoldingMeta(35000),
      new RestartRsHoldingRoot(35000)
  };
  monkey = new ChaosMonkey(util, new ChaosMonkey.CompositeSequentialPolicy(
          new ChaosMonkey.DoActionsOncePolicy(CHAOS_EVERY_MS, actions),
          new ChaosMonkey.PeriodicRandomActionPolicy(CHAOS_EVERY_MS, actions)));
  monkey.start();
}

@Before
public void setUp() throws Exception {
  super.setUp(SERVER_COUNT);
  ChaosMonkey.Action[] actions = new ChaosMonkey.Action[] {
      new RestartRandomRs(60000),
      new BatchRestartRs(5000, 0.5f),
      new RestartActiveMaster(5000),
      new RollingBatchRestartRs(5000, 1.0f),
      new RestartRsHoldingMeta(35000),
      new RestartRsHoldingRoot(35000)
  };
  monkey = new ChaosMonkey(util, new ChaosMonkey.CompositeSequentialPolicy(
          new ChaosMonkey.DoActionsOncePolicy(CHAOS_EVERY_MS, actions),
          new ChaosMonkey.PeriodicRandomActionPolicy(CHAOS_EVERY_MS, actions)));
  monkey.start();
}

@Before
public void setUp() throws Exception {
  super.setUp(SERVER_COUNT);
  ChaosMonkey.Action[] actions = new ChaosMonkey.Action[] {
      new RestartRandomRs(60000),
      new BatchRestartRs(5000, 0.5f),
      new RestartActiveMaster(5000),
      new RollingBatchRestartRs(5000, 1.0f),
      new RestartRsHoldingMeta(35000),
      new RestartRsHoldingRoot(35000)
  };
  monkey = new ChaosMonkey(util, new ChaosMonkey.CompositeSequentialPolicy(
          new ChaosMonkey.DoActionsOncePolicy(CHAOS_EVERY_MS, actions),
          new ChaosMonkey.PeriodicRandomActionPolicy(CHAOS_EVERY_MS, actions)));
  monkey.start();
}

@Before
public void setUp() throws Exception {
  super.setUp(SERVER_COUNT);
  ChaosMonkey.Action[] actions = new ChaosMonkey.Action[] {
      new RestartRandomRs(60000),
      new BatchRestartRs(5000, 0.5f),
      new RestartActiveMaster(5000),
      new RollingBatchRestartRs(5000, 1.0f),
      new RestartRsHoldingMeta(35000),
      new RestartRsHoldingRoot(35000)
  };
  monkey = new ChaosMonkey(util, new ChaosMonkey.CompositeSequentialPolicy(
          new ChaosMonkey.DoActionsOncePolicy(CHAOS_EVERY_MS, actions),
          new ChaosMonkey.PeriodicRandomActionPolicy(CHAOS_EVERY_MS, actions)));
  monkey.start();
}