Struct CatalogWorker 

pub struct CatalogWorker { /* private fields */ }

Implementations

impl CatalogWorker

pub fn start(catalog: DataCatalog) -> Self

pub fn query_last_timestamp( &self, data_type: NautilusDataType, identifier: Option<String>, ) -> Result<Option<u64>>

pub fn get_missing_intervals( &self, start: UnixNanos, end: UnixNanos, data_type: NautilusDataType, identifier: Option<String>, ) -> Result<Vec<(u64, u64)>>

pub fn get_missing_intervals_for_identifiers( &self, start: UnixNanos, end: UnixNanos, data_type: NautilusDataType, identifiers: Vec<String>, ) -> Result<AHashMap<String, Vec<(u64, u64)>>>

pub fn get_coverage_intervals_for_identifiers( &self, start: UnixNanos, end: UnixNanos, data_type: NautilusDataType, identifiers: Vec<String>, ) -> Result<AHashMap<String, CoverageIntervals>>

pub fn query_batch(&self, query: CatalogQuery) -> Result<DataBatch>

pub fn query_batch_async( &self, query: CatalogQuery, on_complete: Box<dyn FnOnce(Result<DataBatch>) + Send>, ) -> Result<()>

Enqueues a batch query and invokes on_complete with the result on the worker thread, without blocking the caller.

pub fn open_session( &self, query: CatalogQuery, chunk_size: Option<usize>, ) -> Result<UUID4>

pub fn pull_session(&self, session_id: UUID4) -> Result<Option<DataBatch>>

pub fn pull_session_async( &self, session_id: UUID4, on_complete: Box<dyn FnOnce(Result<Option<DataBatch>>) + Send>, ) -> Result<()>

Enqueues one session pull and invokes on_complete on the catalog worker.

pub fn close_session(&self, session_id: UUID4) -> Result<bool>

Closes a session, returning whether it was still open.

pub fn query_instruments( &self, query: CatalogInstrumentQuery, ) -> Result<Vec<InstrumentAny>>

pub fn write(&self, job: CatalogWriteJob) -> Result<()>

pub fn write_async(&self, job: CatalogWriteJob) -> Result<()>

pub fn write_instruments(&self, instruments: Vec<InstrumentAny>) -> Result<()>

pub fn write_instruments_async( &self, instruments: Vec<InstrumentAny>, ) -> Result<()>

pub fn flush(&self) -> Result<()>

Trait Implementations

impl Debug for CatalogWorker

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for CatalogWorker

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.