Struct TestCdcHost 

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

Fields

event_bus: EventBus

catalog: Catalog

clock: Clock

mock: MockClock

Implementations

impl TestCdcHost

pub fn with_clock(initial_nanos: u64) -> Self

pub fn new() -> Self

Trait Implementations

impl CdcHost for TestCdcHost

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

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

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

fn done_until(&self) -> CommitVersion

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

fn catalog(&self) -> &Catalog

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.