Rindle docs and package mapSkip to main content

FanoutGate

Trait FanoutGate 

Source
pub trait FanoutGate {
    // Required methods
    fn commit(self: Box<Self>);
    fn abort(self: Box<Self>);
}
Expand description

The commit verdict for an in-flight fan-out, released after the writer’s durable COMMIT (or its failure).

Required Methods§

Source

fn commit(self: Box<Self>)

The COMMIT succeeded: the observer publishes what it derived.

Source

fn abort(self: Box<Self>)

The COMMIT failed (or never ran): the observer discards / recovers.

Implementors§