This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-grpc.git
The following commit(s) were added to refs/heads/main by this push:
new 3ca25317 Delete crdt-example.proto (#163)
3ca25317 is described below
commit 3ca2531749bbb28001c5c57d9bdcd913f7570369
Author: PJ Fanning <[email protected]>
AuthorDate: Fri Aug 11 16:07:51 2023 +0100
Delete crdt-example.proto (#163)
---
interop-tests/src/main/protobuf/crdt-example.proto | 65 ----------------------
1 file changed, 65 deletions(-)
diff --git a/interop-tests/src/main/protobuf/crdt-example.proto
b/interop-tests/src/main/protobuf/crdt-example.proto
deleted file mode 100644
index d4d9364e..00000000
--- a/interop-tests/src/main/protobuf/crdt-example.proto
+++ /dev/null
@@ -1,65 +0,0 @@
-syntax = "proto3";
-
-import "google/protobuf/empty.proto";
-
-package com.example.crdts;
-
-message UpdateCounter {
- string key = 1;
- int64 value = 2;
-}
-
-message CounterValue {
- int64 value = 1;
-}
-
-message Get {
- string key = 1;
-}
-
-message SomeValue {
- string key = 1;
- string description = 2;
-}
-
-message MutateSet {
- string key = 1;
- bool clear = 2;
- repeated SomeValue remove = 3;
- repeated SomeValue add = 4;
-}
-
-message SetSize {
- int32 size = 1;
-}
-
-message SetValue {
- repeated SomeValue items = 1;
-}
-
-message User {
- string name = 1;
-}
-
-message OnlineStatus {
- bool online = 1;
-}
-
-service CrdtExample {
- rpc IncrementGCounter(UpdateCounter) returns (CounterValue);
- rpc GetGCounter(Get) returns (CounterValue);
-
- rpc UpdatePNCounter(UpdateCounter) returns (CounterValue);
- rpc GetPNCounter(Get) returns (CounterValue);
-
- rpc MutateGSet(MutateSet) returns (SetSize);
- rpc GetGSet(Get) returns (SetValue);
-
- rpc MutateORSet(MutateSet) returns (SetSize);
- rpc GetORSet(Get) returns (SetValue);
-
- // Connect the given user. They will stay connected as long as the stream
stays open.
- rpc Connect(User) returns (stream google.protobuf.Empty);
- // Monitor the online status of the given user.
- rpc Monitor(User) returns (stream OnlineStatus);
-}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
