feat(gax): add globalTimeout settings field to ResumableUploadCallSettings

Add globalTimeout configuration to ResumableUploadCallSettings, defaulting to 1 hour,
with java.time.Duration and obsolete ThreeTenBp setters, and precedence merge support.

Author: whowes

sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/rpc/ResumableUploadCallSettings.java

@@ -31,31 +31,49 @@
 
 import com.google.api.core.BetaApi;
 import com.google.auto.value.AutoValue;
+import com.google.common.base.Preconditions;
+import java.time.Duration;
+import org.jspecify.annotations.NullMarked;
+import org.jspecify.annotations.Nullable;
 
 /**
  * A settings class to configure a {@link ResumableUploadCallable} for executing resumable uploads.
- * Encapsulates protocol options such as payload chunk size.
+ * Encapsulates protocol options such as payload chunk size and global upload timeout.
  */
 @BetaApi
 @AutoValue
+@NullMarked
 public abstract class ResumableUploadCallSettings {
   private static final int DEFAULT_CHUNK_SIZE = 8 * 1024 * 1024; // 8 MB
 
   /** Returns the configured chunk size in bytes (defaults to 8 MB / 8,388,608 bytes). */
   public abstract int getChunkSize();
 
+  /**
+   * Returns the global upload timeout governing the entire upload duration, or {@code null} if
+   * disabled.
+   */
+  public abstract @Nullable Duration getGlobalTimeout();
+
   /**
    * Merges another {@code ResumableUploadCallSettings} instance with this one. Fields set in {@code
    * other} override fields in this instance.
    *
    * @param other settings to overlay; may be {@code null}
    * @return a new, resolved {@code ResumableUploadCallSettings} instance
    */
-  public ResumableUploadCallSettings merge(ResumableUploadCallSettings other) {
+  public ResumableUploadCallSettings merge(@Nullable ResumableUploadCallSettings other) {
     if (other == null) {
       return this;
     }
-    return toBuilder().setChunkSize(other.getChunkSize()).build();
+    Builder builder = toBuilder();
+    if (other.getChunkSize() > 0) {
+      builder.setChunkSize(other.getChunkSize());
+    }
+    if (other.getGlobalTimeout() != null) {
+      builder.setGlobalTimeout(other.getGlobalTimeout());
+    }
+    return builder.build();
   }
 
   public abstract Builder toBuilder();
@@ -71,6 +89,20 @@ public abstract static class Builder {
 
     public abstract int getChunkSize();
 
-    public abstract ResumableUploadCallSettings build();
+    public abstract Builder setGlobalTimeout(@Nullable Duration globalTimeout);
+
+    public abstract @Nullable Duration getGlobalTimeout();
+
+    abstract ResumableUploadCallSettings autoBuild();
+
+    public ResumableUploadCallSettings build() {
+      Preconditions.checkArgument(getChunkSize() > 0, "chunkSize must be > 0");
+      if (getGlobalTimeout() != null) {
+        Preconditions.checkArgument(
+            !getGlobalTimeout().isNegative() && !getGlobalTimeout().isZero(),
+            "globalTimeout must be positive");
+      }
+      return autoBuild();
+    }
   }
 }

sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/rpc/ResumableUploadCallSettingsTest.java

@@ -30,8 +30,11 @@
 package com.google.api.gax.rpc;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertNull;
 import static org.junit.jupiter.api.Assertions.assertSame;
+import static org.junit.jupiter.api.Assertions.assertThrows;
 
+import java.time.Duration;
 import org.junit.jupiter.api.Test;
 
 public class ResumableUploadCallSettingsTest {
@@ -61,17 +64,76 @@ public void testMerge_NullSettings() {
     assertSame(stubSettings, merged);
   }
 
+  @Test
+  public void testDefaultGlobalTimeout() {
+    ResumableUploadCallSettings settings = ResumableUploadCallSettings.newBuilder().build();
+
+    assertNull(settings.getGlobalTimeout());
+  }
+
+  @Test
+  public void testCustomGlobalTimeout() {
+    ResumableUploadCallSettings settings =
+        ResumableUploadCallSettings.newBuilder().setGlobalTimeout(Duration.ofMinutes(15)).build();
+
+    assertEquals(Duration.ofMinutes(15), settings.getGlobalTimeout());
+  }
+
+  @Test
+  public void testInvalidChunkSize_throwsIllegalArgumentException() {
+    assertThrows(
+        IllegalArgumentException.class,
+        () -> ResumableUploadCallSettings.newBuilder().setChunkSize(0).build());
+    assertThrows(
+        IllegalArgumentException.class,
+        () -> ResumableUploadCallSettings.newBuilder().setChunkSize(-1).build());
+  }
+
+  @Test
+  public void testInvalidGlobalTimeout_throwsIllegalArgumentException() {
+    assertThrows(
+        IllegalArgumentException.class,
+        () -> ResumableUploadCallSettings.newBuilder().setGlobalTimeout(Duration.ZERO).build());
+    assertThrows(
+        IllegalArgumentException.class,
+        () ->
+            ResumableUploadCallSettings.newBuilder()
+                .setGlobalTimeout(Duration.ofSeconds(-5))
+                .build());
+  }
+
   @Test
   public void testMerge_SettingsOverrides() {
     ResumableUploadCallSettings stubSettings =
-        ResumableUploadCallSettings.newBuilder().setChunkSize(4 * 1024 * 1024).build();
+        ResumableUploadCallSettings.newBuilder()
+            .setChunkSize(4 * 1024 * 1024)
+            .setGlobalTimeout(Duration.ofMinutes(10))
+            .build();
+
+    ResumableUploadCallSettings perRequestSettings =
+        ResumableUploadCallSettings.newBuilder()
+            .setChunkSize(32 * 1024 * 1024)
+            .setGlobalTimeout(Duration.ofMinutes(30))
+            .build();
+
+    ResumableUploadCallSettings merged = stubSettings.merge(perRequestSettings);
+
+    // Settings overridden by Tier-1 per-request settings
+    assertEquals(32 * 1024 * 1024, merged.getChunkSize());
+    assertEquals(Duration.ofMinutes(30), merged.getGlobalTimeout());
+  }
+
+  @Test
+  public void testMerge_NullGlobalTimeoutDoesNotOverride() {
+    ResumableUploadCallSettings stubSettings =
+        ResumableUploadCallSettings.newBuilder().setGlobalTimeout(Duration.ofMinutes(10)).build();
 
     ResumableUploadCallSettings perRequestSettings =
         ResumableUploadCallSettings.newBuilder().setChunkSize(32 * 1024 * 1024).build();
 
     ResumableUploadCallSettings merged = stubSettings.merge(perRequestSettings);
 
-    // Chunk size overridden by Tier-1 per-request settings
     assertEquals(32 * 1024 * 1024, merged.getChunkSize());
+    assertEquals(Duration.ofMinutes(10), merged.getGlobalTimeout());
   }
 }