org.apache.hadoop.crypto.key.kms.KMSClientProvider.invalidateCache()方法的使用及代码示例

x33g5p2x  于2022-01-23 转载在 其他  
字(1.7k)|赞(0)|评价(0)|浏览(96)

本文整理了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

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)

相关文章

微信公众号

最新文章

更多