本文整理了Java中com.liveramp.hank.coordinator.zk.ZkHost.getState()
方法的一些代码示例,展示了ZkHost.getState()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkHost.getState()
方法的具体详情如下:
包路径:com.liveramp.hank.coordinator.zk.ZkHost
类名称:ZkHost
方法名:getState
暂无
代码示例来源:origin: LiveRamp/hank
@Override
public Long getUpSince() throws IOException {
if (getState() == HostState.OFFLINE) {
return null;
}
try {
Stat stat = zk.exists(state.getPath(), false);
if (stat == null) {
return null;
} else {
return stat.getCtime();
}
} catch (Exception e) {
throw new IOException(e);
}
}
代码示例来源:origin: LiveRamp/hank
@Test
public void testSetState() throws Exception {
ZkHost host = ZkHost.create(getZk(), coordinator, getRoot(), ADDRESS, null, Collections.emptyList());
assertEquals(HostState.OFFLINE, host.getState());
assertFalse(Hosts.isOnline(host));
host.setState(HostState.IDLE);
waitUntilHost(HostState.IDLE, host);
assertEquals(HostState.IDLE, host.getState());
assertTrue(Hosts.isOnline(host));
host.setState(HostState.OFFLINE);
waitUntilHost(HostState.OFFLINE, host);
assertEquals(HostState.OFFLINE, host.getState());
assertFalse(Hosts.isOnline(host));
host.close();
}
代码示例来源:origin: LiveRamp/hank
@Test
public void testCreateAndLoad() throws Exception {
final ZkHost host = ZkHost.create(getZk(), coordinator, getRoot(), ADDRESS, null, Collections.emptyList());
assertEquals(ADDRESS, host.getAddress());
assertEquals(0, host.getCommandQueue().size());
assertNull(host.getCurrentCommand());
assertEquals(HostState.OFFLINE, host.getState());
assertFalse(Hosts.isOnline(host));
host.setEphemeralStatistic("a", "A");
host.setEphemeralStatistic("b", "B");
WaitUntil.orDie(() -> {
try {
return "A".equals(host.getStatistic("a"))
&& "B".equals(host.getStatistic("b"));
} catch (IOException e) {
throw new RuntimeException(e);
}
});
assertEquals("A", host.getStatistic("a"));
assertEquals("B", host.getStatistic("b"));
assertNull(host.getStatistic("c"));
host.setAddress(OTHER_ADDRESS);
WaitUntil.orDie(() -> host.getAddress().equals(OTHER_ADDRESS));
assertEquals(OTHER_ADDRESS, host.getAddress());
}
内容来源于网络,如有侵权,请联系作者删除!