Main

Struct Main 

Source
pub struct Main<'m> { /* private fields */ }
Expand description

A main runner.

The idea of the main runner is to perform all setup steps, gathering all tasks (futures) to be executed, and then initialize the stack and drive the tasks, until one of them completes.

In some cases it might be necessary to run a set of tasks on a different context (like actix, or ntex). In this case it is possible to create a SubMain instance using SubMain::sub_main.

Implementations§

Source§

impl<'m> Main<'m>

Source

pub fn new(config: RuntimeConfig) -> Self

Source

pub fn from_env() -> Result<Self>

Source

pub fn add_tasks<I>(self, tasks: I) -> Self
where I: IntoIterator<Item = LocalBoxFuture<'m, Result<()>>>,

Add tasks to run.

Source

pub fn add_checks<I>(&mut self, i: I)
where I: IntoIterator<Item = Box<dyn HealthChecked>>,

Source

pub async fn run(self) -> Result<()>

Methods from Deref<Target = SubMain<'m>>§

Source

pub fn is_empty(&self) -> bool

Returns true is there are no tasks scheduled so far.

Source

pub fn sub_main(&self) -> SubMain<'_>

Create a new sub-main instance.

Source

pub fn sub_main_seed(&self) -> SubMainSeed

Create a seed or a sub-main instance, which can be sent.

Trait Implementations§

Source§

impl<'m> Default for Main<'m>

Source§

fn default() -> Self

Returns the “default value” for a type. Read more
Source§

impl<'m> Deref for Main<'m>

Source§

type Target = SubMain<'m>

The resulting type after dereferencing.
Source§

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

Dereferences the value.
Source§

impl<'m> DerefMut for Main<'m>

Source§

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

Mutably dereferences the value.
Source§

impl Spawner for Main<'_>

Source§

fn spawn_boxed(&mut self, future: Pin<Box<dyn Future<Output = Result<()>>>>)

Source§

impl Startup for Main<'_>

Source§

fn check_boxed(&mut self, check: Box<dyn HealthChecked>)

Add a health check.
Source§

fn use_tracing(&self) -> bool

Allow the application to check if the runtime wants to enable tracing. Read more
Source§

fn runtime_config(&self) -> &RuntimeConfig

Access the runtime config.

Auto Trait Implementations§

§

impl<'m> Freeze for Main<'m>

§

impl<'m> !RefUnwindSafe for Main<'m>

§

impl<'m> !Send for Main<'m>

§

impl<'m> !Sync for Main<'m>

§

impl<'m> Unpin for Main<'m>

§

impl<'m> !UnwindSafe for Main<'m>

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> FutureExt for T

Source§

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more
Source§

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more
Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<P, T> Receiver for P
where P: Deref<Target = T> + ?Sized, T: ?Sized,

Source§

type Target = T

🔬This is a nightly-only experimental API. (arbitrary_self_types)
The target type on which the method may be called.
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<S> SpawnerExt for S
where S: Spawner + ?Sized,

Source§

fn spawn_iter<I>(&mut self, iter: I)
where I: IntoIterator<Item = Pin<Box<dyn Future<Output = Result<()>>>>>,

Source§

fn spawn<F>(&mut self, f: F)
where F: Future<Output = Result<()>> + 'static,

Source§

impl<S> StartupExt for S
where S: Startup + ?Sized,

Source§

fn check_iter<I>(&mut self, iter: I)
where I: IntoIterator<Item = Box<dyn HealthChecked>>,

Add several health checks at once.
Source§

fn check<C>(&mut self, c: C)
where C: HealthChecked + 'static,

Source§

fn spawn_iter<I>(&mut self, iter: I)
where I: IntoIterator<Item = Pin<Box<dyn Future<Output = Result<()>>>>>,

Source§

fn spawn<F>(&mut self, f: F)
where F: Future<Output = Result<()>> + 'static,

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> ErasedDestructor for T
where T: 'static,