本文整理了Java中com.twitter.distributedlog.acl.ZKAccessControl.delete()
方法的一些代码示例,展示了ZKAccessControl.delete()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZKAccessControl.delete()
方法的具体详情如下:
包路径:com.twitter.distributedlog.acl.ZKAccessControl
类名称:ZKAccessControl
方法名:delete
暂无
代码示例来源:origin: twitter/distributedlog
@Override
protected int runCmd() throws Exception {
BKDLConfig bkdlConfig = BKDLConfig.resolveDLConfig(getZooKeeperClient(), getUri());
if (null == bkdlConfig.getACLRootPath()) {
// acl isn't enabled for this namespace.
System.err.println("ACL isn't enabled for namespace " + getUri());
return -1;
}
String zkPath = getUri() + "/" + bkdlConfig.getACLRootPath() + "/" + stream;
ZKAccessControl.delete(getZooKeeperClient(), zkPath);
return 0;
}
代码示例来源:origin: twitter/distributedlog
@Test(timeout = 60000)
public void testDeleteZKAccessControl() throws Exception {
String zkPath = "/delete-zk-access-control";
AccessControlEntry ace = new AccessControlEntry();
ace.setDenyDelete(true);
ZKAccessControl zkac = new ZKAccessControl(ace, zkPath);
Await.result(zkac.create(zkc));
ZKAccessControl readZKAC = Await.result(ZKAccessControl.read(zkc, zkPath, null));
assertEquals(zkac, readZKAC);
Await.result(ZKAccessControl.delete(zkc, zkPath));
try {
Await.result(ZKAccessControl.read(zkc, zkPath, null));
} catch (KeeperException.NoNodeException nne) {
// expected.
}
Await.result(ZKAccessControl.delete(zkc, zkPath));
}
代码示例来源:origin: twitter/distributedlog
Await.result(ZKAccessControl.delete(zkc, zkPath2));
logger.info("Delete ACL for stream {}", stream2);
while (!zkcm.allowTruncate(stream2)) {
内容来源于网络,如有侵权,请联系作者删除!