From dc2f91bebe7eb18a504978f17737715909933ae2 Mon Sep 17 00:00:00 2001 From: Neil Macneale IV Date: Mon, 6 Oct 2025 16:47:02 -0700 Subject: [PATCH] Add split offset to the TableFileInfo proto spec --- .../remotesapi/v1alpha1/chunkstore.pb.go | 20 +++++++++++++------ .../remotesapi/v1alpha1/chunkstore.proto | 1 + 2 files changed, 15 insertions(+), 6 deletions(-) diff --git a/go/gen/proto/dolt/services/remotesapi/v1alpha1/chunkstore.pb.go b/go/gen/proto/dolt/services/remotesapi/v1alpha1/chunkstore.pb.go index c284f83d9a..dae648a740 100644 --- a/go/gen/proto/dolt/services/remotesapi/v1alpha1/chunkstore.pb.go +++ b/go/gen/proto/dolt/services/remotesapi/v1alpha1/chunkstore.pb.go @@ -21,13 +21,12 @@ package remotesapi import ( - reflect "reflect" - sync "sync" - unsafe "unsafe" - protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoimpl "google.golang.org/protobuf/runtime/protoimpl" timestamppb "google.golang.org/protobuf/types/known/timestamppb" + reflect "reflect" + sync "sync" + unsafe "unsafe" ) const ( @@ -1743,6 +1742,7 @@ type TableFileInfo struct { Url string `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"` RefreshAfter *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=refresh_after,json=refreshAfter,proto3" json:"refresh_after,omitempty"` RefreshRequest *RefreshTableFileUrlRequest `protobuf:"bytes,5,opt,name=refresh_request,json=refreshRequest,proto3" json:"refresh_request,omitempty"` + SplitOffset uint64 `protobuf:"varint,6,opt,name=split_offset,json=splitOffset,proto3" json:"split_offset,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } @@ -1812,6 +1812,13 @@ func (x *TableFileInfo) GetRefreshRequest() *RefreshTableFileUrlRequest { return nil } +func (x *TableFileInfo) GetSplitOffset() uint64 { + if x != nil { + return x.SplitOffset + } + return 0 +} + type RefreshTableFileUrlRequest struct { state protoimpl.MessageState `protogen:"open.v1"` RepoId *RepoId `protobuf:"bytes,1,opt,name=repo_id,json=repoId,proto3" json:"repo_id,omitempty"` @@ -2279,14 +2286,15 @@ const file_dolt_services_remotesapi_v1alpha1_chunkstore_proto_rawDesc = "" + "\rappendix_only\x18\x02 \x01(\bB\x02\x18\x01R\fappendixOnly\x12\x1d\n" + "\n" + "repo_token\x18\x03 \x01(\tR\trepoToken\x12\x1b\n" + - "\trepo_path\x18\x04 \x01(\tR\brepoPath\"\x82\x02\n" + + "\trepo_path\x18\x04 \x01(\tR\brepoPath\"\xa5\x02\n" + "\rTableFileInfo\x12\x17\n" + "\afile_id\x18\x01 \x01(\tR\x06fileId\x12\x1d\n" + "\n" + "num_chunks\x18\x02 \x01(\rR\tnumChunks\x12\x10\n" + "\x03url\x18\x03 \x01(\tR\x03url\x12?\n" + "\rrefresh_after\x18\x04 \x01(\v2\x1a.google.protobuf.TimestampR\frefreshAfter\x12f\n" + - "\x0frefresh_request\x18\x05 \x01(\v2=.dolt.services.remotesapi.v1alpha1.RefreshTableFileUrlRequestR\x0erefreshRequest\"\xb5\x01\n" + + "\x0frefresh_request\x18\x05 \x01(\v2=.dolt.services.remotesapi.v1alpha1.RefreshTableFileUrlRequestR\x0erefreshRequest\x12!\n" + + "\fsplit_offset\x18\x06 \x01(\x04R\vsplitOffset\"\xb5\x01\n" + "\x1aRefreshTableFileUrlRequest\x12B\n" + "\arepo_id\x18\x01 \x01(\v2).dolt.services.remotesapi.v1alpha1.RepoIdR\x06repoId\x12\x17\n" + "\afile_id\x18\x02 \x01(\tR\x06fileId\x12\x1d\n" + diff --git a/proto/dolt/services/remotesapi/v1alpha1/chunkstore.proto b/proto/dolt/services/remotesapi/v1alpha1/chunkstore.proto index bb63e8b1c7..78ea6f3faf 100644 --- a/proto/dolt/services/remotesapi/v1alpha1/chunkstore.proto +++ b/proto/dolt/services/remotesapi/v1alpha1/chunkstore.proto @@ -268,6 +268,7 @@ message TableFileInfo { string url = 3; google.protobuf.Timestamp refresh_after = 4; RefreshTableFileUrlRequest refresh_request = 5; + uint64 split_offset = 6; } message RefreshTableFileUrlRequest {