Struct ApplicationBootstrapProvider 

pub struct ApplicationBootstrapProvider { /* private fields */ }

Bootstrap provider for application sources that replays stored insert events

Implementations

impl ApplicationBootstrapProvider

pub fn new() -> Self

Create a new provider with its own isolated bootstrap data storage Note: This creates an independent storage that won’t be connected to any ApplicationSource

pub fn with_shared_data(bootstrap_data: Arc<RwLock<Vec<SourceChange>>>) -> Self

Create a new provider with a shared reference to ApplicationSource’s bootstrap data This allows the provider to access the actual data stored by ApplicationSource

pub fn builder() -> ApplicationBootstrapProviderBuilder

Create a builder for ApplicationBootstrapProvider

impl ApplicationBootstrapProvider

pub async fn store_insert_event(&self, change: SourceChange)

Store an insert event for future bootstrap replay This would be called by the application source when it receives insert events

pub async fn get_stored_events(&self) -> Vec<SourceChange>

Get all stored insert events (for testing or inspection)

pub async fn clear_stored_events(&self)

Clear stored events (for testing or reset)

Trait Implementations

impl BootstrapProvider for ApplicationBootstrapProvider

fn bootstrap<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, request: BootstrapRequest, _context: &'life1 BootstrapContext, _event_tx: BootstrapEventSender, _settings: Option<&'life2 SourceSubscriptionSettings>, ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Perform bootstrap operation for the given request Sends bootstrap events to the provided channel Returns the number of elements sent

impl Default for ApplicationBootstrapProvider

fn default() -> Self

Returns the “default value” for a type.