Package com.xiaomi.infra.chronos.zookeeper

Examples of com.xiaomi.infra.chronos.zookeeper.HostPort

68
69
70
71
72
73
74
75
76
77
78
  }

  @Test
  public void testGetTimestamp() throws FatalChronosException, ChronosException, IOException,
      TException {
    ChronosImplement chronosImplement = createChronosImplement(new HostPort("127.0.0.1", 10086));

    chronosImplement.initTimestamp();
    long firstTimestamp = chronosImplement.getTimestamp();
    long secondTimestamp = chronosImplement.getTimestamp();
    Assert.assertTrue(firstTimestamp < secondTimestamp);
View Full Code Here
41
42
43
44
45
46
47
48
49
50
  }

  @Before
  public void resetZooKeeper() throws IOException, KeeperException, TTransportException,
      ChronosException {
    ChronosServer chronosServer = createChronosServer(new HostPort("127.0.0.1", 10086));
    ZooKeeperUtil.deleteNodeRecursively(chronosServer.getFailoverWatcher(), chronosServer
        .getFailoverWatcher().getBaseZnode());
    chronosServer.getFailoverWatcher().close();
  }
View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
    return new ChronosServer(new ChronosServerWatcher(properties));
  }

  @Test
  public void testGetTimestamp() throws IOException, InterruptedException, TTransportException, ChronosException {
    final ChronosServer chronosServer = createChronosServer(new HostPort("127.0.0.1", 2187));
    Thread thread = new Thread() {
      @Override
      public void run() {
        chronosServer.run();
      }
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
    return new ChronosServer(new ChronosServerWatcher(properties));
  }

  @Test
  public void testGetTimestamp() throws IOException, InterruptedException, TTransportException, ChronosException {
    final ChronosServer chronosServer = createChronosServer(new HostPort("127.0.0.1", 2187));
    Thread thread = new Thread() {
      @Override
      public void run() {
        chronosServer.run();
      }
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
    chronosClient.getChronosClientWatcher().close();
  }
 
  @Test
  public void testGetTimestamps() throws IOException, InterruptedException, TTransportException, ChronosException {
    final ChronosServer chronosServer = createChronosServer(new HostPort("127.0.0.1", 2188));
    Thread thread = new Thread() {
      @Override
      public void run() {
        chronosServer.run();
      }
View Full Code Here
TOP

Related Classes of com.xiaomi.infra.chronos.zookeeper.HostPort

  • com.xiaomi.infra.chronos.client.TestChronosClient
  • com.xiaomi.infra.chronos.client.TestChronosClientWatcher
  • com.xiaomi.infra.chronos.TestChronosImplement
  • com.xiaomi.infra.chronos.TestChronosServer
  • com.xiaomi.infra.chronos.TestChronosWatcher
  • com.xiaomi.infra.chronos.zookeeper.TestFailoverServer
  • com.xiaomi.infra.chronos.zookeeper.TestFailoverWatcher
  • com.xiaomi.infra.chronos.zookeeper.TestHostPort
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.