程序包 org.apache.bookkeeper.mledger.offload.jcloud.provider

类 TieredStorageConfiguration

java.lang.Object
org.apache.bookkeeper.mledger.offload.jcloud.provider.TieredStorageConfiguration
public class TieredStorageConfiguration extends Object
Class responsible for holding all of the tiered storage configuration data that is set in the global Pulsar broker.conf file.

This class is used by the BlobStoreManagedLedgerOffloader to determine which JCloud provider to use for Tiered Storage offloand, along with the associated properties such as region, bucket, user credentials, etc.

  • 字段详细资料

    • BLOB_STORE_PROVIDER_KEY

      public static final String BLOB_STORE_PROVIDER_KEY
      另请参阅:

    • METADATA_FIELD_BUCKET

      public static final String METADATA_FIELD_BUCKET
      另请参阅:

    • METADATA_FIELD_REGION

      public static final String METADATA_FIELD_REGION
      另请参阅:

    • METADATA_FIELD_ENDPOINT

      public static final String METADATA_FIELD_ENDPOINT
      另请参阅:

    • METADATA_FIELD_MAX_BLOCK_SIZE

      public static final String METADATA_FIELD_MAX_BLOCK_SIZE
      另请参阅:

    • METADATA_FIELD_MIN_BLOCK_SIZE

      public static final String METADATA_FIELD_MIN_BLOCK_SIZE
      另请参阅:

    • METADATA_FIELD_READ_BUFFER_SIZE

      public static final String METADATA_FIELD_READ_BUFFER_SIZE
      另请参阅:

    • METADATA_FIELD_WRITE_BUFFER_SIZE

      public static final String METADATA_FIELD_WRITE_BUFFER_SIZE
      另请参阅:

    • OFFLOADER_PROPERTY_PREFIX

      public static final String OFFLOADER_PROPERTY_PREFIX
      另请参阅:

    • MAX_OFFLOAD_SEGMENT_ROLLOVER_TIME_SEC

      public static final String MAX_OFFLOAD_SEGMENT_ROLLOVER_TIME_SEC
      另请参阅:

    • MIN_OFFLOAD_SEGMENT_ROLLOVER_TIME_SEC

      public static final String MIN_OFFLOAD_SEGMENT_ROLLOVER_TIME_SEC
      另请参阅:

    • DEFAULT_MAX_SEGMENT_TIME_IN_SECOND

      public static final long DEFAULT_MAX_SEGMENT_TIME_IN_SECOND
      另请参阅:

    • DEFAULT_MIN_SEGMENT_TIME_IN_SECOND

      public static final long DEFAULT_MIN_SEGMENT_TIME_IN_SECOND
      另请参阅:

    • MAX_OFFLOAD_SEGMENT_SIZE_IN_BYTES

      public static final String MAX_OFFLOAD_SEGMENT_SIZE_IN_BYTES
      另请参阅:

    • DEFAULT_MAX_SEGMENT_SIZE_IN_BYTES

      public static final long DEFAULT_MAX_SEGMENT_SIZE_IN_BYTES
      另请参阅:

    • MB

      protected static final int MB
      另请参阅:

    • GCS_ACCOUNT_KEY_FILE_FIELD

      public static final String GCS_ACCOUNT_KEY_FILE_FIELD
      另请参阅:

    • S3_ID_FIELD

      public static final String S3_ID_FIELD
      另请参阅:

    • S3_SECRET_FIELD

      public static final String S3_SECRET_FIELD
      另请参阅:

    • S3_ROLE_FIELD

      public static final String S3_ROLE_FIELD
      另请参阅:

    • S3_ROLE_SESSION_NAME_FIELD

      public static final String S3_ROLE_SESSION_NAME_FIELD
      另请参阅:

  • 构造器详细资料

    • TieredStorageConfiguration

      public TieredStorageConfiguration(Map<String,String> configProperties)

  • 方法详细资料

    • create

      public static TieredStorageConfiguration create(Properties props) throws IOException
      抛出:
      IOException

    • create

      public static TieredStorageConfiguration create(Map<String,String> props)

    • getKeys

      public List<String> getKeys(String property)

    • getBlobStoreProviderKey

      public String getBlobStoreProviderKey()

    • getDriver

      public String getDriver()

    • getRegion

      public String getRegion()

    • setRegion

      public void setRegion(String s)

    • getBucket

      public String getBucket()

    • getServiceEndpoint

      public String getServiceEndpoint()

    • getMaxSegmentTimeInSecond

      public long getMaxSegmentTimeInSecond()

    • getMinSegmentTimeInSecond

      public long getMinSegmentTimeInSecond()

    • getMaxSegmentSizeInBytes

      public long getMaxSegmentSizeInBytes()

    • setServiceEndpoint

      public void setServiceEndpoint(String s)

    • getConfigProperty

      public String getConfigProperty(String propertyName)
      Used to find a specific configuration property other than one of the predefined ones. This allows for any number of provider specific, or new properties to added in the future.
      参数:
      propertyName -
      返回:

    • getProvider

      public JCloudBlobStoreProvider getProvider()

    • setProvider

      public void setProvider(JCloudBlobStoreProvider provider)

    • getMaxBlockSizeInBytes

      public Integer getMaxBlockSizeInBytes()

    • getMinBlockSizeInBytes

      public Integer getMinBlockSizeInBytes()

    • getReadBufferSizeInBytes

      public Integer getReadBufferSizeInBytes()

    • getWriteBufferSizeInBytes

      public Integer getWriteBufferSizeInBytes()

    • getProviderCredentials

      public Supplier<org.jclouds.domain.Credentials> getProviderCredentials()

    • setProviderCredentials

      public void setProviderCredentials(Supplier<org.jclouds.domain.Credentials> credentials)

    • validate

      public void validate()

    • getProviderMetadata

      public org.jclouds.providers.ProviderMetadata getProviderMetadata()

    • getBlobStoreLocation

      public BlobStoreLocation getBlobStoreLocation()

    • getBlobStore

      public org.jclouds.blobstore.BlobStore getBlobStore()

    • getOffloadDriverMetadata

      public Map<String,String> getOffloadDriverMetadata()

    • getOverrides

      protected Properties getOverrides()