Dima/orion_greptime_proto
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: use path for ApplyStagingManifestRequest (#297)

Browse Source 
Signed-off-by: WenyXu <wenymedia@gmail.com>
This commit is contained in:
Weny Xu
2025-12-30 14:57:56 +08:00
committed by GitHub
parent 520fa524f9
commit a2e5099d72
5 changed files with 418 additions and 369 deletions
Download Patch File Download Diff File Expand all files Collapse all files
go/greptime/v1/region/server.pb.go
+28 -19
View File
@@ -2511,8 +2511,10 @@ type ApplyStagingManifestRequest struct {
RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
// The partition expression of the staging manifest.
PartitionExpr string `protobuf:"bytes,2,opt,name=partition_expr,json=partitionExpr,proto3" json:"partition_expr,omitempty"`
// The file metas to add to the staging manifest.
FilesToAdd *FileMetas `protobuf:"bytes,3,opt,name=files_to_add,json=filesToAdd,proto3" json:"files_to_add,omitempty"`
// The region stores the staging manifest.
CentralRegionId uint64 `protobuf:"varint,3,opt,name=central_region_id,json=centralRegionId,proto3" json:"central_region_id,omitempty"`
// Path to the staging manifest file.
ManifestPath string `protobuf:"bytes,4,opt,name=manifest_path,json=manifestPath,proto3" json:"manifest_path,omitempty"`
}
func (x *ApplyStagingManifestRequest) Reset() {
@@ -2561,11 +2563,18 @@ func (x *ApplyStagingManifestRequest) GetPartitionExpr() string {
return ""
}
func (x *ApplyStagingManifestRequest) GetFilesToAdd() *FileMetas {
func (x *ApplyStagingManifestRequest) GetCentralRegionId() uint64 {
if x != nil {
return x.FilesToAdd
return x.CentralRegionId
}
return nil
return 0
}
func (x *ApplyStagingManifestRequest) GetManifestPath() string {
if x != nil {
return x.ManifestPath
}
return ""
}
var File_greptime_v1_region_server_proto protoreflect.FileDescriptor
@@ -2948,18 +2957,19 @@ var file_greptime_v1_region_server_proto_rawDesc = []byte{
0x0a, 0x09, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28,
0x04, 0x52, 0x08, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x22, 0x1f, 0x0a, 0x09, 0x46,
0x69, 0x6c, 0x65, 0x4d, 0x65, 0x74, 0x61, 0x73, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61,
0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x22, 0xa2, 0x01, 0x0a,
0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x22, 0xb2, 0x01, 0x0a,
0x1b, 0x41, 0x70, 0x70, 0x6c, 0x79, 0x53, 0x74, 0x61, 0x67, 0x69, 0x6e, 0x67, 0x4d, 0x61, 0x6e,
0x69, 0x66, 0x65, 0x73, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1b, 0x0a, 0x09,
0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x04, 0x52,
0x08, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x25, 0x0a, 0x0e, 0x70, 0x61, 0x72,
0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x65, 0x78, 0x70, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28,
0x09, 0x52, 0x0d, 0x70, 0x61, 0x72, 0x74, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x45, 0x78, 0x70, 0x72,
0x12, 0x3f, 0x0a, 0x0c, 0x66, 0x69, 0x6c, 0x65, 0x73, 0x5f, 0x74, 0x6f, 0x5f, 0x61, 0x64, 0x64,
0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d,
0x65, 0x2e, 0x76, 0x31, 0x2e, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x2e, 0x46, 0x69, 0x6c, 0x65,
0x4d, 0x65, 0x74, 0x61, 0x73, 0x52, 0x0a, 0x66, 0x69, 0x6c, 0x65, 0x73, 0x54, 0x6f, 0x41, 0x64,
0x64, 0x32, 0x59, 0x0a, 0x06, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x12, 0x4f, 0x0a, 0x06, 0x48,
0x12, 0x2a, 0x0a, 0x11, 0x63, 0x65, 0x6e, 0x74, 0x72, 0x61, 0x6c, 0x5f, 0x72, 0x65, 0x67, 0x69,
0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0f, 0x63, 0x65, 0x6e,
0x74, 0x72, 0x61, 0x6c, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x23, 0x0a, 0x0d,
0x6d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x5f, 0x70, 0x61, 0x74, 0x68, 0x18, 0x04, 0x20,
0x01, 0x28, 0x09, 0x52, 0x0c, 0x6d, 0x61, 0x6e, 0x69, 0x66, 0x65, 0x73, 0x74, 0x50, 0x61, 0x74,
0x68, 0x32, 0x59, 0x0a, 0x06, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x12, 0x4f, 0x0a, 0x06, 0x48,
0x61, 0x6e, 0x64, 0x6c, 0x65, 0x12, 0x21, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65,
0x2e, 0x76, 0x31, 0x2e, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x2e, 0x52, 0x65, 0x67, 0x69, 0x6f,
0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x22, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74,
@@ -3107,14 +3117,13 @@ var file_greptime_v1_region_server_proto_depIdxs = []int32{
56, // 57: greptime.v1.region.BulkInsertRequest.arrow_ipc:type_name -> greptime.v1.ArrowIpc
29, // 58: greptime.v1.region.SyncRequest.mito_manifest_info:type_name -> greptime.v1.region.MitoManifestInfo
30, // 59: greptime.v1.region.SyncRequest.metric_manifest_info:type_name -> greptime.v1.region.MetricManifestInfo
34, // 60: greptime.v1.region.ApplyStagingManifestRequest.files_to_add:type_name -> greptime.v1.region.FileMetas
1, // 61: greptime.v1.region.Region.Handle:input_type -> greptime.v1.region.RegionRequest
2, // 62: greptime.v1.region.Region.Handle:output_type -> greptime.v1.region.RegionResponse
62, // [62:63] is the sub-list for method output_type
61, // [61:62] is the sub-list for method input_type
61, // [61:61] is the sub-list for extension type_name
61, // [61:61] is the sub-list for extension extendee
0, // [0:61] is the sub-list for field type_name
1, // 60: greptime.v1.region.Region.Handle:input_type -> greptime.v1.region.RegionRequest
2, // 61: greptime.v1.region.Region.Handle:output_type -> greptime.v1.region.RegionResponse
61, // [61:62] is the sub-list for method output_type
60, // [60:61] is the sub-list for method input_type
60, // [60:60] is the sub-list for extension type_name
60, // [60:60] is the sub-list for extension extendee
0, // [0:60] is the sub-list for field type_name
}
func init() { file_greptime_v1_region_server_proto_init() }