minor fixes of TTL in SDK (ydb-platform#12152)

Author: swalrus1

ydb/public/lib/experimental/ydb_logstore.cpp

@@ -16,7 +16,7 @@ namespace NYdb {
 namespace NLogStore {
 
 TMaybe<TTtlSettings> TtlSettingsFromProto(const Ydb::Table::TtlSettings& proto) {
-    if (auto settings = TTtlSettings::DeserializeFromProto(proto)) {
+    if (auto settings = TTtlSettings::FromProto(proto)) {
         return *settings;
     }
     return Nothing();

ydb/public/sdk/cpp/client/ydb_table/table.cpp

@@ -325,7 +325,7 @@ class TTableDescription::TImpl {
         }
 
         // ttl settings
-        if (auto ttlSettings = TTtlSettings::DeserializeFromProto(proto.ttl_settings())) {
+        if (auto ttlSettings = TTtlSettings::FromProto(proto.ttl_settings())) {
             TtlSettings_ = std::move(*ttlSettings);
         }
 
@@ -2729,13 +2729,13 @@ bool operator!=(const TChangefeedDescription& lhs, const TChangefeedDescription&
 
 ////////////////////////////////////////////////////////////////////////////////
 
-TTtlTierSettings::TTtlTierSettings(TDuration evictionDelay, const TAction& action)
-    : EvictAfter_(evictionDelay)
-    , Action_(action) {
-}
+TTtlTierSettings::TTtlTierSettings(TDuration applyAfter, const TAction& action)
+    : ApplyAfter_(applyAfter)
+    , Action_(action)
+{ }
 
 TTtlTierSettings::TTtlTierSettings(const Ydb::Table::TtlTier& tier)
-    : EvictAfter_(TDuration::Seconds(tier.apply_after_seconds())) {
+    : ApplyAfter_(TDuration::Seconds(tier.apply_after_seconds())) {
     switch (tier.action_case()) {
         case Ydb::Table::TtlTier::kDelete:
             Action_ = TTtlDeleteAction();
@@ -2749,7 +2749,7 @@ TTtlTierSettings::TTtlTierSettings(const Ydb::Table::TtlTier& tier)
 }
 
 void TTtlTierSettings::SerializeTo(Ydb::Table::TtlTier& proto) const {
-    proto.set_apply_after_seconds(EvictAfter_.Seconds());
+    proto.set_apply_after_seconds(ApplyAfter_.Seconds());
 
     std::visit(TOverloaded{
             [&proto](const TTtlDeleteAction&) { proto.mutable_delete_(); },
@@ -2761,8 +2761,8 @@ void TTtlTierSettings::SerializeTo(Ydb::Table::TtlTier& proto) const {
         Action_);
 }
 
-TDuration TTtlTierSettings::GetEvictAfter() const {
-    return EvictAfter_;
+TDuration TTtlTierSettings::GetApplyAfter() const {
+    return ApplyAfter_;
 }
 
 const TTtlTierSettings::TAction& TTtlTierSettings::GetAction() const {
@@ -2896,42 +2896,55 @@ const TValueSinceUnixEpochModeSettings& TTtlSettings::GetValueSinceUnixEpoch() c
     return std::get<TValueSinceUnixEpochModeSettings>(Mode_);
 }
 
-std::optional<TTtlSettings> TTtlSettings::DeserializeFromProto(const Ydb::Table::TtlSettings& proto) {
-    TDuration legacyExpireAfter = TDuration::Max();
+std::optional<TTtlSettings> TTtlSettings::FromProto(const Ydb::Table::TtlSettings& proto) {
+    TVector<TTtlTierSettings> tiers;
     for (const auto& tier : proto.tiers()) {
-        if (tier.has_delete_()) {
-            legacyExpireAfter = TDuration::Seconds(tier.apply_after_seconds());
-            break;
-        }
+        tiers.emplace_back(tier);
     }
+    TDuration legacyExpireAfter = GetExpireAfterFrom(tiers).value_or(TDuration::Max());
 
     switch(proto.mode_case()) {
     case Ydb::Table::TtlSettings::kDateTypeColumn:
         return TTtlSettings(proto.date_type_column(), proto.run_interval_seconds());
     case Ydb::Table::TtlSettings::kValueSinceUnixEpoch:
         return TTtlSettings(proto.value_since_unix_epoch(), proto.run_interval_seconds());
     case Ydb::Table::TtlSettings::kDateTypeColumnV1:
-        return TTtlSettings(TDateTypeColumnModeSettings(proto.date_type_column_v1().column_name(), legacyExpireAfter), proto.run_interval_seconds());
+        return TTtlSettings(
+            TDateTypeColumnModeSettings(proto.date_type_column_v1().column_name(), legacyExpireAfter), tiers, proto.run_interval_seconds());
     case Ydb::Table::TtlSettings::kValueSinceUnixEpochV1:
-        return TTtlSettings(TValueSinceUnixEpochModeSettings(proto.value_since_unix_epoch_v1().column_name(), TProtoAccessor::FromProto(proto.value_since_unix_epoch_v1().column_unit()), legacyExpireAfter), proto.run_interval_seconds());
+        return TTtlSettings(TValueSinceUnixEpochModeSettings(proto.value_since_unix_epoch_v1().column_name(),
+                                TProtoAccessor::FromProto(proto.value_since_unix_epoch_v1().column_unit()), legacyExpireAfter),
+            tiers, proto.run_interval_seconds());
     case Ydb::Table::TtlSettings::MODE_NOT_SET:
         return std::nullopt;
         break;
     }
 }
 
 void TTtlSettings::SerializeTo(Ydb::Table::TtlSettings& proto) const {
-    switch (GetMode()) {
-    case EMode::DateTypeColumn:
-        GetDateTypeColumn().SerializeTo(*proto.mutable_date_type_column_v1());
-        break;
-    case EMode::ValueSinceUnixEpoch:
-        GetValueSinceUnixEpoch().SerializeTo(*proto.mutable_value_since_unix_epoch_v1());
-        break;
-    }
+    if (Tiers_.size() == 1 && std::holds_alternative<TTtlDeleteAction>(Tiers_.back().GetAction())) {
+        // serialize DELETE-only TTL to legacy format for backwards-compatibility
+        switch (GetMode()) {
+        case EMode::DateTypeColumn:
+            GetDateTypeColumn().SerializeTo(*proto.mutable_date_type_column());
+            break;
+        case EMode::ValueSinceUnixEpoch:
+            GetValueSinceUnixEpoch().SerializeTo(*proto.mutable_value_since_unix_epoch());
+            break;
+        }
+    } else {
+        switch (GetMode()) {
+        case EMode::DateTypeColumn:
+            GetDateTypeColumn().SerializeTo(*proto.mutable_date_type_column_v1());
+            break;
+        case EMode::ValueSinceUnixEpoch:
+            GetValueSinceUnixEpoch().SerializeTo(*proto.mutable_value_since_unix_epoch_v1());
+            break;
+        }
 
-    for (const auto& tier : Tiers_) {
-        tier.SerializeTo(*proto.add_tiers());
+        for (const auto& tier : Tiers_) {
+            tier.SerializeTo(*proto.add_tiers());
+        }
     }
 
     if (RunInterval_) {
@@ -2963,13 +2976,17 @@ std::optional<TDuration> TTtlSettings::GetExpireAfter() const {
 std::optional<TDuration> TTtlSettings::GetExpireAfterFrom(const TVector<TTtlTierSettings>& tiers) {
     for (const auto& tier : tiers) {
         if (std::holds_alternative<TTtlDeleteAction>(tier.GetAction())) {
-            return tier.GetEvictAfter();
+            return tier.GetApplyAfter();
         }
     }
     return std::nullopt;
 }
 
-TTtlSettings::TTtlSettings(TMode mode, ui32 runIntervalSeconds) : Mode_(std::move(mode)), RunInterval_(TDuration::Seconds(runIntervalSeconds)) {}
+TTtlSettings::TTtlSettings(TMode mode, const TVector<TTtlTierSettings>& tiers, ui32 runIntervalSeconds)
+    : Mode_(std::move(mode))
+    , Tiers_(tiers)
+    , RunInterval_(TDuration::Seconds(runIntervalSeconds))
+{}
 
 TAlterTtlSettings::EAction TAlterTtlSettings::GetAction() const {
     return static_cast<EAction>(Action_.index());

ydb/public/sdk/cpp/client/ydb_table/table.h

@@ -375,15 +375,15 @@ class TTtlTierSettings {
     >;
 
 public:
-    explicit TTtlTierSettings(TDuration evictionDelay, const TAction& action);
+    explicit TTtlTierSettings(TDuration applyAfter, const TAction& action);
     explicit TTtlTierSettings(const Ydb::Table::TtlTier& tier);
     void SerializeTo(Ydb::Table::TtlTier& proto) const;
 
-    TDuration GetEvictAfter() const;
+    TDuration GetApplyAfter() const;
     const TAction& GetAction() const;
 
 private:
-    TDuration EvictAfter_;
+    TDuration ApplyAfter_;
     TAction Action_;
 };
 
@@ -452,16 +452,16 @@ class TTtlSettings {
     explicit TTtlSettings(const TString& columnName, const TVector<TTtlTierSettings>& tiers);
     explicit TTtlSettings(const TString& columnName, const TDuration& expireAfter);
     const TDateTypeColumnModeSettings& GetDateTypeColumn() const;
-    // Deprecated. Use DeserializeFromProto()
+    // Deprecated. Use FromProto()
     explicit TTtlSettings(const Ydb::Table::DateTypeColumnModeSettings& mode, ui32 runIntervalSeconds);
 
     explicit TTtlSettings(const TString& columnName, EUnit columnUnit, const TVector<TTtlTierSettings>& tiers);
     explicit TTtlSettings(const TString& columnName, EUnit columnUnit, const TDuration& expireAfter);
     const TValueSinceUnixEpochModeSettings& GetValueSinceUnixEpoch() const;
-    // Deprecated. Use DeserializeFromProto()
+    // Deprecated. Use FromProto()
     explicit TTtlSettings(const Ydb::Table::ValueSinceUnixEpochModeSettings& mode, ui32 runIntervalSeconds);
 
-    static std::optional<TTtlSettings> DeserializeFromProto(const Ydb::Table::TtlSettings& proto);
+    static std::optional<TTtlSettings> FromProto(const Ydb::Table::TtlSettings& proto);
     void SerializeTo(Ydb::Table::TtlSettings& proto) const;
     EMode GetMode() const;
 
@@ -472,7 +472,7 @@ class TTtlSettings {
     std::optional<TDuration> GetExpireAfter() const;
 
 private:
-    explicit TTtlSettings(TMode mode, ui32 runIntervalSeconds);
+    explicit TTtlSettings(TMode mode, const TVector<TTtlTierSettings>& tiers, ui32 runIntervalSeconds);
     static std::optional<TDuration> GetExpireAfterFrom(const TVector<TTtlTierSettings>& tiers);
 
 private: