Struct IntentSupervisor 

pub struct IntentSupervisor { /* private fields */ }

Starts synchronization intents and restarts failed intents with bounded exponential backoff.

Implementations

impl IntentSupervisor

pub const fn new( max_retries: u32, backoff_base: Duration, backoff_max: Duration, ) -> Self

pub async fn run_intent( &self, sync: &SyncEngine, namespace: NamespaceId, params: SubscribeParams, ) -> SupervisedIntent

Start one continuous intent and record any startup failure.

pub async fn run_intent_with_filter( &self, sync: &SyncEngine, namespace: NamespaceId, params: SubscribeParams, filter_engine: Option<FilterEngine>, ) -> SupervisedIntent

Start one filtered synchronization intent.

pub async fn supervise( &self, sync: &SyncEngine, namespace: NamespaceId, params: SubscribeParams, shutdown: Receiver<()>, ) -> Result<SupervisedIntent>

Supervise one intent until shutdown or until its retry budget is spent.

A normal Finished or Cancelled event ends supervision. A Failed event, an unexpectedly closed stream, or a startup error consumes one retry and restarts the intent after backoff.

Errors

Returns an error if supervision infrastructure fails while waiting for shutdown or retrying an intent.

pub async fn supervise_with_controls( &self, sync: &SyncEngine, namespace: NamespaceId, params: SubscribeParams, shutdown: Receiver<()>, controls: Arc<Mutex<HashMap<NamespaceId, IntentControl>>>, filter: Option<FilterEngine>, ) -> Result<SupervisedIntent>

Supervise an intent while exposing pause/resume controls to its owner.

Errors

Returns an error if the shared control registry is poisoned or the intent supervision infrastructure cannot wait for shutdown.

pub fn backoff_delay(&self, retry_number: u32) -> Duration

Return the delay for a one-based retry number.

Trait Implementations

impl Clone for IntentSupervisor

fn clone(&self) -> IntentSupervisor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for IntentSupervisor

impl Debug for IntentSupervisor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.