Struct Scheduler

pub(crate) struct Scheduler {
    inbox: SchedBox,
    oboxes: Vec<SchedBox>,
    smtp: SmtpConnectionState,
    smtp_handle: JoinHandle<()>,
    ephemeral_handle: JoinHandle<()>,
    ephemeral_interrupt_send: Sender<()>,
    location_handle: JoinHandle<()>,
    location_interrupt_send: Sender<()>,
    recently_seen_loop: RecentlySeenLoop,
}

Job and connection scheduler.

Fields

inbox: SchedBox

oboxes: Vec<SchedBox>

Optional boxes – mvbox, sentbox.

smtp: SmtpConnectionState

smtp_handle: JoinHandle<()>

ephemeral_handle: JoinHandle<()>

ephemeral_interrupt_send: Sender<()>

location_handle: JoinHandle<()>

location_interrupt_send: Sender<()>

recently_seen_loop: RecentlySeenLoop

Implementations

impl Scheduler

pub async fn start(ctx: &Context) -> Result<Self>

Start the scheduler.

fn boxes(&self) -> Chain<Once<&SchedBox>, Iter<'_, SchedBox>>

fn maybe_network(&self)

fn maybe_network_lost(&self)

fn interrupt_inbox(&self)

fn interrupt_oboxes(&self)

fn interrupt_smtp(&self)

fn interrupt_ephemeral_task(&self)

fn interrupt_location(&self)

fn interrupt_recently_seen(&self, contact_id: ContactId, timestamp: i64)

pub(crate) async fn stop(self, context: &Context)

Halt the scheduler.

It consumes the scheduler and never fails to stop it. In the worst case, long-running tasks are forcefully terminated if they cannot shutdown within the timeout.

Trait Implementations

impl Debug for Scheduler

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

Formats the value using the given formatter.