Struct LiveNodeBuilder 

pub struct LiveNodeBuilder { /* private fields */ }

Builder for constructing a LiveNode with a fluent API.

Provides configuration options specific to live nodes, including client factory registration and timeout settings.

Implementations

impl LiveNodeBuilder

pub fn new(trader_id: TraderId, environment: Environment) -> Result<Self>

Creates a new LiveNodeBuilder with required parameters.

Errors

Returns an error if environment is invalid (BACKTEST).

pub fn from_config(config: LiveNodeConfig) -> Result<Self>

Creates a new LiveNodeBuilder from an existing LiveNodeConfig.

Errors

Returns an error if the config’s environment is invalid (BACKTEST).

pub fn name(&self) -> &str

Returns the name for the node.

pub fn with_name(self, name: impl Into<String>) -> Self

Set the name for the node.

pub const fn with_instance_id(self, instance_id: UUID4) -> Self

Set the instance ID for the node.

pub const fn with_load_state(self, load_state: bool) -> Self

Configure whether to load state on startup.

pub const fn with_save_state(self, save_state: bool) -> Self

Configure whether to save state on shutdown.

pub const fn with_timeout_connection(self, timeout_secs: u64) -> Self

Set the connection timeout in seconds.

pub const fn with_timeout_reconciliation(self, timeout_secs: u64) -> Self

Set the reconciliation timeout in seconds.

pub fn with_reconciliation(self, reconciliation: bool) -> Self

Configure whether to run startup reconciliation.

pub fn with_reconciliation_lookback_mins(self, mins: u32) -> Self

Set the reconciliation lookback in minutes.

pub const fn with_timeout_portfolio(self, timeout_secs: u64) -> Self

Set the portfolio initialization timeout in seconds.

pub const fn with_timeout_disconnection_secs(self, timeout_secs: u64) -> Self

Set the disconnection timeout in seconds.

pub const fn with_delay_post_stop_secs(self, delay_secs: u64) -> Self

Set the post-stop delay in seconds.

pub const fn with_delay_shutdown_secs(self, delay_secs: u64) -> Self

Set the shutdown timeout in seconds.

pub fn with_cache_config(self, config: CacheConfig) -> Self

Set the cache configuration.

pub fn with_msgbus_config(self, config: MessageBusConfig) -> Self

Set the message bus configuration.

The Rust live runtime does not support this setting yet. build() returns an error when it is set.

pub fn with_portfolio_config(self, config: PortfolioConfig) -> Self

Set the portfolio configuration.

pub fn with_streaming_config(self, config: StreamingConfig) -> Self

Set the streaming configuration.

The Rust live runtime does not support this setting yet. build() returns an error when it is set.

pub fn with_data_engine_config(self, config: LiveDataEngineConfig) -> Self

Set the data engine configuration.

The Rust live runtime currently supports only the default qsize. build() returns an error for other values.

pub fn with_risk_engine_config(self, config: LiveRiskEngineConfig) -> Self

Set the risk engine configuration.

The Rust live runtime currently supports only the default qsize. build() returns an error for other values.

pub fn with_exec_engine_config(self, config: LiveExecEngineConfig) -> Self

Set the execution engine configuration.

The Rust live runtime currently supports only the default qsize. build() returns an error for other values.

pub fn with_logging(self, logging: LoggerConfig) -> Self

Set the logging configuration.

pub fn add_data_client( self, name: Option<String>, factory: Box<dyn DataClientFactory>, config: Box<dyn ClientConfig>, ) -> Result<Self>

Adds a data client factory with configuration.

Errors

Returns an error if a client with the same name is already registered.

pub fn add_exec_client( self, name: Option<String>, factory: Box<dyn ExecutionClientFactory>, config: Box<dyn ClientConfig>, ) -> Result<Self>

Adds an execution client factory with configuration.

Errors

Returns an error if a client with the same name is already registered.

pub fn build(self) -> Result<LiveNode>

Build the LiveNode with the configured settings.

This will:

1. Build the underlying kernel.
2. Create clients using factories.
3. Register clients with engines.

Errors

Returns an error if node construction fails.

Trait Implementations

impl Debug for LiveNodeBuilder

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

Formats the value using the given formatter.

impl<'py> IntoPyObject<'py> for LiveNodeBuilder

type Target = LiveNodeBuilder

The Python output type

type Output = Bound<'py, <LiveNodeBuilder 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 LiveNodeBuilder

const NAME: &str = "LiveNodeBuilder"

Name of the class.

type Frozen = False

Whether the pyclass is frozen.

impl PyClassImpl for LiveNodeBuilder

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 = /// Builder for constructing a [`LiveNode`] with a fluent API. /// /// Provides configuration options specific to live nodes, /// including client factory registration and timeout settings.

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 = <<LiveNodeBuilder as PyClassImpl>::BaseNativeType as PyClassBaseType>::Layout<LiveNodeBuilder>

Description of how this class is laid out in memory

type BaseType = PyAny

Base class

type ThreadChecker = ThreadCheckerImpl

This handles following two situations:

type Inventory = Pyo3MethodsInventoryForLiveNodeBuilder

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 PyTypeInfo for LiveNodeBuilder

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 LiveNodeBuilder

impl ExtractPyClassWithClone for LiveNodeBuilder