org.apache.zookeeper.data.Id.getScheme()方法的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(9.3k)|赞(0)|评价(0)|浏览(159)

本文整理了Java中org.apache.zookeeper.data.Id.getScheme()方法的一些代码示例,展示了Id.getScheme()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Id.getScheme()方法的具体详情如下:
包路径:org.apache.zookeeper.data.Id
类名称:Id
方法名:getScheme

Id.getScheme介绍

暂无

代码示例

代码示例来源:origin: apache/zookeeper

if (authId.getScheme().equals("super")) {
  return;
Id id = a.getId();
if ((a.getPerms() & perm) != 0) {
  if (id.getScheme().equals("world")
      && id.getId().equals("anyone")) {
    return;
      .getScheme());
  if (ap != null) {
    for (Id authId : ids) {
      if (authId.getScheme().equals(id.getScheme())
          && ap.matches(new ServerAuthenticationProvider.ServerObjs(zks, cnxn),
          new ServerAuthenticationProvider.MatchValues(path, authId.getId(), id.getId(), perm, setAcls))) {

代码示例来源:origin: org.apache.zookeeper/zookeeper

if (authId.getScheme().equals("super")) {
  return;
Id id = a.getId();
if ((a.getPerms() & perm) != 0) {
  if (id.getScheme().equals("world")
      && id.getId().equals("anyone")) {
    return;
      .getScheme());
  if (ap != null) {
    for (Id authId : ids) {                        
      if (authId.getScheme().equals(id.getScheme())
          && ap.matches(authId.getId(), id.getId())) {
        return;

代码示例来源:origin: apache/zookeeper

if (id == null || id.getScheme() == null) {
  throw new KeeperException.InvalidACLException(path);
if (id.getScheme().equals("world") && id.getId().equals("anyone")) {
  rv.add(a);
} else if (id.getScheme().equals("auth")) {
  for (Id cid : authInfo) {
    ServerAuthenticationProvider ap =
      ProviderRegistry.getServerProvider(cid.getScheme());
    if (ap == null) {
      LOG.error("Missing AuthenticationProvider for "
        + cid.getScheme());
    } else if (ap.isAuthenticated()) {
      authIdValid = true;
  ServerAuthenticationProvider ap = ProviderRegistry.getServerProvider(id.getScheme());
  if (ap == null || !ap.isValid(id.getId())) {
    throw new KeeperException.InvalidACLException(path);

代码示例来源:origin: apache/hbase

} else if ("sasl".equals(id.getScheme())) {
 String name = id.getId();

代码示例来源:origin: apache/zookeeper

authInfo.getId(), authInfo.getScheme());
return KeeperException.Code.OK;

代码示例来源:origin: org.apache.zookeeper/zookeeper

ACL a = it.next();
Id id = a.getId();
if (id.getScheme().equals("world") && id.getId().equals("anyone")) {
} else if (id.getScheme().equals("auth")) {
  for (Id cid : authInfo) {
    AuthenticationProvider ap =
      ProviderRegistry.getProvider(cid.getScheme());
    if (ap == null) {
      LOG.error("Missing AuthenticationProvider for "
          + cid.getScheme());
    } else if (ap.isAuthenticated()) {
      authIdValid = true;
      .getScheme());
  if (ap == null) {
    return false;

代码示例来源:origin: apache/zookeeper

@Test
public void testSuperAuth() {
  X509AuthenticationProvider provider = createProvider(superCert);
  MockServerCnxn cnxn = new MockServerCnxn();
  cnxn.clientChain = new X509Certificate[] { superCert };
  Assert.assertEquals(KeeperException.Code.OK, provider.handleAuthentication(cnxn, null));
  Assert.assertEquals("super", cnxn.getAuthInfo().get(0).getScheme());
}

代码示例来源:origin: apache/hbase

boolean foundHBaseOwnerAcl = false;
for(int i = 0; i < 2; i++) {
 if (acls.get(i).getId().getScheme().equals("world") == true) {
  assertEquals("anyone", acls.get(0).getId().getId());
  assertEquals(ZooDefs.Perms.READ, acls.get(0).getPerms());
  foundWorldReadableAcl = true;
 } else {
  if (acls.get(i).getId().getScheme().equals("sasl") == true) {
   assertEquals("hbase", acls.get(1).getId().getId());
   assertEquals("sasl", acls.get(1).getId().getScheme());
   foundHBaseOwnerAcl = true;
  } else { // error: should not get here: test fails.

代码示例来源:origin: apache/hbase

boolean foundHBaseOwnerAcl = false;
for(int i = 0; i < 2; i++) {
 if (acls.get(i).getId().getScheme().equals("world") == true) {
  assertEquals("anyone", acls.get(0).getId().getId());
  assertEquals(ZooDefs.Perms.READ, acls.get(0).getPerms());
  foundWorldReadableAcl = true;
 } else {
  if (acls.get(i).getId().getScheme().equals("sasl") == true) {
   assertEquals("hbase", acls.get(1).getId().getId());
   assertEquals("sasl", acls.get(1).getId().getScheme());
   foundHBaseOwnerAcl = true;
  } else { // error: should not get here: test fails.

代码示例来源:origin: apache/hbase

/**
 * Finally, we check the ACLs of a node outside of the /hbase hierarchy and
 * verify that its ACL is simply 'hbase:Perms.ALL'.
 */
@Test
public void testOutsideHBaseNodeACL() throws Exception {
 if (!secureZKAvailable) {
  return;
 }
 ZKUtil.createWithParents(zkw, "/testACLNode");
 List<ACL> acls = zkw.getRecoverableZooKeeper().getZooKeeper()
   .getACL("/testACLNode", new Stat());
 assertEquals(1, acls.size());
 assertEquals("sasl", acls.get(0).getId().getScheme());
 assertEquals("hbase", acls.get(0).getId().getId());
 assertEquals(ZooDefs.Perms.ALL, acls.get(0).getPerms());
}

代码示例来源:origin: apache/hbase

boolean foundHBaseOwnerAcl = false;
for(int i = 0; i < 2; i++) {
 if (acls.get(i).getId().getScheme().equals("world") == true) {
  assertEquals("anyone", acls.get(0).getId().getId());
  assertEquals(ZooDefs.Perms.READ, acls.get(0).getPerms());
  if (acls.get(i).getId().getScheme().equals("sasl") == true) {
   assertEquals("hbase", acls.get(1).getId().getId());
   assertEquals("sasl", acls.get(1).getId().getScheme());
   foundHBaseOwnerAcl = true;
  } else { // error: should not get here: test fails.

代码示例来源:origin: apache/hbase

/**
 * Create a node and check its ACL. When authentication is enabled on
 * ZooKeeper, all nodes (except /hbase/root-region-server, /hbase/master
 * and /hbase/hbaseid) should be created so that only the hbase server user
 * (master or region server user) that created them can access them, and
 * this user should have all permissions on this node. For
 * /hbase/root-region-server, /hbase/master, and /hbase/hbaseid the
 * permissions should be as above, but should also be world-readable. First
 * we check the general case of /hbase nodes in the following test, and
 * then check the subset of world-readable nodes in the three tests after
 * that.
 */
@Test
public void testHBaseRootZNodeACL() throws Exception {
 if (!secureZKAvailable) {
  return;
 }
 List<ACL> acls = zkw.getRecoverableZooKeeper().getZooKeeper()
   .getACL("/hbase", new Stat());
 assertEquals(1, acls.size());
 assertEquals("sasl", acls.get(0).getId().getScheme());
 assertEquals("hbase", acls.get(0).getId().getId());
 assertEquals(ZooDefs.Perms.ALL, acls.get(0).getPerms());
}

代码示例来源:origin: apache/accumulo

Id actualId = actualAcl.getId();
if (actualAcl.getPerms() == expectedAcl.getPerms() && actualId.getScheme().equals("digest")
  && actualId.getId().startsWith("accumulo:")) {
 initialized.set(true);

代码示例来源:origin: BriData/DBus

/**
 * 获得节点ACL信息
 * @param path
 * @return
 * @throws Exception
 */
@Override
public Map<String, Object> getACL(String path) throws Exception {
  ACL acl = client.getACL().forPath(path).get(0);
  Id id = acl.getId();
  HashMap<String, Object> map = new HashMap<>();
  map.put("perms",acl.getPerms());
  map.put("id",id.getId());
  map.put("scheme",id.getScheme());
  return map;
}

代码示例来源:origin: apache/knox

ZooKeeperACLAdapter(ACL acl) {
  this.permissions = acl.getPerms();
  this.type = acl.getId().getScheme();
  this.id = acl.getId().getId();
}

代码示例来源:origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

private static boolean verifyZKACL(String id, String scheme, int perm,
  List<ACL> acls) {
 for (ACL acl : acls) {
  if (acl.getId().getScheme().equals(scheme) &&
    acl.getId().getId().startsWith(id) &&
    acl.getPerms() == perm) {
   return true;
  }
 }
 return false;
}

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

private static boolean verifyZKACL(String id, String scheme, int perm,
  List<ACL> acls) {
 for (ACL acl : acls) {
  if (acl.getId().getScheme().equals(scheme) &&
    acl.getId().getId().startsWith(id) &&
    acl.getPerms() == perm) {
   return true;
  }
 }
 return false;
}

代码示例来源:origin: org.apache.hbase/hbase-server

/**
 * Finally, we check the ACLs of a node outside of the /hbase hierarchy and
 * verify that its ACL is simply 'hbase:Perms.ALL'.
 */
@Test
public void testOutsideHBaseNodeACL() throws Exception {
 if (!secureZKAvailable) {
  return;
 }
 ZKUtil.createWithParents(zkw, "/testACLNode");
 List<ACL> acls = zkw.getRecoverableZooKeeper().getZooKeeper()
   .getACL("/testACLNode", new Stat());
 assertEquals(1, acls.size());
 assertEquals("sasl", acls.get(0).getId().getScheme());
 assertEquals("hbase", acls.get(0).getId().getId());
 assertEquals(ZooDefs.Perms.ALL, acls.get(0).getPerms());
}

代码示例来源:origin: ch.cern.hadoop/hadoop-common

@Test
public void testGoodACLs() {
 List<ACL> result = ZKUtil.parseACLs(
   "sasl:hdfs/host1@MY.DOMAIN:cdrwa, sasl:hdfs/host2@MY.DOMAIN:ca");
 ACL acl0 = result.get(0);
 assertEquals(Perms.CREATE | Perms.DELETE | Perms.READ |
   Perms.WRITE | Perms.ADMIN, acl0.getPerms());
 assertEquals("sasl", acl0.getId().getScheme());
 assertEquals("hdfs/host1@MY.DOMAIN", acl0.getId().getId());
 
 ACL acl1 = result.get(1);
 assertEquals(Perms.CREATE | Perms.ADMIN, acl1.getPerms());
 assertEquals("sasl", acl1.getId().getScheme());
 assertEquals("hdfs/host2@MY.DOMAIN", acl1.getId().getId());
}

代码示例来源:origin: com.github.jiayuhan-it/hadoop-common

@Test
public void testGoodACLs() {
 List<ACL> result = ZKUtil.parseACLs(
   "sasl:hdfs/host1@MY.DOMAIN:cdrwa, sasl:hdfs/host2@MY.DOMAIN:ca");
 ACL acl0 = result.get(0);
 assertEquals(Perms.CREATE | Perms.DELETE | Perms.READ |
   Perms.WRITE | Perms.ADMIN, acl0.getPerms());
 assertEquals("sasl", acl0.getId().getScheme());
 assertEquals("hdfs/host1@MY.DOMAIN", acl0.getId().getId());
 
 ACL acl1 = result.get(1);
 assertEquals(Perms.CREATE | Perms.ADMIN, acl1.getPerms());
 assertEquals("sasl", acl1.getId().getScheme());
 assertEquals("hdfs/host2@MY.DOMAIN", acl1.getId().getId());
}

相关文章