diff --git a/database.hh b/database.hh index 30d3a29cb2..8e7f21ae81 100644 --- a/database.hh +++ b/database.hh @@ -77,6 +77,7 @@ #include #include "tracing/trace_state.hh" #include "db/view/view.hh" +#include "db/view/view_update_backlog.hh" #include "db/view/row_locking.hh" #include "lister.hh" #include "utils/phased_barrier.hh" @@ -1450,6 +1451,10 @@ public: return _querier_cache; } + db::view::update_backlog get_view_update_backlog() const { + return {max_memory_pending_view_updates() - _view_update_concurrency_sem.current(), max_memory_pending_view_updates()}; + } + friend class distributed_loader; };