Delete DaprHTTPClient for actors. (#1056)

Signed-off-by: Artur Souza <asouza.pro@gmail.com>
dapr · Jun 25, 2024 · d9cfba7 · d9cfba7
1 parent 48364b1
commit d9cfba7
Show file tree

Hide file tree

Showing 7 changed files with 32 additions and 400 deletions.
diff --git a/sdk-actors/src/main/java/io/dapr/actors/runtime/ActorRuntime.java b/sdk-actors/src/main/java/io/dapr/actors/runtime/ActorRuntime.java
@@ -315,7 +315,7 @@ private ActorManager getActorManager(String actorTypeName) {
    * @throws java.lang.IllegalStateException if any required field is missing
    */
   private static DaprClient buildDaprClient(ManagedChannel channel) {
-    return new DaprGrpcClient(channel);
+    return new DaprClientImpl(channel);
   }
 
   /**

diff --git a/...o/dapr/actors/runtime/DaprGrpcClient.java → ...o/dapr/actors/runtime/DaprClientImpl.java b/...o/dapr/actors/runtime/DaprGrpcClient.java → ...o/dapr/actors/runtime/DaprClientImpl.java
@@ -36,7 +36,7 @@
 /**
  * A DaprClient over HTTP for Actor's runtime.
  */
-class DaprGrpcClient implements DaprClient {
+class DaprClientImpl implements DaprClient {
 
   /**
    * Use to handle internal serialization.
@@ -60,7 +60,7 @@ class DaprGrpcClient implements DaprClient {
    *
    * @param channel channel (client needs to close channel after use).
    */
-  DaprGrpcClient(ManagedChannel channel) {
+  DaprClientImpl(ManagedChannel channel) {
     this(DaprGrpc.newStub(channel));
   }
 
@@ -69,7 +69,7 @@ class DaprGrpcClient implements DaprClient {
    *
    * @param daprStubClient Dapr's GRPC client.
    */
-  DaprGrpcClient(DaprGrpc.DaprStub daprStubClient) {
+  DaprClientImpl(DaprGrpc.DaprStub daprStubClient) {
     this.client = daprStubClient;
   }
 

diff --git a/sdk-actors/src/main/java/io/dapr/actors/runtime/DaprHttpClient.java b/sdk-actors/src/main/java/io/dapr/actors/runtime/DaprHttpClient.java
diff --git a/sdk-actors/src/test/java/io/dapr/actors/runtime/DaprGrpcClientTest.java b/sdk-actors/src/test/java/io/dapr/actors/runtime/DaprGrpcClientTest.java
@@ -68,7 +68,7 @@ public class DaprGrpcClientTest {
 
     private final DaprGrpc.DaprImplBase serviceImpl = new CustomDaprClient();
 
-    private DaprGrpcClient client;
+    private DaprClientImpl client;
 
     @Rule
     public final GrpcCleanupRule grpcCleanup = new GrpcCleanupRule();
@@ -87,7 +87,7 @@ public void setup() throws IOException {
                 InProcessChannelBuilder.forName(serverName).directExecutor().build());
 
         // Create a HelloWorldClient using the in-process channel;
-        client = new DaprGrpcClient(DaprGrpc.newStub(channel));
+        client = new DaprClientImpl(DaprGrpc.newStub(channel));
     }
 
     @Test