Skip to content

Commit bdd937d

Browse files
committed
Add durable_tx_offset getter to module host
1 parent 01acbe4 commit bdd937d

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

crates/core/src/host/module_host.rs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@ use spacetimedb_data_structures::map::{HashCollectionExt as _, IntMap};
3232
use spacetimedb_datastore::execution_context::{ExecutionContext, ReducerContext, Workload, WorkloadType};
3333
use spacetimedb_datastore::locking_tx_datastore::MutTxId;
3434
use spacetimedb_datastore::traits::{IsolationLevel, Program, TxData};
35+
use spacetimedb_durability::DurableOffset;
3536
use spacetimedb_execution::pipelined::PipelinedProject;
3637
use spacetimedb_lib::db::raw_def::v9::Lifecycle;
3738
use spacetimedb_lib::identity::{AuthCtx, RequestId};
@@ -1230,6 +1231,10 @@ impl ModuleHost {
12301231
&self.replica_ctx().database
12311232
}
12321233

1234+
pub fn durable_tx_offset(&self) -> Option<DurableOffset> {
1235+
self.replica_ctx().relational_db.durable_tx_offset()
1236+
}
1237+
12331238
pub(crate) fn replica_ctx(&self) -> &ReplicaContext {
12341239
self.module.replica_ctx()
12351240
}

0 commit comments

Comments
 (0)