Skip to content

Commit 57efcc2

Browse files
authored
feat: Add cadence-caller-type to client header (#1045)
Signed-off-by: fimanishi <[email protected]>
1 parent b457361 commit 57efcc2

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

src/main/java/com/uber/cadence/internal/compatibility/proto/serviceclient/GrpcServiceStubs.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -62,6 +62,8 @@ final class GrpcServiceStubs implements IGrpcServiceStubs {
6262
Metadata.Key.of("cadence-client-feature-version", Metadata.ASCII_STRING_MARSHALLER);
6363
private static final Metadata.Key<String> CLIENT_IMPL_HEADER_KEY =
6464
Metadata.Key.of("cadence-client-name", Metadata.ASCII_STRING_MARSHALLER);
65+
private static final Metadata.Key<String> CALLER_TYPE_HEADER_KEY =
66+
Metadata.Key.of("cadence-caller-type", Metadata.ASCII_STRING_MARSHALLER);
6567
private static final Metadata.Key<String> ISOLATION_GROUP_HEADER_KEY =
6668
Metadata.Key.of("cadence-client-isolation-group", Metadata.ASCII_STRING_MARSHALLER);
6769
private static final Metadata.Key<String> RPC_SERVICE_NAME_HEADER_KEY =
@@ -75,6 +77,7 @@ final class GrpcServiceStubs implements IGrpcServiceStubs {
7577
Metadata.Key.of("cadence-authorization", Metadata.ASCII_STRING_MARSHALLER);
7678

7779
private static final String CLIENT_IMPL_HEADER_VALUE = "uber-java";
80+
private static final String CALLER_TYPE_HEADER_VALUE = "sdk";
7881

7982
private final ClientOptions options;
8083
private final ManagedChannel channel;
@@ -110,6 +113,7 @@ final class GrpcServiceStubs implements IGrpcServiceStubs {
110113
headers.put(LIBRARY_VERSION_HEADER_KEY, Version.LIBRARY_VERSION);
111114
headers.put(FEATURE_VERSION_HEADER_KEY, Version.FEATURE_VERSION);
112115
headers.put(CLIENT_IMPL_HEADER_KEY, CLIENT_IMPL_HEADER_VALUE);
116+
headers.put(CALLER_TYPE_HEADER_KEY, CALLER_TYPE_HEADER_VALUE);
113117
headers.put(RPC_SERVICE_NAME_HEADER_KEY, options.getServiceName());
114118
headers.put(RPC_CALLER_NAME_HEADER_KEY, options.getClientAppName());
115119
headers.put(RPC_ENCODING_HEADER_KEY, "proto");

0 commit comments

Comments
 (0)