本文整理了Java中org.apache.hadoop.hbase.security.token.ZKSecretWatcher.refreshKeys()
方法的一些代码示例,展示了ZKSecretWatcher.refreshKeys()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZKSecretWatcher.refreshKeys()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.security.token.ZKSecretWatcher
类名称:ZKSecretWatcher
方法名:refreshKeys
[英]refresh keys
[中]刷新键
代码示例来源:origin: apache/hbase
zkWatcher.refreshKeys();
if (LOG.isDebugEnabled()) {
LOG.debug("Sync token keys from zookeeper");
代码示例来源: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
zkWatcher.refreshKeys();
if (LOG.isDebugEnabled()) {
LOG.debug("Sync token keys from zookeeper");
代码示例来源: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()));
}
}
}
内容来源于网络,如有侵权,请联系作者删除!