1pub mod engine_journal;
2pub mod engine_journal_batcher;
3
4pub use engine_journal::{
5 EngineJournalError, EngineJournalWriter, EventPersistenceMode, InMemoryJournalWriter,
6 JournalAppendResult, JournalCommandSummary, JournalEventRecord, JournalFullRecord,
7 JournalWriter, SharedEngineJournalWriter,
8};
9pub use engine_journal_batcher::{
10 EngineJournalBatcher, EventPayload, JournalBatchSender, JournalBatcherConfig, JournalEntry,
11 JournalFillSideEffect, JournalMessage,
12};
13
14pub fn mock_journal_backends() -> (
15 Option<SharedEngineJournalWriter>,
16 Option<JournalBatchSender>,
17) {
18 let mock_writer =
19 std::sync::Arc::new(InMemoryJournalWriter::new()) as SharedEngineJournalWriter;
20 (Some(mock_writer), None)
21}