Merge pull request #202 from ydb-platform/make_get_channel_protected

Make getChannel method protected
ydb-platform · Dec 8, 2023 · b15a796 · b15a796
2 parents 39a72f9 + ee1b203
commit b15a796
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 5 deletions.
diff --git a/core/src/main/java/tech/ydb/core/impl/BaseGrpcTransport.java b/core/src/main/java/tech/ydb/core/impl/BaseGrpcTransport.java
@@ -43,7 +43,7 @@ public abstract class BaseGrpcTransport implements GrpcTransport {
     protected volatile boolean shutdown;
 
     abstract AuthCallOptions getAuthCallOptions();
-    abstract GrpcChannel getChannel(GrpcRequestSettings settings);
+    protected abstract GrpcChannel getChannel(GrpcRequestSettings settings);
     abstract void updateChannelStatus(GrpcChannel channel, io.grpc.Status status);
 
     @Override

diff --git a/core/src/main/java/tech/ydb/core/impl/FixedCallOptionsTransport.java b/core/src/main/java/tech/ydb/core/impl/FixedCallOptionsTransport.java
@@ -58,7 +58,7 @@ public AuthCallOptions getAuthCallOptions() {
     }
 
     @Override
-    GrpcChannel getChannel(GrpcRequestSettings settings) {
+    protected GrpcChannel getChannel(GrpcRequestSettings settings) {
         return channel;
     }
 

diff --git a/core/src/main/java/tech/ydb/core/impl/MultiChannelTransport.java b/core/src/main/java/tech/ydb/core/impl/MultiChannelTransport.java
@@ -95,7 +95,7 @@ public AuthCallOptions getAuthCallOptions() {
     }
 
     @Override
-    GrpcChannel getChannel(GrpcRequestSettings settings) {
+    protected GrpcChannel getChannel(GrpcRequestSettings settings) {
         EndpointRecord endpoint = endpointPool.getEndpoint(null);
         return channelPool.getChannel(endpoint);
     }

diff --git a/core/src/main/java/tech/ydb/core/impl/SingleChannelTransport.java b/core/src/main/java/tech/ydb/core/impl/SingleChannelTransport.java
@@ -70,7 +70,7 @@ public AuthCallOptions getAuthCallOptions() {
     }
 
     @Override
-    GrpcChannel getChannel(GrpcRequestSettings settings) {
+    protected GrpcChannel getChannel(GrpcRequestSettings settings) {
         return channel;
     }
 

diff --git a/core/src/main/java/tech/ydb/core/impl/YdbTransportImpl.java b/core/src/main/java/tech/ydb/core/impl/YdbTransportImpl.java
@@ -154,7 +154,7 @@ public AuthCallOptions getAuthCallOptions() {
     }
 
     @Override
-    GrpcChannel getChannel(GrpcRequestSettings settings) {
+    protected GrpcChannel getChannel(GrpcRequestSettings settings) {
         EndpointRecord endpoint = endpointPool.getEndpoint(settings.getPreferredNodeID());
         return channelPool.getChannel(endpoint);
     }