chore: Add class-level timeout to ITOtelErrorType.java

Author: diegomarquezp

sdk-platform-java/java-showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/it/ITOtelErrorType.java

@@ -33,31 +33,28 @@
 import static com.google.common.truth.Truth.assertThat;
 import static org.junit.Assert.assertThrows;
 
-import com.google.api.gax.core.FixedCredentialsProvider;
+import com.google.api.client.http.HttpTransport;
 import com.google.api.gax.core.NoCredentialsProvider;
 import com.google.api.gax.httpjson.RestSerializationException;
 import com.google.api.gax.rpc.DeadlineExceededException;
-import com.google.api.gax.rpc.StatusCode.Code;
 import com.google.api.gax.rpc.TransportChannelProvider;
 import com.google.api.gax.rpc.UnavailableException;
 import com.google.api.gax.tracing.ObservabilityAttributes;
 import com.google.api.gax.tracing.SpanTracerFactory;
-import com.google.auth.Credentials;
 import com.google.common.collect.ImmutableList;
 import com.google.rpc.Status;
 import com.google.showcase.v1beta1.EchoClient;
 import com.google.showcase.v1beta1.EchoRequest;
 import com.google.showcase.v1beta1.EchoSettings;
 import com.google.showcase.v1beta1.it.util.TestClientInitializer;
 import com.google.showcase.v1beta1.stub.EchoStubSettings;
-import com.google.api.client.http.HttpTransport;
 import io.grpc.CallOptions;
 import io.grpc.Channel;
 import io.grpc.ClientCall;
 import io.grpc.ClientInterceptor;
 import io.grpc.ManagedChannelBuilder;
-import io.grpc.MethodDescriptor;
 import io.grpc.Metadata;
+import io.grpc.MethodDescriptor;
 import io.opentelemetry.api.GlobalOpenTelemetry;
 import io.opentelemetry.api.common.AttributeKey;
 import io.opentelemetry.sdk.OpenTelemetrySdk;
@@ -74,18 +71,16 @@
 import java.net.ServerSocket;
 import java.net.Socket;
 import java.net.SocketTimeoutException;
-import java.net.URI;
 import java.nio.channels.UnresolvedAddressException;
 import java.security.GeneralSecurityException;
 import java.time.Duration;
 import java.util.List;
-import java.util.Map;
+import java.util.concurrent.TimeUnit;
 import javax.net.ssl.SSLHandshakeException;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.Timeout;
-import java.util.concurrent.TimeUnit;
 
 @Timeout(value = 30, unit = TimeUnit.SECONDS)
 class ITOtelErrorType {
@@ -177,9 +172,7 @@ void testTracing_failedEcho_grpc_recordsErrorType() throws Exception {
         new ClientInterceptor() {
           @Override
           public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
-              MethodDescriptor<ReqT, RespT> method,
-              CallOptions callOptions,
-              Channel next) {
+              MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) {
             return new ClientCall<ReqT, RespT>() {
               @Override
               public void start(Listener<RespT> responseListener, Metadata headers) {
@@ -213,16 +206,15 @@ public void sendMessage(ReqT message) {}
 
       EchoRequest echoRequest =
           EchoRequest.newBuilder()
-              .setError(Status.newBuilder().setCode(com.google.rpc.Code.UNAVAILABLE.ordinal()).build())
+              .setError(
+                  Status.newBuilder().setCode(com.google.rpc.Code.UNAVAILABLE.ordinal()).build())
               .build();
 
       assertThrows(UnavailableException.class, () -> client.echo(echoRequest));
       verifyErrorTypeAttribute("UNAVAILABLE");
     }
-
   }
 
-
   @Test
   void testTracing_failedEcho_httpjson_recordsErrorType() throws Exception {
     SpanTracerFactory tracingFactory = new SpanTracerFactory(openTelemetrySdk);
@@ -244,7 +236,6 @@ public InputStream getContent() {
                     return new ByteArrayInputStream("{}".getBytes());
                   }
 
-
                   @Override
                   public String getContentEncoding() {
                     return null;
@@ -314,16 +305,15 @@ public String getHeaderValue(int index) {
     try (EchoClient client = EchoClient.create(echoStubSettings.createStub())) {
       EchoRequest echoRequest =
           EchoRequest.newBuilder()
-              .setError(Status.newBuilder().setCode(com.google.rpc.Code.UNAVAILABLE.ordinal()).build())
+              .setError(
+                  Status.newBuilder().setCode(com.google.rpc.Code.UNAVAILABLE.ordinal()).build())
               .build();
 
-
       assertThrows(UnavailableException.class, () -> client.echo(echoRequest));
       verifyErrorTypeAttribute("503");
     }
   }
 
-
   @Test
   void testTracing_clientConnectionError_ConnectException_grpc() throws Exception {
     int port;
@@ -493,15 +483,14 @@ void testTracing_clientTimeout_DeadlineExceededException_grpc() throws Exception
 
   @Test
   void testTracing_clientAuthenticationError_GeneralSecurityException_grpc() throws Exception {
-    try (EchoClient client = createInterceptorClient(new GeneralSecurityException("Mock auth failure"))) {
+    try (EchoClient client =
+        createInterceptorClient(new GeneralSecurityException("Mock auth failure"))) {
       assertThrows(
           Exception.class, () -> client.echo(EchoRequest.newBuilder().setContent("test").build()));
       verifyErrorTypeAttribute("CLIENT_AUTHENTICATION_ERROR");
     }
   }
 
-
-
   @Test
   void testTracing_clientAuthenticationError_FileNotFoundException_grpc() throws Exception {
     try (EchoClient client = createInterceptorClient(new FileNotFoundException("Key not found"))) {