pub struct ScriptFileBootstrapProvider { /* private fields */ }Expand description
Bootstrap provider that reads data from JSONL script files
Implementations§
Source§impl ScriptFileBootstrapProvider
impl ScriptFileBootstrapProvider
Sourcepub fn new(config: ScriptFileBootstrapConfig) -> Self
pub fn new(config: ScriptFileBootstrapConfig) -> Self
Create a new script file bootstrap provider from configuration
§Arguments
config- ScriptFile bootstrap configuration
Sourcepub fn with_paths(file_paths: Vec<String>) -> Self
pub fn with_paths(file_paths: Vec<String>) -> Self
Create a new script file bootstrap provider with explicit file paths
§Arguments
file_paths- List of JSONL file paths to read in order
Sourcepub fn builder() -> ScriptFileBootstrapProviderBuilder
pub fn builder() -> ScriptFileBootstrapProviderBuilder
Create a builder for ScriptFileBootstrapProvider
Trait Implementations§
Source§impl BootstrapProvider for ScriptFileBootstrapProvider
impl BootstrapProvider for ScriptFileBootstrapProvider
Source§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,
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 Read more
Source§impl Default for ScriptFileBootstrapProvider
impl Default for ScriptFileBootstrapProvider
Source§fn default() -> ScriptFileBootstrapProvider
fn default() -> ScriptFileBootstrapProvider
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for ScriptFileBootstrapProvider
impl RefUnwindSafe for ScriptFileBootstrapProvider
impl Send for ScriptFileBootstrapProvider
impl Sync for ScriptFileBootstrapProvider
impl Unpin for ScriptFileBootstrapProvider
impl UnsafeUnpin for ScriptFileBootstrapProvider
impl UnwindSafe for ScriptFileBootstrapProvider
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more