public abstract class S3Base extends Object
| Modifier and Type | Class and Description |
|---|---|
protected static class |
S3Base.NotificationResultRecords
Notification result records representation.
|
| Modifier and Type | Field and Description |
|---|---|
protected okhttp3.HttpUrl |
baseUrl |
protected static long |
DEFAULT_CONNECTION_TIMEOUT |
protected static byte[] |
EMPTY_BODY |
protected static int |
MAX_BUCKET_POLICY_SIZE |
protected static String |
NO_SUCH_BUCKET |
protected static String |
NO_SUCH_BUCKET_MESSAGE |
protected static String |
NO_SUCH_BUCKET_POLICY |
protected static String |
NO_SUCH_OBJECT_LOCK_CONFIGURATION |
protected Provider |
provider |
protected String |
region |
protected Map<String,String> |
regionCache |
protected static String |
SERVER_SIDE_ENCRYPTION_CONFIGURATION_NOT_FOUND_ERROR |
protected static String |
US_EAST_1 |
| Modifier | Constructor and Description |
|---|---|
protected |
S3Base(okhttp3.HttpUrl baseUrl,
String region,
boolean isAwsHost,
boolean isAcceleratedHost,
boolean isDualStackHost,
boolean useVirtualStyle,
Provider provider,
okhttp3.OkHttpClient httpClient) |
protected |
S3Base(S3Base client) |
| Modifier and Type | Method and Description |
|---|---|
protected AbortMultipartUploadResponse |
abortMultipartUpload(String bucketName,
String region,
String objectName,
String uploadId,
com.google.common.collect.Multimap<String,String> extraHeaders,
com.google.common.collect.Multimap<String,String> extraQueryParams)
|
protected okhttp3.HttpUrl |
buildUrl(Method method,
String bucketName,
String objectName,
String region,
com.google.common.collect.Multimap<String,String> queryParamMap)
Build URL for given parameters.
|
protected int |
calculatePartCount(List<ComposeSource> sources)
Calculate part count of given compose sources.
|
protected void |
checkArgs(BaseArgs args)
Check whether argument is valid or not.
|
protected ObjectWriteResponse |
completeMultipartUpload(String bucketName,
String region,
String objectName,
String uploadId,
Part[] parts,
com.google.common.collect.Multimap<String,String> extraHeaders,
com.google.common.collect.Multimap<String,String> extraQueryParams)
|
protected CreateMultipartUploadResponse |
createMultipartUpload(String bucketName,
String region,
String objectName,
com.google.common.collect.Multimap<String,String> headers,
com.google.common.collect.Multimap<String,String> extraQueryParams)
|
protected okhttp3.Request |
createRequest(okhttp3.HttpUrl url,
Method method,
okhttp3.Headers headers,
Object body,
int length,
Credentials creds)
Create HTTP request for given paramaters.
|
protected DeleteObjectsResponse |
deleteObjects(String bucketName,
String region,
List<DeleteObject> objectList,
boolean quiet,
boolean bypassGovernanceMode,
com.google.common.collect.Multimap<String,String> extraHeaders,
com.google.common.collect.Multimap<String,String> extraQueryParams)
|
void |
disableAccelerateEndpoint()
Disables accelerate endpoint for Amazon S3 endpoint.
|
void |
disableDualStackEndpoint()
Disables dual-stack endpoint for Amazon S3 endpoint.
|
void |
disableVirtualStyleEndpoint()
Disables virtual-style endpoint.
|
void |
enableAccelerateEndpoint()
Enables accelerate endpoint for Amazon S3 endpoint.
|
void |
enableDualStackEndpoint()
Enables dual-stack endpoint for Amazon S3 endpoint.
|
void |
enableVirtualStyleEndpoint()
Enables virtual-style endpoint.
|
protected okhttp3.Response |
execute(Method method,
BaseArgs args,
com.google.common.collect.Multimap<String,String> headers,
com.google.common.collect.Multimap<String,String> queryParams,
Object body,
int length)
Execute HTTP request for given args and parameters.
|
protected okhttp3.Response |
execute(Method method,
String bucketName,
String objectName,
String region,
okhttp3.Headers headers,
com.google.common.collect.Multimap<String,String> queryParamMap,
Object body,
int length)
Execute HTTP request for given parameters.
|
protected okhttp3.Response |
executeDelete(BaseArgs args,
com.google.common.collect.Multimap<String,String> headers,
com.google.common.collect.Multimap<String,String> queryParams)
Execute DELETE HTTP request for given parameters.
|
protected okhttp3.Response |
executeGet(BaseArgs args,
com.google.common.collect.Multimap<String,String> headers,
com.google.common.collect.Multimap<String,String> queryParams)
Execute GET HTTP request for given parameters.
|
protected okhttp3.Response |
executeHead(BaseArgs args,
com.google.common.collect.Multimap<String,String> headers,
com.google.common.collect.Multimap<String,String> queryParams)
Execute HEAD HTTP request for given parameters.
|
protected okhttp3.Response |
executePost(BaseArgs args,
com.google.common.collect.Multimap<String,String> headers,
com.google.common.collect.Multimap<String,String> queryParams,
Object data)
Execute POST HTTP request for given parameters.
|
protected okhttp3.Response |
executePut(BaseArgs args,
com.google.common.collect.Multimap<String,String> headers,
com.google.common.collect.Multimap<String,String> queryParams,
Object data,
int length)
Execute PUT HTTP request for given parameters.
|
protected String |
getRegion(String bucketName,
String region)
Returns region of given bucket either from region cache or set in constructor.
|
protected okhttp3.Headers |
httpHeaders(com.google.common.collect.Multimap<String,String> headerMap)
Convert Multimap to Headers.
|
void |
ignoreCertCheck()
Ignores check on server certificate for HTTPS connection.
|
protected ListMultipartUploadsResponse |
listMultipartUploads(String bucketName,
String region,
String delimiter,
String encodingType,
String keyMarker,
Integer maxUploads,
String prefix,
String uploadIdMarker,
com.google.common.collect.Multimap<String,String> extraHeaders,
com.google.common.collect.Multimap<String,String> extraQueryParams)
|
protected Iterable<Result<Item>> |
listObjectsV1(ListObjectsArgs args)
Execute list objects v1.
|
protected ListObjectsV1Response |
listObjectsV1(String bucketName,
String region,
String delimiter,
String encodingType,
String marker,
Integer maxKeys,
String prefix,
com.google.common.collect.Multimap<String,String> extraHeaders,
com.google.common.collect.Multimap<String,String> extraQueryParams)
|
protected Iterable<Result<Item>> |
listObjectsV2(ListObjectsArgs args)
Execute list objects v2.
|
protected ListObjectsV2Response |
listObjectsV2(String bucketName,
String region,
String delimiter,
String encodingType,
String startAfter,
Integer maxKeys,
String prefix,
String continuationToken,
boolean fetchOwner,
boolean includeUserMetadata,
com.google.common.collect.Multimap<String,String> extraHeaders,
com.google.common.collect.Multimap<String,String> extraQueryParams)
|
protected Iterable<Result<Item>> |
listObjectVersions(ListObjectsArgs args)
Execute list object versions.
|
protected ListObjectVersionsResponse |
listObjectVersions(String bucketName,
String region,
String delimiter,
String encodingType,
String keyMarker,
Integer maxKeys,
String prefix,
String versionIdMarker,
com.google.common.collect.Multimap<String,String> extraHeaders,
com.google.common.collect.Multimap<String,String> extraQueryParams)
|
protected ListPartsResponse |
listParts(String bucketName,
String region,
String objectName,
Integer maxParts,
Integer partNumberMarker,
String uploadId,
com.google.common.collect.Multimap<String,String> extraHeaders,
com.google.common.collect.Multimap<String,String> extraQueryParams)
Do ListParts S3
API.
|
protected com.google.common.collect.Multimap<String,String> |
merge(com.google.common.collect.Multimap<String,String> m1,
com.google.common.collect.Multimap<String,String> m2)
Merge two Multimaps.
|
protected com.google.common.collect.Multimap<String,String> |
newMultimap(Map<String,String> map)
Create new HashMultimap with copy of Map.
|
protected com.google.common.collect.Multimap<String,String> |
newMultimap(com.google.common.collect.Multimap<String,String> map)
Create new HashMultimap with copy of Multimap.
|
protected com.google.common.collect.Multimap<String,String> |
newMultimap(String... keysAndValues)
Create new HashMultimap by alternating keys and values.
|
protected ObjectWriteResponse |
putObject(PutObjectBaseArgs args,
Object data,
long objectSize,
long partSize,
int partCount,
String contentType)
Execute put object.
|
protected ObjectWriteResponse |
putObject(String bucketName,
String region,
String objectName,
Object data,
int length,
com.google.common.collect.Multimap<String,String> headers,
com.google.common.collect.Multimap<String,String> extraQueryParams)
Do PutObject S3
API.
|
void |
setAppInfo(String name,
String version)
Sets application's name/version to user agent.
|
void |
setTimeout(long connectTimeout,
long writeTimeout,
long readTimeout)
Sets HTTP connect, write and read timeouts.
|
protected StatObjectResponse |
statObject(StatObjectArgs args)
Execute stat object.
|
void |
traceOff()
Disables HTTP call tracing previously enabled.
|
void |
traceOn(OutputStream traceStream)
Enables HTTP call tracing and written to traceStream.
|
protected UploadPartResponse |
uploadPart(String bucketName,
String region,
String objectName,
Object data,
int length,
String uploadId,
int partNumber,
com.google.common.collect.Multimap<String,String> extraHeaders,
com.google.common.collect.Multimap<String,String> extraQueryParams)
|
protected UploadPartCopyResponse |
uploadPartCopy(String bucketName,
String region,
String objectName,
String uploadId,
int partNumber,
com.google.common.collect.Multimap<String,String> headers,
com.google.common.collect.Multimap<String,String> extraQueryParams)
|
protected static final String NO_SUCH_BUCKET_MESSAGE
protected static final String NO_SUCH_BUCKET
protected static final String NO_SUCH_BUCKET_POLICY
protected static final String NO_SUCH_OBJECT_LOCK_CONFIGURATION
protected static final String SERVER_SIDE_ENCRYPTION_CONFIGURATION_NOT_FOUND_ERROR
protected static final byte[] EMPTY_BODY
protected static final long DEFAULT_CONNECTION_TIMEOUT
protected static final int MAX_BUCKET_POLICY_SIZE
protected static final String US_EAST_1
protected okhttp3.HttpUrl baseUrl
protected String region
protected Provider provider
protected S3Base(okhttp3.HttpUrl baseUrl,
String region,
boolean isAwsHost,
boolean isAcceleratedHost,
boolean isDualStackHost,
boolean useVirtualStyle,
Provider provider,
okhttp3.OkHttpClient httpClient)
protected S3Base(S3Base client)
protected void checkArgs(BaseArgs args)
protected com.google.common.collect.Multimap<String,String> merge(com.google.common.collect.Multimap<String,String> m1, com.google.common.collect.Multimap<String,String> m2)
protected com.google.common.collect.Multimap<String,String> newMultimap(String... keysAndValues)
protected com.google.common.collect.Multimap<String,String> newMultimap(Map<String,String> map)
protected com.google.common.collect.Multimap<String,String> newMultimap(com.google.common.collect.Multimap<String,String> map)
protected okhttp3.HttpUrl buildUrl(Method method, String bucketName, String objectName, String region, com.google.common.collect.Multimap<String,String> queryParamMap) throws NoSuchAlgorithmException
NoSuchAlgorithmExceptionprotected okhttp3.Headers httpHeaders(com.google.common.collect.Multimap<String,String> headerMap)
protected okhttp3.Request createRequest(okhttp3.HttpUrl url,
Method method,
okhttp3.Headers headers,
Object body,
int length,
Credentials creds)
throws InsufficientDataException,
InternalException,
IOException,
NoSuchAlgorithmException
protected okhttp3.Response execute(Method method, BaseArgs args, com.google.common.collect.Multimap<String,String> headers, com.google.common.collect.Multimap<String,String> queryParams, Object body, int length) throws ErrorResponseException, InsufficientDataException, InternalException, InvalidKeyException, InvalidResponseException, IOException, NoSuchAlgorithmException, ServerException, XmlParserException
protected okhttp3.Response execute(Method method, String bucketName, String objectName, String region, okhttp3.Headers headers, com.google.common.collect.Multimap<String,String> queryParamMap, Object body, int length) throws ErrorResponseException, InsufficientDataException, InternalException, InvalidKeyException, InvalidResponseException, IOException, NoSuchAlgorithmException, ServerException, XmlParserException
protected String getRegion(String bucketName, String region) throws ErrorResponseException, InsufficientDataException, InternalException, InvalidKeyException, InvalidResponseException, IOException, NoSuchAlgorithmException, ServerException, XmlParserException
protected okhttp3.Response executeGet(BaseArgs args, com.google.common.collect.Multimap<String,String> headers, com.google.common.collect.Multimap<String,String> queryParams) throws ErrorResponseException, InsufficientDataException, InternalException, InvalidKeyException, InvalidResponseException, IOException, NoSuchAlgorithmException, ServerException, XmlParserException
protected okhttp3.Response executeHead(BaseArgs args, com.google.common.collect.Multimap<String,String> headers, com.google.common.collect.Multimap<String,String> queryParams) throws ErrorResponseException, InsufficientDataException, InternalException, InvalidKeyException, InvalidResponseException, IOException, NoSuchAlgorithmException, ServerException, XmlParserException
protected okhttp3.Response executeDelete(BaseArgs args, com.google.common.collect.Multimap<String,String> headers, com.google.common.collect.Multimap<String,String> queryParams) throws ErrorResponseException, InsufficientDataException, InternalException, InvalidKeyException, InvalidResponseException, IOException, NoSuchAlgorithmException, ServerException, XmlParserException
protected okhttp3.Response executePost(BaseArgs args, com.google.common.collect.Multimap<String,String> headers, com.google.common.collect.Multimap<String,String> queryParams, Object data) throws ErrorResponseException, InsufficientDataException, InternalException, InvalidKeyException, InvalidResponseException, IOException, NoSuchAlgorithmException, ServerException, XmlParserException
protected okhttp3.Response executePut(BaseArgs args, com.google.common.collect.Multimap<String,String> headers, com.google.common.collect.Multimap<String,String> queryParams, Object data, int length) throws ErrorResponseException, InsufficientDataException, InternalException, InvalidKeyException, InvalidResponseException, IOException, NoSuchAlgorithmException, ServerException, XmlParserException
protected int calculatePartCount(List<ComposeSource> sources) throws ErrorResponseException, InsufficientDataException, InternalException, InvalidKeyException, InvalidResponseException, IOException, NoSuchAlgorithmException, ServerException, XmlParserException
protected Iterable<Result<Item>> listObjectsV2(ListObjectsArgs args)
protected Iterable<Result<Item>> listObjectsV1(ListObjectsArgs args)
protected Iterable<Result<Item>> listObjectVersions(ListObjectsArgs args)
protected ObjectWriteResponse putObject(PutObjectBaseArgs args, Object data, long objectSize, long partSize, int partCount, String contentType) throws ErrorResponseException, InsufficientDataException, InternalException, InvalidKeyException, InvalidResponseException, IOException, NoSuchAlgorithmException, ServerException, XmlParserException
public void setTimeout(long connectTimeout,
long writeTimeout,
long readTimeout)
Example:
minioClient.setTimeout(TimeUnit.SECONDS.toMillis(10), TimeUnit.SECONDS.toMillis(10),
TimeUnit.SECONDS.toMillis(30));
connectTimeout - HTTP connect timeout in milliseconds.writeTimeout - HTTP write timeout in milliseconds.readTimeout - HTTP read timeout in milliseconds.public void ignoreCertCheck()
throws KeyManagementException,
NoSuchAlgorithmException
Example:
minioClient.ignoreCertCheck();
KeyManagementException - thrown to indicate key management error.NoSuchAlgorithmException - thrown to indicate missing of SSL library.public void setAppInfo(String name, String version)
name - Your application name.version - Your application version.public void traceOn(OutputStream traceStream)
traceStream - OutputStream for writing HTTP call tracing.traceOff()public void traceOff()
throws IOException
IOException - upon connection errortraceOn(java.io.OutputStream)public void enableAccelerateEndpoint()
public void disableAccelerateEndpoint()
public void enableDualStackEndpoint()
public void disableDualStackEndpoint()
public void enableVirtualStyleEndpoint()
public void disableVirtualStyleEndpoint()
protected StatObjectResponse statObject(StatObjectArgs args) throws ErrorResponseException, InsufficientDataException, InternalException, InvalidKeyException, InvalidResponseException, IOException, NoSuchAlgorithmException, ServerException, XmlParserException
protected AbortMultipartUploadResponse abortMultipartUpload(String bucketName, String region, String objectName, String uploadId, com.google.common.collect.Multimap<String,String> extraHeaders, com.google.common.collect.Multimap<String,String> extraQueryParams) throws NoSuchAlgorithmException, InsufficientDataException, IOException, InvalidKeyException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException
bucketName - Name of the bucket.region - Region of the bucket.objectName - Object name in the bucket.uploadId - Upload ID.extraHeaders - Extra headers (Optional).extraQueryParams - Extra query parameters (Optional).AbortMultipartUploadResponse object.ErrorResponseException - thrown to indicate S3 service returned an error response.InsufficientDataException - thrown to indicate not enough data available in InputStream.InternalException - thrown to indicate internal library error.InvalidKeyException - thrown to indicate missing of HMAC SHA-256 library.InvalidResponseException - thrown to indicate S3 service returned invalid or no error
response.IOException - thrown to indicate I/O error on S3 operation.NoSuchAlgorithmException - thrown to indicate missing of MD5 or SHA-256 digest library.XmlParserException - thrown to indicate XML parsing error.ServerExceptionprotected ObjectWriteResponse completeMultipartUpload(String bucketName, String region, String objectName, String uploadId, Part[] parts, com.google.common.collect.Multimap<String,String> extraHeaders, com.google.common.collect.Multimap<String,String> extraQueryParams) throws NoSuchAlgorithmException, InsufficientDataException, IOException, InvalidKeyException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException
bucketName - Name of the bucket.region - Region of the bucket.objectName - Object name in the bucket.uploadId - Upload ID.parts - List of parts.extraHeaders - Extra headers (Optional).extraQueryParams - Extra query parameters (Optional).ObjectWriteResponse object.ErrorResponseException - thrown to indicate S3 service returned an error response.InsufficientDataException - thrown to indicate not enough data available in InputStream.InternalException - thrown to indicate internal library error.InvalidKeyException - thrown to indicate missing of HMAC SHA-256 library.InvalidResponseException - thrown to indicate S3 service returned invalid or no error
response.IOException - thrown to indicate I/O error on S3 operation.NoSuchAlgorithmException - thrown to indicate missing of MD5 or SHA-256 digest library.XmlParserException - thrown to indicate XML parsing error.ServerExceptionprotected CreateMultipartUploadResponse createMultipartUpload(String bucketName, String region, String objectName, com.google.common.collect.Multimap<String,String> headers, com.google.common.collect.Multimap<String,String> extraQueryParams) throws NoSuchAlgorithmException, InsufficientDataException, IOException, InvalidKeyException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException
bucketName - Name of the bucket.region - Region name of buckets in S3 service.objectName - Object name in the bucket.headers - Request headers.extraQueryParams - Extra query parameters for request (Optional).CreateMultipartUploadResponse object.ErrorResponseException - thrown to indicate S3 service returned an error response.InsufficientDataException - thrown to indicate not enough data available in InputStream.InternalException - thrown to indicate internal library error.InvalidKeyException - thrown to indicate missing of HMAC SHA-256 library.InvalidResponseException - thrown to indicate S3 service returned invalid or no error
response.IOException - thrown to indicate I/O error on S3 operation.NoSuchAlgorithmException - thrown to indicate missing of MD5 or SHA-256 digest library.XmlParserException - thrown to indicate XML parsing error.ServerExceptionprotected DeleteObjectsResponse deleteObjects(String bucketName, String region, List<DeleteObject> objectList, boolean quiet, boolean bypassGovernanceMode, com.google.common.collect.Multimap<String,String> extraHeaders, com.google.common.collect.Multimap<String,String> extraQueryParams) throws NoSuchAlgorithmException, InsufficientDataException, IOException, InvalidKeyException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException
bucketName - Name of the bucket.region - Region of the bucket (Optional).objectList - List of object names.quiet - Quiet flag.bypassGovernanceMode - Bypass Governance retention mode.extraHeaders - Extra headers for request (Optional).extraQueryParams - Extra query parameters for request (Optional).DeleteObjectsResponse object.ErrorResponseException - thrown to indicate S3 service returned an error response.InsufficientDataException - thrown to indicate not enough data available in InputStream.InternalException - thrown to indicate internal library error.InvalidKeyException - thrown to indicate missing of HMAC SHA-256 library.InvalidResponseException - thrown to indicate S3 service returned invalid or no error
response.IOException - thrown to indicate I/O error on S3 operation.NoSuchAlgorithmException - thrown to indicate missing of MD5 or SHA-256 digest library.XmlParserException - thrown to indicate XML parsing error.ServerExceptionprotected ListObjectsV2Response listObjectsV2(String bucketName, String region, String delimiter, String encodingType, String startAfter, Integer maxKeys, String prefix, String continuationToken, boolean fetchOwner, boolean includeUserMetadata, com.google.common.collect.Multimap<String,String> extraHeaders, com.google.common.collect.Multimap<String,String> extraQueryParams) throws InvalidKeyException, NoSuchAlgorithmException, InsufficientDataException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException, IOException
bucketName - Name of the bucket.region - Region of the bucket (Optional).delimiter - Delimiter (Optional).encodingType - Encoding type (Optional).startAfter - Fetch listing after this key (Optional).maxKeys - Maximum object information to fetch (Optional).prefix - Prefix (Optional).continuationToken - Continuation token (Optional).fetchOwner - Flag to fetch owner information (Optional).includeUserMetadata - MinIO extension flag to include user metadata (Optional).extraHeaders - Extra headers for request (Optional).extraQueryParams - Extra query parameters for request (Optional).ListObjectsV2Response object.ErrorResponseException - thrown to indicate S3 service returned an error response.InsufficientDataException - thrown to indicate not enough data available in InputStream.InternalException - thrown to indicate internal library error.InvalidKeyException - thrown to indicate missing of HMAC SHA-256 library.InvalidResponseException - thrown to indicate S3 service returned invalid or no error
response.IOException - thrown to indicate I/O error on S3 operation.NoSuchAlgorithmException - thrown to indicate missing of MD5 or SHA-256 digest library.XmlParserException - thrown to indicate XML parsing error.ServerExceptionprotected ListObjectsV1Response listObjectsV1(String bucketName, String region, String delimiter, String encodingType, String marker, Integer maxKeys, String prefix, com.google.common.collect.Multimap<String,String> extraHeaders, com.google.common.collect.Multimap<String,String> extraQueryParams) throws NoSuchAlgorithmException, InsufficientDataException, IOException, InvalidKeyException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException
bucketName - Name of the bucket.region - Region of the bucket (Optional).delimiter - Delimiter (Optional).encodingType - Encoding type (Optional).marker - Marker (Optional).maxKeys - Maximum object information to fetch (Optional).prefix - Prefix (Optional).extraHeaders - Extra headers for request (Optional).extraQueryParams - Extra query parameters for request (Optional).ListObjectsV1Response object.ErrorResponseException - thrown to indicate S3 service returned an error response.InsufficientDataException - thrown to indicate not enough data available in InputStream.InternalException - thrown to indicate internal library error.InvalidKeyException - thrown to indicate missing of HMAC SHA-256 library.InvalidResponseException - thrown to indicate S3 service returned invalid or no error
response.IOException - thrown to indicate I/O error on S3 operation.NoSuchAlgorithmException - thrown to indicate missing of MD5 or SHA-256 digest library.XmlParserException - thrown to indicate XML parsing error.ServerExceptionprotected ListObjectVersionsResponse listObjectVersions(String bucketName, String region, String delimiter, String encodingType, String keyMarker, Integer maxKeys, String prefix, String versionIdMarker, com.google.common.collect.Multimap<String,String> extraHeaders, com.google.common.collect.Multimap<String,String> extraQueryParams) throws NoSuchAlgorithmException, InsufficientDataException, IOException, InvalidKeyException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException
bucketName - Name of the bucket.region - Region of the bucket (Optional).delimiter - Delimiter (Optional).encodingType - Encoding type (Optional).keyMarker - Key marker (Optional).maxKeys - Maximum object information to fetch (Optional).prefix - Prefix (Optional).versionIdMarker - Version ID marker (Optional).extraHeaders - Extra headers for request (Optional).extraQueryParams - Extra query parameters for request (Optional).ListObjectVersionsResponse object.ErrorResponseException - thrown to indicate S3 service returned an error response.InsufficientDataException - thrown to indicate not enough data available in InputStream.InternalException - thrown to indicate internal library error.InvalidKeyException - thrown to indicate missing of HMAC SHA-256 library.InvalidResponseException - thrown to indicate S3 service returned invalid or no error
response.IOException - thrown to indicate I/O error on S3 operation.NoSuchAlgorithmException - thrown to indicate missing of MD5 or SHA-256 digest library.XmlParserException - thrown to indicate XML parsing error.ServerExceptionprotected ObjectWriteResponse putObject(String bucketName, String region, String objectName, Object data, int length, com.google.common.collect.Multimap<String,String> headers, com.google.common.collect.Multimap<String,String> extraQueryParams) throws NoSuchAlgorithmException, InsufficientDataException, IOException, InvalidKeyException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException
bucketName - Name of the bucket.objectName - Object name in the bucket.data - Object data must be BufferedInputStream, RandomAccessFile, byte[] or String.length - Length of object data.headers - Additional headers.extraQueryParams - Additional query parameters if any.ObjectWriteResponse object.ErrorResponseException - thrown to indicate S3 service returned an error response.InsufficientDataException - thrown to indicate not enough data available in InputStream.InternalException - thrown to indicate internal library error.InvalidKeyException - thrown to indicate missing of HMAC SHA-256 library.InvalidResponseException - thrown to indicate S3 service returned invalid or no error
response.IOException - thrown to indicate I/O error on S3 operation.NoSuchAlgorithmException - thrown to indicate missing of MD5 or SHA-256 digest library.XmlParserException - thrown to indicate XML parsing error.ServerExceptionprotected ListMultipartUploadsResponse listMultipartUploads(String bucketName, String region, String delimiter, String encodingType, String keyMarker, Integer maxUploads, String prefix, String uploadIdMarker, com.google.common.collect.Multimap<String,String> extraHeaders, com.google.common.collect.Multimap<String,String> extraQueryParams) throws NoSuchAlgorithmException, InsufficientDataException, IOException, InvalidKeyException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException
bucketName - Name of the bucket.region - Region of the bucket (Optional).delimiter - Delimiter (Optional).encodingType - Encoding type (Optional).keyMarker - Key marker (Optional).maxUploads - Maximum upload information to fetch (Optional).prefix - Prefix (Optional).uploadIdMarker - Upload ID marker (Optional).extraHeaders - Extra headers for request (Optional).extraQueryParams - Extra query parameters for request (Optional).ListMultipartUploadsResponse object.ErrorResponseException - thrown to indicate S3 service returned an error response.InsufficientDataException - thrown to indicate not enough data available in InputStream.InternalException - thrown to indicate internal library error.InvalidKeyException - thrown to indicate missing of HMAC SHA-256 library.InvalidResponseException - thrown to indicate S3 service returned invalid or no error
response.IOException - thrown to indicate I/O error on S3 operation.NoSuchAlgorithmException - thrown to indicate missing of MD5 or SHA-256 digest library.XmlParserException - thrown to indicate XML parsing error.ServerExceptionprotected ListPartsResponse listParts(String bucketName, String region, String objectName, Integer maxParts, Integer partNumberMarker, String uploadId, com.google.common.collect.Multimap<String,String> extraHeaders, com.google.common.collect.Multimap<String,String> extraQueryParams) throws NoSuchAlgorithmException, InsufficientDataException, IOException, InvalidKeyException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException
bucketName - Name of the bucket.region - Name of the bucket (Optional).objectName - Object name in the bucket.maxParts - Maximum parts information to fetch (Optional).partNumberMarker - Part number marker (Optional).uploadId - Upload ID.extraHeaders - Extra headers for request (Optional).extraQueryParams - Extra query parameters for request (Optional).ListPartsResponse object.ErrorResponseException - thrown to indicate S3 service returned an error response.InsufficientDataException - thrown to indicate not enough data available in InputStream.InternalException - thrown to indicate internal library error.InvalidKeyException - thrown to indicate missing of HMAC SHA-256 library.InvalidResponseException - thrown to indicate S3 service returned invalid or no error
response.IOException - thrown to indicate I/O error on S3 operation.NoSuchAlgorithmException - thrown to indicate missing of MD5 or SHA-256 digest library.XmlParserException - thrown to indicate XML parsing error.ServerExceptionprotected UploadPartResponse uploadPart(String bucketName, String region, String objectName, Object data, int length, String uploadId, int partNumber, com.google.common.collect.Multimap<String,String> extraHeaders, com.google.common.collect.Multimap<String,String> extraQueryParams) throws NoSuchAlgorithmException, InsufficientDataException, IOException, InvalidKeyException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException
bucketName - Name of the bucket.region - Region of the bucket (Optional).objectName - Object name in the bucket.data - Object data must be BufferedInputStream, RandomAccessFile, byte[] or String.length - Length of object data.uploadId - Upload ID.partNumber - Part number.extraHeaders - Extra headers for request (Optional).extraQueryParams - Extra query parameters for request (Optional).ErrorResponseException - thrown to indicate S3 service returned an error response.InsufficientDataException - thrown to indicate not enough data available in InputStream.InternalException - thrown to indicate internal library error.InvalidKeyException - thrown to indicate missing of HMAC SHA-256 library.InvalidResponseException - thrown to indicate S3 service returned invalid or no error
response.IOException - thrown to indicate I/O error on S3 operation.NoSuchAlgorithmException - thrown to indicate missing of MD5 or SHA-256 digest library.XmlParserException - thrown to indicate XML parsing error.ServerExceptionprotected UploadPartCopyResponse uploadPartCopy(String bucketName, String region, String objectName, String uploadId, int partNumber, com.google.common.collect.Multimap<String,String> headers, com.google.common.collect.Multimap<String,String> extraQueryParams) throws NoSuchAlgorithmException, InsufficientDataException, IOException, InvalidKeyException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException
bucketName - Name of the bucket.region - Region of the bucket (Optional).objectName - Object name in the bucket.uploadId - Upload ID.partNumber - Part number.headers - Request headers with source object definitions.extraQueryParams - Extra query parameters for request (Optional).UploadPartCopyResponse object.ErrorResponseException - thrown to indicate S3 service returned an error response.InsufficientDataException - thrown to indicate not enough data available in InputStream.InternalException - thrown to indicate internal library error.InvalidKeyException - thrown to indicate missing of HMAC SHA-256 library.InvalidResponseException - thrown to indicate S3 service returned invalid or no error
response.IOException - thrown to indicate I/O error on S3 operation.NoSuchAlgorithmException - thrown to indicate missing of MD5 or SHA-256 digest library.XmlParserException - thrown to indicate XML parsing error.ServerException