feat: introduce java.time methods and variables

README.md

@@ -56,13 +56,13 @@ implementation 'com.google.cloud:google-cloud-datastore'
 If you are using Gradle without BOM, add this to your dependencies:
 
 ```Groovy
-implementation 'com.google.cloud:google-cloud-datastore:2.24.2'
+implementation 'com.google.cloud:google-cloud-datastore:2.24.3'
 ```
 
 If you are using SBT, add this to your dependencies:
 
 ```Scala
-libraryDependencies += "com.google.cloud" % "google-cloud-datastore" % "2.24.2"
+libraryDependencies += "com.google.cloud" % "google-cloud-datastore" % "2.24.3"
 ```
 
 ## Authentication
@@ -479,7 +479,7 @@ Java is a registered trademark of Oracle and/or its affiliates.
 [kokoro-badge-link-5]: http://storage.googleapis.com/cloud-devrel-public/java/badges/java-datastore/java11.html
 [stability-image]: https://img.shields.io/badge/stability-stable-green
 [maven-version-image]: https://img.shields.io/maven-central/v/com.google.cloud/google-cloud-datastore.svg
-[maven-version-link]: https://central.sonatype.com/artifact/com.google.cloud/google-cloud-datastore/2.24.2
+[maven-version-link]: https://central.sonatype.com/artifact/com.google.cloud/google-cloud-datastore/2.24.3
 [authentication]: https://github.com/googleapis/google-cloud-java#authentication
 [auth-scopes]: https://developers.google.com/identity/protocols/oauth2/scopes
 [predefined-iam-roles]: https://cloud.google.com/iam/docs/understanding-roles#predefined_roles

google-cloud-datastore/src/main/java/com/google/cloud/datastore/admin/v1/DatastoreAdminSettings.java

@@ -117,7 +117,7 @@
  * RetrySettings.newBuilder()
  * .setInitialRetryDelayDuration(Duration.ofMillis(500))
  * .setRetryDelayMultiplier(1.5)
- * .setMaxRetryDelay(Duration.ofMillis(5000))
+ * .setMaxRetryDelayDuration(Duration.ofMillis(5000))
  * .setTotalTimeoutDuration(Duration.ofHours(24))
  * .build());
  * datastoreAdminSettingsBuilder

google-cloud-datastore/src/main/java/com/google/cloud/datastore/admin/v1/stub/DatastoreAdminStubSettings.java

@@ -67,9 +67,9 @@
 import com.google.longrunning.Operation;
 import com.google.protobuf.Empty;
 import java.io.IOException;
+import java.time.Duration;
 import java.util.List;
 import javax.annotation.Generated;
-import org.threeten.bp.Duration;
 
 // AUTO-GENERATED DOCUMENTATION AND CLASS.
 /**
@@ -138,7 +138,7 @@
  * RetrySettings.newBuilder()
  * .setInitialRetryDelayDuration(Duration.ofMillis(500))
  * .setRetryDelayMultiplier(1.5)
- * .setMaxRetryDelay(Duration.ofMillis(5000))
+ * .setMaxRetryDelayDuration(Duration.ofMillis(5000))
  * .setTotalTimeoutDuration(Duration.ofHours(24))
  * .build());
  * datastoreAdminSettingsBuilder
@@ -449,21 +449,21 @@ public static class Builder extends StubSettings.Builder<DatastoreAdminStubSetti
  RetrySettings settings = null;
  settings =
  RetrySettings.newBuilder()
- .setInitialRpcTimeout(Duration.ofMillis(60000L))
+ .setInitialRpcTimeoutDuration(Duration.ofMillis(60000L))
  .setRpcTimeoutMultiplier(1.0)
- .setMaxRpcTimeout(Duration.ofMillis(60000L))
- .setTotalTimeout(Duration.ofMillis(60000L))
+ .setMaxRpcTimeoutDuration(Duration.ofMillis(60000L))
+ .setTotalTimeoutDuration(Duration.ofMillis(60000L))
  .build();
  definitions.put("no_retry_0_params", settings);
  settings =
  RetrySettings.newBuilder()
- .setInitialRetryDelay(Duration.ofMillis(100L))
+ .setInitialRetryDelayDuration(Duration.ofMillis(100L))
  .setRetryDelayMultiplier(1.3)
- .setMaxRetryDelay(Duration.ofMillis(60000L))
- .setInitialRpcTimeout(Duration.ofMillis(60000L))
+ .setMaxRetryDelayDuration(Duration.ofMillis(60000L))
+ .setInitialRpcTimeoutDuration(Duration.ofMillis(60000L))
  .setRpcTimeoutMultiplier(1.0)
- .setMaxRpcTimeout(Duration.ofMillis(60000L))
- .setTotalTimeout(Duration.ofMillis(60000L))
+ .setMaxRpcTimeoutDuration(Duration.ofMillis(60000L))
+ .setTotalTimeoutDuration(Duration.ofMillis(60000L))
  .build();
  definitions.put("retry_policy_1_params", settings);
  RETRY_PARAM_DEFINITIONS = definitions.build();
@@ -592,13 +592,13 @@ private static Builder initDefaults(Builder builder) {
  .setPollingAlgorithm(
  OperationTimedPollAlgorithm.create(
  RetrySettings.newBuilder()
- .setInitialRetryDelay(Duration.ofMillis(5000L))
+ .setInitialRetryDelayDuration(Duration.ofMillis(5000L))
  .setRetryDelayMultiplier(1.5)
- .setMaxRetryDelay(Duration.ofMillis(45000L))
- .setInitialRpcTimeout(Duration.ZERO)
+ .setMaxRetryDelayDuration(Duration.ofMillis(45000L))
+ .setInitialRpcTimeoutDuration(Duration.ZERO)
  .setRpcTimeoutMultiplier(1.0)
- .setMaxRpcTimeout(Duration.ZERO)
- .setTotalTimeout(Duration.ofMillis(300000L))
+ .setMaxRpcTimeoutDuration(Duration.ZERO)
+ .setTotalTimeoutDuration(Duration.ofMillis(300000L))
  .build()));
 
  builder
@@ -616,13 +616,13 @@ private static Builder initDefaults(Builder builder) {
  .setPollingAlgorithm(
  OperationTimedPollAlgorithm.create(
  RetrySettings.newBuilder()
- .setInitialRetryDelay(Duration.ofMillis(5000L))
+ .setInitialRetryDelayDuration(Duration.ofMillis(5000L))
  .setRetryDelayMultiplier(1.5)
- .setMaxRetryDelay(Duration.ofMillis(45000L))
- .setInitialRpcTimeout(Duration.ZERO)
+ .setMaxRetryDelayDuration(Duration.ofMillis(45000L))
+ .setInitialRpcTimeoutDuration(Duration.ZERO)
  .setRpcTimeoutMultiplier(1.0)
- .setMaxRpcTimeout(Duration.ZERO)
- .setTotalTimeout(Duration.ofMillis(300000L))
+ .setMaxRpcTimeoutDuration(Duration.ZERO)
+ .setTotalTimeoutDuration(Duration.ofMillis(300000L))
  .build()));
 
  builder
@@ -639,13 +639,13 @@ private static Builder initDefaults(Builder builder) {
  .setPollingAlgorithm(
  OperationTimedPollAlgorithm.create(
  RetrySettings.newBuilder()
- .setInitialRetryDelay(Duration.ofMillis(5000L))
+ .setInitialRetryDelayDuration(Duration.ofMillis(5000L))
  .setRetryDelayMultiplier(1.5)
- .setMaxRetryDelay(Duration.ofMillis(45000L))
- .setInitialRpcTimeout(Duration.ZERO)
+ .setMaxRetryDelayDuration(Duration.ofMillis(45000L))
+ .setInitialRpcTimeoutDuration(Duration.ZERO)
  .setRpcTimeoutMultiplier(1.0)
- .setMaxRpcTimeout(Duration.ZERO)
- .setTotalTimeout(Duration.ofMillis(300000L))
+ .setMaxRpcTimeoutDuration(Duration.ZERO)
+ .setTotalTimeoutDuration(Duration.ofMillis(300000L))
  .build()));
 
  builder
@@ -662,13 +662,13 @@ private static Builder initDefaults(Builder builder) {
  .setPollingAlgorithm(
  OperationTimedPollAlgorithm.create(
  RetrySettings.newBuilder()
- .setInitialRetryDelay(Duration.ofMillis(5000L))
+ .setInitialRetryDelayDuration(Duration.ofMillis(5000L))
  .setRetryDelayMultiplier(1.5)
- .setMaxRetryDelay(Duration.ofMillis(45000L))
- .setInitialRpcTimeout(Duration.ZERO)
+ .setMaxRetryDelayDuration(Duration.ofMillis(45000L))
+ .setInitialRpcTimeoutDuration(Duration.ZERO)
  .setRpcTimeoutMultiplier(1.0)
- .setMaxRpcTimeout(Duration.ZERO)
- .setTotalTimeout(Duration.ofMillis(300000L))
+ .setMaxRpcTimeoutDuration(Duration.ZERO)
+ .setTotalTimeoutDuration(Duration.ofMillis(300000L))
  .build()));
 
  return builder;

google-cloud-datastore/src/main/java/com/google/cloud/datastore/models/ExecutionStats.java

@@ -15,25 +15,27 @@
  */
 package com.google.cloud.datastore.models;
 
+import static com.google.api.gax.util.TimeConversionUtils.toThreetenDuration;
+
 import com.google.api.core.BetaApi;
 import com.google.api.core.InternalApi;
+import com.google.api.core.ObsoleteApi;
 import com.google.cloud.Structs;
 import com.google.common.base.Objects;
 import java.util.Map;
-import org.threeten.bp.Duration;
 
 /** Model class for {@link com.google.datastore.v1.ExecutionStats} */
 @BetaApi
 public class ExecutionStats {
  private final long resultsReturned;
- private final Duration executionDuration;
+ private final java.time.Duration executionDuration;
  private final long readOperations;
  private final Map<String, Object> debugStats;
 
  @InternalApi
  public ExecutionStats(com.google.datastore.v1.ExecutionStats proto) {
  this.resultsReturned = proto.getResultsReturned();
- this.executionDuration = Duration.ofNanos(proto.getExecutionDuration().getNanos());
+ this.executionDuration = java.time.Duration.ofNanos(proto.getExecutionDuration().getNanos());
  this.readOperations = proto.getReadOperations();
  this.debugStats = Structs.asMap(proto.getDebugStats());
  }
@@ -51,8 +53,14 @@ public Map<String, Object> getDebugStats() {
  return debugStats;
  }
 
+ /** This method is obsolete. Use {@link #getExecutionJavaTimeDuration()} instead. */
+ @ObsoleteApi("Use getExecutionJavaTimeDuration() instead")
+ public org.threeten.bp.Duration getExecutionDuration() {
+ return toThreetenDuration(getExecutionJavaTimeDuration());
+ }
+
  /** Returns the total time to execute the query in the backend. */
- public Duration getExecutionDuration() {
+ public java.time.Duration getExecutionJavaTimeDuration() {
  return executionDuration;
  }
 

google-cloud-datastore/src/main/java/com/google/cloud/datastore/testing/LocalDatastoreHelper.java

@@ -16,9 +16,11 @@
 
 package com.google.cloud.datastore.testing;
 
+import static com.google.api.gax.util.TimeConversionUtils.toJavaTimeDuration;
 import static com.google.common.base.MoreObjects.firstNonNull;
 
 import com.google.api.core.InternalApi;
+import com.google.api.core.ObsoleteApi;
 import com.google.cloud.NoCredentials;
 import com.google.cloud.ServiceOptions;
 import com.google.cloud.datastore.DatastoreOptions;
@@ -38,7 +40,6 @@
 import java.util.UUID;
 import java.util.concurrent.TimeoutException;
 import java.util.logging.Logger;
-import org.threeten.bp.Duration;
 
 /**
  * Utility to start and stop local Google Cloud Datastore emulators.
@@ -307,6 +308,14 @@ public void reset() throws IOException {
  sendPostRequest("/reset");
  }
 
+ /** This method is obsolete. Use {@link #stopDuration(java.time.Duration)} instead */
+ @ObsoleteApi("Use stopDuration(java.time.Duration) instead")
+ @Override
+ public void stop(org.threeten.bp.Duration timeout)
+ throws IOException, InterruptedException, TimeoutException {
+ stopDuration(toJavaTimeDuration(timeout));
+ }
+
  /**
  * Stops the Datastore emulator.
  *
@@ -319,23 +328,24 @@ public void reset() throws IOException {
  * this value high to ensure proper shutdown, like 5 seconds or more.
  */
  @Override
- public void stop(Duration timeout) throws IOException, InterruptedException, TimeoutException {
+ public void stopDuration(java.time.Duration timeout)
+ throws IOException, InterruptedException, TimeoutException {
  sendPostRequest("/shutdown");
- waitForProcess(timeout);
+ waitForProcessDuration(timeout);
  deleteRecursively(gcdPath);
  }
 
  /**
- * Stops the Datastore emulator. The same as {@link #stop(Duration)} but with timeout duration of
- * 20 seconds.
+ * Stops the Datastore emulator. The same as {@link #stopDuration(java.time.Duration)} but with
+ * timeout duration of 20 seconds.
  *
  * <p>It is important to stop the emulator. Since the emulator runs in its own process, not
  * stopping it might cause it to become orphan.
  *
  * <p>It is not required to call {@link #reset()} before {@code stop()}.
  */
  public void stop() throws IOException, InterruptedException, TimeoutException {
- stop(Duration.ofSeconds(20));
+ stopDuration(java.time.Duration.ofSeconds(20));
  }
 
  static void deleteRecursively(Path path) throws IOException {

google-cloud-datastore/src/test/java/com/google/cloud/datastore/DatastoreTest.java

@@ -68,6 +68,7 @@
 import com.google.datastore.v1.TransactionOptions;
 import com.google.protobuf.ByteString;
 import java.io.IOException;
+import java.time.Duration;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
@@ -87,7 +88,6 @@
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
-import org.threeten.bp.Duration;
 
 @RunWith(JUnit4.class)
 public class DatastoreTest {
@@ -193,7 +193,7 @@ public void setUp() {
 
  @AfterClass
  public static void afterClass() throws IOException, InterruptedException, TimeoutException {
- helper.stop(Duration.ofMinutes(1));
+ helper.stopDuration(Duration.ofMinutes(1));
  }
 
  @Test

google-cloud-datastore/src/test/java/com/google/cloud/datastore/it/ITDatastoreTest.java

@@ -81,6 +81,7 @@
 import com.google.common.truth.Truth;
 import com.google.datastore.v1.TransactionOptions;
 import com.google.datastore.v1.TransactionOptions.ReadOnly;
+import java.time.Duration;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
@@ -103,7 +104,6 @@
 import org.junit.rules.Timeout;
 import org.junit.runner.RunWith;
 import org.junit.runners.Parameterized;
-import org.threeten.bp.Duration;
 
 @RunWith(Parameterized.class)
 public class ITDatastoreTest {
@@ -674,7 +674,7 @@ private void assertExecutionStats(
  Truth.assertThat(debugStats.get("index_entries_scanned"))
  .isEqualTo(expectedIndexEntriesScanned);
 
- Duration executionDuration = executionStats.getExecutionDuration();
+ Duration executionDuration = executionStats.getExecutionJavaTimeDuration();
  Truth.assertThat(executionDuration).isIn(Range.greaterThan(Duration.ofMillis(0)));
 
  long readOperations = executionStats.getReadOperations();

google-cloud-datastore/src/test/java/com/google/cloud/datastore/models/ExecutionStatsTest.java

@@ -41,8 +41,8 @@ public class ExecutionStatsTest {
  @Test
  public void testModel() {
  Truth.assertThat(executionStats.getDebugStats()).isEqualTo(Structs.asMap(struct));
- Truth.assertThat(executionStats.getExecutionDuration())
- .isEqualTo(org.threeten.bp.Duration.ofNanos(duration.getNanos()));
+ Truth.assertThat(executionStats.getExecutionJavaTimeDuration())
+ .isEqualTo(java.time.Duration.ofNanos(duration.getNanos()));
  Truth.assertThat(executionStats.getReadOperations()).isEqualTo(2);
  Truth.assertThat(executionStats.getResultsReturned()).isEqualTo(3);
  }

google-cloud-datastore/src/test/java/com/google/cloud/datastore/testing/ITLocalDatastoreHelperTest.java

@@ -32,14 +32,14 @@
 import java.io.IOException;
 import java.nio.file.Files;
 import java.nio.file.Path;
+import java.time.Duration;
 import java.util.concurrent.TimeoutException;
 import org.junit.After;
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
-import org.threeten.bp.Duration;
 
 @RunWith(JUnit4.class)
 public class ITLocalDatastoreHelperTest {
@@ -178,7 +178,7 @@ public void testStartStopReset() throws IOException, InterruptedException, Timeo
  assertNotNull(datastore.get(key));
  helper.reset();
  assertNull(datastore.get(key));
- helper.stop(Duration.ofMinutes(1));
+ helper.stopDuration(Duration.ofMinutes(1));
  datastore.get(key);
  Assert.fail();
  } catch (DatastoreException ex) {
@@ -198,7 +198,7 @@ public void testStartStopResetWithBuilder()
  assertNotNull(datastore.get(key));
  helper.reset();
  assertNull(datastore.get(key));
- helper.stop(Duration.ofMinutes(1));
+ helper.stopDuration(Duration.ofMinutes(1));
  datastore.get(key);
  Assert.fail();
  } catch (DatastoreException ex) {

google-cloud-datastore/src/test/java/com/google/cloud/datastore/testing/RemoteDatastoreHelper.java

@@ -27,9 +27,9 @@
 import com.google.cloud.datastore.StructuredQuery;
 import com.google.cloud.http.HttpTransportOptions;
 import io.opentelemetry.sdk.OpenTelemetrySdk;
+import java.time.Duration;
 import java.util.UUID;
 import javax.annotation.Nullable;
-import org.threeten.bp.Duration;
 
 /**
  * Utility to create a remote datastore configuration for testing. Datastore options can be obtained
@@ -110,13 +110,13 @@ public static RemoteDatastoreHelper create(String databaseId) {
  private static RetrySettings retrySettings() {
  return RetrySettings.newBuilder()
  .setMaxAttempts(10)
- .setMaxRetryDelay(Duration.ofMillis(30000L))
- .setTotalTimeout(Duration.ofMillis(120000L))
- .setInitialRetryDelay(Duration.ofMillis(250L))
+ .setMaxRetryDelayDuration(Duration.ofMillis(30000L))
+ .setTotalTimeoutDuration(Duration.ofMillis(120000L))
+ .setInitialRetryDelayDuration(Duration.ofMillis(250L))
  .setRetryDelayMultiplier(1.0)
- .setInitialRpcTimeout(Duration.ofMillis(120000L))
+ .setInitialRpcTimeoutDuration(Duration.ofMillis(120000L))
  .setRpcTimeoutMultiplier(1.0)
- .setMaxRpcTimeout(Duration.ofMillis(120000L))
+ .setMaxRpcTimeoutDuration(Duration.ofMillis(120000L))
  .build();
  }
 }