Struct BacktestNode 

pub struct BacktestNode { /* private fields */ }

Orchestrates catalog-driven backtests from run configurations.

BacktestNode connects the ParquetDataCatalog with BacktestEngine to load historical data and run backtests. Supports both oneshot and streaming modes.

Implementations

impl BacktestNode

pub fn new(configs: Vec<BacktestRunConfig>) -> Result<Self>

Creates a new BacktestNode instance.

Validates that configs are non-empty and internally consistent:

• All data config instrument venues must have a matching venue config.
• L2/L3 book types require order book data in the data configs.
• Data config time ranges must be valid (start <= end).

Errors

Returns an error if configs is empty or validation fails.

pub fn configs(&self) -> &[BacktestRunConfig]

Returns the run configurations.

pub fn build(&mut self) -> Result<()>

Builds backtest engines from the run configurations.

For each config, creates a BacktestEngine, adds venues, and loads instruments from the catalog.

Errors

Returns an error if engine creation, venue setup, or instrument loading fails.

pub fn get_engine_mut(&mut self, id: &str) -> Option<&mut BacktestEngine>

Returns a mutable reference to the engine for the given run config ID.

pub fn get_engine(&self, id: &str) -> Option<&BacktestEngine>

Returns a reference to the engine for the given run config ID.

pub fn get_engines(&self) -> Vec<&BacktestEngine>

Returns all created backtest engines.

pub fn run(&mut self) -> Result<Vec<BacktestResult>>

Runs all configured backtests and returns results.

Automatically calls build() if engines have not been created yet. For each run config, loads data from the catalog and runs the engine. Supports both oneshot (chunk_size = None) and streaming modes.

Errors

Returns an error if building, data loading, or engine execution fails.

pub fn load_catalog(config: &BacktestDataConfig) -> Result<ParquetDataCatalog>

Creates a ParquetDataCatalog from a data config.

Errors

Returns an error if the catalog cannot be created from the URI.

pub fn load_data_config( config: &BacktestDataConfig, start: Option<UnixNanos>, end: Option<UnixNanos>, ) -> Result<Vec<Data>>

Loads data from the catalog for a specific data config.

Errors

Returns an error if catalog creation or data querying fails.

pub fn dispose(&mut self)

Disposes all engines and releases resources.

Trait Implementations

impl Debug for BacktestNode

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

Formats the value using the given formatter.

impl<'py> IntoPyObject<'py> for BacktestNode

type Target = BacktestNode

The Python output type

type Output = Bound<'py, <BacktestNode as IntoPyObject<'py>>::Target>

The smart pointer type to use.

type Error = PyErr

The type returned in the event of a conversion error.

fn into_pyobject( self, py: Python<'py>, ) -> Result<<Self as IntoPyObject<'_>>::Output, <Self as IntoPyObject<'_>>::Error>

Performs the conversion.

impl PyClass for BacktestNode

const NAME: &str = "BacktestNode"

Name of the class.

type Frozen = False

Whether the pyclass is frozen.

impl PyClassImpl for BacktestNode

const MODULE: Option<&str>

Module which the class will be associated with.

const IS_BASETYPE: bool = false

#[pyclass(subclass)]

const IS_SUBCLASS: bool = false

#[pyclass(extends=…)]

const IS_MAPPING: bool = false

#[pyclass(mapping)]

const IS_SEQUENCE: bool = false

#[pyclass(sequence)]

const IS_IMMUTABLE_TYPE: bool = false

#[pyclass(immutable_type)]

const RAW_DOC: &'static CStr = /// Orchestrates catalog-driven backtests from run configurations. /// /// `BacktestNode` connects the [`ParquetDataCatalog`] with [`BacktestEngine`] to load /// historical data and run backtests. Supports both oneshot and streaming modes.

Docstring for the class provided on the struct or enum.

const DOC: &'static CStr

Fully rendered class doc, including the text_signature if a constructor is defined.

type Layout = <<BacktestNode as PyClassImpl>::BaseNativeType as PyClassBaseType>::Layout<BacktestNode>

Description of how this class is laid out in memory

type BaseType = PyAny

Base class

type ThreadChecker = ThreadCheckerImpl

This handles following two situations:

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.

fn items_iter() -> PyClassItemsIter

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

fn dict_offset() -> Option<PyObjectOffset>

Used to provide the dictoffset slot (equivalent to tp_dictoffset)

fn weaklist_offset() -> Option<PyObjectOffset>

Used to provide the weaklistoffset slot (equivalent to tp_weaklistoffset

impl PyClassNewTextSignature for BacktestNode

const TEXT_SIGNATURE: &'static str = "(configs)"

impl PyMethods<BacktestNode> for PyClassImplCollector<BacktestNode>

fn py_methods(self) -> &'static PyClassItems

impl PyTypeInfo for BacktestNode

const NAME: &str = <Self as ::pyo3::PyClass>::NAME

👎Deprecated since 0.28.0: prefer using ::type_object(py).name() to get the correct runtime value

Class name.

const MODULE: Option<&str> = <Self as ::pyo3::impl_::pyclass::PyClassImpl>::MODULE

👎Deprecated since 0.28.0: prefer using ::type_object(py).module() to get the correct runtime value

Module name, if any.

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

Returns the PyTypeObject instance for this type.

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

Returns the safe abstraction over the type object.

fn is_type_of(object: &Bound<'_, PyAny>) -> bool

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

fn is_exact_type_of(object: &Bound<'_, PyAny>) -> bool

Checks if object is an instance of this type.

impl DerefToPyAny for BacktestNode

impl ExtractPyClassWithClone for BacktestNode