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( name: String, trader_id: TraderId, environment: Environment, ) -> Result<Self>

Creates a new LiveNodeBuilder with required parameters.

Errors

Returns an error if environment is invalid (BACKTEST).

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 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 add_data_client( self, name: Option<String>, factory: Box<dyn DataClientFactory>, config: Box<dyn ClientConfig>, ) -> Result<Self>

Adds a data client with factory and 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 with factory and 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. Register all client factories.
3. Create and register all clients.

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

type Frozen = False

Whether the pyclass is frozen.

impl PyClassImpl for LiveNodeBuilder

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 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<isize>

fn weaklist_offset() -> Option<isize>

impl<'a, 'holder, 'py> PyFunctionArgument<'a, 'holder, 'py, false> for &'holder LiveNodeBuilder

type Holder = Option<PyClassGuard<'a, LiveNodeBuilder>>

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

impl<'a, 'holder, 'py> PyFunctionArgument<'a, 'holder, 'py, false> for &'holder mut LiveNodeBuilder

type Holder = Option<PyClassGuardMut<'a, LiveNodeBuilder>>

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

impl PyTypeInfo for LiveNodeBuilder

const NAME: &'static str = "LiveNodeBuilder"

Class name.

const MODULE: Option<&'static str>

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