本文整理了Java中com.liveramp.hank.coordinator.zk.ZooKeeperCoordinator.getDomainGroup()
方法的一些代码示例,展示了ZooKeeperCoordinator.getDomainGroup()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperCoordinator.getDomainGroup()
方法的具体详情如下:
包路径:com.liveramp.hank.coordinator.zk.ZooKeeperCoordinator
类名称:ZooKeeperCoordinator
方法名:getDomainGroup
暂无
代码示例来源:origin: LiveRamp/hank
@Override
public RingGroup addRingGroup(String ringGroupName, String domainGroupName) throws IOException {
try {
RingGroup rg = ZkRingGroup.create(zk, ZkPath.append(ringGroupsRoot, ringGroupName),
(ZkDomainGroup)getDomainGroup(domainGroupName), this);
ringGroups.put(ringGroupName, (ZkRingGroup)rg);
return rg;
} catch (Exception e) {
throw new IOException(e);
}
}
代码示例来源:origin: LiveRamp/hank
@Test
public void testLoad() throws Exception {
// check standard loading stuff
assertEquals("number of loaded domain configs", 1, coord.getDomains().size());
assertEquals("get domain by name", "domain0", coord.getDomain("domain0").getName());
assertEquals("number of loaded domain group configs", 1, coord.getDomainGroups().size());
assertEquals("get domain group by name", "myDomainGroup", coord.getDomainGroup("myDomainGroup").getName());
assertEquals("number of loaded ring groups", 1, coord.getRingGroups().size());
assertEquals("get ring group by name", "myRingGroup", coord.getRingGroup("myRingGroup").getName());
}
代码示例来源:origin: LiveRamp/hank
@Test
public void testAddDomainGroup() throws Exception {
// keep a second coordinator aside
final ZooKeeperCoordinator coord2 = getCoord();
coord.addDomainGroup("myDomainGroup2");
DomainGroup c = coord.getDomainGroup("myDomainGroup2");
assertNotNull(c);
assertEquals("myDomainGroup2", c.getName());
assertEquals(0, c.getDomainVersions().size());
// repeat the assertions with the other coord instance to ensure changes are
// visible
WaitUntil.orDie(() -> coord2.getDomainGroup("myDomainGroup2") != null);
assertNotNull("myDomainGroup2 should be found", c);
assertEquals("myDomainGroup2", c.getName());
assertEquals(0, c.getDomainVersions().size());
coord2.close();
}
内容来源于网络,如有侵权,请联系作者删除!