本文整理了Java中org.apache.hadoop.crypto.key.kms.KMSClientProvider.invalidateCache()
方法的一些代码示例,展示了KMSClientProvider.invalidateCache()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。KMSClientProvider.invalidateCache()
方法的具体详情如下:
包路径:org.apache.hadoop.crypto.key.kms.KMSClientProvider
类名称:KMSClientProvider
方法名:invalidateCache
暂无
代码示例来源:origin: org.apache.hadoop/hadoop-common
@Override
public void invalidateCache(String keyName) throws IOException {
for (KMSClientProvider provider : providers) {
provider.invalidateCache(keyName);
}
}
代码示例来源:origin: org.apache.hadoop/hadoop-common
private KeyVersion rollNewVersionInternal(String name, byte[] material)
throws NoSuchAlgorithmException, IOException {
checkNotEmpty(name, "name");
Map<String, String> jsonMaterial = new HashMap<String, String>();
if (material != null) {
jsonMaterial.put(KMSRESTConstants.MATERIAL_FIELD,
Base64.encodeBase64String(material));
}
URL url = createURL(KMSRESTConstants.KEY_RESOURCE, name, null, null);
HttpURLConnection conn = createConnection(url, HTTP_POST);
conn.setRequestProperty(CONTENT_TYPE, APPLICATION_JSON_MIME);
Map response = call(conn, jsonMaterial,
HttpURLConnection.HTTP_OK, Map.class);
KeyVersion keyVersion = parseJSONKeyVersion(response);
invalidateCache(name);
return keyVersion;
}
代码示例来源:origin: org.apache.hadoop/hadoop-kms
kmscp.generateEncryptedKey(keyName).getEncryptionKeyVersionName());
kmscp.invalidateCache(keyName);
kq.get(keyName).put(mockEKV);
assertEquals("Key version incorrect after invalidating cache + putting"
kmscp.invalidateCache(keyName);
assertEquals("Cache invalidation guarantee failed.", "k1@0",
kmscp.generateEncryptedKey(keyName)
内容来源于网络,如有侵权,请联系作者删除!