diff options
| author | akozhikhov <akozhikhov@yandex-team.com> | 2024-07-10 18:47:15 +0300 |
|---|---|---|
| committer | akozhikhov <akozhikhov@yandex-team.com> | 2024-07-10 19:03:46 +0300 |
| commit | 1c80bc50980e66b306543ebd1ed4cce471cf6671 (patch) | |
| tree | c1909b48ff90e5fa824d5ea8fc1d995daef947df | |
| parent | 9b4d936eca17721b5c4fc64ef48747f34146ae42 (diff) | |
| download | ydb-1c80bc50980e66b306543ebd1ed4cce471cf6671.tar.gz | |
YT-22158: Update revision in chunk replica cache upon chunk confirmation
d1af0c04e1056925312e8916b0fffae9e9d49a6c
| -rw-r--r-- | yt/yt/client/chunk_client/chunk_replica.h | 11 | ||||
| -rw-r--r-- | yt/yt/client/chunk_client/public.h | 2 |
2 files changed, 13 insertions, 0 deletions
diff --git a/yt/yt/client/chunk_client/chunk_replica.h b/yt/yt/client/chunk_client/chunk_replica.h index 91ccfc0e9a..e11a7b23e8 100644 --- a/yt/yt/client/chunk_client/chunk_replica.h +++ b/yt/yt/client/chunk_client/chunk_replica.h @@ -2,6 +2,8 @@ #include "public.h" +#include <yt/yt/client/hydra/public.h> + #include <yt/yt/client/node_tracker_client/public.h> namespace NYT::NChunkClient { @@ -88,6 +90,15 @@ void FormatValue(TStringBuilderBase* builder, TChunkReplicaWithLocation replica, //////////////////////////////////////////////////////////////////////////////// +struct TWrittenChunkReplicasInfo +{ + TChunkReplicaWithLocationList Replicas; + // Revision upon confirmation of the chunk. Not every writer is expected to set this field. + NHydra::TRevision ConfirmationRevision = NHydra::NullRevision; +}; + +//////////////////////////////////////////////////////////////////////////////// + class TChunkReplica { public: diff --git a/yt/yt/client/chunk_client/public.h b/yt/yt/client/chunk_client/public.h index b1771c530a..6c656fc858 100644 --- a/yt/yt/client/chunk_client/public.h +++ b/yt/yt/client/chunk_client/public.h @@ -141,6 +141,8 @@ using TChunkReplicaWithMediumList = TCompactVector<TChunkReplicaWithMedium, Typi class TChunkReplicaWithLocation; using TChunkReplicaWithLocationList = TCompactVector<TChunkReplicaWithLocation, TypicalReplicaCount>; +struct TWrittenChunkReplicasInfo; + class TChunkReplica; using TChunkReplicaList = TCompactVector<TChunkReplica, TypicalReplicaCount>; |