Skip to content

Commit 2eefc2a

Browse files
committed
collect load
1 parent 19ece8f commit 2eefc2a

File tree

11 files changed

+324
-110
lines changed

11 files changed

+324
-110
lines changed

golang/pkg/clusterpb/cluster.pb.go

+1-1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

golang/pkg/commonpb/common.pb.go

+1-1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

golang/pkg/horaeprompb/prometheus.pb.go

+1-1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

golang/pkg/metaeventpb/meta_event.pb.go

+1-1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

golang/pkg/metaeventpb/meta_event_grpc.pb.go

+1-1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

golang/pkg/metaservicepb/meta_service.pb.go

+298-101
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

golang/pkg/metaservicepb/meta_service_grpc.pb.go

+1-1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

golang/pkg/metastoragepb/meta_storage.pb.go

+1-1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

golang/pkg/storagepb/storage.pb.go

+1-1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

golang/pkg/storagepb/storage_grpc.pb.go

+1-1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

protos/meta_service.proto

+17
Original file line numberDiff line numberDiff line change
@@ -166,20 +166,37 @@ message ShardInfo {
166166
PartialOpen = 1;
167167
}
168168

169+
message Load {
170+
uint64 written_bytes = 1;
171+
uint64 read_bytes = 2;
172+
}
173+
169174
uint32 id = 1;
170175
cluster.ShardRole role = 2;
171176
uint64 version = 3;
172177
// When status is missing, it means Ready
173178
optional Status status = 4;
179+
// When load is missing, it represents the use of an older version of the
180+
// protocol
181+
optional Load load = 5;
174182
}
175183

176184
message NodeInfo {
185+
message Load {
186+
float cpu_usage_core = 6;
187+
uint32 cpu_total_core = 7;
188+
uint64 memory_total_bytes = 8;
189+
uint64 memory_usage_bytes = 9;
190+
}
177191
// ip:port
178192
string endpoint = 1;
179193
uint32 lease = 2;
180194
string zone = 3;
181195
string binary_version = 4;
182196
repeated ShardInfo shard_infos = 5;
197+
// When load is missing, it represents the use of an older version of the
198+
// protocol
199+
optional Load load = 6;
183200
}
184201

185202
message NodeHeartbeatResponse {

0 commit comments

Comments
 (0)