diff --git a/CHANGELOG.md b/CHANGELOG.md index 5c8dfc6e3..67249c581 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -17,6 +17,7 @@ Changelog for NeoFS Node - `--timeout` flag in `neofs-cli` subcommands (#1837) - `container nodes` command to output list of nodes for container, grouped by replica (#1704) - Configuration flag to ignore shard in `neofs-node` (#1840) +- Add new RPC `TreeService.Healthcheck` ### Changed - Allow to evacuate shard data with `EvacuateShard` control RPC (#1800) diff --git a/pkg/services/tree/service.go b/pkg/services/tree/service.go index a7b87ee09..aca6b9617 100644 --- a/pkg/services/tree/service.go +++ b/pkg/services/tree/service.go @@ -558,3 +558,7 @@ func (s *Service) getContainerInfo(cid cidSDK.ID, pub []byte) ([]netmapSDK.NodeI } return cntNodes, -1, len(cntNodes), nil } + +func (s *Service) Healthcheck(context.Context, *HealthcheckRequest) (*HealthcheckResponse, error) { + return new(HealthcheckResponse), nil +} diff --git a/pkg/services/tree/service.pb.go b/pkg/services/tree/service.pb.go index 2d30dce79..e87642e75 100644 --- a/pkg/services/tree/service.pb.go +++ b/pkg/services/tree/service.pb.go @@ -10,11 +10,10 @@ package tree import ( - reflect "reflect" - sync "sync" - protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" ) const ( @@ -936,6 +935,120 @@ func (x *GetOpLogResponse) GetSignature() *Signature { return nil } +type HealthcheckResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + // Response body. + Body *HealthcheckResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` + // Response signature. + Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` +} + +func (x *HealthcheckResponse) Reset() { + *x = HealthcheckResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_pkg_services_tree_service_proto_msgTypes[16] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *HealthcheckResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*HealthcheckResponse) ProtoMessage() {} + +func (x *HealthcheckResponse) ProtoReflect() protoreflect.Message { + mi := &file_pkg_services_tree_service_proto_msgTypes[16] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use HealthcheckResponse.ProtoReflect.Descriptor instead. +func (*HealthcheckResponse) Descriptor() ([]byte, []int) { + return file_pkg_services_tree_service_proto_rawDescGZIP(), []int{16} +} + +func (x *HealthcheckResponse) GetBody() *HealthcheckResponse_Body { + if x != nil { + return x.Body + } + return nil +} + +func (x *HealthcheckResponse) GetSignature() *Signature { + if x != nil { + return x.Signature + } + return nil +} + +type HealthcheckRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + // Request body. + Body *HealthcheckRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` + // Request signature. + Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` +} + +func (x *HealthcheckRequest) Reset() { + *x = HealthcheckRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_pkg_services_tree_service_proto_msgTypes[17] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *HealthcheckRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*HealthcheckRequest) ProtoMessage() {} + +func (x *HealthcheckRequest) ProtoReflect() protoreflect.Message { + mi := &file_pkg_services_tree_service_proto_msgTypes[17] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use HealthcheckRequest.ProtoReflect.Descriptor instead. +func (*HealthcheckRequest) Descriptor() ([]byte, []int) { + return file_pkg_services_tree_service_proto_rawDescGZIP(), []int{17} +} + +func (x *HealthcheckRequest) GetBody() *HealthcheckRequest_Body { + if x != nil { + return x.Body + } + return nil +} + +func (x *HealthcheckRequest) GetSignature() *Signature { + if x != nil { + return x.Signature + } + return nil +} + type AddRequest_Body struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache @@ -956,7 +1069,7 @@ type AddRequest_Body struct { func (x *AddRequest_Body) Reset() { *x = AddRequest_Body{} if protoimpl.UnsafeEnabled { - mi := &file_pkg_services_tree_service_proto_msgTypes[16] + mi := &file_pkg_services_tree_service_proto_msgTypes[18] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -969,7 +1082,7 @@ func (x *AddRequest_Body) String() string { func (*AddRequest_Body) ProtoMessage() {} func (x *AddRequest_Body) ProtoReflect() protoreflect.Message { - mi := &file_pkg_services_tree_service_proto_msgTypes[16] + mi := &file_pkg_services_tree_service_proto_msgTypes[18] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1032,7 +1145,7 @@ type AddResponse_Body struct { func (x *AddResponse_Body) Reset() { *x = AddResponse_Body{} if protoimpl.UnsafeEnabled { - mi := &file_pkg_services_tree_service_proto_msgTypes[17] + mi := &file_pkg_services_tree_service_proto_msgTypes[19] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1045,7 +1158,7 @@ func (x *AddResponse_Body) String() string { func (*AddResponse_Body) ProtoMessage() {} func (x *AddResponse_Body) ProtoReflect() protoreflect.Message { - mi := &file_pkg_services_tree_service_proto_msgTypes[17] + mi := &file_pkg_services_tree_service_proto_msgTypes[19] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1090,7 +1203,7 @@ type AddByPathRequest_Body struct { func (x *AddByPathRequest_Body) Reset() { *x = AddByPathRequest_Body{} if protoimpl.UnsafeEnabled { - mi := &file_pkg_services_tree_service_proto_msgTypes[18] + mi := &file_pkg_services_tree_service_proto_msgTypes[20] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1103,7 +1216,7 @@ func (x *AddByPathRequest_Body) String() string { func (*AddByPathRequest_Body) ProtoMessage() {} func (x *AddByPathRequest_Body) ProtoReflect() protoreflect.Message { - mi := &file_pkg_services_tree_service_proto_msgTypes[18] + mi := &file_pkg_services_tree_service_proto_msgTypes[20] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1175,7 +1288,7 @@ type AddByPathResponse_Body struct { func (x *AddByPathResponse_Body) Reset() { *x = AddByPathResponse_Body{} if protoimpl.UnsafeEnabled { - mi := &file_pkg_services_tree_service_proto_msgTypes[19] + mi := &file_pkg_services_tree_service_proto_msgTypes[21] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1188,7 +1301,7 @@ func (x *AddByPathResponse_Body) String() string { func (*AddByPathResponse_Body) ProtoMessage() {} func (x *AddByPathResponse_Body) ProtoReflect() protoreflect.Message { - mi := &file_pkg_services_tree_service_proto_msgTypes[19] + mi := &file_pkg_services_tree_service_proto_msgTypes[21] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1236,7 +1349,7 @@ type RemoveRequest_Body struct { func (x *RemoveRequest_Body) Reset() { *x = RemoveRequest_Body{} if protoimpl.UnsafeEnabled { - mi := &file_pkg_services_tree_service_proto_msgTypes[20] + mi := &file_pkg_services_tree_service_proto_msgTypes[22] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1249,7 +1362,7 @@ func (x *RemoveRequest_Body) String() string { func (*RemoveRequest_Body) ProtoMessage() {} func (x *RemoveRequest_Body) ProtoReflect() protoreflect.Message { - mi := &file_pkg_services_tree_service_proto_msgTypes[20] + mi := &file_pkg_services_tree_service_proto_msgTypes[22] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1302,7 +1415,7 @@ type RemoveResponse_Body struct { func (x *RemoveResponse_Body) Reset() { *x = RemoveResponse_Body{} if protoimpl.UnsafeEnabled { - mi := &file_pkg_services_tree_service_proto_msgTypes[21] + mi := &file_pkg_services_tree_service_proto_msgTypes[23] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1315,7 +1428,7 @@ func (x *RemoveResponse_Body) String() string { func (*RemoveResponse_Body) ProtoMessage() {} func (x *RemoveResponse_Body) ProtoReflect() protoreflect.Message { - mi := &file_pkg_services_tree_service_proto_msgTypes[21] + mi := &file_pkg_services_tree_service_proto_msgTypes[23] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1354,7 +1467,7 @@ type MoveRequest_Body struct { func (x *MoveRequest_Body) Reset() { *x = MoveRequest_Body{} if protoimpl.UnsafeEnabled { - mi := &file_pkg_services_tree_service_proto_msgTypes[22] + mi := &file_pkg_services_tree_service_proto_msgTypes[24] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1367,7 +1480,7 @@ func (x *MoveRequest_Body) String() string { func (*MoveRequest_Body) ProtoMessage() {} func (x *MoveRequest_Body) ProtoReflect() protoreflect.Message { - mi := &file_pkg_services_tree_service_proto_msgTypes[22] + mi := &file_pkg_services_tree_service_proto_msgTypes[24] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1434,7 +1547,7 @@ type MoveResponse_Body struct { func (x *MoveResponse_Body) Reset() { *x = MoveResponse_Body{} if protoimpl.UnsafeEnabled { - mi := &file_pkg_services_tree_service_proto_msgTypes[23] + mi := &file_pkg_services_tree_service_proto_msgTypes[25] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1447,7 +1560,7 @@ func (x *MoveResponse_Body) String() string { func (*MoveResponse_Body) ProtoMessage() {} func (x *MoveResponse_Body) ProtoReflect() protoreflect.Message { - mi := &file_pkg_services_tree_service_proto_msgTypes[23] + mi := &file_pkg_services_tree_service_proto_msgTypes[25] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1489,7 +1602,7 @@ type GetNodeByPathRequest_Body struct { func (x *GetNodeByPathRequest_Body) Reset() { *x = GetNodeByPathRequest_Body{} if protoimpl.UnsafeEnabled { - mi := &file_pkg_services_tree_service_proto_msgTypes[24] + mi := &file_pkg_services_tree_service_proto_msgTypes[26] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1502,7 +1615,7 @@ func (x *GetNodeByPathRequest_Body) String() string { func (*GetNodeByPathRequest_Body) ProtoMessage() {} func (x *GetNodeByPathRequest_Body) ProtoReflect() protoreflect.Message { - mi := &file_pkg_services_tree_service_proto_msgTypes[24] + mi := &file_pkg_services_tree_service_proto_msgTypes[26] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1593,7 +1706,7 @@ type GetNodeByPathResponse_Info struct { func (x *GetNodeByPathResponse_Info) Reset() { *x = GetNodeByPathResponse_Info{} if protoimpl.UnsafeEnabled { - mi := &file_pkg_services_tree_service_proto_msgTypes[25] + mi := &file_pkg_services_tree_service_proto_msgTypes[27] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1606,7 +1719,7 @@ func (x *GetNodeByPathResponse_Info) String() string { func (*GetNodeByPathResponse_Info) ProtoMessage() {} func (x *GetNodeByPathResponse_Info) ProtoReflect() protoreflect.Message { - mi := &file_pkg_services_tree_service_proto_msgTypes[25] + mi := &file_pkg_services_tree_service_proto_msgTypes[27] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1662,7 +1775,7 @@ type GetNodeByPathResponse_Body struct { func (x *GetNodeByPathResponse_Body) Reset() { *x = GetNodeByPathResponse_Body{} if protoimpl.UnsafeEnabled { - mi := &file_pkg_services_tree_service_proto_msgTypes[26] + mi := &file_pkg_services_tree_service_proto_msgTypes[28] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1675,7 +1788,7 @@ func (x *GetNodeByPathResponse_Body) String() string { func (*GetNodeByPathResponse_Body) ProtoMessage() {} func (x *GetNodeByPathResponse_Body) ProtoReflect() protoreflect.Message { - mi := &file_pkg_services_tree_service_proto_msgTypes[26] + mi := &file_pkg_services_tree_service_proto_msgTypes[28] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1719,7 +1832,7 @@ type GetSubTreeRequest_Body struct { func (x *GetSubTreeRequest_Body) Reset() { *x = GetSubTreeRequest_Body{} if protoimpl.UnsafeEnabled { - mi := &file_pkg_services_tree_service_proto_msgTypes[27] + mi := &file_pkg_services_tree_service_proto_msgTypes[29] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1732,7 +1845,7 @@ func (x *GetSubTreeRequest_Body) String() string { func (*GetSubTreeRequest_Body) ProtoMessage() {} func (x *GetSubTreeRequest_Body) ProtoReflect() protoreflect.Message { - mi := &file_pkg_services_tree_service_proto_msgTypes[27] + mi := &file_pkg_services_tree_service_proto_msgTypes[29] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1801,7 +1914,7 @@ type GetSubTreeResponse_Body struct { func (x *GetSubTreeResponse_Body) Reset() { *x = GetSubTreeResponse_Body{} if protoimpl.UnsafeEnabled { - mi := &file_pkg_services_tree_service_proto_msgTypes[28] + mi := &file_pkg_services_tree_service_proto_msgTypes[30] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1814,7 +1927,7 @@ func (x *GetSubTreeResponse_Body) String() string { func (*GetSubTreeResponse_Body) ProtoMessage() {} func (x *GetSubTreeResponse_Body) ProtoReflect() protoreflect.Message { - mi := &file_pkg_services_tree_service_proto_msgTypes[28] + mi := &file_pkg_services_tree_service_proto_msgTypes[30] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1874,7 +1987,7 @@ type ApplyRequest_Body struct { func (x *ApplyRequest_Body) Reset() { *x = ApplyRequest_Body{} if protoimpl.UnsafeEnabled { - mi := &file_pkg_services_tree_service_proto_msgTypes[29] + mi := &file_pkg_services_tree_service_proto_msgTypes[31] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1887,7 +2000,7 @@ func (x *ApplyRequest_Body) String() string { func (*ApplyRequest_Body) ProtoMessage() {} func (x *ApplyRequest_Body) ProtoReflect() protoreflect.Message { - mi := &file_pkg_services_tree_service_proto_msgTypes[29] + mi := &file_pkg_services_tree_service_proto_msgTypes[31] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1933,7 +2046,7 @@ type ApplyResponse_Body struct { func (x *ApplyResponse_Body) Reset() { *x = ApplyResponse_Body{} if protoimpl.UnsafeEnabled { - mi := &file_pkg_services_tree_service_proto_msgTypes[30] + mi := &file_pkg_services_tree_service_proto_msgTypes[32] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1946,7 +2059,7 @@ func (x *ApplyResponse_Body) String() string { func (*ApplyResponse_Body) ProtoMessage() {} func (x *ApplyResponse_Body) ProtoReflect() protoreflect.Message { - mi := &file_pkg_services_tree_service_proto_msgTypes[30] + mi := &file_pkg_services_tree_service_proto_msgTypes[32] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1980,7 +2093,7 @@ type GetOpLogRequest_Body struct { func (x *GetOpLogRequest_Body) Reset() { *x = GetOpLogRequest_Body{} if protoimpl.UnsafeEnabled { - mi := &file_pkg_services_tree_service_proto_msgTypes[31] + mi := &file_pkg_services_tree_service_proto_msgTypes[33] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1993,7 +2106,7 @@ func (x *GetOpLogRequest_Body) String() string { func (*GetOpLogRequest_Body) ProtoMessage() {} func (x *GetOpLogRequest_Body) ProtoReflect() protoreflect.Message { - mi := &file_pkg_services_tree_service_proto_msgTypes[31] + mi := &file_pkg_services_tree_service_proto_msgTypes[33] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2049,7 +2162,7 @@ type GetOpLogResponse_Body struct { func (x *GetOpLogResponse_Body) Reset() { *x = GetOpLogResponse_Body{} if protoimpl.UnsafeEnabled { - mi := &file_pkg_services_tree_service_proto_msgTypes[32] + mi := &file_pkg_services_tree_service_proto_msgTypes[34] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2062,7 +2175,7 @@ func (x *GetOpLogResponse_Body) String() string { func (*GetOpLogResponse_Body) ProtoMessage() {} func (x *GetOpLogResponse_Body) ProtoReflect() protoreflect.Message { - mi := &file_pkg_services_tree_service_proto_msgTypes[32] + mi := &file_pkg_services_tree_service_proto_msgTypes[34] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2085,6 +2198,82 @@ func (x *GetOpLogResponse_Body) GetOperation() *LogMove { return nil } +type HealthcheckResponse_Body struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *HealthcheckResponse_Body) Reset() { + *x = HealthcheckResponse_Body{} + if protoimpl.UnsafeEnabled { + mi := &file_pkg_services_tree_service_proto_msgTypes[35] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *HealthcheckResponse_Body) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*HealthcheckResponse_Body) ProtoMessage() {} + +func (x *HealthcheckResponse_Body) ProtoReflect() protoreflect.Message { + mi := &file_pkg_services_tree_service_proto_msgTypes[35] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use HealthcheckResponse_Body.ProtoReflect.Descriptor instead. +func (*HealthcheckResponse_Body) Descriptor() ([]byte, []int) { + return file_pkg_services_tree_service_proto_rawDescGZIP(), []int{16, 0} +} + +type HealthcheckRequest_Body struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *HealthcheckRequest_Body) Reset() { + *x = HealthcheckRequest_Body{} + if protoimpl.UnsafeEnabled { + mi := &file_pkg_services_tree_service_proto_msgTypes[36] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *HealthcheckRequest_Body) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*HealthcheckRequest_Body) ProtoMessage() {} + +func (x *HealthcheckRequest_Body) ProtoReflect() protoreflect.Message { + mi := &file_pkg_services_tree_service_proto_msgTypes[36] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use HealthcheckRequest_Body.ProtoReflect.Descriptor instead. +func (*HealthcheckRequest_Body) Descriptor() ([]byte, []int) { + return file_pkg_services_tree_service_proto_rawDescGZIP(), []int{17, 0} +} + var File_pkg_services_tree_service_proto protoreflect.FileDescriptor var file_pkg_services_tree_service_proto_rawDesc = []byte{ @@ -2320,41 +2509,61 @@ var file_pkg_services_tree_service_proto_rawDesc = []byte{ 0x6e, 0x61, 0x74, 0x75, 0x72, 0x65, 0x1a, 0x33, 0x0a, 0x04, 0x42, 0x6f, 0x64, 0x79, 0x12, 0x2b, 0x0a, 0x09, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0d, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x4c, 0x6f, 0x67, 0x4d, 0x6f, 0x76, 0x65, - 0x52, 0x09, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x32, 0xd7, 0x03, 0x0a, 0x0b, - 0x54, 0x72, 0x65, 0x65, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x2a, 0x0a, 0x03, 0x41, - 0x64, 0x64, 0x12, 0x10, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x41, 0x64, 0x64, 0x52, 0x65, 0x71, - 0x75, 0x65, 0x73, 0x74, 0x1a, 0x11, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x41, 0x64, 0x64, 0x52, - 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x3c, 0x0a, 0x09, 0x41, 0x64, 0x64, 0x42, 0x79, - 0x50, 0x61, 0x74, 0x68, 0x12, 0x16, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x41, 0x64, 0x64, 0x42, - 0x79, 0x50, 0x61, 0x74, 0x68, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x17, 0x2e, 0x74, - 0x72, 0x65, 0x65, 0x2e, 0x41, 0x64, 0x64, 0x42, 0x79, 0x50, 0x61, 0x74, 0x68, 0x52, 0x65, 0x73, - 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x33, 0x0a, 0x06, 0x52, 0x65, 0x6d, 0x6f, 0x76, 0x65, 0x12, - 0x13, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x52, 0x65, 0x6d, 0x6f, 0x76, 0x65, 0x52, 0x65, 0x71, - 0x75, 0x65, 0x73, 0x74, 0x1a, 0x14, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x52, 0x65, 0x6d, 0x6f, - 0x76, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x2d, 0x0a, 0x04, 0x4d, 0x6f, - 0x76, 0x65, 0x12, 0x11, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x4d, 0x6f, 0x76, 0x65, 0x52, 0x65, - 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x12, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x4d, 0x6f, 0x76, - 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x48, 0x0a, 0x0d, 0x47, 0x65, 0x74, - 0x4e, 0x6f, 0x64, 0x65, 0x42, 0x79, 0x50, 0x61, 0x74, 0x68, 0x12, 0x1a, 0x2e, 0x74, 0x72, 0x65, - 0x65, 0x2e, 0x47, 0x65, 0x74, 0x4e, 0x6f, 0x64, 0x65, 0x42, 0x79, 0x50, 0x61, 0x74, 0x68, 0x52, - 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1b, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x47, 0x65, - 0x74, 0x4e, 0x6f, 0x64, 0x65, 0x42, 0x79, 0x50, 0x61, 0x74, 0x68, 0x52, 0x65, 0x73, 0x70, 0x6f, - 0x6e, 0x73, 0x65, 0x12, 0x41, 0x0a, 0x0a, 0x47, 0x65, 0x74, 0x53, 0x75, 0x62, 0x54, 0x72, 0x65, - 0x65, 0x12, 0x17, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x47, 0x65, 0x74, 0x53, 0x75, 0x62, 0x54, - 0x72, 0x65, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x18, 0x2e, 0x74, 0x72, 0x65, - 0x65, 0x2e, 0x47, 0x65, 0x74, 0x53, 0x75, 0x62, 0x54, 0x72, 0x65, 0x65, 0x52, 0x65, 0x73, 0x70, - 0x6f, 0x6e, 0x73, 0x65, 0x30, 0x01, 0x12, 0x30, 0x0a, 0x05, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x12, - 0x12, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x52, 0x65, 0x71, 0x75, - 0x65, 0x73, 0x74, 0x1a, 0x13, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x41, 0x70, 0x70, 0x6c, 0x79, - 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x3b, 0x0a, 0x08, 0x47, 0x65, 0x74, 0x4f, - 0x70, 0x4c, 0x6f, 0x67, 0x12, 0x15, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x47, 0x65, 0x74, 0x4f, - 0x70, 0x4c, 0x6f, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x74, 0x72, - 0x65, 0x65, 0x2e, 0x47, 0x65, 0x74, 0x4f, 0x70, 0x4c, 0x6f, 0x67, 0x52, 0x65, 0x73, 0x70, 0x6f, - 0x6e, 0x73, 0x65, 0x30, 0x01, 0x42, 0x33, 0x5a, 0x31, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, - 0x63, 0x6f, 0x6d, 0x2f, 0x6e, 0x73, 0x70, 0x63, 0x63, 0x2d, 0x64, 0x65, 0x76, 0x2f, 0x6e, 0x65, - 0x6f, 0x66, 0x73, 0x2d, 0x6e, 0x6f, 0x64, 0x65, 0x2f, 0x70, 0x6b, 0x67, 0x2f, 0x73, 0x65, 0x72, - 0x76, 0x69, 0x63, 0x65, 0x73, 0x2f, 0x74, 0x72, 0x65, 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, - 0x6f, 0x33, + 0x52, 0x09, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x80, 0x01, 0x0a, 0x13, + 0x48, 0x65, 0x61, 0x6c, 0x74, 0x68, 0x63, 0x68, 0x65, 0x63, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, + 0x6e, 0x73, 0x65, 0x12, 0x32, 0x0a, 0x04, 0x62, 0x6f, 0x64, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, + 0x0b, 0x32, 0x1e, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x48, 0x65, 0x61, 0x6c, 0x74, 0x68, 0x63, + 0x68, 0x65, 0x63, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x2e, 0x42, 0x6f, 0x64, + 0x79, 0x52, 0x04, 0x62, 0x6f, 0x64, 0x79, 0x12, 0x2d, 0x0a, 0x09, 0x73, 0x69, 0x67, 0x6e, 0x61, + 0x74, 0x75, 0x72, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x74, 0x72, 0x65, + 0x65, 0x2e, 0x53, 0x69, 0x67, 0x6e, 0x61, 0x74, 0x75, 0x72, 0x65, 0x52, 0x09, 0x73, 0x69, 0x67, + 0x6e, 0x61, 0x74, 0x75, 0x72, 0x65, 0x1a, 0x06, 0x0a, 0x04, 0x42, 0x6f, 0x64, 0x79, 0x22, 0x7e, + 0x0a, 0x12, 0x48, 0x65, 0x61, 0x6c, 0x74, 0x68, 0x63, 0x68, 0x65, 0x63, 0x6b, 0x52, 0x65, 0x71, + 0x75, 0x65, 0x73, 0x74, 0x12, 0x31, 0x0a, 0x04, 0x62, 0x6f, 0x64, 0x79, 0x18, 0x01, 0x20, 0x01, + 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x48, 0x65, 0x61, 0x6c, 0x74, 0x68, + 0x63, 0x68, 0x65, 0x63, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x42, 0x6f, 0x64, + 0x79, 0x52, 0x04, 0x62, 0x6f, 0x64, 0x79, 0x12, 0x2d, 0x0a, 0x09, 0x73, 0x69, 0x67, 0x6e, 0x61, + 0x74, 0x75, 0x72, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x74, 0x72, 0x65, + 0x65, 0x2e, 0x53, 0x69, 0x67, 0x6e, 0x61, 0x74, 0x75, 0x72, 0x65, 0x52, 0x09, 0x73, 0x69, 0x67, + 0x6e, 0x61, 0x74, 0x75, 0x72, 0x65, 0x1a, 0x06, 0x0a, 0x04, 0x42, 0x6f, 0x64, 0x79, 0x32, 0x9b, + 0x04, 0x0a, 0x0b, 0x54, 0x72, 0x65, 0x65, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x2a, + 0x0a, 0x03, 0x41, 0x64, 0x64, 0x12, 0x10, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x41, 0x64, 0x64, + 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x11, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x41, + 0x64, 0x64, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x3c, 0x0a, 0x09, 0x41, 0x64, + 0x64, 0x42, 0x79, 0x50, 0x61, 0x74, 0x68, 0x12, 0x16, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x41, + 0x64, 0x64, 0x42, 0x79, 0x50, 0x61, 0x74, 0x68, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, + 0x17, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x41, 0x64, 0x64, 0x42, 0x79, 0x50, 0x61, 0x74, 0x68, + 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x33, 0x0a, 0x06, 0x52, 0x65, 0x6d, 0x6f, + 0x76, 0x65, 0x12, 0x13, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x52, 0x65, 0x6d, 0x6f, 0x76, 0x65, + 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x14, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x52, + 0x65, 0x6d, 0x6f, 0x76, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x2d, 0x0a, + 0x04, 0x4d, 0x6f, 0x76, 0x65, 0x12, 0x11, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x4d, 0x6f, 0x76, + 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x12, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, + 0x4d, 0x6f, 0x76, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x48, 0x0a, 0x0d, + 0x47, 0x65, 0x74, 0x4e, 0x6f, 0x64, 0x65, 0x42, 0x79, 0x50, 0x61, 0x74, 0x68, 0x12, 0x1a, 0x2e, + 0x74, 0x72, 0x65, 0x65, 0x2e, 0x47, 0x65, 0x74, 0x4e, 0x6f, 0x64, 0x65, 0x42, 0x79, 0x50, 0x61, + 0x74, 0x68, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1b, 0x2e, 0x74, 0x72, 0x65, 0x65, + 0x2e, 0x47, 0x65, 0x74, 0x4e, 0x6f, 0x64, 0x65, 0x42, 0x79, 0x50, 0x61, 0x74, 0x68, 0x52, 0x65, + 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x41, 0x0a, 0x0a, 0x47, 0x65, 0x74, 0x53, 0x75, 0x62, + 0x54, 0x72, 0x65, 0x65, 0x12, 0x17, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x47, 0x65, 0x74, 0x53, + 0x75, 0x62, 0x54, 0x72, 0x65, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x18, 0x2e, + 0x74, 0x72, 0x65, 0x65, 0x2e, 0x47, 0x65, 0x74, 0x53, 0x75, 0x62, 0x54, 0x72, 0x65, 0x65, 0x52, + 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x30, 0x01, 0x12, 0x30, 0x0a, 0x05, 0x41, 0x70, 0x70, + 0x6c, 0x79, 0x12, 0x12, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x52, + 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x13, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x41, 0x70, + 0x70, 0x6c, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x3b, 0x0a, 0x08, 0x47, + 0x65, 0x74, 0x4f, 0x70, 0x4c, 0x6f, 0x67, 0x12, 0x15, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x47, + 0x65, 0x74, 0x4f, 0x70, 0x4c, 0x6f, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, + 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x47, 0x65, 0x74, 0x4f, 0x70, 0x4c, 0x6f, 0x67, 0x52, 0x65, + 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x30, 0x01, 0x12, 0x42, 0x0a, 0x0b, 0x48, 0x65, 0x61, 0x6c, + 0x74, 0x68, 0x63, 0x68, 0x65, 0x63, 0x6b, 0x12, 0x18, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x48, + 0x65, 0x61, 0x6c, 0x74, 0x68, 0x63, 0x68, 0x65, 0x63, 0x6b, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, + 0x74, 0x1a, 0x19, 0x2e, 0x74, 0x72, 0x65, 0x65, 0x2e, 0x48, 0x65, 0x61, 0x6c, 0x74, 0x68, 0x63, + 0x68, 0x65, 0x63, 0x6b, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x33, 0x5a, 0x31, + 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x6e, 0x73, 0x70, 0x63, 0x63, + 0x2d, 0x64, 0x65, 0x76, 0x2f, 0x6e, 0x65, 0x6f, 0x66, 0x73, 0x2d, 0x6e, 0x6f, 0x64, 0x65, 0x2f, + 0x70, 0x6b, 0x67, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x73, 0x2f, 0x74, 0x72, 0x65, + 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, } var ( @@ -2369,7 +2578,7 @@ func file_pkg_services_tree_service_proto_rawDescGZIP() []byte { return file_pkg_services_tree_service_proto_rawDescData } -var file_pkg_services_tree_service_proto_msgTypes = make([]protoimpl.MessageInfo, 33) +var file_pkg_services_tree_service_proto_msgTypes = make([]protoimpl.MessageInfo, 37) var file_pkg_services_tree_service_proto_goTypes = []interface{}{ (*AddRequest)(nil), // 0: tree.AddRequest (*AddResponse)(nil), // 1: tree.AddResponse @@ -2387,89 +2596,99 @@ var file_pkg_services_tree_service_proto_goTypes = []interface{}{ (*ApplyResponse)(nil), // 13: tree.ApplyResponse (*GetOpLogRequest)(nil), // 14: tree.GetOpLogRequest (*GetOpLogResponse)(nil), // 15: tree.GetOpLogResponse - (*AddRequest_Body)(nil), // 16: tree.AddRequest.Body - (*AddResponse_Body)(nil), // 17: tree.AddResponse.Body - (*AddByPathRequest_Body)(nil), // 18: tree.AddByPathRequest.Body - (*AddByPathResponse_Body)(nil), // 19: tree.AddByPathResponse.Body - (*RemoveRequest_Body)(nil), // 20: tree.RemoveRequest.Body - (*RemoveResponse_Body)(nil), // 21: tree.RemoveResponse.Body - (*MoveRequest_Body)(nil), // 22: tree.MoveRequest.Body - (*MoveResponse_Body)(nil), // 23: tree.MoveResponse.Body - (*GetNodeByPathRequest_Body)(nil), // 24: tree.GetNodeByPathRequest.Body - (*GetNodeByPathResponse_Info)(nil), // 25: tree.GetNodeByPathResponse.Info - (*GetNodeByPathResponse_Body)(nil), // 26: tree.GetNodeByPathResponse.Body - (*GetSubTreeRequest_Body)(nil), // 27: tree.GetSubTreeRequest.Body - (*GetSubTreeResponse_Body)(nil), // 28: tree.GetSubTreeResponse.Body - (*ApplyRequest_Body)(nil), // 29: tree.ApplyRequest.Body - (*ApplyResponse_Body)(nil), // 30: tree.ApplyResponse.Body - (*GetOpLogRequest_Body)(nil), // 31: tree.GetOpLogRequest.Body - (*GetOpLogResponse_Body)(nil), // 32: tree.GetOpLogResponse.Body - (*Signature)(nil), // 33: tree.Signature - (*KeyValue)(nil), // 34: tree.KeyValue - (*LogMove)(nil), // 35: tree.LogMove + (*HealthcheckResponse)(nil), // 16: tree.HealthcheckResponse + (*HealthcheckRequest)(nil), // 17: tree.HealthcheckRequest + (*AddRequest_Body)(nil), // 18: tree.AddRequest.Body + (*AddResponse_Body)(nil), // 19: tree.AddResponse.Body + (*AddByPathRequest_Body)(nil), // 20: tree.AddByPathRequest.Body + (*AddByPathResponse_Body)(nil), // 21: tree.AddByPathResponse.Body + (*RemoveRequest_Body)(nil), // 22: tree.RemoveRequest.Body + (*RemoveResponse_Body)(nil), // 23: tree.RemoveResponse.Body + (*MoveRequest_Body)(nil), // 24: tree.MoveRequest.Body + (*MoveResponse_Body)(nil), // 25: tree.MoveResponse.Body + (*GetNodeByPathRequest_Body)(nil), // 26: tree.GetNodeByPathRequest.Body + (*GetNodeByPathResponse_Info)(nil), // 27: tree.GetNodeByPathResponse.Info + (*GetNodeByPathResponse_Body)(nil), // 28: tree.GetNodeByPathResponse.Body + (*GetSubTreeRequest_Body)(nil), // 29: tree.GetSubTreeRequest.Body + (*GetSubTreeResponse_Body)(nil), // 30: tree.GetSubTreeResponse.Body + (*ApplyRequest_Body)(nil), // 31: tree.ApplyRequest.Body + (*ApplyResponse_Body)(nil), // 32: tree.ApplyResponse.Body + (*GetOpLogRequest_Body)(nil), // 33: tree.GetOpLogRequest.Body + (*GetOpLogResponse_Body)(nil), // 34: tree.GetOpLogResponse.Body + (*HealthcheckResponse_Body)(nil), // 35: tree.HealthcheckResponse.Body + (*HealthcheckRequest_Body)(nil), // 36: tree.HealthcheckRequest.Body + (*Signature)(nil), // 37: tree.Signature + (*KeyValue)(nil), // 38: tree.KeyValue + (*LogMove)(nil), // 39: tree.LogMove } var file_pkg_services_tree_service_proto_depIdxs = []int32{ - 16, // 0: tree.AddRequest.body:type_name -> tree.AddRequest.Body - 33, // 1: tree.AddRequest.signature:type_name -> tree.Signature - 17, // 2: tree.AddResponse.body:type_name -> tree.AddResponse.Body - 33, // 3: tree.AddResponse.signature:type_name -> tree.Signature - 18, // 4: tree.AddByPathRequest.body:type_name -> tree.AddByPathRequest.Body - 33, // 5: tree.AddByPathRequest.signature:type_name -> tree.Signature - 19, // 6: tree.AddByPathResponse.body:type_name -> tree.AddByPathResponse.Body - 33, // 7: tree.AddByPathResponse.signature:type_name -> tree.Signature - 20, // 8: tree.RemoveRequest.body:type_name -> tree.RemoveRequest.Body - 33, // 9: tree.RemoveRequest.signature:type_name -> tree.Signature - 21, // 10: tree.RemoveResponse.body:type_name -> tree.RemoveResponse.Body - 33, // 11: tree.RemoveResponse.signature:type_name -> tree.Signature - 22, // 12: tree.MoveRequest.body:type_name -> tree.MoveRequest.Body - 33, // 13: tree.MoveRequest.signature:type_name -> tree.Signature - 23, // 14: tree.MoveResponse.body:type_name -> tree.MoveResponse.Body - 33, // 15: tree.MoveResponse.signature:type_name -> tree.Signature - 24, // 16: tree.GetNodeByPathRequest.body:type_name -> tree.GetNodeByPathRequest.Body - 33, // 17: tree.GetNodeByPathRequest.signature:type_name -> tree.Signature - 26, // 18: tree.GetNodeByPathResponse.body:type_name -> tree.GetNodeByPathResponse.Body - 33, // 19: tree.GetNodeByPathResponse.signature:type_name -> tree.Signature - 27, // 20: tree.GetSubTreeRequest.body:type_name -> tree.GetSubTreeRequest.Body - 33, // 21: tree.GetSubTreeRequest.signature:type_name -> tree.Signature - 28, // 22: tree.GetSubTreeResponse.body:type_name -> tree.GetSubTreeResponse.Body - 33, // 23: tree.GetSubTreeResponse.signature:type_name -> tree.Signature - 29, // 24: tree.ApplyRequest.body:type_name -> tree.ApplyRequest.Body - 33, // 25: tree.ApplyRequest.signature:type_name -> tree.Signature - 30, // 26: tree.ApplyResponse.body:type_name -> tree.ApplyResponse.Body - 33, // 27: tree.ApplyResponse.signature:type_name -> tree.Signature - 31, // 28: tree.GetOpLogRequest.body:type_name -> tree.GetOpLogRequest.Body - 33, // 29: tree.GetOpLogRequest.signature:type_name -> tree.Signature - 32, // 30: tree.GetOpLogResponse.body:type_name -> tree.GetOpLogResponse.Body - 33, // 31: tree.GetOpLogResponse.signature:type_name -> tree.Signature - 34, // 32: tree.AddRequest.Body.meta:type_name -> tree.KeyValue - 34, // 33: tree.AddByPathRequest.Body.meta:type_name -> tree.KeyValue - 34, // 34: tree.MoveRequest.Body.meta:type_name -> tree.KeyValue - 34, // 35: tree.GetNodeByPathResponse.Info.meta:type_name -> tree.KeyValue - 25, // 36: tree.GetNodeByPathResponse.Body.nodes:type_name -> tree.GetNodeByPathResponse.Info - 34, // 37: tree.GetSubTreeResponse.Body.meta:type_name -> tree.KeyValue - 35, // 38: tree.ApplyRequest.Body.operation:type_name -> tree.LogMove - 35, // 39: tree.GetOpLogResponse.Body.operation:type_name -> tree.LogMove - 0, // 40: tree.TreeService.Add:input_type -> tree.AddRequest - 2, // 41: tree.TreeService.AddByPath:input_type -> tree.AddByPathRequest - 4, // 42: tree.TreeService.Remove:input_type -> tree.RemoveRequest - 6, // 43: tree.TreeService.Move:input_type -> tree.MoveRequest - 8, // 44: tree.TreeService.GetNodeByPath:input_type -> tree.GetNodeByPathRequest - 10, // 45: tree.TreeService.GetSubTree:input_type -> tree.GetSubTreeRequest - 12, // 46: tree.TreeService.Apply:input_type -> tree.ApplyRequest - 14, // 47: tree.TreeService.GetOpLog:input_type -> tree.GetOpLogRequest - 1, // 48: tree.TreeService.Add:output_type -> tree.AddResponse - 3, // 49: tree.TreeService.AddByPath:output_type -> tree.AddByPathResponse - 5, // 50: tree.TreeService.Remove:output_type -> tree.RemoveResponse - 7, // 51: tree.TreeService.Move:output_type -> tree.MoveResponse - 9, // 52: tree.TreeService.GetNodeByPath:output_type -> tree.GetNodeByPathResponse - 11, // 53: tree.TreeService.GetSubTree:output_type -> tree.GetSubTreeResponse - 13, // 54: tree.TreeService.Apply:output_type -> tree.ApplyResponse - 15, // 55: tree.TreeService.GetOpLog:output_type -> tree.GetOpLogResponse - 48, // [48:56] is the sub-list for method output_type - 40, // [40:48] is the sub-list for method input_type - 40, // [40:40] is the sub-list for extension type_name - 40, // [40:40] is the sub-list for extension extendee - 0, // [0:40] is the sub-list for field type_name + 18, // 0: tree.AddRequest.body:type_name -> tree.AddRequest.Body + 37, // 1: tree.AddRequest.signature:type_name -> tree.Signature + 19, // 2: tree.AddResponse.body:type_name -> tree.AddResponse.Body + 37, // 3: tree.AddResponse.signature:type_name -> tree.Signature + 20, // 4: tree.AddByPathRequest.body:type_name -> tree.AddByPathRequest.Body + 37, // 5: tree.AddByPathRequest.signature:type_name -> tree.Signature + 21, // 6: tree.AddByPathResponse.body:type_name -> tree.AddByPathResponse.Body + 37, // 7: tree.AddByPathResponse.signature:type_name -> tree.Signature + 22, // 8: tree.RemoveRequest.body:type_name -> tree.RemoveRequest.Body + 37, // 9: tree.RemoveRequest.signature:type_name -> tree.Signature + 23, // 10: tree.RemoveResponse.body:type_name -> tree.RemoveResponse.Body + 37, // 11: tree.RemoveResponse.signature:type_name -> tree.Signature + 24, // 12: tree.MoveRequest.body:type_name -> tree.MoveRequest.Body + 37, // 13: tree.MoveRequest.signature:type_name -> tree.Signature + 25, // 14: tree.MoveResponse.body:type_name -> tree.MoveResponse.Body + 37, // 15: tree.MoveResponse.signature:type_name -> tree.Signature + 26, // 16: tree.GetNodeByPathRequest.body:type_name -> tree.GetNodeByPathRequest.Body + 37, // 17: tree.GetNodeByPathRequest.signature:type_name -> tree.Signature + 28, // 18: tree.GetNodeByPathResponse.body:type_name -> tree.GetNodeByPathResponse.Body + 37, // 19: tree.GetNodeByPathResponse.signature:type_name -> tree.Signature + 29, // 20: tree.GetSubTreeRequest.body:type_name -> tree.GetSubTreeRequest.Body + 37, // 21: tree.GetSubTreeRequest.signature:type_name -> tree.Signature + 30, // 22: tree.GetSubTreeResponse.body:type_name -> tree.GetSubTreeResponse.Body + 37, // 23: tree.GetSubTreeResponse.signature:type_name -> tree.Signature + 31, // 24: tree.ApplyRequest.body:type_name -> tree.ApplyRequest.Body + 37, // 25: tree.ApplyRequest.signature:type_name -> tree.Signature + 32, // 26: tree.ApplyResponse.body:type_name -> tree.ApplyResponse.Body + 37, // 27: tree.ApplyResponse.signature:type_name -> tree.Signature + 33, // 28: tree.GetOpLogRequest.body:type_name -> tree.GetOpLogRequest.Body + 37, // 29: tree.GetOpLogRequest.signature:type_name -> tree.Signature + 34, // 30: tree.GetOpLogResponse.body:type_name -> tree.GetOpLogResponse.Body + 37, // 31: tree.GetOpLogResponse.signature:type_name -> tree.Signature + 35, // 32: tree.HealthcheckResponse.body:type_name -> tree.HealthcheckResponse.Body + 37, // 33: tree.HealthcheckResponse.signature:type_name -> tree.Signature + 36, // 34: tree.HealthcheckRequest.body:type_name -> tree.HealthcheckRequest.Body + 37, // 35: tree.HealthcheckRequest.signature:type_name -> tree.Signature + 38, // 36: tree.AddRequest.Body.meta:type_name -> tree.KeyValue + 38, // 37: tree.AddByPathRequest.Body.meta:type_name -> tree.KeyValue + 38, // 38: tree.MoveRequest.Body.meta:type_name -> tree.KeyValue + 38, // 39: tree.GetNodeByPathResponse.Info.meta:type_name -> tree.KeyValue + 27, // 40: tree.GetNodeByPathResponse.Body.nodes:type_name -> tree.GetNodeByPathResponse.Info + 38, // 41: tree.GetSubTreeResponse.Body.meta:type_name -> tree.KeyValue + 39, // 42: tree.ApplyRequest.Body.operation:type_name -> tree.LogMove + 39, // 43: tree.GetOpLogResponse.Body.operation:type_name -> tree.LogMove + 0, // 44: tree.TreeService.Add:input_type -> tree.AddRequest + 2, // 45: tree.TreeService.AddByPath:input_type -> tree.AddByPathRequest + 4, // 46: tree.TreeService.Remove:input_type -> tree.RemoveRequest + 6, // 47: tree.TreeService.Move:input_type -> tree.MoveRequest + 8, // 48: tree.TreeService.GetNodeByPath:input_type -> tree.GetNodeByPathRequest + 10, // 49: tree.TreeService.GetSubTree:input_type -> tree.GetSubTreeRequest + 12, // 50: tree.TreeService.Apply:input_type -> tree.ApplyRequest + 14, // 51: tree.TreeService.GetOpLog:input_type -> tree.GetOpLogRequest + 17, // 52: tree.TreeService.Healthcheck:input_type -> tree.HealthcheckRequest + 1, // 53: tree.TreeService.Add:output_type -> tree.AddResponse + 3, // 54: tree.TreeService.AddByPath:output_type -> tree.AddByPathResponse + 5, // 55: tree.TreeService.Remove:output_type -> tree.RemoveResponse + 7, // 56: tree.TreeService.Move:output_type -> tree.MoveResponse + 9, // 57: tree.TreeService.GetNodeByPath:output_type -> tree.GetNodeByPathResponse + 11, // 58: tree.TreeService.GetSubTree:output_type -> tree.GetSubTreeResponse + 13, // 59: tree.TreeService.Apply:output_type -> tree.ApplyResponse + 15, // 60: tree.TreeService.GetOpLog:output_type -> tree.GetOpLogResponse + 16, // 61: tree.TreeService.Healthcheck:output_type -> tree.HealthcheckResponse + 53, // [53:62] is the sub-list for method output_type + 44, // [44:53] is the sub-list for method input_type + 44, // [44:44] is the sub-list for extension type_name + 44, // [44:44] is the sub-list for extension extendee + 0, // [0:44] is the sub-list for field type_name } func init() { file_pkg_services_tree_service_proto_init() } @@ -2672,7 +2891,7 @@ func file_pkg_services_tree_service_proto_init() { } } file_pkg_services_tree_service_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*AddRequest_Body); i { + switch v := v.(*HealthcheckResponse); i { case 0: return &v.state case 1: @@ -2684,7 +2903,7 @@ func file_pkg_services_tree_service_proto_init() { } } file_pkg_services_tree_service_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*AddResponse_Body); i { + switch v := v.(*HealthcheckRequest); i { case 0: return &v.state case 1: @@ -2696,7 +2915,7 @@ func file_pkg_services_tree_service_proto_init() { } } file_pkg_services_tree_service_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*AddByPathRequest_Body); i { + switch v := v.(*AddRequest_Body); i { case 0: return &v.state case 1: @@ -2708,7 +2927,7 @@ func file_pkg_services_tree_service_proto_init() { } } file_pkg_services_tree_service_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*AddByPathResponse_Body); i { + switch v := v.(*AddResponse_Body); i { case 0: return &v.state case 1: @@ -2720,7 +2939,7 @@ func file_pkg_services_tree_service_proto_init() { } } file_pkg_services_tree_service_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*RemoveRequest_Body); i { + switch v := v.(*AddByPathRequest_Body); i { case 0: return &v.state case 1: @@ -2732,7 +2951,7 @@ func file_pkg_services_tree_service_proto_init() { } } file_pkg_services_tree_service_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*RemoveResponse_Body); i { + switch v := v.(*AddByPathResponse_Body); i { case 0: return &v.state case 1: @@ -2744,7 +2963,7 @@ func file_pkg_services_tree_service_proto_init() { } } file_pkg_services_tree_service_proto_msgTypes[22].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*MoveRequest_Body); i { + switch v := v.(*RemoveRequest_Body); i { case 0: return &v.state case 1: @@ -2756,7 +2975,7 @@ func file_pkg_services_tree_service_proto_init() { } } file_pkg_services_tree_service_proto_msgTypes[23].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*MoveResponse_Body); i { + switch v := v.(*RemoveResponse_Body); i { case 0: return &v.state case 1: @@ -2768,7 +2987,7 @@ func file_pkg_services_tree_service_proto_init() { } } file_pkg_services_tree_service_proto_msgTypes[24].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*GetNodeByPathRequest_Body); i { + switch v := v.(*MoveRequest_Body); i { case 0: return &v.state case 1: @@ -2780,7 +2999,7 @@ func file_pkg_services_tree_service_proto_init() { } } file_pkg_services_tree_service_proto_msgTypes[25].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*GetNodeByPathResponse_Info); i { + switch v := v.(*MoveResponse_Body); i { case 0: return &v.state case 1: @@ -2792,7 +3011,7 @@ func file_pkg_services_tree_service_proto_init() { } } file_pkg_services_tree_service_proto_msgTypes[26].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*GetNodeByPathResponse_Body); i { + switch v := v.(*GetNodeByPathRequest_Body); i { case 0: return &v.state case 1: @@ -2804,7 +3023,7 @@ func file_pkg_services_tree_service_proto_init() { } } file_pkg_services_tree_service_proto_msgTypes[27].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*GetSubTreeRequest_Body); i { + switch v := v.(*GetNodeByPathResponse_Info); i { case 0: return &v.state case 1: @@ -2816,7 +3035,7 @@ func file_pkg_services_tree_service_proto_init() { } } file_pkg_services_tree_service_proto_msgTypes[28].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*GetSubTreeResponse_Body); i { + switch v := v.(*GetNodeByPathResponse_Body); i { case 0: return &v.state case 1: @@ -2828,7 +3047,7 @@ func file_pkg_services_tree_service_proto_init() { } } file_pkg_services_tree_service_proto_msgTypes[29].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ApplyRequest_Body); i { + switch v := v.(*GetSubTreeRequest_Body); i { case 0: return &v.state case 1: @@ -2840,7 +3059,7 @@ func file_pkg_services_tree_service_proto_init() { } } file_pkg_services_tree_service_proto_msgTypes[30].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ApplyResponse_Body); i { + switch v := v.(*GetSubTreeResponse_Body); i { case 0: return &v.state case 1: @@ -2852,7 +3071,7 @@ func file_pkg_services_tree_service_proto_init() { } } file_pkg_services_tree_service_proto_msgTypes[31].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*GetOpLogRequest_Body); i { + switch v := v.(*ApplyRequest_Body); i { case 0: return &v.state case 1: @@ -2864,6 +3083,30 @@ func file_pkg_services_tree_service_proto_init() { } } file_pkg_services_tree_service_proto_msgTypes[32].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*ApplyResponse_Body); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_pkg_services_tree_service_proto_msgTypes[33].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*GetOpLogRequest_Body); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_pkg_services_tree_service_proto_msgTypes[34].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*GetOpLogResponse_Body); i { case 0: return &v.state @@ -2875,6 +3118,30 @@ func file_pkg_services_tree_service_proto_init() { return nil } } + file_pkg_services_tree_service_proto_msgTypes[35].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*HealthcheckResponse_Body); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_pkg_services_tree_service_proto_msgTypes[36].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*HealthcheckRequest_Body); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } } type x struct{} out := protoimpl.TypeBuilder{ @@ -2882,7 +3149,7 @@ func file_pkg_services_tree_service_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: file_pkg_services_tree_service_proto_rawDesc, NumEnums: 0, - NumMessages: 33, + NumMessages: 37, NumExtensions: 0, NumServices: 1, }, diff --git a/pkg/services/tree/service.proto b/pkg/services/tree/service.proto index e1f8d678c..9bcefbf95 100644 --- a/pkg/services/tree/service.proto +++ b/pkg/services/tree/service.proto @@ -47,6 +47,8 @@ service TreeService { rpc Apply (ApplyRequest) returns (ApplyResponse); // GetOpLog returns a stream of logged operations starting from some height. rpc GetOpLog(GetOpLogRequest) returns (stream GetOpLogResponse); + // Healthcheck is a dummy rpc to check service availability + rpc Healthcheck(HealthcheckRequest) returns (HealthcheckResponse); } message AddRequest { @@ -328,3 +330,23 @@ message GetOpLogResponse { // Response signature. Signature signature = 2; }; + +message HealthcheckResponse { + message Body { + } + + // Response body. + Body body = 1; + // Response signature. + Signature signature = 2; +}; + +message HealthcheckRequest { + message Body { + } + + // Request body. + Body body = 1; + // Request signature. + Signature signature = 2; +} diff --git a/pkg/services/tree/service_grpc.pb.go b/pkg/services/tree/service_grpc.pb.go index fba0bfc0c..590f11071 100644 --- a/pkg/services/tree/service_grpc.pb.go +++ b/pkg/services/tree/service_grpc.pb.go @@ -8,7 +8,6 @@ package tree import ( context "context" - grpc "google.golang.org/grpc" codes "google.golang.org/grpc/codes" status "google.golang.org/grpc/status" @@ -40,6 +39,8 @@ type TreeServiceClient interface { Apply(ctx context.Context, in *ApplyRequest, opts ...grpc.CallOption) (*ApplyResponse, error) // GetOpLog returns a stream of logged operations starting from some height. GetOpLog(ctx context.Context, in *GetOpLogRequest, opts ...grpc.CallOption) (TreeService_GetOpLogClient, error) + // Healthcheck is a dummy rpc to check service availability + Healthcheck(ctx context.Context, in *HealthcheckRequest, opts ...grpc.CallOption) (*HealthcheckResponse, error) } type treeServiceClient struct { @@ -168,6 +169,15 @@ func (x *treeServiceGetOpLogClient) Recv() (*GetOpLogResponse, error) { return m, nil } +func (c *treeServiceClient) Healthcheck(ctx context.Context, in *HealthcheckRequest, opts ...grpc.CallOption) (*HealthcheckResponse, error) { + out := new(HealthcheckResponse) + err := c.cc.Invoke(ctx, "/tree.TreeService/Healthcheck", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + // TreeServiceServer is the server API for TreeService service. // All implementations should embed UnimplementedTreeServiceServer // for forward compatibility @@ -189,6 +199,8 @@ type TreeServiceServer interface { Apply(context.Context, *ApplyRequest) (*ApplyResponse, error) // GetOpLog returns a stream of logged operations starting from some height. GetOpLog(*GetOpLogRequest, TreeService_GetOpLogServer) error + // Healthcheck is a dummy rpc to check service availability + Healthcheck(context.Context, *HealthcheckRequest) (*HealthcheckResponse, error) } // UnimplementedTreeServiceServer should be embedded to have forward compatible implementations. @@ -219,6 +231,9 @@ func (UnimplementedTreeServiceServer) Apply(context.Context, *ApplyRequest) (*Ap func (UnimplementedTreeServiceServer) GetOpLog(*GetOpLogRequest, TreeService_GetOpLogServer) error { return status.Errorf(codes.Unimplemented, "method GetOpLog not implemented") } +func (UnimplementedTreeServiceServer) Healthcheck(context.Context, *HealthcheckRequest) (*HealthcheckResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method Healthcheck not implemented") +} // UnsafeTreeServiceServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to TreeServiceServer will @@ -381,6 +396,24 @@ func (x *treeServiceGetOpLogServer) Send(m *GetOpLogResponse) error { return x.ServerStream.SendMsg(m) } +func _TreeService_Healthcheck_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(HealthcheckRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(TreeServiceServer).Healthcheck(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/tree.TreeService/Healthcheck", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(TreeServiceServer).Healthcheck(ctx, req.(*HealthcheckRequest)) + } + return interceptor(ctx, in, info, handler) +} + // TreeService_ServiceDesc is the grpc.ServiceDesc for TreeService service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) @@ -412,6 +445,10 @@ var TreeService_ServiceDesc = grpc.ServiceDesc{ MethodName: "Apply", Handler: _TreeService_Apply_Handler, }, + { + MethodName: "Healthcheck", + Handler: _TreeService_Healthcheck_Handler, + }, }, Streams: []grpc.StreamDesc{ { diff --git a/pkg/services/tree/service_neofs.pb.go b/pkg/services/tree/service_neofs.pb.go index 0eea38fe0..44ddb1985 100644 --- a/pkg/services/tree/service_neofs.pb.go +++ b/pkg/services/tree/service_neofs.pb.go @@ -1390,3 +1390,145 @@ func (x *GetOpLogResponse) ReadSignedData(buf []byte) ([]byte, error) { func (x *GetOpLogResponse) SetSignature(sig *Signature) { x.Signature = sig } + +// StableSize returns the size of x in protobuf format. +// +// Structures with the same field values have the same binary size. +func (x *HealthcheckResponse_Body) StableSize() (size int) { + return size +} + +// StableMarshal marshals x in protobuf binary format with stable field order. +// +// If buffer length is less than x.StableSize(), new buffer is allocated. +// +// Returns any error encountered which did not allow writing the data completely. +// Otherwise, returns the buffer in which the data is written. +// +// Structures with the same field values have the same binary format. +func (x *HealthcheckResponse_Body) StableMarshal(buf []byte) []byte { + return buf +} + +// StableSize returns the size of x in protobuf format. +// +// Structures with the same field values have the same binary size. +func (x *HealthcheckResponse) StableSize() (size int) { + size += proto.NestedStructureSize(1, x.Body) + size += proto.NestedStructureSize(2, x.Signature) + return size +} + +// StableMarshal marshals x in protobuf binary format with stable field order. +// +// If buffer length is less than x.StableSize(), new buffer is allocated. +// +// Returns any error encountered which did not allow writing the data completely. +// Otherwise, returns the buffer in which the data is written. +// +// Structures with the same field values have the same binary format. +func (x *HealthcheckResponse) StableMarshal(buf []byte) []byte { + if x == nil { + return []byte{} + } + if buf == nil { + buf = make([]byte, x.StableSize()) + } + var offset int + offset += proto.NestedStructureMarshal(1, buf[offset:], x.Body) + offset += proto.NestedStructureMarshal(2, buf[offset:], x.Signature) + return buf +} + +// ReadSignedData fills buf with signed data of x. +// If buffer length is less than x.SignedDataSize(), new buffer is allocated. +// +// Returns any error encountered which did not allow writing the data completely. +// Otherwise, returns the buffer in which the data is written. +// +// Structures with the same field values have the same signed data. +func (x *HealthcheckResponse) SignedDataSize() int { + return x.GetBody().StableSize() +} + +// SignedDataSize returns size of the request signed data in bytes. +// +// Structures with the same field values have the same signed data size. +func (x *HealthcheckResponse) ReadSignedData(buf []byte) ([]byte, error) { + return x.GetBody().StableMarshal(buf), nil +} + +func (x *HealthcheckResponse) SetSignature(sig *Signature) { + x.Signature = sig +} + +// StableSize returns the size of x in protobuf format. +// +// Structures with the same field values have the same binary size. +func (x *HealthcheckRequest_Body) StableSize() (size int) { + return size +} + +// StableMarshal marshals x in protobuf binary format with stable field order. +// +// If buffer length is less than x.StableSize(), new buffer is allocated. +// +// Returns any error encountered which did not allow writing the data completely. +// Otherwise, returns the buffer in which the data is written. +// +// Structures with the same field values have the same binary format. +func (x *HealthcheckRequest_Body) StableMarshal(buf []byte) []byte { + return buf +} + +// StableSize returns the size of x in protobuf format. +// +// Structures with the same field values have the same binary size. +func (x *HealthcheckRequest) StableSize() (size int) { + size += proto.NestedStructureSize(1, x.Body) + size += proto.NestedStructureSize(2, x.Signature) + return size +} + +// StableMarshal marshals x in protobuf binary format with stable field order. +// +// If buffer length is less than x.StableSize(), new buffer is allocated. +// +// Returns any error encountered which did not allow writing the data completely. +// Otherwise, returns the buffer in which the data is written. +// +// Structures with the same field values have the same binary format. +func (x *HealthcheckRequest) StableMarshal(buf []byte) []byte { + if x == nil { + return []byte{} + } + if buf == nil { + buf = make([]byte, x.StableSize()) + } + var offset int + offset += proto.NestedStructureMarshal(1, buf[offset:], x.Body) + offset += proto.NestedStructureMarshal(2, buf[offset:], x.Signature) + return buf +} + +// ReadSignedData fills buf with signed data of x. +// If buffer length is less than x.SignedDataSize(), new buffer is allocated. +// +// Returns any error encountered which did not allow writing the data completely. +// Otherwise, returns the buffer in which the data is written. +// +// Structures with the same field values have the same signed data. +func (x *HealthcheckRequest) SignedDataSize() int { + return x.GetBody().StableSize() +} + +// SignedDataSize returns size of the request signed data in bytes. +// +// Structures with the same field values have the same signed data size. +func (x *HealthcheckRequest) ReadSignedData(buf []byte) ([]byte, error) { + return x.GetBody().StableMarshal(buf), nil +} + +func (x *HealthcheckRequest) SetSignature(sig *Signature) { + x.Signature = sig +} diff --git a/pkg/services/tree/types.pb.go b/pkg/services/tree/types.pb.go index 75c56a189..29be48744 100644 --- a/pkg/services/tree/types.pb.go +++ b/pkg/services/tree/types.pb.go @@ -10,11 +10,10 @@ package tree import ( - reflect "reflect" - sync "sync" - protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" ) const (