diff --git a/nightly/.doctrees/api_reference/accounting.doctree b/nightly/.doctrees/api_reference/accounting.doctree index 63cdc2bbb872..0e5a3384a8c8 100644 Binary files a/nightly/.doctrees/api_reference/accounting.doctree and b/nightly/.doctrees/api_reference/accounting.doctree differ diff --git a/nightly/.doctrees/api_reference/adapters/betfair.doctree b/nightly/.doctrees/api_reference/adapters/betfair.doctree index 4600b8ade94d..06c2400056a9 100644 Binary files a/nightly/.doctrees/api_reference/adapters/betfair.doctree and b/nightly/.doctrees/api_reference/adapters/betfair.doctree differ diff --git a/nightly/.doctrees/api_reference/adapters/binance.doctree b/nightly/.doctrees/api_reference/adapters/binance.doctree index ee0ecab50378..df2688b08ac8 100644 Binary files a/nightly/.doctrees/api_reference/adapters/binance.doctree and b/nightly/.doctrees/api_reference/adapters/binance.doctree differ diff --git a/nightly/.doctrees/api_reference/adapters/interactive_brokers.doctree b/nightly/.doctrees/api_reference/adapters/interactive_brokers.doctree index 4b4db7735e44..e344b4108df6 100644 Binary files a/nightly/.doctrees/api_reference/adapters/interactive_brokers.doctree and b/nightly/.doctrees/api_reference/adapters/interactive_brokers.doctree differ diff --git a/nightly/.doctrees/api_reference/analysis.doctree b/nightly/.doctrees/api_reference/analysis.doctree index 3cb9d269a8d5..3b130a43823a 100644 Binary files a/nightly/.doctrees/api_reference/analysis.doctree and b/nightly/.doctrees/api_reference/analysis.doctree differ diff --git a/nightly/.doctrees/api_reference/backtest.doctree b/nightly/.doctrees/api_reference/backtest.doctree index 2d0414734c4a..db3f3453a3db 100644 Binary files a/nightly/.doctrees/api_reference/backtest.doctree and b/nightly/.doctrees/api_reference/backtest.doctree differ diff --git a/nightly/.doctrees/api_reference/cache.doctree b/nightly/.doctrees/api_reference/cache.doctree index 08c391578fa9..3de78b59b7b2 100644 Binary files a/nightly/.doctrees/api_reference/cache.doctree and b/nightly/.doctrees/api_reference/cache.doctree differ diff --git a/nightly/.doctrees/api_reference/common.doctree b/nightly/.doctrees/api_reference/common.doctree index 4239823d1f4f..3aecdf13f473 100644 Binary files a/nightly/.doctrees/api_reference/common.doctree and b/nightly/.doctrees/api_reference/common.doctree differ diff --git a/nightly/.doctrees/api_reference/config.doctree b/nightly/.doctrees/api_reference/config.doctree index 6684a7138e10..fe3acc629892 100644 Binary files a/nightly/.doctrees/api_reference/config.doctree and b/nightly/.doctrees/api_reference/config.doctree differ diff --git a/nightly/.doctrees/api_reference/core.doctree b/nightly/.doctrees/api_reference/core.doctree index 6bb3623804b0..8eb784bb4398 100644 Binary files a/nightly/.doctrees/api_reference/core.doctree and b/nightly/.doctrees/api_reference/core.doctree differ diff --git a/nightly/.doctrees/api_reference/data.doctree b/nightly/.doctrees/api_reference/data.doctree index 84a6e7a5c4d7..5a707478cc5c 100644 Binary files a/nightly/.doctrees/api_reference/data.doctree and b/nightly/.doctrees/api_reference/data.doctree differ diff --git a/nightly/.doctrees/api_reference/execution.doctree b/nightly/.doctrees/api_reference/execution.doctree index 0181d7381cef..22e1d34dfa8e 100644 Binary files a/nightly/.doctrees/api_reference/execution.doctree and b/nightly/.doctrees/api_reference/execution.doctree differ diff --git a/nightly/.doctrees/api_reference/indicators.doctree b/nightly/.doctrees/api_reference/indicators.doctree index cda7d19d9cbd..38febf14aae2 100644 Binary files a/nightly/.doctrees/api_reference/indicators.doctree and b/nightly/.doctrees/api_reference/indicators.doctree differ diff --git a/nightly/.doctrees/api_reference/live.doctree b/nightly/.doctrees/api_reference/live.doctree index 1454e978afef..18298a85f782 100644 Binary files a/nightly/.doctrees/api_reference/live.doctree and b/nightly/.doctrees/api_reference/live.doctree differ diff --git a/nightly/.doctrees/api_reference/model/book.doctree b/nightly/.doctrees/api_reference/model/book.doctree index 38a83d83a779..0530289122da 100644 Binary files a/nightly/.doctrees/api_reference/model/book.doctree and b/nightly/.doctrees/api_reference/model/book.doctree differ diff --git a/nightly/.doctrees/api_reference/model/data.doctree b/nightly/.doctrees/api_reference/model/data.doctree index acab29d9ceff..8ff9578a18ff 100644 Binary files a/nightly/.doctrees/api_reference/model/data.doctree and b/nightly/.doctrees/api_reference/model/data.doctree differ diff --git a/nightly/.doctrees/api_reference/model/events.doctree b/nightly/.doctrees/api_reference/model/events.doctree index ce801ce4ec4e..3221f3660185 100644 Binary files a/nightly/.doctrees/api_reference/model/events.doctree and b/nightly/.doctrees/api_reference/model/events.doctree differ diff --git a/nightly/.doctrees/api_reference/model/identifiers.doctree b/nightly/.doctrees/api_reference/model/identifiers.doctree index ae59fd6e75ba..ae8b0c5e1099 100644 Binary files a/nightly/.doctrees/api_reference/model/identifiers.doctree and b/nightly/.doctrees/api_reference/model/identifiers.doctree differ diff --git a/nightly/.doctrees/api_reference/model/instruments.doctree b/nightly/.doctrees/api_reference/model/instruments.doctree index d4800d3ca45c..8b33ac2f59f4 100644 Binary files a/nightly/.doctrees/api_reference/model/instruments.doctree and b/nightly/.doctrees/api_reference/model/instruments.doctree differ diff --git a/nightly/.doctrees/api_reference/model/objects.doctree b/nightly/.doctrees/api_reference/model/objects.doctree index 49cf949033bd..c05f2b16c3a5 100644 Binary files a/nightly/.doctrees/api_reference/model/objects.doctree and b/nightly/.doctrees/api_reference/model/objects.doctree differ diff --git a/nightly/.doctrees/api_reference/model/orders.doctree b/nightly/.doctrees/api_reference/model/orders.doctree index 88c7931de2aa..cbbbc02ca580 100644 Binary files a/nightly/.doctrees/api_reference/model/orders.doctree and b/nightly/.doctrees/api_reference/model/orders.doctree differ diff --git a/nightly/.doctrees/api_reference/model/position.doctree b/nightly/.doctrees/api_reference/model/position.doctree index a1d3de353452..30574b04bd72 100644 Binary files a/nightly/.doctrees/api_reference/model/position.doctree and b/nightly/.doctrees/api_reference/model/position.doctree differ diff --git a/nightly/.doctrees/api_reference/model/tick_scheme.doctree b/nightly/.doctrees/api_reference/model/tick_scheme.doctree index b34be7f08957..37cf4ad4f941 100644 Binary files a/nightly/.doctrees/api_reference/model/tick_scheme.doctree and b/nightly/.doctrees/api_reference/model/tick_scheme.doctree differ diff --git a/nightly/.doctrees/api_reference/persistence.doctree b/nightly/.doctrees/api_reference/persistence.doctree index 1c6e19ef4394..24f060ef0932 100644 Binary files a/nightly/.doctrees/api_reference/persistence.doctree and b/nightly/.doctrees/api_reference/persistence.doctree differ diff --git a/nightly/.doctrees/api_reference/portfolio.doctree b/nightly/.doctrees/api_reference/portfolio.doctree index 667be3c5b87b..83faa3313314 100644 Binary files a/nightly/.doctrees/api_reference/portfolio.doctree and b/nightly/.doctrees/api_reference/portfolio.doctree differ diff --git a/nightly/.doctrees/api_reference/risk.doctree b/nightly/.doctrees/api_reference/risk.doctree index 1a8c461e69df..c3ab19ceac9b 100644 Binary files a/nightly/.doctrees/api_reference/risk.doctree and b/nightly/.doctrees/api_reference/risk.doctree differ diff --git a/nightly/.doctrees/api_reference/serialization.doctree b/nightly/.doctrees/api_reference/serialization.doctree index f976ecd5bb84..b0278381f295 100644 Binary files a/nightly/.doctrees/api_reference/serialization.doctree and b/nightly/.doctrees/api_reference/serialization.doctree differ diff --git a/nightly/.doctrees/api_reference/system.doctree b/nightly/.doctrees/api_reference/system.doctree index 88ff5dd9784d..78e464dd3b18 100644 Binary files a/nightly/.doctrees/api_reference/system.doctree and b/nightly/.doctrees/api_reference/system.doctree differ diff --git a/nightly/.doctrees/api_reference/trading.doctree b/nightly/.doctrees/api_reference/trading.doctree index 6f7aaff6fe40..676695fbfc41 100644 Binary files a/nightly/.doctrees/api_reference/trading.doctree and b/nightly/.doctrees/api_reference/trading.doctree differ diff --git a/nightly/.doctrees/environment.pickle b/nightly/.doctrees/environment.pickle index 54b964d38e72..a3182a5ed65f 100644 Binary files a/nightly/.doctrees/environment.pickle and b/nightly/.doctrees/environment.pickle differ diff --git a/nightly/api_reference/adapters/interactive_brokers.html b/nightly/api_reference/adapters/interactive_brokers.html index 5bf591795605..d89b52c14a65 100644 --- a/nightly/api_reference/adapters/interactive_brokers.html +++ b/nightly/api_reference/adapters/interactive_brokers.html @@ -11860,7 +11860,7 @@

at - 0x7f2a2ad11890> + 0x7fc90a35ebd0> = diff --git a/nightly/api_reference/config.html b/nightly/api_reference/config.html index 86f724c5acba..e34aeb04d520 100644 --- a/nightly/api_reference/config.html +++ b/nightly/api_reference/config.html @@ -5494,7 +5494,7 @@

default True - ) – If a ‘trader-’ prefix is applied to keys. + ) – If a ‘trader-’ prefix is used for keys.

  • @@ -5512,7 +5512,7 @@

    default False - ) – If the traders instance ID should be used for keys. + ) – If the traders instance ID is used for keys.

  • @@ -6254,7 +6254,7 @@

    - stream + use_trader_prefix @@ -6266,19 +6266,41 @@

    - str + bool - + + + + + + = - - - | - + + + + + + True - + + + , + + + + use_trader_id + + - None + : + + + + + + + bool @@ -6292,7 +6314,7 @@

    - None + True @@ -6331,6 +6353,40 @@

    , + + + + streams_prefix + + + + + : + + + + + + + str + + + + + + + = + + + + + + + 'streams' + + + + , @@ -6550,23 +6606,37 @@

  • - stream + use_trader_prefix ( - str + bool , - optional + default True - ) – The additional prefix for externally published stream names (must have a - - database - - config). + ) – If a ‘trader-’ prefix is used for stream names. +

    +
    • +
  • +

    + + use_trader_id + + ( + + bool + + + , + + + default True + + ) – If the traders ID is used for stream names.

  • @@ -6584,7 +6654,43 @@

    default False - ) – If the traders instance ID should be used in stream names. + ) – If the traders instance ID is used for stream names. +

    +

    • +
  • +

    + + streams_prefix + + ( + + str + + + , + + + default 'streams' + + ) – The prefix for externally published stream names (must have a + + database + + config). +If + + use_trader_id + + and + + use_instance_id + + are + + both + + false, then it becomes possible for +many traders to be configured to write to the same streams.

  • diff --git a/nightly/core/drop_db/all.html b/nightly/core/drop_db/all.html index 1f14d75215b7..0c6873e7345e 100644 --- a/nightly/core/drop_db/all.html +++ b/nightly/core/drop_db/all.html @@ -1,2 +1,2 @@ -List of all items in this crate
    +List of all items in this crate

    List of all items

    Functions

    \ No newline at end of file diff --git a/nightly/core/drop_db/fn.main.html b/nightly/core/drop_db/fn.main.html index 0092bbad3219..17e2c4f95b7d 100644 --- a/nightly/core/drop_db/fn.main.html +++ b/nightly/core/drop_db/fn.main.html @@ -1,2 +1,2 @@ -main in drop_db - Rust
    +main in drop_db - Rust

    Function drop_db::main

    source · 
    pub(crate) fn main() -> Result<(), Box<dyn Error>>
    \ No newline at end of file diff --git a/nightly/core/drop_db/index.html b/nightly/core/drop_db/index.html index a61880345b1f..826c52090efd 100644 --- a/nightly/core/drop_db/index.html +++ b/nightly/core/drop_db/index.html @@ -1,3 +1,3 @@ -drop_db - Rust

    • source§

    fn multiunzip( self ) -> (FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI, FromJ, FromK)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF, G, FromG, H, FromH, I, FromI, J, FromJ, K, FromK> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI, FromJ, FromK)> for IT
    where IT: Iterator<Item = (A, B, C, D, E, F, G, H, I, J, K)>, @@ -1170,7 +1170,7 @@ FromH: Default + Extend<H>, FromI: Default + Extend<I>, FromJ: Default + Extend<J>, - FromK: Default + Extend<K>,

    source§

    fn multiunzip( + FromK: Default + Extend<K>,

    source§

    fn multiunzip( self ) -> (FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI, FromJ, FromK)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF, G, FromG, H, FromH, I, FromI, J, FromJ, K, FromK, L, FromL> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI, FromJ, FromK, FromL)> for IT
    where IT: Iterator<Item = (A, B, C, D, E, F, G, H, I, J, K, L)>, @@ -1185,7 +1185,7 @@ FromI: Default + Extend<I>, FromJ: Default + Extend<J>, FromK: Default + Extend<K>, - FromL: Default + Extend<L>,

    source§

    fn multiunzip( + FromL: Default + Extend<L>,

    source§

    fn multiunzip( self ) -> (FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI, FromJ, FromK, FromL)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF, G, FromG, H, FromH, I, FromI, J, FromJ, K, FromK, L, FromL> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI, FromJ, FromK, FromL)> for IT
    where IT: Iterator<Item = (A, B, C, D, E, F, G, H, I, J, K, L)>, @@ -1200,7 +1200,7 @@ FromI: Default + Extend<I>, FromJ: Default + Extend<J>, FromK: Default + Extend<K>, - FromL: Default + Extend<L>,

    source§

    fn multiunzip( + FromL: Default + Extend<L>,

    source§

    fn multiunzip( self ) -> (FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI, FromJ, FromK, FromL)

    Unzip this iterator into multiple collections.
    source§

    impl<T> Same for T

    §

    type Output = T

    Should always be Self
    source§

    impl<T, U> TryFrom<U> for T
    where U: Into<T>,

    §

    type Error = Infallible

    The type returned in the event of a conversion error.
    source§

    fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

    Performs the conversion.
    source§

    impl<T, U> TryInto<U> for T
    where diff --git a/nightly/core/nautilus_persistence/backend/kmerge_batch/struct.ElementBatchIter.html b/nightly/core/nautilus_persistence/backend/kmerge_batch/struct.ElementBatchIter.html index c378f5ae1b48..278245f1b483 100644 --- a/nightly/core/nautilus_persistence/backend/kmerge_batch/struct.ElementBatchIter.html +++ b/nightly/core/nautilus_persistence/backend/kmerge_batch/struct.ElementBatchIter.html @@ -1,4 +1,4 @@ -ElementBatchIter in nautilus_persistence::backend::kmerge_batch - Rust
    +ElementBatchIter in nautilus_persistence::backend::kmerge_batch - Rust

    Struct nautilus_persistence::backend::kmerge_batch::ElementBatchIter

    source · 
    pub struct ElementBatchIter<I, T>
    where
     I: Iterator<Item = IntoIter<T>>,
    {
     pub item: T,
diff --git a/nightly/core/nautilus_persistence/backend/kmerge_batch/struct.KMerge.html b/nightly/core/nautilus_persistence/backend/kmerge_batch/struct.KMerge.html
index 04f702da560a..796af51135b8 100644
--- a/nightly/core/nautilus_persistence/backend/kmerge_batch/struct.KMerge.html
+++ b/nightly/core/nautilus_persistence/backend/kmerge_batch/struct.KMerge.html
@@ -1,4 +1,4 @@
-KMerge in nautilus_persistence::backend::kmerge_batch - Rust
    
+KMerge in nautilus_persistence::backend::kmerge_batch - Rust
    
     
    Struct nautilus_persistence::backend::kmerge_batch::KMerge
    source · 
    pub struct KMerge<I, T, C>
    where
     I: Iterator<Item = IntoIter<T>>,
    { /* private fields */ }
    Implementations§
    source§
    impl<I, T, C> KMerge<I, T, C>
    where
     I: Iterator<Item = IntoIter<T>>,
@@ -620,7 +620,7 @@
     F: FnMut(Self::Item) -> K,
    Collect the items in this iterator and return a HashMap which
 contains each item that appears in the iterator and the number
 of times it appears,
-determining identity using a keying function. Read more
    source§
    fn multiunzip<FromI>(self) -> FromI
    where
+determining identity using a keying function. Read more
    source§
    fn multiunzip<FromI>(self) -> FromI
    where
     Self: Sized + MultiUnzip<FromI>,
    Converts an iterator of tuples into a tuple of containers. Read more

    source§

    impl<T> Itertools for T
    where T: Iterator + ?Sized,

    source§

    fn interleave<J>( self, @@ -1021,62 +1021,62 @@ determining identity using a keying function. Read more

    source§

    fn multiunzip<FromI>(self) -> FromI
    where Self: Sized + MultiUnzip<FromI>,

    Converts an iterator of tuples into a tuple of containers. Read more
    source§

    fn try_len(&self) -> Result<usize, (usize, Option<usize>)>

    Returns the length of the iterator if one exists. Otherwise return self.size_hint(). Read more
    source§

    impl<IT> MultiUnzip<()> for IT
    where - IT: Iterator<Item = ()>,

    source§

    fn multiunzip(self)

    Unzip this iterator into multiple collections.
    source§

    impl<IT> MultiUnzip<()> for IT
    where - IT: Iterator<Item = ()>,

    source§

    fn multiunzip(self)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA> MultiUnzip<(FromA,)> for IT
    where + IT: Iterator<Item = ()>,

    source§

    fn multiunzip(self)

    Unzip this iterator into multiple collections.
    source§

    impl<IT> MultiUnzip<()> for IT
    where + IT: Iterator<Item = ()>,

    source§

    fn multiunzip(self)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA> MultiUnzip<(FromA,)> for IT
    where IT: Iterator<Item = (A,)>, - FromA: Default + Extend<A>,

    source§

    fn multiunzip(self) -> (FromA,)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA> MultiUnzip<(FromA,)> for IT
    where + FromA: Default + Extend<A>,

    source§

    fn multiunzip(self) -> (FromA,)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA> MultiUnzip<(FromA,)> for IT
    where IT: Iterator<Item = (A,)>, - FromA: Default + Extend<A>,

    source§

    fn multiunzip(self) -> (FromA,)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB> MultiUnzip<(FromA, FromB)> for IT
    where + FromA: Default + Extend<A>,

    source§

    fn multiunzip(self) -> (FromA,)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB> MultiUnzip<(FromA, FromB)> for IT
    where IT: Iterator<Item = (A, B)>, FromA: Default + Extend<A>, - FromB: Default + Extend<B>,

    source§

    fn multiunzip(self) -> (FromA, FromB)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB> MultiUnzip<(FromA, FromB)> for IT
    where + FromB: Default + Extend<B>,

    source§

    fn multiunzip(self) -> (FromA, FromB)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB> MultiUnzip<(FromA, FromB)> for IT
    where IT: Iterator<Item = (A, B)>, FromA: Default + Extend<A>, - FromB: Default + Extend<B>,

    source§

    fn multiunzip(self) -> (FromA, FromB)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC> MultiUnzip<(FromA, FromB, FromC)> for IT
    where + FromB: Default + Extend<B>,

    source§

    fn multiunzip(self) -> (FromA, FromB)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC> MultiUnzip<(FromA, FromB, FromC)> for IT
    where IT: Iterator<Item = (A, B, C)>, FromA: Default + Extend<A>, FromB: Default + Extend<B>, - FromC: Default + Extend<C>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC> MultiUnzip<(FromA, FromB, FromC)> for IT
    where + FromC: Default + Extend<C>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC> MultiUnzip<(FromA, FromB, FromC)> for IT
    where IT: Iterator<Item = (A, B, C)>, FromA: Default + Extend<A>, FromB: Default + Extend<B>, - FromC: Default + Extend<C>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD> MultiUnzip<(FromA, FromB, FromC, FromD)> for IT
    where + FromC: Default + Extend<C>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD> MultiUnzip<(FromA, FromB, FromC, FromD)> for IT
    where IT: Iterator<Item = (A, B, C, D)>, FromA: Default + Extend<A>, FromB: Default + Extend<B>, FromC: Default + Extend<C>, - FromD: Default + Extend<D>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC, FromD)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD> MultiUnzip<(FromA, FromB, FromC, FromD)> for IT
    where + FromD: Default + Extend<D>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC, FromD)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD> MultiUnzip<(FromA, FromB, FromC, FromD)> for IT
    where IT: Iterator<Item = (A, B, C, D)>, FromA: Default + Extend<A>, FromB: Default + Extend<B>, FromC: Default + Extend<C>, - FromD: Default + Extend<D>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC, FromD)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE> MultiUnzip<(FromA, FromB, FromC, FromD, FromE)> for IT
    where + FromD: Default + Extend<D>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC, FromD)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE> MultiUnzip<(FromA, FromB, FromC, FromD, FromE)> for IT
    where IT: Iterator<Item = (A, B, C, D, E)>, FromA: Default + Extend<A>, FromB: Default + Extend<B>, FromC: Default + Extend<C>, FromD: Default + Extend<D>, - FromE: Default + Extend<E>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC, FromD, FromE)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE> MultiUnzip<(FromA, FromB, FromC, FromD, FromE)> for IT
    where + FromE: Default + Extend<E>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC, FromD, FromE)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE> MultiUnzip<(FromA, FromB, FromC, FromD, FromE)> for IT
    where IT: Iterator<Item = (A, B, C, D, E)>, FromA: Default + Extend<A>, FromB: Default + Extend<B>, FromC: Default + Extend<C>, FromD: Default + Extend<D>, - FromE: Default + Extend<E>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC, FromD, FromE)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF)> for IT
    where + FromE: Default + Extend<E>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC, FromD, FromE)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF)> for IT
    where IT: Iterator<Item = (A, B, C, D, E, F)>, FromA: Default + Extend<A>, FromB: Default + Extend<B>, FromC: Default + Extend<C>, FromD: Default + Extend<D>, FromE: Default + Extend<E>, - FromF: Default + Extend<F>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC, FromD, FromE, FromF)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF)> for IT
    where + FromF: Default + Extend<F>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC, FromD, FromE, FromF)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF)> for IT
    where IT: Iterator<Item = (A, B, C, D, E, F)>, FromA: Default + Extend<A>, FromB: Default + Extend<B>, FromC: Default + Extend<C>, FromD: Default + Extend<D>, FromE: Default + Extend<E>, - FromF: Default + Extend<F>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC, FromD, FromE, FromF)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF, G, FromG> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF, FromG)> for IT
    where + FromF: Default + Extend<F>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC, FromD, FromE, FromF)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF, G, FromG> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF, FromG)> for IT
    where IT: Iterator<Item = (A, B, C, D, E, F, G)>, FromA: Default + Extend<A>, FromB: Default + Extend<B>, @@ -1084,7 +1084,7 @@ FromD: Default + Extend<D>, FromE: Default + Extend<E>, FromF: Default + Extend<F>, - FromG: Default + Extend<G>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC, FromD, FromE, FromF, FromG)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF, G, FromG> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF, FromG)> for IT
    where + FromG: Default + Extend<G>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC, FromD, FromE, FromF, FromG)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF, G, FromG> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF, FromG)> for IT
    where IT: Iterator<Item = (A, B, C, D, E, F, G)>, FromA: Default + Extend<A>, FromB: Default + Extend<B>, @@ -1092,7 +1092,7 @@ FromD: Default + Extend<D>, FromE: Default + Extend<E>, FromF: Default + Extend<F>, - FromG: Default + Extend<G>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC, FromD, FromE, FromF, FromG)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF, G, FromG, H, FromH> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH)> for IT
    where + FromG: Default + Extend<G>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC, FromD, FromE, FromF, FromG)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF, G, FromG, H, FromH> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH)> for IT
    where IT: Iterator<Item = (A, B, C, D, E, F, G, H)>, FromA: Default + Extend<A>, FromB: Default + Extend<B>, @@ -1101,7 +1101,7 @@ FromE: Default + Extend<E>, FromF: Default + Extend<F>, FromG: Default + Extend<G>, - FromH: Default + Extend<H>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF, G, FromG, H, FromH> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH)> for IT
    where + FromH: Default + Extend<H>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF, G, FromG, H, FromH> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH)> for IT
    where IT: Iterator<Item = (A, B, C, D, E, F, G, H)>, FromA: Default + Extend<A>, FromB: Default + Extend<B>, @@ -1110,7 +1110,7 @@ FromE: Default + Extend<E>, FromF: Default + Extend<F>, FromG: Default + Extend<G>, - FromH: Default + Extend<H>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF, G, FromG, H, FromH, I, FromI> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI)> for IT
    where + FromH: Default + Extend<H>,

    source§

    fn multiunzip(self) -> (FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF, G, FromG, H, FromH, I, FromI> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI)> for IT
    where IT: Iterator<Item = (A, B, C, D, E, F, G, H, I)>, FromA: Default + Extend<A>, FromB: Default + Extend<B>, @@ -1120,7 +1120,7 @@ FromF: Default + Extend<F>, FromG: Default + Extend<G>, FromH: Default + Extend<H>, - FromI: Default + Extend<I>,

    source§

    fn multiunzip( + FromI: Default + Extend<I>,

    • source§

    fn multiunzip( self ) -> (FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF, G, FromG, H, FromH, I, FromI> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI)> for IT
    where IT: Iterator<Item = (A, B, C, D, E, F, G, H, I)>, @@ -1132,7 +1132,7 @@ FromF: Default + Extend<F>, FromG: Default + Extend<G>, FromH: Default + Extend<H>, - FromI: Default + Extend<I>,

    source§

    fn multiunzip( + FromI: Default + Extend<I>,

    source§

    fn multiunzip( self ) -> (FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF, G, FromG, H, FromH, I, FromI, J, FromJ> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI, FromJ)> for IT
    where IT: Iterator<Item = (A, B, C, D, E, F, G, H, I, J)>, @@ -1145,7 +1145,7 @@ FromG: Default + Extend<G>, FromH: Default + Extend<H>, FromI: Default + Extend<I>, - FromJ: Default + Extend<J>,

    source§

    fn multiunzip( + FromJ: Default + Extend<J>,

    source§

    fn multiunzip( self ) -> (FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI, FromJ)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF, G, FromG, H, FromH, I, FromI, J, FromJ> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI, FromJ)> for IT
    where IT: Iterator<Item = (A, B, C, D, E, F, G, H, I, J)>, @@ -1158,7 +1158,7 @@ FromG: Default + Extend<G>, FromH: Default + Extend<H>, FromI: Default + Extend<I>, - FromJ: Default + Extend<J>,

    source§

    fn multiunzip( + FromJ: Default + Extend<J>,

    source§

    fn multiunzip( self ) -> (FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI, FromJ)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF, G, FromG, H, FromH, I, FromI, J, FromJ, K, FromK> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI, FromJ, FromK)> for IT
    where IT: Iterator<Item = (A, B, C, D, E, F, G, H, I, J, K)>, @@ -1172,7 +1172,7 @@ FromH: Default + Extend<H>, FromI: Default + Extend<I>, FromJ: Default + Extend<J>, - FromK: Default + Extend<K>,

    source§

    fn multiunzip( + FromK: Default + Extend<K>,

    source§

    fn multiunzip( self ) -> (FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI, FromJ, FromK)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF, G, FromG, H, FromH, I, FromI, J, FromJ, K, FromK> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI, FromJ, FromK)> for IT
    where IT: Iterator<Item = (A, B, C, D, E, F, G, H, I, J, K)>, @@ -1186,7 +1186,7 @@ FromH: Default + Extend<H>, FromI: Default + Extend<I>, FromJ: Default + Extend<J>, - FromK: Default + Extend<K>,

    source§

    fn multiunzip( + FromK: Default + Extend<K>,

    source§

    fn multiunzip( self ) -> (FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI, FromJ, FromK)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF, G, FromG, H, FromH, I, FromI, J, FromJ, K, FromK, L, FromL> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI, FromJ, FromK, FromL)> for IT
    where IT: Iterator<Item = (A, B, C, D, E, F, G, H, I, J, K, L)>, @@ -1201,7 +1201,7 @@ FromI: Default + Extend<I>, FromJ: Default + Extend<J>, FromK: Default + Extend<K>, - FromL: Default + Extend<L>,

    source§

    fn multiunzip( + FromL: Default + Extend<L>,

    source§

    fn multiunzip( self ) -> (FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI, FromJ, FromK, FromL)

    Unzip this iterator into multiple collections.
    source§

    impl<IT, A, FromA, B, FromB, C, FromC, D, FromD, E, FromE, F, FromF, G, FromG, H, FromH, I, FromI, J, FromJ, K, FromK, L, FromL> MultiUnzip<(FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI, FromJ, FromK, FromL)> for IT
    where IT: Iterator<Item = (A, B, C, D, E, F, G, H, I, J, K, L)>, @@ -1216,7 +1216,7 @@ FromI: Default + Extend<I>, FromJ: Default + Extend<J>, FromK: Default + Extend<K>, - FromL: Default + Extend<L>,

    source§

    fn multiunzip( + FromL: Default + Extend<L>,

    source§

    fn multiunzip( self ) -> (FromA, FromB, FromC, FromD, FromE, FromF, FromG, FromH, FromI, FromJ, FromK, FromL)

    Unzip this iterator into multiple collections.
    source§

    impl<T> Same for T

    §

    type Output = T

    Should always be Self
    source§

    impl<T, U> TryFrom<U> for T
    where U: Into<T>,

    §

    type Error = Infallible

    The type returned in the event of a conversion error.
    source§

    fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

    Performs the conversion.
    source§

    impl<T, U> TryInto<U> for T
    where diff --git a/nightly/core/nautilus_persistence/backend/session/index.html b/nightly/core/nautilus_persistence/backend/session/index.html index 803ee4eafa99..d7c6dff1c740 100644 --- a/nightly/core/nautilus_persistence/backend/session/index.html +++ b/nightly/core/nautilus_persistence/backend/session/index.html @@ -1,2 +1,2 @@ -nautilus_persistence::backend::session - Rust
    +nautilus_persistence::backend::session - Rust

    Module nautilus_persistence::backend::session

    source ·

    Structs

    Type Aliases

    \ No newline at end of file diff --git a/nightly/core/nautilus_persistence/backend/session/struct.DataBackendSession.html b/nightly/core/nautilus_persistence/backend/session/struct.DataBackendSession.html index f8416cd564e9..a8bae9acfc1b 100644 --- a/nightly/core/nautilus_persistence/backend/session/struct.DataBackendSession.html +++ b/nightly/core/nautilus_persistence/backend/session/struct.DataBackendSession.html @@ -1,4 +1,4 @@ -DataBackendSession in nautilus_persistence::backend::session - Rust
    +DataBackendSession in nautilus_persistence::backend::session - Rust

    Struct nautilus_persistence::backend::session::DataBackendSession

    source · 
    pub struct DataBackendSession {
     pub chunk_size: usize,
     pub runtime: Arc<Runtime>,
@@ -28,7 +28,7 @@ 
    Safety
    
 
    The file data must be ordered by the ts_init in ascending order for this
 to work correctly.

    source

    pub fn get_query_result(&mut self) -> QueryResult

    Trait Implementations§

    source§

    impl IntoPy<Py<PyAny>> for DataBackendSession

    source§

    fn into_py(self, py: Python<'_>) -> PyObject

    Performs the conversion.
    source§

    impl PyClass for DataBackendSession

    §

    type Frozen = False

    Whether the pyclass is frozen. Read more
    source§

    impl PyClassImpl for DataBackendSession

    source§

    const IS_BASETYPE: bool = false

    #[pyclass(subclass)]
    source§

    const IS_SUBCLASS: bool = false

    #[pyclass(extends=…)]
    source§

    const IS_MAPPING: bool = false

    #[pyclass(mapping)]
    source§

    const IS_SEQUENCE: bool = false

    #[pyclass(sequence)]
    §

    type BaseType = PyAny

    Base class
    §

    type ThreadChecker = SendablePyClass<DataBackendSession>

    This handles following two situations: Read more
    §

    type PyClassMutability = <<PyAny as PyClassBaseType>::PyClassMutability as PyClassMutability>::MutableChild

    Immutable or mutable
    §

    type Dict = PyClassDummySlot

    Specify this class has #[pyclass(dict)] or not.
    §

    type WeakRef = PyClassDummySlot

    Specify this class has #[pyclass(weakref)] or not.
    §

    type BaseNativeType = PyAny

    The closest native ancestor. This is PyAny by default, and when you declare -#[pyclass(extends=PyDict)], it’s PyDict.
    source§

    fn items_iter() -> PyClassItemsIter

    source§

    fn doc(py: Python<'_>) -> PyResult<&'static CStr>

    Rendered class doc
    source§

    fn lazy_type_object() -> &'static LazyTypeObject<Self>

    §

    fn dict_offset() -> Option<isize>

    §

    fn weaklist_offset() -> Option<isize>

    source§

    impl PyClassNewTextSignature<DataBackendSession> for PyClassImplCollector<DataBackendSession>

    source§

    fn new_text_signature(self) -> Option<&'static str>

    source§

    impl<'a, 'py> PyFunctionArgument<'a, 'py> for &'a DataBackendSession

    §

    type Holder = Option<PyRef<'py, DataBackendSession>>

    source§

    fn extract(obj: &'py PyAny, holder: &'a mut Self::Holder) -> PyResult<Self>

    source§

    impl<'a, 'py> PyFunctionArgument<'a, 'py> for &'a mut DataBackendSession

    §

    type Holder = Option<PyRefMut<'py, DataBackendSession>>

    source§

    fn extract(obj: &'py PyAny, holder: &'a mut Self::Holder) -> PyResult<Self>

    source§

    impl PyMethods<DataBackendSession> for PyClassImplCollector<DataBackendSession>

    source§

    fn py_methods(self) -> &'static PyClassItems

    source§

    impl PyTypeInfo for DataBackendSession

    §

    type AsRefTarget = PyCell<DataBackendSession>

    Utility type to make Py::as_ref work.
    source§

    const NAME: &'static str = "DataBackendSession"

    Class name.
    source§

    const MODULE: Option<&'static str> = _

    Module name, if any.
    source§

    fn type_object_raw(py: Python<'_>) -> *mut PyTypeObject

    Returns the PyTypeObject instance for this type.
    §

    fn type_object(py: Python<'_>) -> &PyType

    Returns the safe abstraction over the type object.
    §

    fn is_type_of(object: &PyAny) -> bool

    Checks if object is an instance of this type or a subclass of this type.
    §

    fn is_exact_type_of(object: &PyAny) -> bool

    Checks if object is an instance of this type.
    source§

    impl Send for DataBackendSession

    Auto Trait Implementations§

    §

    impl !RefUnwindSafe for DataBackendSession

    §

    impl Sync for DataBackendSession

    §

    impl Unpin for DataBackendSession

    §

    impl !UnwindSafe for DataBackendSession

    Blanket Implementations§

    source§

    impl<T> Any for T
    where +#[pyclass(extends=PyDict)], it’s PyDict.

    source§

    fn items_iter() -> PyClassItemsIter

    source§

    fn doc(py: Python<'_>) -> PyResult<&'static CStr>

    Rendered class doc
    source§

    fn lazy_type_object() -> &'static LazyTypeObject<Self>

    §

    fn dict_offset() -> Option<isize>

    §

    fn weaklist_offset() -> Option<isize>

    source§

    impl PyClassNewTextSignature<DataBackendSession> for PyClassImplCollector<DataBackendSession>

    source§

    fn new_text_signature(self) -> Option<&'static str>

    source§

    impl<'a, 'py> PyFunctionArgument<'a, 'py> for &'a DataBackendSession

    §

    type Holder = Option<PyRef<'py, DataBackendSession>>

    source§

    fn extract(obj: &'py PyAny, holder: &'a mut Self::Holder) -> PyResult<Self>

    source§

    impl<'a, 'py> PyFunctionArgument<'a, 'py> for &'a mut DataBackendSession

    §

    type Holder = Option<PyRefMut<'py, DataBackendSession>>

    source§

    fn extract(obj: &'py PyAny, holder: &'a mut Self::Holder) -> PyResult<Self>

    source§

    impl PyMethods<DataBackendSession> for PyClassImplCollector<DataBackendSession>

    source§

    fn py_methods(self) -> &'static PyClassItems

    source§

    impl PyTypeInfo for DataBackendSession

    §

    type AsRefTarget = PyCell<DataBackendSession>

    Utility type to make Py::as_ref work.
    source§

    const NAME: &'static str = "DataBackendSession"

    Class name.
    source§

    const MODULE: Option<&'static str> = _

    Module name, if any.
    source§

    fn type_object_raw(py: Python<'_>) -> *mut PyTypeObject

    Returns the PyTypeObject instance for this type.
    §

    fn type_object(py: Python<'_>) -> &PyType

    Returns the safe abstraction over the type object.
    §

    fn is_type_of(object: &PyAny) -> bool

    Checks if object is an instance of this type or a subclass of this type.
    §

    fn is_exact_type_of(object: &PyAny) -> bool

    Checks if object is an instance of this type.
    source§

    impl Send for DataBackendSession

    Auto Trait Implementations§

    §

    impl !RefUnwindSafe for DataBackendSession

    §

    impl Sync for DataBackendSession

    §

    impl Unpin for DataBackendSession

    §

    impl !UnwindSafe for DataBackendSession

    Blanket Implementations§

    source§

    impl<T> Any for T
    where T: 'static + ?Sized,

    source§

    fn type_id(&self) -> TypeId

    Gets the TypeId of self. Read more
    source§

    impl<T> Borrow<T> for T
    where T: ?Sized,

    source§

    fn borrow(&self) -> &T

    Immutably borrows from an owned value. Read more
    source§

    impl<T> BorrowMut<T> for T
    where T: ?Sized,

    source§

    fn borrow_mut(&mut self) -> &mut T

    Mutably borrows from an owned value. Read more
    source§

    impl<T> From<T> for T

    source§

    fn from(t: T) -> T

    Returns the argument unchanged.

    diff --git a/nightly/core/nautilus_persistence/backend/session/struct.DataQueryResult.html b/nightly/core/nautilus_persistence/backend/session/struct.DataQueryResult.html index e7a4259670b9..d8a4e195fa0e 100644 --- a/nightly/core/nautilus_persistence/backend/session/struct.DataQueryResult.html +++ b/nightly/core/nautilus_persistence/backend/session/struct.DataQueryResult.html @@ -1,4 +1,4 @@ -DataQueryResult in nautilus_persistence::backend::session - Rust
    +DataQueryResult in nautilus_persistence::backend::session - Rust

    Struct nautilus_persistence::backend::session::DataQueryResult

    source · 
    pub struct DataQueryResult {
     pub result: QueryResult,
     pub acc: Vec<Data>,
@@ -190,7 +190,7 @@
     F: FnMut(Self::Item) -> K,
     K: PartialOrd,
    🔬This is a nightly-only experimental API. (is_sorted)
    Checks if the elements of this iterator are sorted using the given key extraction function. Read more
    source§

    impl PyClass for DataQueryResult

    §

    type Frozen = False

    Whether the pyclass is frozen. Read more
    source§

    impl PyClassImpl for DataQueryResult

    source§

    const IS_BASETYPE: bool = false

    #[pyclass(subclass)]
    source§

    const IS_SUBCLASS: bool = false

    #[pyclass(extends=…)]
    source§

    const IS_MAPPING: bool = false

    #[pyclass(mapping)]
    source§

    const IS_SEQUENCE: bool = false

    #[pyclass(sequence)]
    §

    type BaseType = PyAny

    Base class
    §

    type ThreadChecker = SendablePyClass<DataQueryResult>

    This handles following two situations: Read more
    §

    type PyClassMutability = <<PyAny as PyClassBaseType>::PyClassMutability as PyClassMutability>::MutableChild

    Immutable or mutable
    §

    type Dict = PyClassDummySlot

    Specify this class has #[pyclass(dict)] or not.
    §

    type WeakRef = PyClassDummySlot

    Specify this class has #[pyclass(weakref)] or not.
    §

    type BaseNativeType = PyAny

    The closest native ancestor. This is PyAny by default, and when you declare -#[pyclass(extends=PyDict)], it’s PyDict.
    source§

    fn items_iter() -> PyClassItemsIter

    source§

    fn doc(py: Python<'_>) -> PyResult<&'static CStr>

    Rendered class doc
    source§

    fn lazy_type_object() -> &'static LazyTypeObject<Self>

    §

    fn dict_offset() -> Option<isize>

    §

    fn weaklist_offset() -> Option<isize>

    source§

    impl<'a, 'py> PyFunctionArgument<'a, 'py> for &'a DataQueryResult

    §

    type Holder = Option<PyRef<'py, DataQueryResult>>

    source§

    fn extract(obj: &'py PyAny, holder: &'a mut Self::Holder) -> PyResult<Self>

    source§

    impl<'a, 'py> PyFunctionArgument<'a, 'py> for &'a mut DataQueryResult

    §

    type Holder = Option<PyRefMut<'py, DataQueryResult>>

    source§

    fn extract(obj: &'py PyAny, holder: &'a mut Self::Holder) -> PyResult<Self>

    source§

    impl PyMethods<DataQueryResult> for PyClassImplCollector<DataQueryResult>

    source§

    fn py_methods(self) -> &'static PyClassItems

    source§

    impl PyTypeInfo for DataQueryResult

    §

    type AsRefTarget = PyCell<DataQueryResult>

    Utility type to make Py::as_ref work.
    source§

    const NAME: &'static str = "DataQueryResult"

    Class name.
    source§

    const MODULE: Option<&'static str> = _

    Module name, if any.
    source§

    fn type_object_raw(py: Python<'_>) -> *mut PyTypeObject

    Returns the PyTypeObject instance for this type.
    §

    fn type_object(py: Python<'_>) -> &PyType

    Returns the safe abstraction over the type object.
    §

    fn is_type_of(object: &PyAny) -> bool

    Checks if object is an instance of this type or a subclass of this type.
    §

    fn is_exact_type_of(object: &PyAny) -> bool

    Checks if object is an instance of this type.
    source§

    impl Send for DataQueryResult

    Auto Trait Implementations§

    §

    impl !RefUnwindSafe for DataQueryResult

    §

    impl !Sync for DataQueryResult

    §

    impl Unpin for DataQueryResult

    §

    impl !UnwindSafe for DataQueryResult

    Blanket Implementations§

    source§

    impl<T> Any for T
    where +#[pyclass(extends=PyDict)], it’s PyDict.

    source§

    fn items_iter() -> PyClassItemsIter

    source§

    fn doc(py: Python<'_>) -> PyResult<&'static CStr>

    Rendered class doc
    source§

    fn lazy_type_object() -> &'static LazyTypeObject<Self>

    §

    fn dict_offset() -> Option<isize>

    §

    fn weaklist_offset() -> Option<isize>

    source§

    impl<'a, 'py> PyFunctionArgument<'a, 'py> for &'a DataQueryResult

    §

    type Holder = Option<PyRef<'py, DataQueryResult>>

    source§

    fn extract(obj: &'py PyAny, holder: &'a mut Self::Holder) -> PyResult<Self>

    source§

    impl<'a, 'py> PyFunctionArgument<'a, 'py> for &'a mut DataQueryResult

    §

    type Holder = Option<PyRefMut<'py, DataQueryResult>>

    source§

    fn extract(obj: &'py PyAny, holder: &'a mut Self::Holder) -> PyResult<Self>

    source§

    impl PyMethods<DataQueryResult> for PyClassImplCollector<DataQueryResult>

    source§

    fn py_methods(self) -> &'static PyClassItems

    source§

    impl PyTypeInfo for DataQueryResult

    §

    type AsRefTarget = PyCell<DataQueryResult>

    Utility type to make Py::as_ref work.
    source§

    const NAME: &'static str = "DataQueryResult"

    Class name.
    source§

    const MODULE: Option<&'static str> = _

    Module name, if any.
    source§

    fn type_object_raw(py: Python<'_>) -> *mut PyTypeObject

    Returns the PyTypeObject instance for this type.
    §

    fn type_object(py: Python<'_>) -> &PyType

    Returns the safe abstraction over the type object.
    §

    fn is_type_of(object: &PyAny) -> bool

    Checks if object is an instance of this type or a subclass of this type.
    §

    fn is_exact_type_of(object: &PyAny) -> bool

    Checks if object is an instance of this type.
    source§

    impl Send for DataQueryResult

    Auto Trait Implementations§

    §

    impl !RefUnwindSafe for DataQueryResult

    §

    impl !Sync for DataQueryResult

    §

    impl Unpin for DataQueryResult

    §

    impl !UnwindSafe for DataQueryResult

    Blanket Implementations§

    source§

    impl<T> Any for T
    where T: 'static + ?Sized,

    source§

    fn type_id(&self) -> TypeId

    Gets the TypeId of self. Read more
    source§

    impl<T> Borrow<T> for T
    where T: ?Sized,

    source§

    fn borrow(&self) -> &T

    Immutably borrows from an owned value. Read more
    source§

    impl<T> BorrowMut<T> for T
    where T: ?Sized,

    source§

    fn borrow_mut(&mut self) -> &mut T

    Mutably borrows from an owned value. Read more
    source§

    impl<T> From<T> for T

    source§

    fn from(t: T) -> T

    Returns the argument unchanged.

    diff --git a/nightly/core/nautilus_persistence/backend/session/struct.TsInitComparator.html b/nightly/core/nautilus_persistence/backend/session/struct.TsInitComparator.html index 82d0f47c803e..135481751648 100644 --- a/nightly/core/nautilus_persistence/backend/session/struct.TsInitComparator.html +++ b/nightly/core/nautilus_persistence/backend/session/struct.TsInitComparator.html @@ -1,4 +1,4 @@ -TsInitComparator in nautilus_persistence::backend::session - Rust
    +TsInitComparator in nautilus_persistence::backend::session - Rust

    Struct nautilus_persistence::backend::session::TsInitComparator

    source · 
    pub struct TsInitComparator;

    Trait Implementations§

    source§

    impl<I> Compare<ElementBatchIter<I, Data>> for TsInitComparator
    where I: Iterator<Item = IntoIter<Data>>,

    source§

    fn compare( &self, diff --git a/nightly/core/nautilus_persistence/backend/session/type.QueryResult.html b/nightly/core/nautilus_persistence/backend/session/type.QueryResult.html index ec29bcfa431c..7d4ef7550163 100644 --- a/nightly/core/nautilus_persistence/backend/session/type.QueryResult.html +++ b/nightly/core/nautilus_persistence/backend/session/type.QueryResult.html @@ -1,2 +1,2 @@ -QueryResult in nautilus_persistence::backend::session - Rust
    +QueryResult in nautilus_persistence::backend::session - Rust

    Type Alias nautilus_persistence::backend::session::QueryResult

    source · 
    pub type QueryResult = KMerge<EagerStream<IntoIter<Data>>, Data, TsInitComparator>;

    Aliased Type§

    struct QueryResult { /* private fields */ }
    \ No newline at end of file diff --git a/nightly/core/nautilus_persistence/db/database/enum.DatabaseEngine.html b/nightly/core/nautilus_persistence/db/database/enum.DatabaseEngine.html index 5584b73d12a6..0c23d0573a24 100644 --- a/nightly/core/nautilus_persistence/db/database/enum.DatabaseEngine.html +++ b/nightly/core/nautilus_persistence/db/database/enum.DatabaseEngine.html @@ -1,4 +1,4 @@ -DatabaseEngine in nautilus_persistence::db::database - Rust
    +DatabaseEngine in nautilus_persistence::db::database - Rust

    Enum nautilus_persistence::db::database::DatabaseEngine

    source · 
    pub enum DatabaseEngine {
     POSTGRES,
     SQLITE,
diff --git a/nightly/core/nautilus_persistence/db/database/fn.init_db_schema.html b/nightly/core/nautilus_persistence/db/database/fn.init_db_schema.html
index 15611592817b..f58489deecc1 100644
--- a/nightly/core/nautilus_persistence/db/database/fn.init_db_schema.html
+++ b/nightly/core/nautilus_persistence/db/database/fn.init_db_schema.html
@@ -1,2 +1,2 @@
-init_db_schema in nautilus_persistence::db::database - Rust
    
+init_db_schema in nautilus_persistence::db::database - Rust
    
     
    Function nautilus_persistence::db::database::init_db_schema
    source · 
    pub async fn init_db_schema(db: &Database, schema_dir: &str) -> Result<()>
    
\ No newline at end of file
diff --git a/nightly/core/nautilus_persistence/db/database/fn.setup_test_database.html b/nightly/core/nautilus_persistence/db/database/fn.setup_test_database.html
index f19924bc04f9..67f4709764c3 100644
--- a/nightly/core/nautilus_persistence/db/database/fn.setup_test_database.html
+++ b/nightly/core/nautilus_persistence/db/database/fn.setup_test_database.html
@@ -1,2 +1,2 @@
-setup_test_database in nautilus_persistence::db::database - Rust
    
+setup_test_database in nautilus_persistence::db::database - Rust
    
     
    Function nautilus_persistence::db::database::setup_test_database
    source · 
    pub async fn setup_test_database() -> Database
    
\ No newline at end of file
diff --git a/nightly/core/nautilus_persistence/db/database/index.html b/nightly/core/nautilus_persistence/db/database/index.html
index 749fac63c026..10f14c99f152 100644
--- a/nightly/core/nautilus_persistence/db/database/index.html
+++ b/nightly/core/nautilus_persistence/db/database/index.html
@@ -1,2 +1,2 @@
-nautilus_persistence::db::database - Rust
    
+nautilus_persistence::db::database - Rust
    
     
    Module nautilus_persistence::db::database
    source · 
    Structs
    Enums
    Functions
    
\ No newline at end of file
diff --git a/nightly/core/nautilus_persistence/db/database/struct.Database.html b/nightly/core/nautilus_persistence/db/database/struct.Database.html
index 1849ee8106a5..fa14fc295384 100644
--- a/nightly/core/nautilus_persistence/db/database/struct.Database.html
+++ b/nightly/core/nautilus_persistence/db/database/struct.Database.html
@@ -1,4 +1,4 @@
-Database in nautilus_persistence::db::database - Rust
    
+Database in nautilus_persistence::db::database - Rust
    
     
    Struct nautilus_persistence::db::database::Database
    source · 
    pub struct Database {
     pub pool: Pool<Any>,
 }
    Fields§
    §pool: Pool<Any>
    Implementations§
    source§
    impl Database
    source
    pub async fn new(
diff --git a/nightly/core/nautilus_persistence/db/index.html b/nightly/core/nautilus_persistence/db/index.html
index a3a4cfc2a38d..df5383387161 100644
--- a/nightly/core/nautilus_persistence/db/index.html
+++ b/nightly/core/nautilus_persistence/db/index.html
@@ -1,2 +1,2 @@
-nautilus_persistence::db - Rust
    
+nautilus_persistence::db - Rust
    
     
    Module nautilus_persistence::db
    source · 
    Modules
    
\ No newline at end of file
diff --git a/nightly/core/nautilus_persistence/db/schema/index.html b/nightly/core/nautilus_persistence/db/schema/index.html
index 08cf7deebc09..10d2e12678f3 100644
--- a/nightly/core/nautilus_persistence/db/schema/index.html
+++ b/nightly/core/nautilus_persistence/db/schema/index.html
@@ -1,2 +1,2 @@
-nautilus_persistence::db::schema - Rust
    
+nautilus_persistence::db::schema - Rust
    
     
    Module nautilus_persistence::db::schema
    source · 
    Structs
    
\ No newline at end of file
diff --git a/nightly/core/nautilus_persistence/db/schema/struct.GeneralItem.html b/nightly/core/nautilus_persistence/db/schema/struct.GeneralItem.html
index 23570757ed5e..a5043e91148e 100644
--- a/nightly/core/nautilus_persistence/db/schema/struct.GeneralItem.html
+++ b/nightly/core/nautilus_persistence/db/schema/struct.GeneralItem.html
@@ -1,4 +1,4 @@
-GeneralItem in nautilus_persistence::db::schema - Rust
    
+GeneralItem in nautilus_persistence::db::schema - Rust
    
     
    Struct nautilus_persistence::db::schema::GeneralItem
    source · 
    pub struct GeneralItem {
     pub key: String,
     pub value: String,
diff --git a/nightly/core/nautilus_persistence/db/sql/index.html b/nightly/core/nautilus_persistence/db/sql/index.html
index 759e077e559c..45fd4c76ac77 100644
--- a/nightly/core/nautilus_persistence/db/sql/index.html
+++ b/nightly/core/nautilus_persistence/db/sql/index.html
@@ -1,2 +1,2 @@
-nautilus_persistence::db::sql - Rust
    
+nautilus_persistence::db::sql - Rust
    
     
    Module nautilus_persistence::db::sql
    source · 
    Structs
    
\ No newline at end of file
diff --git a/nightly/core/nautilus_persistence/db/sql/struct.SqlCacheDatabase.html b/nightly/core/nautilus_persistence/db/sql/struct.SqlCacheDatabase.html
index 0523c45ff5f1..394db21759ee 100644
--- a/nightly/core/nautilus_persistence/db/sql/struct.SqlCacheDatabase.html
+++ b/nightly/core/nautilus_persistence/db/sql/struct.SqlCacheDatabase.html
@@ -1,4 +1,4 @@
-SqlCacheDatabase in nautilus_persistence::db::sql - Rust
    
+SqlCacheDatabase in nautilus_persistence::db::sql - Rust
    
     
    Struct nautilus_persistence::db::sql::SqlCacheDatabase
    source · 
    pub struct SqlCacheDatabase { /* private fields */ }
    Implementations§
    source§
    impl SqlCacheDatabase
    source
    pub fn new(trader_id: TraderId, database: Database) -> Self
    source
    pub fn key_trader(&self) -> String
    source
    pub fn key_general(&self) -> String
    source
    pub async fn add(&self, key: String, value: String) -> Result<u64, Error>
    source
    pub async fn get(&self, key: String) -> Vec<GeneralItem>
    Auto Trait Implementations§
    Blanket Implementations§
    source§
    impl<T> Any for T
    where
     T: 'static + ?Sized,
    source§
    fn type_id(&self) -> TypeId
    Gets the TypeId of self. Read more
    source§
    impl<T> Borrow<T> for T
    where
     T: ?Sized,
    source§
    fn borrow(&self) -> &T
    Immutably borrows from an owned value. Read more
    source§
    impl<T> BorrowMut<T> for T
    where
diff --git a/nightly/core/nautilus_persistence/index.html b/nightly/core/nautilus_persistence/index.html
index 30ac10f280cf..26f33d462c3c 100644
--- a/nightly/core/nautilus_persistence/index.html
+++ b/nightly/core/nautilus_persistence/index.html
@@ -1,3 +1,3 @@
-nautilus_persistence - Rust