pub struct HttpBootstrapProvider { /* private fields */ }Expand description
HTTP Bootstrap Provider that fetches data from REST APIs.
Implementations§
Source§impl HttpBootstrapProvider
impl HttpBootstrapProvider
Sourcepub fn new(config: HttpBootstrapConfig) -> Result<Self>
pub fn new(config: HttpBootstrapConfig) -> Result<Self>
Create a new HTTP bootstrap provider from configuration.
Trait Implementations§
Source§impl BootstrapProvider for HttpBootstrapProvider
impl BootstrapProvider for HttpBootstrapProvider
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<BootstrapResult>> + 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<BootstrapResult>> + 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 a [
BootstrapResult] carrying the event count and handover metadata. Read moreAuto Trait Implementations§
impl !RefUnwindSafe for HttpBootstrapProvider
impl !UnwindSafe for HttpBootstrapProvider
impl Freeze for HttpBootstrapProvider
impl Send for HttpBootstrapProvider
impl Sync for HttpBootstrapProvider
impl Unpin for HttpBootstrapProvider
impl UnsafeUnpin for HttpBootstrapProvider
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