Struct Runtime 

pub struct Runtime(/* private fields */);

Holds shared state and components used by Rust SDK workers.

Implementations

impl Runtime

pub fn new<F>( options: RuntimeOptions, tokio_builder: TokioRuntimeBuilder<F>, ) -> Result<Self, Error>

where F: Fn() + Send + Sync + 'static,

Creates a runtime with a newly constructed Tokio runtime.

pub fn new_assume_tokio(options: RuntimeOptions) -> Result<Self, Error>

Creates a runtime using the currently active Tokio runtime.

Panics

Panics if there is no currently active Tokio runtime.

pub fn new_assume_tokio_initialized_telem( telemetry: TelemetryInstance, heartbeat_interval: Option<Duration>, ) -> Self

Creates a runtime from an initialized telemetry instance using the currently active Tokio runtime.

Panics

Panics if there is no currently active Tokio runtime.

Methods from Deref<Target = CoreRuntime>

pub fn tokio_handle(&self) -> Handle

Get a handle to the tokio runtime used by this Core runtime.

pub fn telemetry(&self) -> &TelemetryInstance

Return a reference to the owned TelemetryInstance

pub fn telemetry_mut(&mut self) -> &mut TelemetryInstance

Return a mutable reference to the owned TelemetryInstance

Trait Implementations

impl Deref for Runtime

type Target = CoreRuntime

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for Runtime

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.