From cdc63627cf1dc1faf7640a59a686911f3963f8ff Mon Sep 17 00:00:00 2001
From: Marcel Lanz <marcellanz@n-1.ch>
Date: Mon, 18 Jan 2021 21:42:47 +0100
Subject: [PATCH] [proto] having gRPC service names PascalCase'd.

---
 protocols/protocol/cloudstate/action.proto        | 8 ++++----
 protocols/protocol/cloudstate/crdt.proto          | 2 +-
 protocols/protocol/cloudstate/entity.proto        | 4 ++--
 protocols/protocol/cloudstate/event_sourced.proto | 2 +-
 protocols/protocol/cloudstate/value_entity.proto  | 2 +-
 5 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/protocols/protocol/cloudstate/action.proto b/protocols/protocol/cloudstate/action.proto
index a387ac74b..0c007cec8 100644
--- a/protocols/protocol/cloudstate/action.proto
+++ b/protocols/protocol/cloudstate/action.proto
@@ -66,7 +66,7 @@ service ActionProtocol {
     // The input command will contain the service name, command name, request metadata and the command
     // payload. The reply may contain a direct reply, a forward or a failure, and it may contain many
     // side effects.
-    rpc handleUnary(ActionCommand) returns (ActionResponse) {}
+    rpc HandleUnary(ActionCommand) returns (ActionResponse) {}
 
     // Handle a streamed in command.
     //
@@ -89,7 +89,7 @@ service ActionProtocol {
     //
     // Either the client or the server may cancel the stream at any time, cancellation is indicated
     // through an HTTP2 stream RST message.
-    rpc handleStreamedIn(stream ActionCommand) returns (ActionResponse) {}
+    rpc HandleStreamedIn(stream ActionCommand) returns (ActionResponse) {}
 
     // Handle a streamed out command.
     //
@@ -100,7 +100,7 @@ service ActionProtocol {
     //
     // Either the client or the server may cancel the stream at any time, cancellation is indicated
     // through an HTTP2 stream RST message.
-    rpc handleStreamedOut(ActionCommand) returns (stream ActionResponse) {}
+    rpc HandleStreamedOut(ActionCommand) returns (stream ActionResponse) {}
 
     // Handle a full duplex streamed command.
     //
@@ -127,6 +127,6 @@ service ActionProtocol {
     //
     // Either the client or the server may cancel the stream at any time, cancellation is indicated
     // through an HTTP2 stream RST message.
-    rpc handleStreamed(stream ActionCommand) returns (stream ActionResponse) {}
+    rpc HandleStreamed(stream ActionCommand) returns (stream ActionResponse) {}
 
 }
diff --git a/protocols/protocol/cloudstate/crdt.proto b/protocols/protocol/cloudstate/crdt.proto
index b236e5d1a..4ce4902b3 100644
--- a/protocols/protocol/cloudstate/crdt.proto
+++ b/protocols/protocol/cloudstate/crdt.proto
@@ -59,7 +59,7 @@ service Crdt {
     //
     // The user function must respond with one reply per command in. They do not necessarily have to be sent in the same
     // order that the commands were sent, the command ID is used to correlate commands to replies.
-    rpc handle(stream CrdtStreamIn) returns (stream CrdtStreamOut);
+    rpc Handle(stream CrdtStreamIn) returns (stream CrdtStreamOut);
 }
 
 // Message for the Crdt handle stream in.
diff --git a/protocols/protocol/cloudstate/entity.proto b/protocols/protocol/cloudstate/entity.proto
index 65f38b29b..9c5486c60 100644
--- a/protocols/protocol/cloudstate/entity.proto
+++ b/protocols/protocol/cloudstate/entity.proto
@@ -308,11 +308,11 @@ message ProxyInfo {
 service EntityDiscovery {
 
     // Discover what entities the user function wishes to serve.
-    rpc discover(ProxyInfo) returns (EntitySpec) {}
+    rpc Discover(ProxyInfo) returns (EntitySpec) {}
 
     // Report an error back to the user function. This will only be invoked to tell the user function
     // that it has done something wrong, eg, violated the protocol, tried to use an entity type that
     // isn't supported, or attempted to forward to an entity that doesn't exist, etc. These messages
     // should be logged clearly for debugging purposes.
-    rpc reportError(UserFunctionError) returns (google.protobuf.Empty) {}
+    rpc ReportError(UserFunctionError) returns (google.protobuf.Empty) {}
 }
diff --git a/protocols/protocol/cloudstate/event_sourced.proto b/protocols/protocol/cloudstate/event_sourced.proto
index 5232205b9..66f38e3e0 100644
--- a/protocols/protocol/cloudstate/event_sourced.proto
+++ b/protocols/protocol/cloudstate/event_sourced.proto
@@ -111,5 +111,5 @@ service EventSourced {
     // message. The entity should reply in order, and any events that the entity requests to be
     // persisted the entity should handle itself, applying them to its own state, as if they had
     // arrived as events when the event stream was being replayed on load.
-    rpc handle(stream EventSourcedStreamIn) returns (stream EventSourcedStreamOut) {}
+    rpc Handle(stream EventSourcedStreamIn) returns (stream EventSourcedStreamOut) {}
 }
diff --git a/protocols/protocol/cloudstate/value_entity.proto b/protocols/protocol/cloudstate/value_entity.proto
index 109721ce2..dd073a4b6 100644
--- a/protocols/protocol/cloudstate/value_entity.proto
+++ b/protocols/protocol/cloudstate/value_entity.proto
@@ -36,7 +36,7 @@ service ValueEntity {
   // to the entity. The entity is expected to reply to each command with exactly one reply message.
   // The entity should process commands and reply to commands in the order they came
   // in. When processing a command the entity can read and persist (update or delete) the state.
-  rpc handle(stream ValueEntityStreamIn) returns (stream ValueEntityStreamOut) {}
+  rpc Handle(stream ValueEntityStreamIn) returns (stream ValueEntityStreamOut) {}
 }
 
 // Input message type for the gRPC stream in.