pub struct HyperliquidBootstrapProvider { /* private fields */ }Expand description
Bootstrap provider for Hyperliquid market data.
Implementations§
Source§impl HyperliquidBootstrapProvider
impl HyperliquidBootstrapProvider
pub fn new(config: HyperliquidSourceConfig) -> Self
Sourcepub fn with_stream_state(
config: HyperliquidSourceConfig,
stream_initialized: Arc<RwLock<InitializedEntities>>,
) -> Self
pub fn with_stream_state( config: HyperliquidSourceConfig, stream_initialized: Arc<RwLock<InitializedEntities>>, ) -> Self
Create a bootstrap provider that shares initialized-entity tracking with the streaming layer so that singletons bootstrapped as Inserts are subsequently emitted as Updates (not duplicate Inserts) by the stream.
Trait Implementations§
Source§impl BootstrapProvider for HyperliquidBootstrapProvider
impl BootstrapProvider for HyperliquidBootstrapProvider
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 HyperliquidBootstrapProvider
impl !UnwindSafe for HyperliquidBootstrapProvider
impl Freeze for HyperliquidBootstrapProvider
impl Send for HyperliquidBootstrapProvider
impl Sync for HyperliquidBootstrapProvider
impl Unpin for HyperliquidBootstrapProvider
impl UnsafeUnpin for HyperliquidBootstrapProvider
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