Skip to main content

TaskManager

Struct TaskManager 

Source
pub struct TaskManager { /* private fields */ }
๐Ÿ‘ŽDeprecated:

use ShutdownManager instead

Expand description

Listens to status and error messages from tasks, as well as notifying them to gracefully shutdown. Keeps track of if task stop unexpectedly, such as in a panic.

Implementationsยง

Sourceยง

impl TaskManager

Source

pub fn new(shutdown_timer_secs: u64) -> Self

Source

pub fn named<S: Into<String>>(self, name: S) -> Self

Source

pub async fn catch_interrupt( &mut self, ) -> Result<(), Box<dyn Error + Send + Sync>>

Source

pub fn subscribe(&self) -> TaskClient

Source

pub fn subscribe_named<S: Into<String>>(&self, suffix: S) -> TaskClient

Source

pub fn signal_shutdown(&self) -> Result<(), SendError<()>>

Source

pub async fn start_status_listener( &mut self, sender: StatusSender, start_status: TaskStatus, )

Source

pub async fn wait_for_error(&mut self) -> Option<Box<dyn Error + Send + Sync>>

Source

pub async fn wait_for_graceful_shutdown(&mut self)

Source

pub async fn wait_for_shutdown(&mut self)

Trait Implementationsยง

Sourceยง

impl Debug for TaskManager

Sourceยง

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Sourceยง

impl Default for TaskManager

Sourceยง

fn default() -> Self

Returns the โ€œdefault valueโ€ for a type. Read more
Sourceยง

impl From<TaskManager> for TaskHandle

Sourceยง

fn from(value: TaskManager) -> Self

Converts to this type from the input type.

Auto Trait Implementationsยง

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> 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<T, U> TryFrom<U> for T
where U: Into<T>,

Sourceยง

type Error = !

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

fn try_from(value: U) -> Result<T, !>

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