Struct streamlette::Decider

pub struct Decider { /* private fields */ }

Encapsulates a single instance of Streamlette, that eventually comes to consensus on a single decision.

Implementations

impl Decider

pub fn new(config: impl DeciderConfig) -> Self

Creates a new Decider.

pub fn debug_graphviz(&self) -> String

Prints the graphivz representation of everything we have now.

pub fn pre_tick(&mut self) -> Option<Bytes>

Runs the first half of the tick of the Decider. If the decision has been made, return it.

Does no I/O. Either use Decider::tick_to_end, or call the Decider::sync_state method periodically.

pub fn post_tick(&mut self) -> Option<Bytes>

Runs the first half of the tick of the Decider. If the decision has been made, return it.

Does no I/O. Either use Decider::tick_to_end, or call the Decider::sync_state method periodically.

pub async fn sync_state(&mut self, timeout: Option<Duration>)

Synchronized state, given a timeout.

pub async fn tick_to_end(&mut self) -> Bytes

Ticks this decider until the decision has been made. We use a gradually increasing synchronization interval.

If liveness is required, it is generally not okay to drop the Decider after this function returns. Otherwise, some participants’ tick_to_end may not return. Instead, the decider should be kept running (by calling sync_state) until you’re sure everyone has gotten the message.