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

ZKSecretWatcher.<init>介绍

暂无

代码示例

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

/**
 * Create a new secret manager instance for generating keys.
 * @param conf Configuration to use
 * @param zk Connection to zookeeper for handling leader elections
 * @param keyUpdateInterval Time (in milliseconds) between rolling a new master key for token signing
 * @param tokenMaxLifetime Maximum age (in milliseconds) before a token expires and is no longer valid
 */
/* TODO: Restrict access to this constructor to make rogues instances more difficult.
 * For the moment this class is instantiated from
 * org.apache.hadoop.hbase.ipc.SecureServer so public access is needed.
 */
public AuthenticationTokenSecretManager(Configuration conf,
                    ZKWatcher zk, String serverName,
                    long keyUpdateInterval, long tokenMaxLifetime) {
 this.zkWatcher = new ZKSecretWatcher(conf, zk, this);
 this.keyUpdateInterval = keyUpdateInterval;
 this.tokenMaxLifetime = tokenMaxLifetime;
 this.leaderElector = new LeaderElector(zk, serverName);
 this.name = NAME_PREFIX+serverName;
 this.clusterId = new ZKClusterId(zk, zk);
}

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

@Test
 public void testRefreshKeys() throws Exception {
  Configuration conf = TEST_UTIL.getConfiguration();
  ZKWatcher zk = newZK(conf, "127.0.0.1", new MockAbortable());
  AuthenticationTokenSecretManager keyManager =
    new AuthenticationTokenSecretManager(conf, zk, "127.0.0.1",
      60 * 60 * 1000, 60 * 1000);
  ZKSecretWatcher watcher = new ZKSecretWatcher(conf, zk, keyManager);
  ZKUtil.deleteChildrenRecursively(zk, watcher.getKeysParentZNode());
  Integer[] keys = { 1, 2, 3, 4, 5, 6 };
  for (Integer key : keys) {
   AuthenticationKey ak = new AuthenticationKey(key,
     System.currentTimeMillis() + 600 * 1000, null);
   ZKUtil.createWithParents(zk,
     ZNodePaths.joinZNode(watcher.getKeysParentZNode(), key.toString()),
     Writables.getBytes(ak));
  }
  Assert.assertNull(keyManager.getCurrentKey());
  watcher.refreshKeys();
  for (Integer key : keys) {
   Assert.assertNotNull(keyManager.getKey(key.intValue()));
  }
 }
}

代码示例来源：origin: harbby/presto-connectors

/**
 * Create a new secret manager instance for generating keys.
 * @param conf Configuration to use
 * @param zk Connection to zookeeper for handling leader elections
 * @param keyUpdateInterval Time (in milliseconds) between rolling a new master key for token signing
 * @param tokenMaxLifetime Maximum age (in milliseconds) before a token expires and is no longer valid
 */
/* TODO: Restrict access to this constructor to make rogues instances more difficult.
 * For the moment this class is instantiated from
 * org.apache.hadoop.hbase.ipc.SecureServer so public access is needed.
 */
public AuthenticationTokenSecretManager(Configuration conf,
  ZooKeeperWatcher zk, String serverName,
  long keyUpdateInterval, long tokenMaxLifetime) {
 this.zkWatcher = new ZKSecretWatcher(conf, zk, this);
 this.keyUpdateInterval = keyUpdateInterval;
 this.tokenMaxLifetime = tokenMaxLifetime;
 this.leaderElector = new LeaderElector(zk, serverName);
 this.name = NAME_PREFIX+serverName;
 this.clusterId = new ZKClusterId(zk, zk);
}

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

@Test
 public void testRefreshKeys() throws Exception {
  Configuration conf = TEST_UTIL.getConfiguration();
  ZKWatcher zk = newZK(conf, "127.0.0.1", new MockAbortable());
  AuthenticationTokenSecretManager keyManager =
    new AuthenticationTokenSecretManager(conf, zk, "127.0.0.1",
      60 * 60 * 1000, 60 * 1000);
  ZKSecretWatcher watcher = new ZKSecretWatcher(conf, zk, keyManager);
  ZKUtil.deleteChildrenRecursively(zk, watcher.getKeysParentZNode());
  Integer[] keys = { 1, 2, 3, 4, 5, 6 };
  for (Integer key : keys) {
   AuthenticationKey ak = new AuthenticationKey(key,
     System.currentTimeMillis() + 600 * 1000, null);
   ZKUtil.createWithParents(zk,
     ZNodePaths.joinZNode(watcher.getKeysParentZNode(), key.toString()),
     Writables.getBytes(ak));
  }
  Assert.assertNull(keyManager.getCurrentKey());
  watcher.refreshKeys();
  for (Integer key : keys) {
   Assert.assertNotNull(keyManager.getKey(key.intValue()));
  }
 }
}