Struct ManagedBacktestSession 

pub struct ManagedBacktestSession { /* private fields */ }

High-level managed backtest session.

This wrapper owns the control manager, supported subscription managers, cancellation, status gating, and shutdown order. Callers only need to react to ManagedEvents and send ContinueParams after ReadyForContinue.

Implementations

impl ManagedBacktestSession

pub async fn start( url: String, api_key: String, create: CreateBacktestSessionRequest, ) -> Result<Self, ManagedSessionError>

Start a managed session with an internally owned cancellation token.

pub async fn start_with_cancel( url: String, api_key: String, create: CreateBacktestSessionRequest, parent_cancel: CancellationToken, ) -> Result<Self, ManagedSessionError>

Start a managed session tied to a caller-owned cancellation token.

Cancelling parent_cancel aborts startup and stops manager tasks.

pub fn session_info(&self) -> &SessionInfo

Metadata reported by the server when the session was created.

pub fn subscribe_transactions(&mut self, program_ids: Vec<String>)

Subscribe to transaction notifications for the configured programs.

pub fn subscribe_account_diffs(&mut self, program_ids: Vec<String>)

Subscribe to account-diff notifications for the configured programs.

pub async fn next_event(&mut self) -> Result<ManagedEvent, ManagedSessionError>

Receive the next control or subscription event.

On Completed, trailing subscription notifications are drained and delivered before the Completed event.

pub async fn send_continue( &mut self, params: ContinueParams, ) -> Result<(), ManagedSessionError>

Wait until the control connection and all subscription connections are up, then send a Continue request.

Call this after receiving ManagedEvent::ReadyForContinue or ManagedEvent::Paused. If there are no subscriptions, only the control connection is gated.

pub async fn send_continue_to( &mut self, params: ContinueToParams, ) -> Result<(), ManagedSessionError>

Wait until the control connection and all subscription connections are up, then send a ContinueTo request to step to a specific slot/batch boundary.

Pair with ManagedEvent::DiscoveryBatch to drive a discovery-paced loop: receive a discovery event, send ContinueTo(slot, batch_index), and wait for ManagedEvent::Paused before inspecting state.

pub async fn shutdown(self)

Cancel the session and join all manager tasks.

Trait Implementations

impl Drop for ManagedBacktestSession

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.