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

项目:LCIndex-HBase-0.94.16    文件:IntegrationTestDataIngestSlowDeterministic.java   
@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();
}
项目:IRIndex    文件:IntegrationTestDataIngestSlowDeterministic.java   
@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();
}
项目:HBase-Research    文件:IntegrationTestDataIngestSlowDeterministic.java   
@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();
}
项目:hbase-0.94.8-qod    文件:IntegrationTestDataIngestSlowDeterministic.java   
@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();
}
项目:hbase-0.94.8-qod    文件:IntegrationTestDataIngestSlowDeterministic.java   
@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();
}
项目:hindex    文件:IntegrationTestDataIngestSlowDeterministic.java   
@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();
}