This is an automated email from the ASF dual-hosted git repository.
tison pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-horaedb-proto.git
The following commit(s) were added to refs/heads/main by this push:
new e73cf30 feat!: rename CeresmetaRpcService to MetaRpcService (#118)
e73cf30 is described below
commit e73cf3071e9f291af67cccad1e376210fcc2175e
Author: tison <[email protected]>
AuthorDate: Tue Dec 26 19:59:19 2023 +0800
feat!: rename CeresmetaRpcService to MetaRpcService (#118)
Signed-off-by: tison <[email protected]>
---
Cargo.toml | 2 +-
golang/pkg/metaservicepb/meta_service.pb.go | 119 +++++++++--------
golang/pkg/metaservicepb/meta_service_grpc.pb.go | 156 +++++++++++------------
java/pom.xml | 2 +-
protos/meta_service.proto | 2 +-
5 files changed, 140 insertions(+), 141 deletions(-)
diff --git a/Cargo.toml b/Cargo.toml
index b6af5da..7beeaca 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -17,7 +17,7 @@
[package]
name = "horaedbproto"
-version = "1.0.24"
+version = "2.0.0"
edition = "2021"
license = "Apache-2.0"
readme = "README.md"
diff --git a/golang/pkg/metaservicepb/meta_service.pb.go
b/golang/pkg/metaservicepb/meta_service.pb.go
index e014450..90e91b3 100644
--- a/golang/pkg/metaservicepb/meta_service.pb.go
+++ b/golang/pkg/metaservicepb/meta_service.pb.go
@@ -1681,52 +1681,51 @@ var file_meta_service_proto_rawDesc = []byte{
0x6f, 0x6e, 0x73, 0x65, 0x12, 0x2e, 0x0a, 0x06, 0x68, 0x65, 0x61, 0x64,
0x65, 0x72, 0x18, 0x01,
0x20, 0x01, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x63, 0x6f, 0x6d, 0x6d, 0x6f,
0x6e, 0x2e, 0x52, 0x65,
0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72,
0x52, 0x06, 0x68, 0x65,
- 0x61, 0x64, 0x65, 0x72, 0x32, 0xfe, 0x04, 0x0a, 0x13, 0x43, 0x65, 0x72,
0x65, 0x73, 0x6d, 0x65,
- 0x74, 0x61, 0x52, 0x70, 0x63, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
0x12, 0x5a, 0x0a, 0x0d,
- 0x41, 0x6c, 0x6c, 0x6f, 0x63, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x49,
0x44, 0x12, 0x22, 0x2e,
- 0x6d, 0x65, 0x74, 0x61, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
0x2e, 0x41, 0x6c, 0x6c,
- 0x6f, 0x63, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x49, 0x64, 0x52, 0x65,
0x71, 0x75, 0x65, 0x73,
- 0x74, 0x1a, 0x23, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x5f, 0x73, 0x65, 0x72,
0x76, 0x69, 0x63, 0x65,
- 0x2e, 0x41, 0x6c, 0x6c, 0x6f, 0x63, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61,
0x49, 0x64, 0x52, 0x65,
- 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x66, 0x0a, 0x11,
0x47, 0x65, 0x74, 0x54,
- 0x61, 0x62, 0x6c, 0x65, 0x73, 0x4f, 0x66, 0x53, 0x68, 0x61, 0x72, 0x64,
0x73, 0x12, 0x26, 0x2e,
- 0x6d, 0x65, 0x74, 0x61, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
0x2e, 0x47, 0x65, 0x74,
- 0x54, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x4f, 0x66, 0x53, 0x68, 0x61, 0x72,
0x64, 0x73, 0x52, 0x65,
- 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x27, 0x2e, 0x6d, 0x65, 0x74, 0x61,
0x5f, 0x73, 0x65, 0x72,
- 0x76, 0x69, 0x63, 0x65, 0x2e, 0x47, 0x65, 0x74, 0x54, 0x61, 0x62, 0x6c,
0x65, 0x73, 0x4f, 0x66,
- 0x53, 0x68, 0x61, 0x72, 0x64, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
0x73, 0x65, 0x22, 0x00,
- 0x12, 0x54, 0x0a, 0x0b, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x61,
0x62, 0x6c, 0x65, 0x12,
- 0x20, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69,
0x63, 0x65, 0x2e, 0x43,
- 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65,
0x71, 0x75, 0x65, 0x73,
- 0x74, 0x1a, 0x21, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x5f, 0x73, 0x65, 0x72,
0x76, 0x69, 0x63, 0x65,
- 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65,
0x52, 0x65, 0x73, 0x70,
- 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x4e, 0x0a, 0x09, 0x44, 0x72,
0x6f, 0x70, 0x54, 0x61,
- 0x62, 0x6c, 0x65, 0x12, 0x1e, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x5f, 0x73,
0x65, 0x72, 0x76, 0x69,
- 0x63, 0x65, 0x2e, 0x44, 0x72, 0x6f, 0x70, 0x54, 0x61, 0x62, 0x6c, 0x65,
0x52, 0x65, 0x71, 0x75,
- 0x65, 0x73, 0x74, 0x1a, 0x1f, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x5f, 0x73,
0x65, 0x72, 0x76, 0x69,
- 0x63, 0x65, 0x2e, 0x44, 0x72, 0x6f, 0x70, 0x54, 0x61, 0x62, 0x6c, 0x65,
0x52, 0x65, 0x73, 0x70,
- 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x54, 0x0a, 0x0b, 0x52, 0x6f,
0x75, 0x74, 0x65, 0x54,
- 0x61, 0x62, 0x6c, 0x65, 0x73, 0x12, 0x20, 0x2e, 0x6d, 0x65, 0x74, 0x61,
0x5f, 0x73, 0x65, 0x72,
- 0x76, 0x69, 0x63, 0x65, 0x2e, 0x52, 0x6f, 0x75, 0x74, 0x65, 0x54, 0x61,
0x62, 0x6c, 0x65, 0x73,
- 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x21, 0x2e, 0x6d, 0x65,
0x74, 0x61, 0x5f, 0x73,
- 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x52, 0x6f, 0x75, 0x74, 0x65,
0x54, 0x61, 0x62, 0x6c,
- 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00,
0x12, 0x4b, 0x0a, 0x08,
- 0x47, 0x65, 0x74, 0x4e, 0x6f, 0x64, 0x65, 0x73, 0x12, 0x1d, 0x2e, 0x6d,
0x65, 0x74, 0x61, 0x5f,
- 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x47, 0x65, 0x74, 0x4e,
0x6f, 0x64, 0x65, 0x73,
- 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x2e, 0x6d, 0x65,
0x74, 0x61, 0x5f, 0x73,
- 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x47, 0x65, 0x74, 0x4e, 0x6f,
0x64, 0x65, 0x73, 0x52,
- 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x5a, 0x0a,
0x0d, 0x4e, 0x6f, 0x64,
- 0x65, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x12, 0x22,
0x2e, 0x6d, 0x65, 0x74,
- 0x61, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x4e, 0x6f,
0x64, 0x65, 0x48, 0x65,
- 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65,
0x73, 0x74, 0x1a, 0x23,
- 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63,
0x65, 0x2e, 0x4e, 0x6f,
- 0x64, 0x65, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x52,
0x65, 0x73, 0x70, 0x6f,
- 0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0x44, 0x5a, 0x42, 0x67, 0x69, 0x74,
0x68, 0x75, 0x62, 0x2e,
- 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x70, 0x61, 0x63, 0x68, 0x65, 0x2f, 0x69,
0x6e, 0x63, 0x75, 0x62,
- 0x61, 0x74, 0x6f, 0x72, 0x2d, 0x68, 0x6f, 0x72, 0x61, 0x65, 0x64, 0x62,
0x2d, 0x70, 0x72, 0x6f,
- 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2f, 0x70, 0x6b,
0x67, 0x2f, 0x6d, 0x65,
- 0x74, 0x61, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x70, 0x62, 0x62,
0x06, 0x70, 0x72, 0x6f,
- 0x74, 0x6f, 0x33,
+ 0x61, 0x64, 0x65, 0x72, 0x32, 0xf9, 0x04, 0x0a, 0x0e, 0x4d, 0x65, 0x74,
0x61, 0x52, 0x70, 0x63,
+ 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x5a, 0x0a, 0x0d, 0x41,
0x6c, 0x6c, 0x6f, 0x63,
+ 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x49, 0x44, 0x12, 0x22, 0x2e, 0x6d,
0x65, 0x74, 0x61, 0x5f,
+ 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x41, 0x6c, 0x6c, 0x6f,
0x63, 0x53, 0x63, 0x68,
+ 0x65, 0x6d, 0x61, 0x49, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
0x1a, 0x23, 0x2e, 0x6d,
+ 0x65, 0x74, 0x61, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e,
0x41, 0x6c, 0x6c, 0x6f,
+ 0x63, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x49, 0x64, 0x52, 0x65, 0x73,
0x70, 0x6f, 0x6e, 0x73,
+ 0x65, 0x22, 0x00, 0x12, 0x66, 0x0a, 0x11, 0x47, 0x65, 0x74, 0x54, 0x61,
0x62, 0x6c, 0x65, 0x73,
+ 0x4f, 0x66, 0x53, 0x68, 0x61, 0x72, 0x64, 0x73, 0x12, 0x26, 0x2e, 0x6d,
0x65, 0x74, 0x61, 0x5f,
+ 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x47, 0x65, 0x74, 0x54,
0x61, 0x62, 0x6c, 0x65,
+ 0x73, 0x4f, 0x66, 0x53, 0x68, 0x61, 0x72, 0x64, 0x73, 0x52, 0x65, 0x71,
0x75, 0x65, 0x73, 0x74,
+ 0x1a, 0x27, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x5f, 0x73, 0x65, 0x72, 0x76,
0x69, 0x63, 0x65, 0x2e,
+ 0x47, 0x65, 0x74, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x4f, 0x66, 0x53,
0x68, 0x61, 0x72, 0x64,
+ 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12,
0x54, 0x0a, 0x0b, 0x43,
+ 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x20,
0x2e, 0x6d, 0x65, 0x74,
+ 0x61, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x43, 0x72,
0x65, 0x61, 0x74, 0x65,
+ 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
0x1a, 0x21, 0x2e, 0x6d,
+ 0x65, 0x74, 0x61, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e,
0x43, 0x72, 0x65, 0x61,
+ 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f,
0x6e, 0x73, 0x65, 0x22,
+ 0x00, 0x12, 0x4e, 0x0a, 0x09, 0x44, 0x72, 0x6f, 0x70, 0x54, 0x61, 0x62,
0x6c, 0x65, 0x12, 0x1e,
+ 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63,
0x65, 0x2e, 0x44, 0x72,
+ 0x6f, 0x70, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65,
0x73, 0x74, 0x1a, 0x1f,
+ 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63,
0x65, 0x2e, 0x44, 0x72,
+ 0x6f, 0x70, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f,
0x6e, 0x73, 0x65, 0x22,
+ 0x00, 0x12, 0x54, 0x0a, 0x0b, 0x52, 0x6f, 0x75, 0x74, 0x65, 0x54, 0x61,
0x62, 0x6c, 0x65, 0x73,
+ 0x12, 0x20, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x5f, 0x73, 0x65, 0x72, 0x76,
0x69, 0x63, 0x65, 0x2e,
+ 0x52, 0x6f, 0x75, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x52,
0x65, 0x71, 0x75, 0x65,
+ 0x73, 0x74, 0x1a, 0x21, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x5f, 0x73, 0x65,
0x72, 0x76, 0x69, 0x63,
+ 0x65, 0x2e, 0x52, 0x6f, 0x75, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65,
0x73, 0x52, 0x65, 0x73,
+ 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x4b, 0x0a, 0x08, 0x47,
0x65, 0x74, 0x4e, 0x6f,
+ 0x64, 0x65, 0x73, 0x12, 0x1d, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x5f, 0x73,
0x65, 0x72, 0x76, 0x69,
+ 0x63, 0x65, 0x2e, 0x47, 0x65, 0x74, 0x4e, 0x6f, 0x64, 0x65, 0x73, 0x52,
0x65, 0x71, 0x75, 0x65,
+ 0x73, 0x74, 0x1a, 0x1e, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x5f, 0x73, 0x65,
0x72, 0x76, 0x69, 0x63,
+ 0x65, 0x2e, 0x47, 0x65, 0x74, 0x4e, 0x6f, 0x64, 0x65, 0x73, 0x52, 0x65,
0x73, 0x70, 0x6f, 0x6e,
+ 0x73, 0x65, 0x22, 0x00, 0x12, 0x5a, 0x0a, 0x0d, 0x4e, 0x6f, 0x64, 0x65,
0x48, 0x65, 0x61, 0x72,
+ 0x74, 0x62, 0x65, 0x61, 0x74, 0x12, 0x22, 0x2e, 0x6d, 0x65, 0x74, 0x61,
0x5f, 0x73, 0x65, 0x72,
+ 0x76, 0x69, 0x63, 0x65, 0x2e, 0x4e, 0x6f, 0x64, 0x65, 0x48, 0x65, 0x61,
0x72, 0x74, 0x62, 0x65,
+ 0x61, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x23, 0x2e,
0x6d, 0x65, 0x74, 0x61,
+ 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x4e, 0x6f, 0x64,
0x65, 0x48, 0x65, 0x61,
+ 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
0x73, 0x65, 0x22, 0x00,
+ 0x42, 0x44, 0x5a, 0x42, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63,
0x6f, 0x6d, 0x2f, 0x61,
+ 0x70, 0x61, 0x63, 0x68, 0x65, 0x2f, 0x69, 0x6e, 0x63, 0x75, 0x62, 0x61,
0x74, 0x6f, 0x72, 0x2d,
+ 0x68, 0x6f, 0x72, 0x61, 0x65, 0x64, 0x62, 0x2d, 0x70, 0x72, 0x6f, 0x74,
0x6f, 0x2f, 0x67, 0x6f,
+ 0x6c, 0x61, 0x6e, 0x67, 0x2f, 0x70, 0x6b, 0x67, 0x2f, 0x6d, 0x65, 0x74,
0x61, 0x73, 0x65, 0x72,
+ 0x76, 0x69, 0x63, 0x65, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74,
0x6f, 0x33,
}
var (
@@ -1811,20 +1810,20 @@ var file_meta_service_proto_depIdxs = []int32{
26, // 33: meta_service.NodeHeartbeatResponse.header:type_name ->
common.ResponseHeader
9, // 34:
meta_service.GetTablesOfShardsResponse.TablesByShardEntry.value:type_name ->
meta_service.TablesOfShard
13, // 35:
meta_service.RouteTablesResponse.EntriesEntry.value:type_name ->
meta_service.RouteEntry
- 2, // 36: meta_service.CeresmetaRpcService.AllocSchemaID:input_type ->
meta_service.AllocSchemaIdRequest
- 8, // 37:
meta_service.CeresmetaRpcService.GetTablesOfShards:input_type ->
meta_service.GetTablesOfShardsRequest
- 4, // 38: meta_service.CeresmetaRpcService.CreateTable:input_type ->
meta_service.CreateTableRequest
- 17, // 39: meta_service.CeresmetaRpcService.DropTable:input_type ->
meta_service.DropTableRequest
- 11, // 40: meta_service.CeresmetaRpcService.RouteTables:input_type ->
meta_service.RouteTablesRequest
- 15, // 41: meta_service.CeresmetaRpcService.GetNodes:input_type ->
meta_service.GetNodesRequest
- 19, // 42: meta_service.CeresmetaRpcService.NodeHeartbeat:input_type ->
meta_service.NodeHeartbeatRequest
- 3, // 43: meta_service.CeresmetaRpcService.AllocSchemaID:output_type
-> meta_service.AllocSchemaIdResponse
- 10, // 44:
meta_service.CeresmetaRpcService.GetTablesOfShards:output_type ->
meta_service.GetTablesOfShardsResponse
- 7, // 45: meta_service.CeresmetaRpcService.CreateTable:output_type ->
meta_service.CreateTableResponse
- 18, // 46: meta_service.CeresmetaRpcService.DropTable:output_type ->
meta_service.DropTableResponse
- 14, // 47: meta_service.CeresmetaRpcService.RouteTables:output_type ->
meta_service.RouteTablesResponse
- 16, // 48: meta_service.CeresmetaRpcService.GetNodes:output_type ->
meta_service.GetNodesResponse
- 22, // 49: meta_service.CeresmetaRpcService.NodeHeartbeat:output_type
-> meta_service.NodeHeartbeatResponse
+ 2, // 36: meta_service.MetaRpcService.AllocSchemaID:input_type ->
meta_service.AllocSchemaIdRequest
+ 8, // 37: meta_service.MetaRpcService.GetTablesOfShards:input_type ->
meta_service.GetTablesOfShardsRequest
+ 4, // 38: meta_service.MetaRpcService.CreateTable:input_type ->
meta_service.CreateTableRequest
+ 17, // 39: meta_service.MetaRpcService.DropTable:input_type ->
meta_service.DropTableRequest
+ 11, // 40: meta_service.MetaRpcService.RouteTables:input_type ->
meta_service.RouteTablesRequest
+ 15, // 41: meta_service.MetaRpcService.GetNodes:input_type ->
meta_service.GetNodesRequest
+ 19, // 42: meta_service.MetaRpcService.NodeHeartbeat:input_type ->
meta_service.NodeHeartbeatRequest
+ 3, // 43: meta_service.MetaRpcService.AllocSchemaID:output_type ->
meta_service.AllocSchemaIdResponse
+ 10, // 44: meta_service.MetaRpcService.GetTablesOfShards:output_type ->
meta_service.GetTablesOfShardsResponse
+ 7, // 45: meta_service.MetaRpcService.CreateTable:output_type ->
meta_service.CreateTableResponse
+ 18, // 46: meta_service.MetaRpcService.DropTable:output_type ->
meta_service.DropTableResponse
+ 14, // 47: meta_service.MetaRpcService.RouteTables:output_type ->
meta_service.RouteTablesResponse
+ 16, // 48: meta_service.MetaRpcService.GetNodes:output_type ->
meta_service.GetNodesResponse
+ 22, // 49: meta_service.MetaRpcService.NodeHeartbeat:output_type ->
meta_service.NodeHeartbeatResponse
43, // [43:50] is the sub-list for method output_type
36, // [36:43] is the sub-list for method input_type
36, // [36:36] is the sub-list for extension type_name
diff --git a/golang/pkg/metaservicepb/meta_service_grpc.pb.go
b/golang/pkg/metaservicepb/meta_service_grpc.pb.go
index 8b8970b..c01e20f 100644
--- a/golang/pkg/metaservicepb/meta_service_grpc.pb.go
+++ b/golang/pkg/metaservicepb/meta_service_grpc.pb.go
@@ -18,10 +18,10 @@ import (
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
-// CeresmetaRpcServiceClient is the client API for CeresmetaRpcService service.
+// MetaRpcServiceClient is the client API for MetaRpcService service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please
refer to
https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
-type CeresmetaRpcServiceClient interface {
+type MetaRpcServiceClient interface {
AllocSchemaID(ctx context.Context, in *AllocSchemaIdRequest, opts
...grpc.CallOption) (*AllocSchemaIdResponse, error)
GetTablesOfShards(ctx context.Context, in *GetTablesOfShardsRequest,
opts ...grpc.CallOption) (*GetTablesOfShardsResponse, error)
CreateTable(ctx context.Context, in *CreateTableRequest, opts
...grpc.CallOption) (*CreateTableResponse, error)
@@ -31,81 +31,81 @@ type CeresmetaRpcServiceClient interface {
NodeHeartbeat(ctx context.Context, in *NodeHeartbeatRequest, opts
...grpc.CallOption) (*NodeHeartbeatResponse, error)
}
-type ceresmetaRpcServiceClient struct {
+type metaRpcServiceClient struct {
cc grpc.ClientConnInterface
}
-func NewCeresmetaRpcServiceClient(cc grpc.ClientConnInterface)
CeresmetaRpcServiceClient {
- return &ceresmetaRpcServiceClient{cc}
+func NewMetaRpcServiceClient(cc grpc.ClientConnInterface) MetaRpcServiceClient
{
+ return &metaRpcServiceClient{cc}
}
-func (c *ceresmetaRpcServiceClient) AllocSchemaID(ctx context.Context, in
*AllocSchemaIdRequest, opts ...grpc.CallOption) (*AllocSchemaIdResponse, error)
{
+func (c *metaRpcServiceClient) AllocSchemaID(ctx context.Context, in
*AllocSchemaIdRequest, opts ...grpc.CallOption) (*AllocSchemaIdResponse, error)
{
out := new(AllocSchemaIdResponse)
- err := c.cc.Invoke(ctx,
"/meta_service.CeresmetaRpcService/AllocSchemaID", in, out, opts...)
+ err := c.cc.Invoke(ctx, "/meta_service.MetaRpcService/AllocSchemaID",
in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
-func (c *ceresmetaRpcServiceClient) GetTablesOfShards(ctx context.Context, in
*GetTablesOfShardsRequest, opts ...grpc.CallOption)
(*GetTablesOfShardsResponse, error) {
+func (c *metaRpcServiceClient) GetTablesOfShards(ctx context.Context, in
*GetTablesOfShardsRequest, opts ...grpc.CallOption)
(*GetTablesOfShardsResponse, error) {
out := new(GetTablesOfShardsResponse)
- err := c.cc.Invoke(ctx,
"/meta_service.CeresmetaRpcService/GetTablesOfShards", in, out, opts...)
+ err := c.cc.Invoke(ctx,
"/meta_service.MetaRpcService/GetTablesOfShards", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
-func (c *ceresmetaRpcServiceClient) CreateTable(ctx context.Context, in
*CreateTableRequest, opts ...grpc.CallOption) (*CreateTableResponse, error) {
+func (c *metaRpcServiceClient) CreateTable(ctx context.Context, in
*CreateTableRequest, opts ...grpc.CallOption) (*CreateTableResponse, error) {
out := new(CreateTableResponse)
- err := c.cc.Invoke(ctx,
"/meta_service.CeresmetaRpcService/CreateTable", in, out, opts...)
+ err := c.cc.Invoke(ctx, "/meta_service.MetaRpcService/CreateTable", in,
out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
-func (c *ceresmetaRpcServiceClient) DropTable(ctx context.Context, in
*DropTableRequest, opts ...grpc.CallOption) (*DropTableResponse, error) {
+func (c *metaRpcServiceClient) DropTable(ctx context.Context, in
*DropTableRequest, opts ...grpc.CallOption) (*DropTableResponse, error) {
out := new(DropTableResponse)
- err := c.cc.Invoke(ctx, "/meta_service.CeresmetaRpcService/DropTable",
in, out, opts...)
+ err := c.cc.Invoke(ctx, "/meta_service.MetaRpcService/DropTable", in,
out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
-func (c *ceresmetaRpcServiceClient) RouteTables(ctx context.Context, in
*RouteTablesRequest, opts ...grpc.CallOption) (*RouteTablesResponse, error) {
+func (c *metaRpcServiceClient) RouteTables(ctx context.Context, in
*RouteTablesRequest, opts ...grpc.CallOption) (*RouteTablesResponse, error) {
out := new(RouteTablesResponse)
- err := c.cc.Invoke(ctx,
"/meta_service.CeresmetaRpcService/RouteTables", in, out, opts...)
+ err := c.cc.Invoke(ctx, "/meta_service.MetaRpcService/RouteTables", in,
out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
-func (c *ceresmetaRpcServiceClient) GetNodes(ctx context.Context, in
*GetNodesRequest, opts ...grpc.CallOption) (*GetNodesResponse, error) {
+func (c *metaRpcServiceClient) GetNodes(ctx context.Context, in
*GetNodesRequest, opts ...grpc.CallOption) (*GetNodesResponse, error) {
out := new(GetNodesResponse)
- err := c.cc.Invoke(ctx, "/meta_service.CeresmetaRpcService/GetNodes",
in, out, opts...)
+ err := c.cc.Invoke(ctx, "/meta_service.MetaRpcService/GetNodes", in,
out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
-func (c *ceresmetaRpcServiceClient) NodeHeartbeat(ctx context.Context, in
*NodeHeartbeatRequest, opts ...grpc.CallOption) (*NodeHeartbeatResponse, error)
{
+func (c *metaRpcServiceClient) NodeHeartbeat(ctx context.Context, in
*NodeHeartbeatRequest, opts ...grpc.CallOption) (*NodeHeartbeatResponse, error)
{
out := new(NodeHeartbeatResponse)
- err := c.cc.Invoke(ctx,
"/meta_service.CeresmetaRpcService/NodeHeartbeat", in, out, opts...)
+ err := c.cc.Invoke(ctx, "/meta_service.MetaRpcService/NodeHeartbeat",
in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
-// CeresmetaRpcServiceServer is the server API for CeresmetaRpcService service.
-// All implementations must embed UnimplementedCeresmetaRpcServiceServer
+// MetaRpcServiceServer is the server API for MetaRpcService service.
+// All implementations must embed UnimplementedMetaRpcServiceServer
// for forward compatibility
-type CeresmetaRpcServiceServer interface {
+type MetaRpcServiceServer interface {
AllocSchemaID(context.Context, *AllocSchemaIdRequest)
(*AllocSchemaIdResponse, error)
GetTablesOfShards(context.Context, *GetTablesOfShardsRequest)
(*GetTablesOfShardsResponse, error)
CreateTable(context.Context, *CreateTableRequest)
(*CreateTableResponse, error)
@@ -113,207 +113,207 @@ type CeresmetaRpcServiceServer interface {
RouteTables(context.Context, *RouteTablesRequest)
(*RouteTablesResponse, error)
GetNodes(context.Context, *GetNodesRequest) (*GetNodesResponse, error)
NodeHeartbeat(context.Context, *NodeHeartbeatRequest)
(*NodeHeartbeatResponse, error)
- mustEmbedUnimplementedCeresmetaRpcServiceServer()
+ mustEmbedUnimplementedMetaRpcServiceServer()
}
-// UnimplementedCeresmetaRpcServiceServer must be embedded to have forward
compatible implementations.
-type UnimplementedCeresmetaRpcServiceServer struct {
+// UnimplementedMetaRpcServiceServer must be embedded to have forward
compatible implementations.
+type UnimplementedMetaRpcServiceServer struct {
}
-func (UnimplementedCeresmetaRpcServiceServer) AllocSchemaID(context.Context,
*AllocSchemaIdRequest) (*AllocSchemaIdResponse, error) {
+func (UnimplementedMetaRpcServiceServer) AllocSchemaID(context.Context,
*AllocSchemaIdRequest) (*AllocSchemaIdResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method AllocSchemaID
not implemented")
}
-func (UnimplementedCeresmetaRpcServiceServer)
GetTablesOfShards(context.Context, *GetTablesOfShardsRequest)
(*GetTablesOfShardsResponse, error) {
+func (UnimplementedMetaRpcServiceServer) GetTablesOfShards(context.Context,
*GetTablesOfShardsRequest) (*GetTablesOfShardsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method
GetTablesOfShards not implemented")
}
-func (UnimplementedCeresmetaRpcServiceServer) CreateTable(context.Context,
*CreateTableRequest) (*CreateTableResponse, error) {
+func (UnimplementedMetaRpcServiceServer) CreateTable(context.Context,
*CreateTableRequest) (*CreateTableResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method CreateTable not
implemented")
}
-func (UnimplementedCeresmetaRpcServiceServer) DropTable(context.Context,
*DropTableRequest) (*DropTableResponse, error) {
+func (UnimplementedMetaRpcServiceServer) DropTable(context.Context,
*DropTableRequest) (*DropTableResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method DropTable not
implemented")
}
-func (UnimplementedCeresmetaRpcServiceServer) RouteTables(context.Context,
*RouteTablesRequest) (*RouteTablesResponse, error) {
+func (UnimplementedMetaRpcServiceServer) RouteTables(context.Context,
*RouteTablesRequest) (*RouteTablesResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method RouteTables not
implemented")
}
-func (UnimplementedCeresmetaRpcServiceServer) GetNodes(context.Context,
*GetNodesRequest) (*GetNodesResponse, error) {
+func (UnimplementedMetaRpcServiceServer) GetNodes(context.Context,
*GetNodesRequest) (*GetNodesResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetNodes not
implemented")
}
-func (UnimplementedCeresmetaRpcServiceServer) NodeHeartbeat(context.Context,
*NodeHeartbeatRequest) (*NodeHeartbeatResponse, error) {
+func (UnimplementedMetaRpcServiceServer) NodeHeartbeat(context.Context,
*NodeHeartbeatRequest) (*NodeHeartbeatResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method NodeHeartbeat
not implemented")
}
-func (UnimplementedCeresmetaRpcServiceServer)
mustEmbedUnimplementedCeresmetaRpcServiceServer() {}
+func (UnimplementedMetaRpcServiceServer)
mustEmbedUnimplementedMetaRpcServiceServer() {}
-// UnsafeCeresmetaRpcServiceServer may be embedded to opt out of forward
compatibility for this service.
-// Use of this interface is not recommended, as added methods to
CeresmetaRpcServiceServer will
+// UnsafeMetaRpcServiceServer may be embedded to opt out of forward
compatibility for this service.
+// Use of this interface is not recommended, as added methods to
MetaRpcServiceServer will
// result in compilation errors.
-type UnsafeCeresmetaRpcServiceServer interface {
- mustEmbedUnimplementedCeresmetaRpcServiceServer()
+type UnsafeMetaRpcServiceServer interface {
+ mustEmbedUnimplementedMetaRpcServiceServer()
}
-func RegisterCeresmetaRpcServiceServer(s grpc.ServiceRegistrar, srv
CeresmetaRpcServiceServer) {
- s.RegisterService(&CeresmetaRpcService_ServiceDesc, srv)
+func RegisterMetaRpcServiceServer(s grpc.ServiceRegistrar, srv
MetaRpcServiceServer) {
+ s.RegisterService(&MetaRpcService_ServiceDesc, srv)
}
-func _CeresmetaRpcService_AllocSchemaID_Handler(srv interface{}, ctx
context.Context, dec func(interface{}) error, interceptor
grpc.UnaryServerInterceptor) (interface{}, error) {
+func _MetaRpcService_AllocSchemaID_Handler(srv interface{}, ctx
context.Context, dec func(interface{}) error, interceptor
grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(AllocSchemaIdRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
- return srv.(CeresmetaRpcServiceServer).AllocSchemaID(ctx, in)
+ return srv.(MetaRpcServiceServer).AllocSchemaID(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
- FullMethod: "/meta_service.CeresmetaRpcService/AllocSchemaID",
+ FullMethod: "/meta_service.MetaRpcService/AllocSchemaID",
}
handler := func(ctx context.Context, req interface{}) (interface{},
error) {
- return srv.(CeresmetaRpcServiceServer).AllocSchemaID(ctx,
req.(*AllocSchemaIdRequest))
+ return srv.(MetaRpcServiceServer).AllocSchemaID(ctx,
req.(*AllocSchemaIdRequest))
}
return interceptor(ctx, in, info, handler)
}
-func _CeresmetaRpcService_GetTablesOfShards_Handler(srv interface{}, ctx
context.Context, dec func(interface{}) error, interceptor
grpc.UnaryServerInterceptor) (interface{}, error) {
+func _MetaRpcService_GetTablesOfShards_Handler(srv interface{}, ctx
context.Context, dec func(interface{}) error, interceptor
grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetTablesOfShardsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
- return srv.(CeresmetaRpcServiceServer).GetTablesOfShards(ctx,
in)
+ return srv.(MetaRpcServiceServer).GetTablesOfShards(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
- FullMethod:
"/meta_service.CeresmetaRpcService/GetTablesOfShards",
+ FullMethod: "/meta_service.MetaRpcService/GetTablesOfShards",
}
handler := func(ctx context.Context, req interface{}) (interface{},
error) {
- return srv.(CeresmetaRpcServiceServer).GetTablesOfShards(ctx,
req.(*GetTablesOfShardsRequest))
+ return srv.(MetaRpcServiceServer).GetTablesOfShards(ctx,
req.(*GetTablesOfShardsRequest))
}
return interceptor(ctx, in, info, handler)
}
-func _CeresmetaRpcService_CreateTable_Handler(srv interface{}, ctx
context.Context, dec func(interface{}) error, interceptor
grpc.UnaryServerInterceptor) (interface{}, error) {
+func _MetaRpcService_CreateTable_Handler(srv interface{}, ctx context.Context,
dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor)
(interface{}, error) {
in := new(CreateTableRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
- return srv.(CeresmetaRpcServiceServer).CreateTable(ctx, in)
+ return srv.(MetaRpcServiceServer).CreateTable(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
- FullMethod: "/meta_service.CeresmetaRpcService/CreateTable",
+ FullMethod: "/meta_service.MetaRpcService/CreateTable",
}
handler := func(ctx context.Context, req interface{}) (interface{},
error) {
- return srv.(CeresmetaRpcServiceServer).CreateTable(ctx,
req.(*CreateTableRequest))
+ return srv.(MetaRpcServiceServer).CreateTable(ctx,
req.(*CreateTableRequest))
}
return interceptor(ctx, in, info, handler)
}
-func _CeresmetaRpcService_DropTable_Handler(srv interface{}, ctx
context.Context, dec func(interface{}) error, interceptor
grpc.UnaryServerInterceptor) (interface{}, error) {
+func _MetaRpcService_DropTable_Handler(srv interface{}, ctx context.Context,
dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor)
(interface{}, error) {
in := new(DropTableRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
- return srv.(CeresmetaRpcServiceServer).DropTable(ctx, in)
+ return srv.(MetaRpcServiceServer).DropTable(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
- FullMethod: "/meta_service.CeresmetaRpcService/DropTable",
+ FullMethod: "/meta_service.MetaRpcService/DropTable",
}
handler := func(ctx context.Context, req interface{}) (interface{},
error) {
- return srv.(CeresmetaRpcServiceServer).DropTable(ctx,
req.(*DropTableRequest))
+ return srv.(MetaRpcServiceServer).DropTable(ctx,
req.(*DropTableRequest))
}
return interceptor(ctx, in, info, handler)
}
-func _CeresmetaRpcService_RouteTables_Handler(srv interface{}, ctx
context.Context, dec func(interface{}) error, interceptor
grpc.UnaryServerInterceptor) (interface{}, error) {
+func _MetaRpcService_RouteTables_Handler(srv interface{}, ctx context.Context,
dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor)
(interface{}, error) {
in := new(RouteTablesRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
- return srv.(CeresmetaRpcServiceServer).RouteTables(ctx, in)
+ return srv.(MetaRpcServiceServer).RouteTables(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
- FullMethod: "/meta_service.CeresmetaRpcService/RouteTables",
+ FullMethod: "/meta_service.MetaRpcService/RouteTables",
}
handler := func(ctx context.Context, req interface{}) (interface{},
error) {
- return srv.(CeresmetaRpcServiceServer).RouteTables(ctx,
req.(*RouteTablesRequest))
+ return srv.(MetaRpcServiceServer).RouteTables(ctx,
req.(*RouteTablesRequest))
}
return interceptor(ctx, in, info, handler)
}
-func _CeresmetaRpcService_GetNodes_Handler(srv interface{}, ctx
context.Context, dec func(interface{}) error, interceptor
grpc.UnaryServerInterceptor) (interface{}, error) {
+func _MetaRpcService_GetNodes_Handler(srv interface{}, ctx context.Context,
dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor)
(interface{}, error) {
in := new(GetNodesRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
- return srv.(CeresmetaRpcServiceServer).GetNodes(ctx, in)
+ return srv.(MetaRpcServiceServer).GetNodes(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
- FullMethod: "/meta_service.CeresmetaRpcService/GetNodes",
+ FullMethod: "/meta_service.MetaRpcService/GetNodes",
}
handler := func(ctx context.Context, req interface{}) (interface{},
error) {
- return srv.(CeresmetaRpcServiceServer).GetNodes(ctx,
req.(*GetNodesRequest))
+ return srv.(MetaRpcServiceServer).GetNodes(ctx,
req.(*GetNodesRequest))
}
return interceptor(ctx, in, info, handler)
}
-func _CeresmetaRpcService_NodeHeartbeat_Handler(srv interface{}, ctx
context.Context, dec func(interface{}) error, interceptor
grpc.UnaryServerInterceptor) (interface{}, error) {
+func _MetaRpcService_NodeHeartbeat_Handler(srv interface{}, ctx
context.Context, dec func(interface{}) error, interceptor
grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(NodeHeartbeatRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
- return srv.(CeresmetaRpcServiceServer).NodeHeartbeat(ctx, in)
+ return srv.(MetaRpcServiceServer).NodeHeartbeat(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
- FullMethod: "/meta_service.CeresmetaRpcService/NodeHeartbeat",
+ FullMethod: "/meta_service.MetaRpcService/NodeHeartbeat",
}
handler := func(ctx context.Context, req interface{}) (interface{},
error) {
- return srv.(CeresmetaRpcServiceServer).NodeHeartbeat(ctx,
req.(*NodeHeartbeatRequest))
+ return srv.(MetaRpcServiceServer).NodeHeartbeat(ctx,
req.(*NodeHeartbeatRequest))
}
return interceptor(ctx, in, info, handler)
}
-// CeresmetaRpcService_ServiceDesc is the grpc.ServiceDesc for
CeresmetaRpcService service.
+// MetaRpcService_ServiceDesc is the grpc.ServiceDesc for MetaRpcService
service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
-var CeresmetaRpcService_ServiceDesc = grpc.ServiceDesc{
- ServiceName: "meta_service.CeresmetaRpcService",
- HandlerType: (*CeresmetaRpcServiceServer)(nil),
+var MetaRpcService_ServiceDesc = grpc.ServiceDesc{
+ ServiceName: "meta_service.MetaRpcService",
+ HandlerType: (*MetaRpcServiceServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "AllocSchemaID",
- Handler: _CeresmetaRpcService_AllocSchemaID_Handler,
+ Handler: _MetaRpcService_AllocSchemaID_Handler,
},
{
MethodName: "GetTablesOfShards",
- Handler:
_CeresmetaRpcService_GetTablesOfShards_Handler,
+ Handler: _MetaRpcService_GetTablesOfShards_Handler,
},
{
MethodName: "CreateTable",
- Handler: _CeresmetaRpcService_CreateTable_Handler,
+ Handler: _MetaRpcService_CreateTable_Handler,
},
{
MethodName: "DropTable",
- Handler: _CeresmetaRpcService_DropTable_Handler,
+ Handler: _MetaRpcService_DropTable_Handler,
},
{
MethodName: "RouteTables",
- Handler: _CeresmetaRpcService_RouteTables_Handler,
+ Handler: _MetaRpcService_RouteTables_Handler,
},
{
MethodName: "GetNodes",
- Handler: _CeresmetaRpcService_GetNodes_Handler,
+ Handler: _MetaRpcService_GetNodes_Handler,
},
{
MethodName: "NodeHeartbeat",
- Handler: _CeresmetaRpcService_NodeHeartbeat_Handler,
+ Handler: _MetaRpcService_NodeHeartbeat_Handler,
},
},
Streams: []grpc.StreamDesc{},
diff --git a/java/pom.xml b/java/pom.xml
index eca3f88..f52b8e2 100644
--- a/java/pom.xml
+++ b/java/pom.xml
@@ -30,7 +30,7 @@
<groupId>org.apache.horaedb</groupId>
<artifactId>horaedb-proto-internal</artifactId>
- <version>1.0.0</version>
+ <version>2.0.0</version>
<licenses>
<license>
diff --git a/protos/meta_service.proto b/protos/meta_service.proto
index 4787831..fbade0e 100644
--- a/protos/meta_service.proto
+++ b/protos/meta_service.proto
@@ -25,7 +25,7 @@ option go_package =
"github.com/apache/incubator-horaedb-proto/golang/pkg/metase
import "common.proto";
import "cluster.proto";
-service CeresmetaRpcService {
+service MetaRpcService {
rpc AllocSchemaID(AllocSchemaIdRequest) returns (AllocSchemaIdResponse) {}
rpc GetTablesOfShards(GetTablesOfShardsRequest)
returns (GetTablesOfShardsResponse) {}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
