Add async support

Signed-off-by: Bala.FA <[email protected]>
minio · Apr 4, 2022 · 8fff64c · 8fff64c
1 parent 304b5b7
commit 8fff64c
Show file tree

Hide file tree

Showing 66 changed files with 8,317 additions and 1,591 deletions.
diff --git a/api/src/main/java/io/minio/AbortMultipartUploadResponse.java b/api/src/main/java/io/minio/AbortMultipartUploadResponse.java
@@ -18,7 +18,7 @@
 
 import okhttp3.Headers;
 
-/** Response class of {@link MinioClient#abortMultipartUpload}. */
+/** Response class of {@link S3Base#abortMultipartUploadAsync}. */
 public class AbortMultipartUploadResponse extends GenericResponse {
   private String uploadId;
 

diff --git a/api/src/main/java/io/minio/BucketExistsArgs.java b/api/src/main/java/io/minio/BucketExistsArgs.java
@@ -16,7 +16,7 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#bucketExists}. */
+/** Argument class of {@link MinioAsyncClient#bucketExists} and {@link MinioClient#bucketExists}. */
 public class BucketExistsArgs extends BucketArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/ComposeObjectArgs.java b/api/src/main/java/io/minio/ComposeObjectArgs.java
@@ -21,7 +21,9 @@
 import java.util.Objects;
 import okhttp3.HttpUrl;
 
-/** Argument class of {@link MinioClient#composeObject}. */
+/**
+ * Argument class of {@link MinioAsyncClient#composeObject} and {@link MinioClient#composeObject}.
+ */
 public class ComposeObjectArgs extends ObjectWriteArgs {
   List<ComposeSource> sources;
 

diff --git a/api/src/main/java/io/minio/CopyObjectArgs.java b/api/src/main/java/io/minio/CopyObjectArgs.java
@@ -19,7 +19,7 @@
 import java.util.Objects;
 import okhttp3.HttpUrl;
 
-/** Argument class of {@link MinioClient#copyObject}. */
+/** Argument class of {@link MinioAsyncClient#copyObject} and {@link MinioClient#copyObject}. */
 public class CopyObjectArgs extends ObjectWriteArgs {
   private CopySource source = null;
   private Directive metadataDirective;

diff --git a/api/src/main/java/io/minio/CreateMultipartUploadResponse.java b/api/src/main/java/io/minio/CreateMultipartUploadResponse.java
@@ -19,7 +19,7 @@
 import io.minio.messages.InitiateMultipartUploadResult;
 import okhttp3.Headers;
 
-/** Response class of {@link MinioClient#createMultipartUpload}. */
+/** Response class of {@link S3Base#createMultipartUploadAsync}. */
 public class CreateMultipartUploadResponse extends GenericResponse {
   private InitiateMultipartUploadResult result;
 

diff --git a/api/src/main/java/io/minio/DeleteBucketEncryptionArgs.java b/api/src/main/java/io/minio/DeleteBucketEncryptionArgs.java
@@ -16,7 +16,10 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#deleteBucketEncryption}. */
+/**
+ * Argument class of {@link MinioAsyncClient#deleteBucketEncryption} and {@link
+ * MinioClient#deleteBucketEncryption}.
+ */
 public class DeleteBucketEncryptionArgs extends BucketArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/DeleteBucketLifecycleArgs.java b/api/src/main/java/io/minio/DeleteBucketLifecycleArgs.java
@@ -16,7 +16,10 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#deleteBucketLifecycle}. */
+/**
+ * Argument class of {@link MinioAsyncClient#deleteBucketLifecycle} and {@link
+ * MinioClient#deleteBucketLifecycle}.
+ */
 public class DeleteBucketLifecycleArgs extends BucketArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/DeleteBucketNotificationArgs.java b/api/src/main/java/io/minio/DeleteBucketNotificationArgs.java
@@ -16,7 +16,10 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#deleteBucketNotification}. */
+/**
+ * Argument class of {@link MinioAsyncClient#deleteBucketNotification} and {@link
+ * MinioClient#deleteBucketNotification}.
+ */
 public class DeleteBucketNotificationArgs extends BucketArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/DeleteBucketPolicyArgs.java b/api/src/main/java/io/minio/DeleteBucketPolicyArgs.java
@@ -16,7 +16,10 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#deleteBucketPolicy}. */
+/**
+ * Argument class of {@link MinioAsyncClient#deleteBucketPolicy} and {@link
+ * MinioClient#deleteBucketPolicy}.
+ */
 public class DeleteBucketPolicyArgs extends BucketArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/DeleteBucketReplicationArgs.java b/api/src/main/java/io/minio/DeleteBucketReplicationArgs.java
@@ -16,7 +16,10 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#deleteBucketReplication}. */
+/**
+ * Argument class of {@link MinioAsyncClient#deleteBucketReplication} and {@link
+ * MinioClient#deleteBucketReplication}.
+ */
 public class DeleteBucketReplicationArgs extends BucketArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/DeleteBucketTagsArgs.java b/api/src/main/java/io/minio/DeleteBucketTagsArgs.java
@@ -16,7 +16,10 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#deleteBucketTags}. */
+/**
+ * Argument class of {@link MinioAsyncClient#deleteBucketTags} and {@link
+ * MinioClient#deleteBucketTags}.
+ */
 public class DeleteBucketTagsArgs extends BucketArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/DeleteObjectLockConfigurationArgs.java b/api/src/main/java/io/minio/DeleteObjectLockConfigurationArgs.java
@@ -16,7 +16,10 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#deleteObjectLockConfiguration}. */
+/**
+ * Argument class of {@link MinioAsyncClient#deleteObjectLockConfiguration} and {@link
+ * MinioClient#deleteObjectLockConfiguration}.
+ */
 public class DeleteObjectLockConfigurationArgs extends BucketArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/DeleteObjectTagsArgs.java b/api/src/main/java/io/minio/DeleteObjectTagsArgs.java
@@ -16,7 +16,10 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#deleteObjectTags}. */
+/**
+ * Argument class of {@link MinioAsyncClient#deleteObjectTags} and {@link
+ * MinioClient#deleteObjectTags}.
+ */
 public class DeleteObjectTagsArgs extends ObjectVersionArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/DeleteObjectsResponse.java b/api/src/main/java/io/minio/DeleteObjectsResponse.java
@@ -19,7 +19,7 @@
 import io.minio.messages.DeleteResult;
 import okhttp3.Headers;
 
-/** Response class of {@link MinioClient#listObjectsV1}. */
+/** Response class of {@link S3Base#deleteObjectsAsync}. */
 public class DeleteObjectsResponse extends GenericResponse {
   private DeleteResult result;
 

diff --git a/api/src/main/java/io/minio/DisableObjectLegalHoldArgs.java b/api/src/main/java/io/minio/DisableObjectLegalHoldArgs.java
@@ -16,7 +16,10 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#disableObjectLegalHold}. */
+/**
+ * Argument class of {@link MinioAsyncClient#disableObjectLegalHold} and {@link
+ * MinioClient#disableObjectLegalHold}.
+ */
 public class DisableObjectLegalHoldArgs extends ObjectVersionArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/DownloadObjectArgs.java b/api/src/main/java/io/minio/DownloadObjectArgs.java
@@ -20,7 +20,9 @@
 import java.nio.file.Paths;
 import java.util.Objects;
 
-/** Argument class of {@link MinioClient#downloadObject}. */
+/**
+ * Argument class of {@link MinioAsyncClient#downloadObject} and {@link MinioClient#downloadObject}.
+ */
 public class DownloadObjectArgs extends ObjectReadArgs {
   private String filename;
 

diff --git a/api/src/main/java/io/minio/EnableObjectLegalHoldArgs.java b/api/src/main/java/io/minio/EnableObjectLegalHoldArgs.java
@@ -16,7 +16,10 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#enableObjectLegalHold}. */
+/**
+ * Argument class of {@link MinioAsyncClient#enableObjectLegalHold} and {@link
+ * MinioClient#enableObjectLegalHold}.
+ */
 public class EnableObjectLegalHoldArgs extends ObjectVersionArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/GetBucketEncryptionArgs.java b/api/src/main/java/io/minio/GetBucketEncryptionArgs.java
@@ -16,7 +16,10 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#getBucketEncryption}. */
+/**
+ * Argument class of {@link MinioAsyncClient#getBucketEncryption} and {@link
+ * MinioClient#getBucketEncryption}.
+ */
 public class GetBucketEncryptionArgs extends BucketArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/GetBucketLifecycleArgs.java b/api/src/main/java/io/minio/GetBucketLifecycleArgs.java
@@ -16,7 +16,10 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#getBucketLifecycle}. */
+/**
+ * Argument class of {@link MinioAsyncClient#getBucketLifecycle} and {@link
+ * MinioClient#getBucketLifecycle}.
+ */
 public class GetBucketLifecycleArgs extends BucketArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/GetBucketNotificationArgs.java b/api/src/main/java/io/minio/GetBucketNotificationArgs.java
@@ -16,7 +16,10 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#getBucketNotification}. */
+/**
+ * Argument class of {@link MinioAsyncClient#getBucketNotification} and {@link
+ * MinioClient#getBucketNotification}.
+ */
 public class GetBucketNotificationArgs extends BucketArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/GetBucketPolicyArgs.java b/api/src/main/java/io/minio/GetBucketPolicyArgs.java
@@ -16,7 +16,10 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#getBucketPolicy}. */
+/**
+ * Argument class of {@link MinioAsyncClient#getBucketPolicy} and {@link
+ * MinioClient#getBucketPolicy}.
+ */
 public class GetBucketPolicyArgs extends BucketArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/GetBucketReplicationArgs.java b/api/src/main/java/io/minio/GetBucketReplicationArgs.java
@@ -16,7 +16,10 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#getBucketReplication}. */
+/**
+ * Argument class of {@link MinioAsyncClient#getBucketReplication} and {@link
+ * MinioClient#getBucketReplication}.
+ */
 public class GetBucketReplicationArgs extends BucketArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/GetBucketTagsArgs.java b/api/src/main/java/io/minio/GetBucketTagsArgs.java
@@ -16,7 +16,9 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#getBucketTags}. */
+/**
+ * Argument class of {@link MinioAsyncClient#getBucketTags} and {@link MinioClient#getBucketTags}.
+ */
 public class GetBucketTagsArgs extends BucketArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/GetBucketVersioningArgs.java b/api/src/main/java/io/minio/GetBucketVersioningArgs.java
@@ -16,7 +16,10 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#getBucketVersioning}. */
+/**
+ * Argument class of {@link MinioAsyncClient#getBucketVersioning} and {@link
+ * MinioClient#getBucketVersioning}.
+ */
 public class GetBucketVersioningArgs extends BucketArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/GetObjectArgs.java b/api/src/main/java/io/minio/GetObjectArgs.java
@@ -16,7 +16,7 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#getObject}. */
+/** Argument class of {@link MinioAsyncClient#getObject} and {@link MinioClient#getObject}. */
 public class GetObjectArgs extends ObjectConditionalReadArgs {
   protected GetObjectArgs() {}
 

diff --git a/api/src/main/java/io/minio/GetObjectLockConfigurationArgs.java b/api/src/main/java/io/minio/GetObjectLockConfigurationArgs.java
@@ -16,7 +16,10 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#getObjectLockConfiguration}. */
+/**
+ * Argument class of {@link MinioAsyncClient#getObjectLockConfiguration} and {@link
+ * MinioClient#getObjectLockConfiguration}.
+ */
 public class GetObjectLockConfigurationArgs extends BucketArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/GetObjectResponse.java b/api/src/main/java/io/minio/GetObjectResponse.java
@@ -20,7 +20,11 @@
 import java.io.InputStream;
 import okhttp3.Headers;
 
-/** Response class of {@link MinioClient#getObject}. */
+/**
+ * Response class of {@link MinioAsyncClient#getObject} and {@link MinioClient#getObject}. This
+ * class is {@link InputStream} interface compatible and it must be closed after use to release
+ * underneath network resources.
+ */
 public class GetObjectResponse extends FilterInputStream {
   private GenericResponse response;
 

diff --git a/api/src/main/java/io/minio/GetObjectRetentionArgs.java b/api/src/main/java/io/minio/GetObjectRetentionArgs.java
@@ -16,7 +16,10 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#getObjectRetention}. */
+/**
+ * Argument class of {@link MinioAsyncClient#getObjectRetention} and {@link
+ * MinioClient#getObjectRetention}.
+ */
 public class GetObjectRetentionArgs extends ObjectVersionArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/GetObjectTagsArgs.java b/api/src/main/java/io/minio/GetObjectTagsArgs.java
@@ -16,7 +16,9 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#getObjectTags}. */
+/**
+ * Argument class of {@link MinioAsyncClient#getObjectTags} and {@link MinioClient#getObjectTags}.
+ */
 public class GetObjectTagsArgs extends ObjectVersionArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/GetPresignedObjectUrlArgs.java b/api/src/main/java/io/minio/GetPresignedObjectUrlArgs.java
@@ -20,7 +20,10 @@
 import java.util.Objects;
 import java.util.concurrent.TimeUnit;
 
-/** Argument class of {@link MinioClient#getPresignedObjectUrl}. */
+/**
+ * Argument class of {@link MinioAsyncClient#getPresignedObjectUrl} and {@link
+ * MinioClient#getPresignedObjectUrl}.
+ */
 public class GetPresignedObjectUrlArgs extends ObjectVersionArgs {
   // default expiration for a presigned URL is 7 days in seconds
   public static final int DEFAULT_EXPIRY_TIME = (int) TimeUnit.DAYS.toSeconds(7);

diff --git a/api/src/main/java/io/minio/IsObjectLegalHoldEnabledArgs.java b/api/src/main/java/io/minio/IsObjectLegalHoldEnabledArgs.java
@@ -16,7 +16,10 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#isObjectLegalHoldEnabled}. */
+/**
+ * Argument class of {@link MinioAsyncClient#isObjectLegalHoldEnabled} and {@link
+ * MinioClient#isObjectLegalHoldEnabled}.
+ */
 public class IsObjectLegalHoldEnabledArgs extends ObjectVersionArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/ListBucketsArgs.java b/api/src/main/java/io/minio/ListBucketsArgs.java
@@ -16,7 +16,7 @@
 
 package io.minio;
 
-/** Argument class of {@link MinioClient#listBuckets}. */
+/** Argument class of {@link MinioAsyncClient#listBuckets} and {@link MinioClient#listBuckets}. */
 public class ListBucketsArgs extends BaseArgs {
   public static Builder builder() {
     return new Builder();

diff --git a/api/src/main/java/io/minio/ListMultipartUploadsResponse.java b/api/src/main/java/io/minio/ListMultipartUploadsResponse.java
@@ -19,7 +19,7 @@
 import io.minio.messages.ListMultipartUploadsResult;
 import okhttp3.Headers;
 
-/** Response class of {@link MinioClient#listMultipartUploads}. */
+/** Response class of {@link S3Base#listMultipartUploadsAsync}. */
 public class ListMultipartUploadsResponse extends GenericResponse {
   private ListMultipartUploadsResult result;
 

diff --git a/api/src/main/java/io/minio/ListObjectVersionsResponse.java b/api/src/main/java/io/minio/ListObjectVersionsResponse.java
@@ -19,7 +19,7 @@
 import io.minio.messages.ListVersionsResult;
 import okhttp3.Headers;
 
-/** Response class of {@link MinioClient#listObjectVersions}. */
+/** Response class of {@link S3Base#listObjectVersionsAsync}. */
 public class ListObjectVersionsResponse extends GenericResponse {
   private ListVersionsResult result;
 

diff --git a/api/src/main/java/io/minio/ListObjectsArgs.java b/api/src/main/java/io/minio/ListObjectsArgs.java
@@ -18,7 +18,7 @@
 
 import java.util.Objects;
 
-/** Argument class of {@link MinioClient#listObjects}. */
+/** Argument class of {@link MinioAsyncClient#listObjects} and {@link MinioClient#listObjects}. */
 public class ListObjectsArgs extends BucketArgs {
   private String delimiter = "";
   private boolean useUrlEncodingType = true;

diff --git a/api/src/main/java/io/minio/ListObjectsV1Response.java b/api/src/main/java/io/minio/ListObjectsV1Response.java
@@ -19,7 +19,7 @@
 import io.minio.messages.ListBucketResultV1;
 import okhttp3.Headers;
 
-/** Response class of {@link MinioClient#listObjectsV1}. */
+/** Response class of {@link S3Base#listObjectsV1}. */
 public class ListObjectsV1Response extends GenericResponse {
   private ListBucketResultV1 result;