Package org.apache.hadoop.ozone.om

Class S3SecretManagerImpl

java.lang.Object
org.apache.hadoop.ozone.om.S3SecretManagerImpl
All Implemented Interfaces:
org.apache.hadoop.ozone.om.S3SecretManager
public class S3SecretManagerImpl extends Object implements org.apache.hadoop.ozone.om.S3SecretManager
S3 Secret manager.

  • Constructor Summary

    Constructors
    Constructor
    Description
    S3SecretManagerImpl(org.apache.hadoop.ozone.om.S3SecretStore s3SecretStore, org.apache.hadoop.ozone.om.S3SecretCache s3SecretCache)
    Constructs S3SecretManager.

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.hadoop.ozone.om.S3Batcher
    batcher()
     
    org.apache.hadoop.ozone.om.S3SecretCache
    cache()
     
    void
    clearS3Cache(List<Long> flushedTransactionIds)
     
    <T> T
    doUnderLock(String lockId, org.apache.hadoop.ozone.om.S3SecretFunction<T> action)
     
    org.apache.hadoop.ozone.om.helpers.S3SecretValue
    getSecret(String kerberosID)
     
    String
    getSecretString(String awsAccessKey)
     
    void
    revokeSecret(String kerberosId)
     
    void
    storeSecret(String kerberosId, org.apache.hadoop.ozone.om.helpers.S3SecretValue secretValue)
     
    void
    updateCache(String kerberosID, org.apache.hadoop.ozone.om.helpers.S3SecretValue secret)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.apache.hadoop.ozone.om.S3SecretManager

    clearCache, hasS3Secret, invalidateCacheEntry, isBatchSupported

  • Constructor Details

    • S3SecretManagerImpl

      public S3SecretManagerImpl(org.apache.hadoop.ozone.om.S3SecretStore s3SecretStore, org.apache.hadoop.ozone.om.S3SecretCache s3SecretCache)
      Constructs S3SecretManager.
      Parameters:
      s3SecretStore - s3 secret store.
      s3SecretCache - s3 secret cache.

  • Method Details

    • getSecret

      public org.apache.hadoop.ozone.om.helpers.S3SecretValue getSecret(String kerberosID) throws IOException
      Specified by:
      getSecret in interface org.apache.hadoop.ozone.om.S3SecretManager
      Throws:
      IOException

    • getSecretString

      public String getSecretString(String awsAccessKey) throws IOException
      Specified by:
      getSecretString in interface org.apache.hadoop.ozone.om.S3SecretManager
      Throws:
      IOException

    • storeSecret

      public void storeSecret(String kerberosId, org.apache.hadoop.ozone.om.helpers.S3SecretValue secretValue) throws IOException
      Specified by:
      storeSecret in interface org.apache.hadoop.ozone.om.S3SecretManager
      Throws:
      IOException

    • revokeSecret

      public void revokeSecret(String kerberosId) throws IOException
      Specified by:
      revokeSecret in interface org.apache.hadoop.ozone.om.S3SecretManager
      Throws:
      IOException

    • clearS3Cache

      public void clearS3Cache(List<Long> flushedTransactionIds)
      Specified by:
      clearS3Cache in interface org.apache.hadoop.ozone.om.S3SecretManager

    • doUnderLock

      public <T> T doUnderLock(String lockId, org.apache.hadoop.ozone.om.S3SecretFunction<T> action) throws IOException
      Specified by:
      doUnderLock in interface org.apache.hadoop.ozone.om.S3SecretManager
      Throws:
      IOException

    • cache

      public org.apache.hadoop.ozone.om.S3SecretCache cache()
      Specified by:
      cache in interface org.apache.hadoop.ozone.om.S3SecretManager

    • batcher

      public org.apache.hadoop.ozone.om.S3Batcher batcher()
      Specified by:
      batcher in interface org.apache.hadoop.ozone.om.S3SecretManager

    • updateCache

      public void updateCache(String kerberosID, org.apache.hadoop.ozone.om.helpers.S3SecretValue secret)
      Specified by:
      updateCache in interface org.apache.hadoop.ozone.om.S3SecretManager