use threeten methods in tests

googleapis · Dec 11, 2024 · ce6a279 · ce6a279
1 parent 540b19d
commit ce6a279
Show file tree

Hide file tree

Showing 15 changed files with 136 additions and 113 deletions.
diff --git a/...e/src/test/java/com/google/cloud/bigtable/admin/v2/BigtableInstanceAdminSettingsTest.java b/...e/src/test/java/com/google/cloud/bigtable/admin/v2/BigtableInstanceAdminSettingsTest.java
@@ -22,11 +22,11 @@
 import com.google.api.gax.rpc.StatusCode.Code;
 import com.google.cloud.bigtable.admin.v2.stub.BigtableInstanceAdminStubSettings;
 import java.io.IOException;
-import java.time.Duration;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
 import org.mockito.Mockito;
+import org.threeten.bp.Duration;
 
 @RunWith(JUnit4.class)
 public class BigtableInstanceAdminSettingsTest {
@@ -139,7 +139,7 @@ public void testToString() throws IOException {
     stubSettings
         .getInstanceSettings()
         .setRetrySettings(
-            RetrySettings.newBuilder().setTotalTimeoutDuration(Duration.ofMinutes(812)).build());
+            RetrySettings.newBuilder().setTotalTimeout(Duration.ofMinutes(812)).build());
 
     BigtableInstanceAdminSettings settings = builder.build();
     checkToString(settings);

diff --git a/...able/src/test/java/com/google/cloud/bigtable/admin/v2/BigtableTableAdminSettingsTest.java b/...able/src/test/java/com/google/cloud/bigtable/admin/v2/BigtableTableAdminSettingsTest.java
@@ -165,7 +165,7 @@ public void testToString() throws IOException {
         .getBackupSettings()
         .setRetrySettings(
             RetrySettings.newBuilder()
-                .setTotalTimeoutDuration(java.time.Duration.ofMinutes(812))
+                .setTotalTimeout(org.threeten.bp.Duration.ofMinutes(812))
                 .build());
 
     BigtableTableAdminSettings settings = builder.build();

diff --git a/...e/src/test/java/com/google/cloud/bigtable/admin/v2/stub/AwaitConsistencyCallableTest.java b/...e/src/test/java/com/google/cloud/bigtable/admin/v2/stub/AwaitConsistencyCallableTest.java
@@ -35,7 +35,6 @@
 import com.google.bigtable.admin.v2.TableName;
 import com.google.cloud.bigtable.admin.v2.models.ConsistencyRequest;
 import com.google.cloud.bigtable.data.v2.internal.TableAdminRequestContext;
-import java.time.Duration;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeUnit;
 import org.junit.Before;
@@ -48,6 +47,7 @@
 import org.mockito.junit.MockitoJUnit;
 import org.mockito.junit.MockitoRule;
 import org.mockito.quality.Strictness;
+import org.threeten.bp.Duration;
 
 @RunWith(JUnit4.class)
 public class AwaitConsistencyCallableTest {
@@ -80,14 +80,14 @@ public void setUp() {
 
     RetrySettings retrySettings =
         RetrySettings.newBuilder()
-            .setTotalTimeoutDuration(Duration.ofMillis(100))
+            .setTotalTimeout(Duration.ofMillis(100))
             // Delay settings: 1 ms const
-            .setInitialRetryDelayDuration(Duration.ofMillis(1))
-            .setMaxRetryDelayDuration(Duration.ofMillis(1))
+            .setInitialRetryDelay(Duration.ofMillis(1))
+            .setMaxRetryDelay(Duration.ofMillis(1))
             .setRetryDelayMultiplier(1.0)
             // RPC timeout: ignored const 1 s
-            .setInitialRpcTimeoutDuration(Duration.ofSeconds(1))
-            .setMaxRpcTimeoutDuration(Duration.ofSeconds(1))
+            .setInitialRpcTimeout(Duration.ofSeconds(1))
+            .setMaxRpcTimeout(Duration.ofSeconds(1))
             .setRpcTimeoutMultiplier(1.0)
             .build();
 

diff --git a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/it/BulkMutateIT.java b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/it/BulkMutateIT.java
@@ -37,13 +37,13 @@
 import com.google.cloud.bigtable.test_helpers.env.EmulatorEnv;
 import com.google.cloud.bigtable.test_helpers.env.TestEnvRule;
 import java.io.IOException;
-import java.time.Duration;
 import java.util.Objects;
 import java.util.UUID;
 import org.junit.ClassRule;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
+import org.threeten.bp.Duration;
 
 @RunWith(JUnit4.class)
 public class BulkMutateIT {
@@ -158,7 +158,7 @@ public void testManyMutations() throws IOException, InterruptedException {
         .stubSettings()
         .bulkMutateRowsSettings()
         .setBatchingSettings(
-            batchingSettings.toBuilder().setDelayThresholdDuration(Duration.ofHours(1)).build());
+            batchingSettings.toBuilder().setDelayThreshold(Duration.ofHours(1)).build());
     try (BigtableDataClient client = BigtableDataClient.create(settings);
         BatcherImpl<RowMutationEntry, Void, BulkMutation, Void> batcher =
             (BatcherImpl<RowMutationEntry, Void, BulkMutation, Void>)
@@ -207,7 +207,7 @@ public void testManyMutationsOnAuthorizedView() throws IOException, InterruptedE
         .stubSettings()
         .bulkMutateRowsSettings()
         .setBatchingSettings(
-            batchingSettings.toBuilder().setDelayThresholdDuration(Duration.ofHours(1)).build());
+            batchingSettings.toBuilder().setDelayThreshold(Duration.ofHours(1)).build());
     try (BigtableDataClient client = BigtableDataClient.create(settings);
         Batcher<RowMutationEntry, Void> batcher =
             client.newBulkMutationBatcher(

diff --git a/...able/src/test/java/com/google/cloud/bigtable/data/v2/models/ChangeStreamMutationTest.java b/...able/src/test/java/com/google/cloud/bigtable/data/v2/models/ChangeStreamMutationTest.java
@@ -15,6 +15,7 @@
  */
 package com.google.cloud.bigtable.data.v2.models;
 
+import static com.google.api.gax.util.TimeConversionUtils.toThreetenInstant;
 import static com.google.common.truth.Truth.assertThat;
 
 import com.google.bigtable.v2.MutateRowRequest;
@@ -45,6 +46,10 @@ public class ChangeStreamMutationTest {
       RequestContext.create(PROJECT_ID, INSTANCE_ID, APP_PROFILE_ID);
   private static final Instant FAKE_COMMIT_TIMESTAMP = Instant.ofEpochSecond(0, 1000L);
   private static final Instant FAKE_LOW_WATERMARK = Instant.ofEpochSecond(0, 2000L);
+  private static final org.threeten.bp.Instant FAKE_COMMIT_TIMESTAMP_THREETEN =
+      toThreetenInstant(FAKE_COMMIT_TIMESTAMP);
+  private static final org.threeten.bp.Instant FAKE_LOW_WATERMARK_THREETEN =
+      toThreetenInstant(FAKE_LOW_WATERMARK);
 
   @Test
   public void userInitiatedMutationTest() throws IOException, ClassNotFoundException {
@@ -81,9 +86,12 @@ public void userInitiatedMutationTest() throws IOException, ClassNotFoundExcepti
     assertThat(changeStreamMutation.getType()).isEqualTo(ChangeStreamMutation.MutationType.USER);
     assertThat(changeStreamMutation.getSourceClusterId()).isEqualTo("fake-source-cluster-id");
     assertThat(changeStreamMutation.getCommitTime()).isEqualTo(FAKE_COMMIT_TIMESTAMP);
+    assertThat(changeStreamMutation.getCommitTimestamp()).isEqualTo(FAKE_COMMIT_TIMESTAMP_THREETEN);
     assertThat(changeStreamMutation.getTieBreaker()).isEqualTo(0);
     assertThat(changeStreamMutation.getToken()).isEqualTo("fake-token");
     assertThat(changeStreamMutation.getEstimatedLowWatermarkTime()).isEqualTo(FAKE_LOW_WATERMARK);
+    assertThat(changeStreamMutation.getEstimatedLowWatermark())
+        .isEqualTo(FAKE_LOW_WATERMARK_THREETEN);
 
     // Test serialization.
     ByteArrayOutputStream bos = new ByteArrayOutputStream();
@@ -112,7 +120,7 @@ public void gcMutationTest() throws IOException, ClassNotFoundException {
                 ByteString.copyFromUtf8("fake-qualifier"),
                 Range.TimestampRange.create(1000L, 2000L))
             .setToken("fake-token")
-            .setLowWatermarkTime(FAKE_LOW_WATERMARK)
+            .setEstimatedLowWatermark(FAKE_LOW_WATERMARK_THREETEN)
             .build();
 
     // Test the getters.
@@ -121,9 +129,12 @@ public void gcMutationTest() throws IOException, ClassNotFoundException {
         .isEqualTo(ChangeStreamMutation.MutationType.GARBAGE_COLLECTION);
     Assert.assertTrue(changeStreamMutation.getSourceClusterId().isEmpty());
     assertThat(changeStreamMutation.getCommitTime()).isEqualTo(FAKE_COMMIT_TIMESTAMP);
+    assertThat(changeStreamMutation.getCommitTimestamp()).isEqualTo(FAKE_COMMIT_TIMESTAMP_THREETEN);
     assertThat(changeStreamMutation.getTieBreaker()).isEqualTo(0);
     assertThat(changeStreamMutation.getToken()).isEqualTo("fake-token");
     assertThat(changeStreamMutation.getEstimatedLowWatermarkTime()).isEqualTo(FAKE_LOW_WATERMARK);
+    assertThat(changeStreamMutation.getEstimatedLowWatermark())
+        .isEqualTo(FAKE_LOW_WATERMARK_THREETEN);
 
     // Test serialization.
     ByteArrayOutputStream bos = new ByteArrayOutputStream();
@@ -161,7 +172,7 @@ public void toRowMutationTest() {
                 Value.rawTimestamp(1000),
                 Value.rawValue(ByteString.copyFrom(Longs.toByteArray(1234L))))
             .setToken("fake-token")
-            .setLowWatermarkTime(FAKE_LOW_WATERMARK)
+            .setEstimatedLowWatermark(FAKE_LOW_WATERMARK_THREETEN)
             .build();
 
     // Convert it to a rowMutation and construct a MutateRowRequest.
@@ -204,7 +215,7 @@ public void toRowMutationWithoutTokenShouldFailTest() {
         ChangeStreamMutation.createUserMutation(
                 ByteString.copyFromUtf8("key"), "fake-source-cluster-id", FAKE_COMMIT_TIMESTAMP, 0)
             .deleteFamily("fake-family")
-            .setLowWatermarkTime(FAKE_LOW_WATERMARK);
+            .setEstimatedLowWatermark(FAKE_LOW_WATERMARK_THREETEN);
     Assert.assertThrows(IllegalStateException.class, builder::build);
   }
 
@@ -244,7 +255,7 @@ public void toRowMutationEntryTest() {
                 Value.rawTimestamp(1000),
                 Value.rawValue(ByteString.copyFrom(Longs.toByteArray(1234L))))
             .setToken("fake-token")
-            .setLowWatermarkTime(FAKE_LOW_WATERMARK)
+            .setEstimatedLowWatermark(FAKE_LOW_WATERMARK_THREETEN)
             .build();
 
     // Convert it to a rowMutationEntry and construct a MutateRowRequest.
@@ -284,7 +295,7 @@ public void toRowMutationEntryWithoutTokenShouldFailTest() {
         ChangeStreamMutation.createUserMutation(
                 ByteString.copyFromUtf8("key"), "fake-source-cluster-id", FAKE_COMMIT_TIMESTAMP, 0)
             .deleteFamily("fake-family")
-            .setLowWatermarkTime(FAKE_LOW_WATERMARK);
+            .setEstimatedLowWatermark(FAKE_LOW_WATERMARK_THREETEN);
     Assert.assertThrows(IllegalStateException.class, builder::build);
   }
 
@@ -309,7 +320,7 @@ public void testWithLongValue() {
                 1000L,
                 ByteString.copyFrom(Longs.toByteArray(1L)))
             .setToken("fake-token")
-            .setLowWatermarkTime(FAKE_LOW_WATERMARK)
+            .setEstimatedLowWatermark(FAKE_LOW_WATERMARK_THREETEN)
             .build();
 
     RowMutation rowMutation = changeStreamMutation.toRowMutation(TABLE_ID);

diff --git a/...t/java/com/google/cloud/bigtable/data/v2/models/DefaultChangeStreamRecordAdapterTest.java b/...t/java/com/google/cloud/bigtable/data/v2/models/DefaultChangeStreamRecordAdapterTest.java
@@ -15,6 +15,7 @@
  */
 package com.google.cloud.bigtable.data.v2.models;
 
+import static com.google.api.gax.util.TimeConversionUtils.toThreetenInstant;
 import static com.google.common.truth.Truth.assertThat;
 
 import com.google.bigtable.v2.Mutation;
@@ -41,6 +42,8 @@ public class DefaultChangeStreamRecordAdapterTest {
   private ChangeStreamRecordBuilder<ChangeStreamRecord> changeStreamRecordBuilder;
   private static final Instant FAKE_COMMIT_TIMESTAMP = Instant.ofEpochSecond(0L, 1000L);
   private static final Instant FAKE_LOW_WATERMARK = Instant.ofEpochSecond(0L, 2000L);
+  private static final org.threeten.bp.Instant FAKE_LOW_WATERMARK_THREETEN =
+      toThreetenInstant(FAKE_LOW_WATERMARK);
 
   @Rule public ExpectedException expect = ExpectedException.none();
 
@@ -59,7 +62,7 @@ public void isHeartbeatTest() {
         ChangeStreamMutation.createGcMutation(
                 ByteString.copyFromUtf8("key"), FAKE_COMMIT_TIMESTAMP, 0)
             .setToken("token")
-            .setLowWatermarkTime(FAKE_LOW_WATERMARK)
+            .setEstimatedLowWatermark(FAKE_LOW_WATERMARK_THREETEN)
             .build();
     Assert.assertTrue(adapter.isHeartbeat(heartbeatRecord));
     Assert.assertFalse(adapter.isHeartbeat(closeStreamRecord));
@@ -73,8 +76,8 @@ public void getTokenFromHeartbeatTest() {
             ReadChangeStreamResponse.Heartbeat.newBuilder()
                 .setEstimatedLowWatermark(
                     Timestamp.newBuilder()
-                        .setSeconds(FAKE_LOW_WATERMARK.getEpochSecond())
-                        .setNanos(FAKE_LOW_WATERMARK.getNano()))
+                        .setSeconds(FAKE_LOW_WATERMARK_THREETEN.getEpochSecond())
+                        .setNanos(FAKE_LOW_WATERMARK_THREETEN.getNano()))
                 .setContinuationToken(
                     StreamContinuationToken.newBuilder().setToken("heartbeat-token").build())
                 .build());
@@ -99,7 +102,7 @@ public void isChangeStreamMutationTest() {
         ChangeStreamMutation.createGcMutation(
                 ByteString.copyFromUtf8("key"), FAKE_COMMIT_TIMESTAMP, 0)
             .setToken("token")
-            .setLowWatermarkTime(FAKE_LOW_WATERMARK)
+            .setEstimatedLowWatermark(FAKE_LOW_WATERMARK_THREETEN)
             .build();
     Assert.assertFalse(adapter.isChangeStreamMutation(heartbeatRecord));
     Assert.assertFalse(adapter.isChangeStreamMutation(closeStreamRecord));
@@ -112,7 +115,7 @@ public void getTokenFromChangeStreamMutationTest() {
         ChangeStreamMutation.createGcMutation(
                 ByteString.copyFromUtf8("key"), FAKE_COMMIT_TIMESTAMP, 0)
             .setToken("change-stream-mutation-token")
-            .setLowWatermarkTime(FAKE_LOW_WATERMARK)
+            .setEstimatedLowWatermark(FAKE_LOW_WATERMARK_THREETEN)
             .build();
     Assert.assertEquals(
         adapter.getTokenFromChangeStreamMutation(changeStreamMutationRecord),
@@ -133,8 +136,8 @@ public void heartbeatTest() {
         ReadChangeStreamResponse.Heartbeat.newBuilder()
             .setEstimatedLowWatermark(
                 Timestamp.newBuilder()
-                    .setSeconds(FAKE_LOW_WATERMARK.getEpochSecond())
-                    .setNanos(FAKE_LOW_WATERMARK.getNano())
+                    .setSeconds(FAKE_LOW_WATERMARK_THREETEN.getEpochSecond())
+                    .setNanos(FAKE_LOW_WATERMARK_THREETEN.getNano())
                     .build())
             .setContinuationToken(
                 StreamContinuationToken.newBuilder().setToken("random-token").build())
@@ -186,7 +189,7 @@ public void singleDeleteFamilyTest() {
                 ByteString.copyFromUtf8("key"), "fake-source-cluster-id", FAKE_COMMIT_TIMESTAMP, 0)
             .deleteFamily("fake-family")
             .setToken("fake-token")
-            .setLowWatermarkTime(FAKE_LOW_WATERMARK)
+            .setEstimatedLowWatermark(FAKE_LOW_WATERMARK_THREETEN)
             .build();
 
     // Create the ChangeStreamMutation through the ChangeStreamRecordBuilder.
@@ -225,7 +228,7 @@ public void singleDeleteCellTest() {
                 ByteString.copyFromUtf8("fake-qualifier"),
                 Range.TimestampRange.create(1000L, 2000L))
             .setToken("fake-token")
-            .setLowWatermarkTime(FAKE_LOW_WATERMARK)
+            .setEstimatedLowWatermark(FAKE_LOW_WATERMARK_THREETEN)
             .build();
 
     // Create the ChangeStreamMutation through the ChangeStreamRecordBuilder.
@@ -258,7 +261,7 @@ public void singleNonChunkedCellTest() {
                 100L,
                 ByteString.copyFromUtf8("fake-value"))
             .setToken("fake-token")
-            .setLowWatermarkTime(FAKE_LOW_WATERMARK)
+            .setEstimatedLowWatermark(FAKE_LOW_WATERMARK_THREETEN)
             .build();
 
     // Create the ChangeStreamMutation through the ChangeStreamRecordBuilder.
@@ -290,7 +293,7 @@ public void singleChunkedCellTest() {
                 100L,
                 ByteString.copyFromUtf8("fake-value1-value2"))
             .setToken("fake-token")
-            .setLowWatermarkTime(FAKE_LOW_WATERMARK)
+            .setEstimatedLowWatermark(FAKE_LOW_WATERMARK_THREETEN)
             .build();
 
     // Create the ChangeStreamMutation through the ChangeStreamRecordBuilder.
@@ -327,7 +330,7 @@ public void multipleChunkedCellsTest() {
     }
     expectedChangeStreamMutationBuilder
         .setToken("fake-token")
-        .setLowWatermarkTime(FAKE_LOW_WATERMARK);
+        .setEstimatedLowWatermark(FAKE_LOW_WATERMARK_THREETEN);
 
     // Create the ChangeStreamMutation through the ChangeStreamRecordBuilder.
     changeStreamRecordBuilder.startUserMutation(
@@ -369,7 +372,7 @@ public void multipleDifferentModsTest() {
                 100L,
                 ByteString.copyFromUtf8("chunked-value"))
             .setToken("fake-token")
-            .setLowWatermarkTime(FAKE_LOW_WATERMARK);
+            .setEstimatedLowWatermark(FAKE_LOW_WATERMARK_THREETEN);
 
     // Create the ChangeStreamMutation through the ChangeStreamRecordBuilder.
     changeStreamRecordBuilder.startUserMutation(
@@ -418,7 +421,7 @@ public void resetTest() {
                 ByteString.copyFromUtf8("key"), "fake-source-cluster-id", FAKE_COMMIT_TIMESTAMP, 0)
             .deleteFamily("fake-family")
             .setToken("fake-token")
-            .setLowWatermarkTime(FAKE_LOW_WATERMARK)
+            .setEstimatedLowWatermark(FAKE_LOW_WATERMARK_THREETEN)
             .build();
     changeStreamRecordBuilder.startUserMutation(
         ByteString.copyFromUtf8("key"), "fake-source-cluster-id", FAKE_COMMIT_TIMESTAMP, 0);
@@ -438,7 +441,7 @@ public void resetTest() {
                 100L,
                 ByteString.copyFromUtf8("fake-value1-value2"))
             .setToken("fake-token")
-            .setLowWatermarkTime(FAKE_LOW_WATERMARK)
+            .setEstimatedLowWatermark(FAKE_LOW_WATERMARK_THREETEN)
             .build();
 
     changeStreamRecordBuilder.startUserMutation(

diff --git a/...rc/test/java/com/google/cloud/bigtable/data/v2/stub/BigtableBatchingCallSettingsTest.java b/...rc/test/java/com/google/cloud/bigtable/data/v2/stub/BigtableBatchingCallSettingsTest.java
@@ -25,11 +25,11 @@
 import com.google.api.gax.rpc.StatusCode;
 import com.google.cloud.bigtable.data.v2.stub.mutaterows.MutateRowsBatchingDescriptor;
 import com.google.common.collect.ImmutableSet;
-import java.time.Duration;
 import java.util.Set;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
+import org.threeten.bp.Duration;
 
 @RunWith(JUnit4.class)
 public class BigtableBatchingCallSettingsTest {
@@ -38,7 +38,7 @@ public class BigtableBatchingCallSettingsTest {
       BatchingSettings.newBuilder()
           .setElementCountThreshold(10L)
           .setRequestByteThreshold(20L)
-          .setDelayThresholdDuration(Duration.ofMillis(5))
+          .setDelayThreshold(Duration.ofMillis(5))
           .setFlowControlSettings(
               FlowControlSettings.newBuilder()
                   .setMaxOutstandingElementCount(100L)
@@ -111,7 +111,7 @@ public void testBuilderFromSettings() {
     BigtableBatchingCallSettings.Builder builder =
         BigtableBatchingCallSettings.newBuilder(new MutateRowsBatchingDescriptor());
     RetrySettings retrySettings =
-        RetrySettings.newBuilder().setTotalTimeoutDuration(Duration.ofMinutes(1)).build();
+        RetrySettings.newBuilder().setTotalTimeout(Duration.ofMinutes(1)).build();
     builder
         .setBatchingSettings(BATCHING_SETTINGS)
         .setRetryableCodes(StatusCode.Code.UNAVAILABLE, StatusCode.Code.UNAUTHENTICATED)

diff --git a/...est/java/com/google/cloud/bigtable/data/v2/stub/BigtableBulkReadRowsCallSettingsTest.java b/...est/java/com/google/cloud/bigtable/data/v2/stub/BigtableBulkReadRowsCallSettingsTest.java
@@ -24,11 +24,11 @@
 import com.google.api.gax.rpc.StatusCode;
 import com.google.cloud.bigtable.data.v2.stub.readrows.ReadRowsBatchingDescriptor;
 import com.google.common.collect.ImmutableSet;
-import java.time.Duration;
 import java.util.Set;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
+import org.threeten.bp.Duration;
 
 @RunWith(JUnit4.class)
 public class BigtableBulkReadRowsCallSettingsTest {
@@ -37,7 +37,7 @@ public class BigtableBulkReadRowsCallSettingsTest {
       BatchingSettings.newBuilder()
           .setElementCountThreshold(10L)
           .setRequestByteThreshold(20L)
-          .setDelayThresholdDuration(Duration.ofMillis(5))
+          .setDelayThreshold(Duration.ofMillis(5))
           .setFlowControlSettings(
               FlowControlSettings.newBuilder()
                   .setMaxOutstandingElementCount(100L)
@@ -78,7 +78,7 @@ public void testBuilderFromSettings() {
     BigtableBulkReadRowsCallSettings.Builder builder =
         BigtableBulkReadRowsCallSettings.newBuilder(new ReadRowsBatchingDescriptor());
     RetrySettings retrySettings =
-        RetrySettings.newBuilder().setTotalTimeoutDuration(Duration.ofMinutes(1)).build();
+        RetrySettings.newBuilder().setTotalTimeout(Duration.ofMinutes(1)).build();
     builder
         .setBatchingSettings(BATCHING_SETTINGS)
         .setRetryableCodes(StatusCode.Code.UNAVAILABLE, StatusCode.Code.UNAUTHENTICATED)