r/consensus: expose learner start offset from consensus

Signed-off-by: Michal Maslanka <michal@redpanda.com>
mmaslankaprv · Oct 3, 2023 · 65d9655 · 65d9655
1 parent b29235a
commit 65d9655
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/src/v/raft/consensus.cc b/src/v/raft/consensus.cc
@@ -3846,4 +3846,13 @@ void consensus::upsert_recovery_state(
     }
 }
 
+std::optional<model::offset> consensus::get_learner_start_offset() const {
+    const auto& latest_cfg = _configuration_manager.get_latest();
+
+    if (latest_cfg.get_configuration_update()) {
+        return latest_cfg.get_configuration_update()->learner_start_offset;
+    }
+    return std::nullopt;
+}
+
 } // namespace raft
diff --git a/src/v/raft/consensus.h b/src/v/raft/consensus.h
@@ -752,6 +752,8 @@ class consensus {
       model::offset leader_last_offset,
       bool already_recovering);
 
+    std::optional<model::offset> get_learner_start_offset() const;
+
     bool use_serde_configuration() const {
         return _features.is_active(features::feature::raft_config_serde);
     }