aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorbabenko <babenko@yandex-team.com>2023-11-16 20:53:35 +0300
committerbabenko <babenko@yandex-team.com>2023-11-16 21:10:45 +0300
commite41da361751eec0b148c9bd85a4b6a1a862e5da5 (patch)
tree6f119702fa66ac1d05425f9f2035387ee40ace7c
parentac026fffa4220a9c78a616ad3aa837ef2799790f (diff)
downloadydb-e41da361751eec0b148c9bd85a4b6a1a862e5da5.tar.gz
Rewrite erasure journal repair
-rw-r--r--yt/yt/client/api/config.h3
-rw-r--r--yt/yt/client/journal_client/config.cpp11
-rw-r--r--yt/yt/client/journal_client/config.h8
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);