Struct Runtime 

pub struct Runtime { /* private fields */ }

Automation runtime that manages concurrent task lifecycles.

The runtime owns a CancellationToken shared by all spawned tasks and collects their JoinHandles for graceful shutdown. It does not own specific business dependencies – those are passed when spawning individual loops.

Implementations

impl Runtime

pub fn new() -> Self

Create a new runtime with a fresh cancellation token.

pub fn cancel_token(&self) -> CancellationToken

Return a clone of the cancellation token for passing to tasks.

pub fn spawn<F>(&mut self, name: impl Into<String>, future: F)

where F: Future<Output = ()> + Send + 'static,

Spawn an automation task with a descriptive name.

The task’s JoinHandle is tracked for shutdown. The task should check CancellationToken::is_cancelled() in its loop to exit gracefully when shutdown is initiated.

pub fn task_count(&self) -> usize

Return the number of spawned tasks.

pub async fn shutdown(&mut self)

Initiate graceful shutdown.

1. Cancels the token, signaling all tasks to stop.
2. Awaits all JoinHandles with a 30-second timeout.
3. If timeout is exceeded, logs a warning (caller decides whether to force-exit).

pub async fn run_until_shutdown(self)

Block until a shutdown signal is received, then gracefully stop all tasks.

This is the typical entry point for the tuitbot run command:

1. Spawn all tasks.
2. Call run_until_shutdown() to block until Ctrl+C / SIGTERM.
3. All tasks are stopped and awaited.

Trait Implementations

impl Default for Runtime

fn default() -> Self

Returns the “default value” for a type.