Struct TestCdcHost 

pub struct TestCdcHost {
    pub event_bus: EventBus,
    pub materialized_catalog: MaterializedCatalog,
    pub clock: Clock,
    pub mock: MockClock,
    /* private fields */
}

In-memory CdcHost for tests. Owns its own MaterializedCatalog, EventBus and a Clock::Mock (cloned MockClock accessible via the public mock field).

Fields

event_bus: EventBus

materialized_catalog: MaterializedCatalog

clock: Clock

mock: MockClock

Implementations

impl TestCdcHost

pub fn with_clock(initial_nanos: u64) -> Self

Build a fresh host with the mock clock initialised to initial_nanos.

pub fn new() -> Self

Build a host with the mock clock initialized to 1 s past the epoch.

Trait Implementations

impl CdcHost for TestCdcHost

fn begin_command(&self) -> Result<CommandTransaction>

Begin a new command transaction.

fn begin_query(&self) -> Result<QueryTransaction>

Begin a new read-only query transaction.

fn current_version(&self) -> Result<CommitVersion>

Get the current committed version.

fn done_until(&self) -> CommitVersion

Get the version up to which all transactions are complete.

fn wait_for_mark_timeout( &self, _version: CommitVersion, _timeout: Duration, ) -> bool

Wait for the watermark to reach the specified version. Returns true if the version was reached, false if timeout.

fn materialized_catalog(&self) -> &MaterializedCatalog

Get the materialized catalog for fingerprint-based shape lookup.

impl Clone for TestCdcHost

fn clone(&self) -> TestCdcHost

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for TestCdcHost

fn default() -> Self

Returns the “default value” for a type.