core: add getCallOptions() to CallCredentials.RequestInfo (#9538)

This is needed internally (b/134067789#comment20).
grpc · Sep 13, 2022 · 38b3382 · 38b3382
1 parent 9853a0c
commit 38b3382
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 0 deletions.
diff --git a/api/src/main/java/io/grpc/CallCredentials.java b/api/src/main/java/io/grpc/CallCredentials.java
@@ -91,6 +91,13 @@ public abstract static class RequestInfo {
      */
     public abstract MethodDescriptor<?, ?> getMethodDescriptor();
 
+    /**
+     * The call options used to call this RPC.
+     */
+    public CallOptions getCallOptions() {
+      throw new UnsupportedOperationException("Not implemented");
+    }
+
     /**
      * The security level on the transport.
      */

diff --git a/core/src/main/java/io/grpc/internal/CallCredentialsApplyingTransportFactory.java b/core/src/main/java/io/grpc/internal/CallCredentialsApplyingTransportFactory.java
@@ -127,6 +127,11 @@ public ClientStream newStream(
               return method;
             }
 
+            @Override
+            public CallOptions getCallOptions() {
+              return callOptions;
+            }
+
             @Override
             public SecurityLevel getSecurityLevel() {
               return firstNonNull(

diff --git a/core/src/test/java/io/grpc/internal/CallCredentialsApplyingTest.java b/core/src/test/java/io/grpc/internal/CallCredentialsApplyingTest.java
@@ -148,6 +148,7 @@ public void parameterPropagation_base() {
     RequestInfo info = infoCaptor.getValue();
     assertSame(transportAttrs, info.getTransportAttrs());
     assertSame(method, info.getMethodDescriptor());
+    assertSame(callOptions, info.getCallOptions());
     assertSame(AUTHORITY, info.getAuthority());
     assertSame(SecurityLevel.NONE, info.getSecurityLevel());
   }