diff options
author | babenko <babenko@yandex-team.com> | 2023-11-16 20:53:35 +0300 |
---|---|---|
committer | babenko <babenko@yandex-team.com> | 2023-11-16 21:10:45 +0300 |
commit | e41da361751eec0b148c9bd85a4b6a1a862e5da5 (patch) | |
tree | 6f119702fa66ac1d05425f9f2035387ee40ace7c | |
parent | ac026fffa4220a9c78a616ad3aa837ef2799790f (diff) | |
download | ydb-e41da361751eec0b148c9bd85a4b6a1a862e5da5.tar.gz |
Rewrite erasure journal repair
-rw-r--r-- | yt/yt/client/api/config.h | 3 | ||||
-rw-r--r-- | yt/yt/client/journal_client/config.cpp | 11 | ||||
-rw-r--r-- | yt/yt/client/journal_client/config.h | 8 |
3 files changed, 6 insertions, 16 deletions
diff --git a/yt/yt/client/api/config.h b/yt/yt/client/api/config.h index 5bc5506299..1452163231 100644 --- a/yt/yt/client/api/config.h +++ b/yt/yt/client/api/config.h @@ -127,6 +127,7 @@ DEFINE_REFCOUNTED_TYPE(TPersistentQueuePollerConfig) class TFileReaderConfig : public virtual NChunkClient::TMultiChunkReaderConfig { +public: REGISTER_YSON_STRUCT(TFileReaderConfig); static void Register(TRegistrar) @@ -141,6 +142,7 @@ class TFileWriterConfig : public NChunkClient::TMultiChunkWriterConfig , public NFileClient::TFileChunkWriterConfig { +public: REGISTER_YSON_STRUCT(TFileWriterConfig); static void Register(TRegistrar) @@ -155,6 +157,7 @@ class TJournalReaderConfig : public NJournalClient::TChunkReaderConfig , public TWorkloadConfig { +public: REGISTER_YSON_STRUCT(TJournalReaderConfig); static void Register(TRegistrar) diff --git a/yt/yt/client/journal_client/config.cpp b/yt/yt/client/journal_client/config.cpp index dde03da128..b8f9f81018 100644 --- a/yt/yt/client/journal_client/config.cpp +++ b/yt/yt/client/journal_client/config.cpp @@ -1,16 +1,11 @@ #include "config.h" + namespace NYT::NJournalClient { //////////////////////////////////////////////////////////////////////////////// -void TChunkReaderConfig::Register(TRegistrar registrar) -{ - registrar.Parameter("replica_data_size_read_threshold", &TThis::ReplicaDataSizeReadThreshold) - .Default(1_MB); - - registrar.Parameter("slow_path_delay", &TThis::SlowPathDelay) - .Default(TDuration::Seconds(5)); -} +void TChunkReaderConfig::Register(TRegistrar /*registrar*/) +{ } //////////////////////////////////////////////////////////////////////////////// diff --git a/yt/yt/client/journal_client/config.h b/yt/yt/client/journal_client/config.h index e44278f99b..b89a248d2b 100644 --- a/yt/yt/client/journal_client/config.h +++ b/yt/yt/client/journal_client/config.h @@ -14,14 +14,6 @@ class TChunkReaderConfig : public virtual NChunkClient::TReplicationReaderConfig { public: - //! Reader will skip replicas with less than this amount of relevant data - //! data available. - i64 ReplicaDataSizeReadThreshold; - - //! When fetching replica metas, journal reader will wait for this period of time - //! before starting slow path in hope to run fast path. - TDuration SlowPathDelay; - REGISTER_YSON_STRUCT(TChunkReaderConfig); static void Register(TRegistrar registrar); |