Struct Runtime 

pub struct Runtime { /* private fields */ }

Implementations

impl Runtime

pub fn new() -> Self

pub fn with_name_prefix(&self, name_prefix: impl Into<Arc<str>>) -> Self

pub fn name_prefix(&self) -> &str

pub fn with_attributes(&self, attributes: Attributes) -> Self

pub fn attributes(&self) -> &Attributes

pub fn effective_attributes(&self, local: &Attributes) -> Attributes

pub fn shutdown(&self)

pub fn is_shutdown(&self) -> bool

pub fn active_streams(&self) -> usize

pub fn materialize<Mat: Send + 'static>( &self, graph: &RunnableGraph<Mat>, ) -> StreamResult<Mat>

pub fn schedule_once<F>(&self, delay: Duration, task: F) -> Cancellable

where F: FnOnce() + Send + 'static,

pub fn schedule_with_fixed_delay<F>( &self, initial_delay: Duration, delay: Duration, task: F, ) -> Cancellable

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

pub fn schedule_at_fixed_rate<F>( &self, initial_delay: Duration, interval: Duration, task: F, ) -> Cancellable

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

Trait Implementations

impl Clone for Runtime

fn clone(&self) -> Runtime

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for Runtime

fn default() -> Self

Returns the “default value” for a type.