Struct PlatformBootstrapProvider 

pub struct PlatformBootstrapProvider { /* private fields */ }

Platform bootstrap provider that connects to Query API service

Implementations

impl PlatformBootstrapProvider

pub fn new(config: PlatformBootstrapConfig) -> Result<Self>

Create a new platform bootstrap provider from configuration

Arguments

• config - Platform bootstrap configuration

Returns

Returns a new instance of PlatformBootstrapProvider or an error if configuration is invalid

pub fn with_url( query_api_url: impl Into<String>, timeout_seconds: u64, ) -> Result<Self>

Create a new platform bootstrap provider with explicit parameters

Arguments

• query_api_url - Base URL of the Query API service (e.g., “http://my-source-query-api:8080”)
• timeout_seconds - Timeout for HTTP requests in seconds

Returns

Returns a new instance of PlatformBootstrapProvider or an error if the URL is invalid

pub fn builder() -> PlatformBootstrapProviderBuilder

Create a builder for PlatformBootstrapProvider

Trait Implementations

impl BootstrapProvider for PlatformBootstrapProvider

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