public abstract class S3Base extends Object implements AutoCloseable
Modifier and Type | Class and Description |
---|---|
protected static class |
S3Base.NotificationResultRecords
Notification result records representation.
|
Modifier and Type | Field and Description |
---|---|
protected String |
awsDomainSuffix |
protected boolean |
awsDualstack |
protected String |
awsS3Prefix |
protected okhttp3.HttpUrl |
baseUrl |
protected boolean |
closeHttpClient |
protected static long |
DEFAULT_CONNECTION_TIMEOUT |
protected okhttp3.OkHttpClient |
httpClient |
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 |
protected boolean |
useVirtualStyle |
Modifier | Constructor and Description |
---|---|
protected |
S3Base(okhttp3.HttpUrl baseUrl,
String region,
boolean isAwsHost,
boolean isFipsHost,
boolean isAccelerateHost,
boolean isDualStackHost,
boolean useVirtualStyle,
Provider provider,
okhttp3.OkHttpClient httpClient)
Deprecated.
This method is no longer supported.
|
protected |
S3Base(okhttp3.HttpUrl baseUrl,
String awsS3Prefix,
String awsDomainSuffix,
boolean awsDualstack,
boolean useVirtualStyle,
String region,
Provider provider,
okhttp3.OkHttpClient httpClient)
Deprecated.
This method is no longer supported.
|
protected |
S3Base(okhttp3.HttpUrl baseUrl,
String awsS3Prefix,
String awsDomainSuffix,
boolean awsDualstack,
boolean useVirtualStyle,
String region,
Provider provider,
okhttp3.OkHttpClient httpClient,
boolean closeHttpClient) |
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 CompletableFuture<AbortMultipartUploadResponse> |
abortMultipartUploadAsync(String bucketName,
String region,
String objectName,
String uploadId,
com.google.common.collect.Multimap<String,String> extraHeaders,
com.google.common.collect.Multimap<String,String> extraQueryParams)
Do AbortMultipartUpload
S3 API asynchronously.
|
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)
Deprecated.
|
protected CompletableFuture<Integer> |
calculatePartCountAsync(List<ComposeSource> sources) |
protected void |
checkArgs(BaseArgs args)
Check whether argument is valid or not.
|
void |
close() |
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)
Deprecated.
This method is no longer supported. Use
completeMultipartUploadAsync(java.lang.String, java.lang.String, java.lang.String, java.lang.String, io.minio.messages.Part[], com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>) . |
protected CompletableFuture<ObjectWriteResponse> |
completeMultipartUploadAsync(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)
Do CompleteMultipartUpload
S3 API asynchronously.
|
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 CompletableFuture<CreateMultipartUploadResponse> |
createMultipartUploadAsync(String bucketName,
String region,
String objectName,
com.google.common.collect.Multimap<String,String> headers,
com.google.common.collect.Multimap<String,String> extraQueryParams)
Do CreateMultipartUpload
S3 API asynchronously.
|
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)
Deprecated.
This method is no longer supported. Use
deleteObjectsAsync(java.lang.String, java.lang.String, java.util.List<io.minio.messages.DeleteObject>, boolean, boolean, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>) . |
protected CompletableFuture<DeleteObjectsResponse> |
deleteObjectsAsync(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)
Do DeleteObjects S3
API asynchronously.
|
void |
disableAccelerateEndpoint()
Deprecated.
This method is no longer supported.
|
void |
disableDualStackEndpoint()
Disables dual-stack endpoint for Amazon S3 endpoint.
|
void |
disableVirtualStyleEndpoint()
Disables virtual-style endpoint.
|
void |
enableAccelerateEndpoint()
Deprecated.
This method is no longer supported.
|
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)
Deprecated.
|
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)
Deprecated.
|
protected CompletableFuture<okhttp3.Response> |
executeAsync(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 asynchronously for given args and parameters.
|
protected CompletableFuture<okhttp3.Response> |
executeAsync(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 asynchronously 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)
Deprecated.
|
protected CompletableFuture<okhttp3.Response> |
executeDeleteAsync(BaseArgs args,
com.google.common.collect.Multimap<String,String> headers,
com.google.common.collect.Multimap<String,String> queryParams)
Execute asynchronously 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)
Deprecated.
|
protected CompletableFuture<okhttp3.Response> |
executeGetAsync(BaseArgs args,
com.google.common.collect.Multimap<String,String> headers,
com.google.common.collect.Multimap<String,String> queryParams)
Execute asynchronously 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)
Deprecated.
|
protected CompletableFuture<okhttp3.Response> |
executeHeadAsync(BaseArgs args,
com.google.common.collect.Multimap<String,String> headers,
com.google.common.collect.Multimap<String,String> queryParams)
Execute asynchronously 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)
Deprecated.
|
protected CompletableFuture<okhttp3.Response> |
executePostAsync(BaseArgs args,
com.google.common.collect.Multimap<String,String> headers,
com.google.common.collect.Multimap<String,String> queryParams,
Object data)
Execute asynchronously 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)
Deprecated.
|
protected CompletableFuture<okhttp3.Response> |
executePutAsync(BaseArgs args,
com.google.common.collect.Multimap<String,String> headers,
com.google.common.collect.Multimap<String,String> queryParams,
Object data,
int length)
Execute asynchronously PUT HTTP request for given parameters.
|
protected String |
getRegion(String bucketName,
String region)
Deprecated.
This method is no longer supported. Use
getRegionAsync(java.lang.String, java.lang.String) . |
protected CompletableFuture<String> |
getRegionAsync(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)
Deprecated.
This method is no longer supported. Use
listMultipartUploadsAsync(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.Integer, java.lang.String, java.lang.String, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>) . |
protected CompletableFuture<ListMultipartUploadsResponse> |
listMultipartUploadsAsync(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)
Do ListMultipartUploads
S3 API asynchronously.
|
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)
Deprecated.
This method is no longer supported. Use
listObjectsV1Async(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.Integer, java.lang.String, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>) . |
protected CompletableFuture<ListObjectsV1Response> |
listObjectsV1Async(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)
Do ListObjects
version 1 S3 API asynchronously.
|
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)
Deprecated.
This method is no longer supported. Use
listObjectsV2Async(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.Integer, java.lang.String, java.lang.String, boolean, boolean, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>) . |
protected CompletableFuture<ListObjectsV2Response> |
listObjectsV2Async(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)
Do ListObjects
version 1 S3 API asynchronously.
|
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)
Deprecated.
This method is no longer supported. Use
listObjectVersionsAsync(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.Integer, java.lang.String, java.lang.String, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>) . |
protected CompletableFuture<ListObjectVersionsResponse> |
listObjectVersionsAsync(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)
Do ListObjectVersions
API asynchronously.
|
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)
Deprecated.
This method is no longer supported. Use
listPartsAsync(java.lang.String, java.lang.String, java.lang.String, java.lang.Integer, java.lang.Integer, java.lang.String, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>) . |
protected CompletableFuture<ListPartsResponse> |
listPartsAsync(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 asynchronously.
|
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 io.minio.PartReader |
newPartReader(Object data,
long objectSize,
long partSize,
int partCount) |
protected ObjectWriteResponse |
putObject(PutObjectBaseArgs args,
Object data,
long objectSize,
long partSize,
int partCount,
String contentType)
Deprecated.
This method is no longer supported. Use
putObjectAsync(io.minio.PutObjectBaseArgs, java.lang.Object, long, long, int, java.lang.String) . |
protected ObjectWriteResponse |
putObject(String bucketName,
String region,
String objectName,
Object data,
long length,
com.google.common.collect.Multimap<String,String> headers,
com.google.common.collect.Multimap<String,String> extraQueryParams)
Deprecated.
This method is no longer supported. Use
putObjectAsync(io.minio.PutObjectBaseArgs, java.lang.Object, long, long, int, java.lang.String) . |
protected CompletableFuture<ObjectWriteResponse> |
putObjectAsync(PutObjectBaseArgs args,
Object data,
long objectSize,
long partSize,
int partCount,
String contentType)
Execute put object asynchronously from object data from
RandomAccessFile or InputStream . |
protected CompletableFuture<ObjectWriteResponse> |
putObjectAsync(String bucketName,
String region,
String objectName,
Object data,
long length,
com.google.common.collect.Multimap<String,String> headers,
com.google.common.collect.Multimap<String,String> extraQueryParams)
Do PutObject S3
API asynchronously.
|
void |
setAppInfo(String name,
String version)
Sets application's name/version to user agent.
|
void |
setAwsS3Prefix(String awsS3Prefix)
Sets AWS S3 domain prefix.
|
void |
setTimeout(long connectTimeout,
long writeTimeout,
long readTimeout)
Sets HTTP connect, write and read timeouts.
|
protected CompletableFuture<StatObjectResponse> |
statObjectAsync(StatObjectArgs args)
Execute stat object asynchronously.
|
void |
throwEncapsulatedException(ExecutionException e)
Throws encapsulated exception wrapped by
ExecutionException . |
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,
long length,
String uploadId,
int partNumber,
com.google.common.collect.Multimap<String,String> extraHeaders,
com.google.common.collect.Multimap<String,String> extraQueryParams)
Deprecated.
|
protected CompletableFuture<UploadPartResponse> |
uploadPartAsync(String bucketName,
String region,
String objectName,
Object data,
long length,
String uploadId,
int partNumber,
com.google.common.collect.Multimap<String,String> extraHeaders,
com.google.common.collect.Multimap<String,String> extraQueryParams)
Do UploadPart S3
API asynchronously.
|
protected CompletableFuture<UploadPartResponse> |
uploadPartAsync(String bucketName,
String region,
String objectName,
io.minio.PartSource partSource,
int partNumber,
String uploadId,
com.google.common.collect.Multimap<String,String> extraHeaders,
com.google.common.collect.Multimap<String,String> extraQueryParams)
Do UploadPart S3
API for PartSource asynchronously.
|
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 CompletableFuture<UploadPartCopyResponse> |
uploadPartCopyAsync(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 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 awsS3Prefix
protected String awsDomainSuffix
protected boolean awsDualstack
protected boolean useVirtualStyle
protected String region
protected Provider provider
protected okhttp3.OkHttpClient httpClient
protected boolean closeHttpClient
@Deprecated protected S3Base(okhttp3.HttpUrl baseUrl, String awsS3Prefix, String awsDomainSuffix, boolean awsDualstack, boolean useVirtualStyle, String region, Provider provider, okhttp3.OkHttpClient httpClient)
protected S3Base(okhttp3.HttpUrl baseUrl, String awsS3Prefix, String awsDomainSuffix, boolean awsDualstack, boolean useVirtualStyle, String region, Provider provider, okhttp3.OkHttpClient httpClient, boolean closeHttpClient)
@Deprecated protected S3Base(okhttp3.HttpUrl baseUrl, String region, boolean isAwsHost, boolean isFipsHost, boolean isAccelerateHost, 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)
public void throwEncapsulatedException(ExecutionException e) throws ErrorResponseException, InsufficientDataException, InternalException, InvalidKeyException, InvalidResponseException, IOException, NoSuchAlgorithmException, ServerException, XmlParserException
ExecutionException
.protected okhttp3.HttpUrl buildUrl(Method method, String bucketName, String objectName, String region, com.google.common.collect.Multimap<String,String> queryParamMap) throws NoSuchAlgorithmException
NoSuchAlgorithmException
protected 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 CompletableFuture<okhttp3.Response> executeAsync(Method method, String bucketName, String objectName, String region, okhttp3.Headers headers, com.google.common.collect.Multimap<String,String> queryParamMap, Object body, int length) throws InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
protected CompletableFuture<okhttp3.Response> executeAsync(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 InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
@Deprecated 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
executeAsync(io.minio.http.Method, java.lang.String, java.lang.String, java.lang.String, okhttp3.Headers, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, java.lang.Object, int)
.@Deprecated 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
executeAsync(io.minio.http.Method, java.lang.String, java.lang.String, java.lang.String, okhttp3.Headers, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, java.lang.Object, int)
.protected CompletableFuture<String> getRegionAsync(String bucketName, String region) throws InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
@Deprecated protected String getRegion(String bucketName, String region) throws ErrorResponseException, InsufficientDataException, InternalException, InvalidKeyException, InvalidResponseException, IOException, NoSuchAlgorithmException, ServerException, XmlParserException
getRegionAsync(java.lang.String, java.lang.String)
.protected CompletableFuture<okhttp3.Response> executeGetAsync(BaseArgs args, com.google.common.collect.Multimap<String,String> headers, com.google.common.collect.Multimap<String,String> queryParams) throws InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
@Deprecated 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
executeGetAsync(io.minio.BaseArgs, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>)
.protected CompletableFuture<okhttp3.Response> executeHeadAsync(BaseArgs args, com.google.common.collect.Multimap<String,String> headers, com.google.common.collect.Multimap<String,String> queryParams) throws InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
@Deprecated 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
executeHeadAsync(io.minio.BaseArgs, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>)
.protected CompletableFuture<okhttp3.Response> executeDeleteAsync(BaseArgs args, com.google.common.collect.Multimap<String,String> headers, com.google.common.collect.Multimap<String,String> queryParams) throws InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
@Deprecated 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
executeDeleteAsync(io.minio.BaseArgs, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>)
.protected CompletableFuture<okhttp3.Response> executePostAsync(BaseArgs args, com.google.common.collect.Multimap<String,String> headers, com.google.common.collect.Multimap<String,String> queryParams, Object data) throws InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
@Deprecated 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
executePostAsync(io.minio.BaseArgs, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, java.lang.Object)
.protected CompletableFuture<okhttp3.Response> executePutAsync(BaseArgs args, com.google.common.collect.Multimap<String,String> headers, com.google.common.collect.Multimap<String,String> queryParams, Object data, int length) throws InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
@Deprecated 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
executePutAsync(io.minio.BaseArgs, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, java.lang.Object, int)
.protected CompletableFuture<Integer> calculatePartCountAsync(List<ComposeSource> sources) throws InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
@Deprecated 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 io.minio.PartReader newPartReader(Object data, long objectSize, long partSize, int partCount)
@Deprecated 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
putObjectAsync(io.minio.PutObjectBaseArgs, java.lang.Object, long, long, int, java.lang.String)
.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)
@Deprecated public void enableAccelerateEndpoint()
@Deprecated public void disableAccelerateEndpoint()
public void enableDualStackEndpoint()
public void disableDualStackEndpoint()
public void enableVirtualStyleEndpoint()
public void disableVirtualStyleEndpoint()
protected CompletableFuture<StatObjectResponse> statObjectAsync(StatObjectArgs args) throws InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
protected CompletableFuture<AbortMultipartUploadResponse> abortMultipartUploadAsync(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 InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
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).CompletableFuture
<AbortMultipartUploadResponse
> object.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.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.@Deprecated 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
abortMultipartUploadAsync(java.lang.String, java.lang.String, java.lang.String, java.lang.String, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>)
.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.ServerException
protected CompletableFuture<ObjectWriteResponse> completeMultipartUploadAsync(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 InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
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).CompletableFuture
<ObjectWriteResponse
> object.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.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.@Deprecated 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) throws NoSuchAlgorithmException, InsufficientDataException, IOException, InvalidKeyException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException
completeMultipartUploadAsync(java.lang.String, java.lang.String, java.lang.String, java.lang.String, io.minio.messages.Part[], com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>)
.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.ServerException
protected CompletableFuture<CreateMultipartUploadResponse> createMultipartUploadAsync(String bucketName, String region, String objectName, com.google.common.collect.Multimap<String,String> headers, com.google.common.collect.Multimap<String,String> extraQueryParams) throws InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
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).CompletableFuture
<CreateMultipartUploadResponse
> object.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.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.@Deprecated 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) throws NoSuchAlgorithmException, InsufficientDataException, IOException, InvalidKeyException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException
createMultipartUploadAsync(java.lang.String, java.lang.String, java.lang.String, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>)
.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.ServerException
protected CompletableFuture<DeleteObjectsResponse> deleteObjectsAsync(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 InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
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).CompletableFuture
<DeleteObjectsResponse
> object.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.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.@Deprecated 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) throws NoSuchAlgorithmException, InsufficientDataException, IOException, InvalidKeyException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException
deleteObjectsAsync(java.lang.String, java.lang.String, java.util.List<io.minio.messages.DeleteObject>, boolean, boolean, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>)
.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.ServerException
protected CompletableFuture<ListObjectsV2Response> listObjectsV2Async(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 InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
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).CompletableFuture
<ListObjectsV2Response
> object.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.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.@Deprecated 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) throws InvalidKeyException, NoSuchAlgorithmException, InsufficientDataException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException, IOException
listObjectsV2Async(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.Integer, java.lang.String, java.lang.String, boolean, boolean, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>)
.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.ServerException
protected CompletableFuture<ListObjectsV1Response> listObjectsV1Async(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 InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
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).CompletableFuture
<ListObjectsV1Response
> object.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.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.@Deprecated 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) throws NoSuchAlgorithmException, InsufficientDataException, IOException, InvalidKeyException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException
listObjectsV1Async(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.Integer, java.lang.String, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>)
.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.ServerException
protected CompletableFuture<ListObjectVersionsResponse> listObjectVersionsAsync(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 InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
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).CompletableFuture
<ListObjectVersionsResponse
> object.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.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.@Deprecated 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) throws NoSuchAlgorithmException, InsufficientDataException, IOException, InvalidKeyException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException
listObjectVersionsAsync(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.Integer, java.lang.String, java.lang.String, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>)
.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.ServerException
protected CompletableFuture<ObjectWriteResponse> putObjectAsync(PutObjectBaseArgs args, Object data, long objectSize, long partSize, int partCount, String contentType) throws InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
RandomAccessFile
or InputStream
.args
- PutObjectBaseArgs
.data
- RandomAccessFile
or InputStream
.objectSize
- object size.partSize
- part size for multipart upload.partCount
- Number of parts for multipart upload.contentType
- content-type of object.CompletableFuture
<ObjectWriteResponse
> object.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.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.protected CompletableFuture<ObjectWriteResponse> putObjectAsync(String bucketName, String region, String objectName, Object data, long length, com.google.common.collect.Multimap<String,String> headers, com.google.common.collect.Multimap<String,String> extraQueryParams) throws InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
bucketName
- Name of the bucket.objectName
- Object name in the bucket.data
- Object data must be InputStream, RandomAccessFile, byte[] or String.length
- Length of object data.headers
- Additional headers.extraQueryParams
- Additional query parameters if any.CompletableFuture
<ObjectWriteResponse
> object.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.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.@Deprecated protected ObjectWriteResponse putObject(String bucketName, String region, String objectName, Object data, long 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
putObjectAsync(io.minio.PutObjectBaseArgs, java.lang.Object, long, long, int, java.lang.String)
.bucketName
- Name of the bucket.objectName
- Object name in the bucket.data
- Object data must be InputStream, 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.ServerException
protected CompletableFuture<ListMultipartUploadsResponse> listMultipartUploadsAsync(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 InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
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).CompletableFuture
<ListMultipartUploadsResponse
> object.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.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.@Deprecated 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) throws NoSuchAlgorithmException, InsufficientDataException, IOException, InvalidKeyException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException
listMultipartUploadsAsync(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.Integer, java.lang.String, java.lang.String, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>)
.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.ServerException
protected CompletableFuture<ListPartsResponse> listPartsAsync(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 InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
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).CompletableFuture
<ListPartsResponse
> object.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.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.@Deprecated 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) throws NoSuchAlgorithmException, InsufficientDataException, IOException, InvalidKeyException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException
listPartsAsync(java.lang.String, java.lang.String, java.lang.String, java.lang.Integer, java.lang.Integer, java.lang.String, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>)
.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.ServerException
protected CompletableFuture<UploadPartResponse> uploadPartAsync(String bucketName, String region, String objectName, io.minio.PartSource partSource, int partNumber, String uploadId, com.google.common.collect.Multimap<String,String> extraHeaders, com.google.common.collect.Multimap<String,String> extraQueryParams) throws InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
bucketName
- Name of the bucket.region
- Region of the bucket (Optional).objectName
- Object name in the bucket.partSource
- PartSource Object.partNumber
- Part number.uploadId
- Upload ID.extraHeaders
- Extra headers for request (Optional).extraQueryParams
- Extra query parameters for request (Optional).CompletableFuture
<UploadPartResponse
> object.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.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.protected CompletableFuture<UploadPartResponse> uploadPartAsync(String bucketName, String region, String objectName, Object data, long length, String uploadId, int partNumber, com.google.common.collect.Multimap<String,String> extraHeaders, com.google.common.collect.Multimap<String,String> extraQueryParams) throws InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
bucketName
- Name of the bucket.region
- Region of the bucket (Optional).objectName
- Object name in the bucket.data
- Object data must be InputStream, 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).CompletableFuture
<UploadPartResponse
> object.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.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.@Deprecated protected UploadPartResponse uploadPart(String bucketName, String region, String objectName, Object data, long 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
uploadPartAsync(java.lang.String, java.lang.String, java.lang.String, io.minio.PartSource, int, java.lang.String, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>)
.bucketName
- Name of the bucket.region
- Region of the bucket (Optional).objectName
- Object name in the bucket.data
- Object data must be InputStream, 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).UploadPartResponse
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
@Deprecated 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) throws NoSuchAlgorithmException, InsufficientDataException, IOException, InvalidKeyException, ServerException, XmlParserException, ErrorResponseException, InternalException, InvalidResponseException
uploadPartCopyAsync(java.lang.String, java.lang.String, java.lang.String, java.lang.String, int, com.google.common.collect.Multimap<java.lang.String, java.lang.String>, com.google.common.collect.Multimap<java.lang.String, java.lang.String>)
.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
protected CompletableFuture<UploadPartCopyResponse> uploadPartCopyAsync(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 InsufficientDataException, InternalException, InvalidKeyException, IOException, NoSuchAlgorithmException, XmlParserException
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).CompletableFuture
<UploadPartCopyResponse
> object.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.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.public void close() throws Exception
close
in interface AutoCloseable
Exception