Enum Control 

pub enum Control {
    Start,
    Stop,
    GracefulStop {
        signal: Signal,
        grace: Duration,
    },
    TryRestart,
    TryGracefulRestart {
        signal: Signal,
        grace: Duration,
    },
    ContinueTryGracefulRestart,
    Signal(Signal),
    Delete,
    NextEnding,
    SyncFunc(Box<dyn FnOnce(&JobTaskContext<'_>) + Send + Sync + 'static>),
    AsyncFunc(Box<dyn FnOnce(&JobTaskContext<'_>) -> Box<dyn Future<Output = ()> + Send + Sync> + Send + Sync + 'static>),
    SetSyncSpawnHook(Arc<dyn Fn(&mut TokioCommandWrap, &JobTaskContext<'_>) + Send + Sync + 'static>),
    SetAsyncSpawnHook(Arc<dyn Fn(&mut TokioCommandWrap, &JobTaskContext<'_>) -> Box<dyn Future<Output = ()> + Send + Sync> + Send + Sync + 'static>),
    UnsetSpawnHook,
    SetSyncErrorHandler(Arc<dyn Fn(SyncIoError) + Send + Sync + 'static>),
    SetAsyncErrorHandler(Arc<dyn Fn(SyncIoError) -> Box<dyn Future<Output = ()> + Send + Sync> + Send + Sync + 'static>),
    UnsetErrorHandler,
}

The underlying control message types for Job.

You may use Job::control() to send these messages directly, but in general should prefer the higher-level methods on Job itself.

Variants

Start

For Job::start().

Stop

For Job::stop().

GracefulStop

For Job::stop_with_signal().

Fields

signal: Signal

Signal to send immediately

grace: Duration

Time to wait before forceful termination

TryRestart

For Job::try_restart().

TryGracefulRestart

For Job::try_restart_with_signal().

Fields

signal: Signal

Signal to send immediately

grace: Duration

Time to wait before forceful termination and restart

ContinueTryGracefulRestart

Internal implementation detail of Control::TryGracefulRestart.

Signal(Signal)

For Job::signal().

Delete

For Job::delete() and Job::delete_now().

NextEnding

For Job::to_wait().

SyncFunc(Box<dyn FnOnce(&JobTaskContext<'_>) + Send + Sync + 'static>)

For Job::run().

AsyncFunc(Box<dyn FnOnce(&JobTaskContext<'_>) -> Box<dyn Future<Output = ()> + Send + Sync> + Send + Sync + 'static>)

For Job::run_async().

SetSyncSpawnHook(Arc<dyn Fn(&mut TokioCommandWrap, &JobTaskContext<'_>) + Send + Sync + 'static>)

For Job::set_spawn_hook().

SetAsyncSpawnHook(Arc<dyn Fn(&mut TokioCommandWrap, &JobTaskContext<'_>) -> Box<dyn Future<Output = ()> + Send + Sync> + Send + Sync + 'static>)

For Job::set_spawn_async_hook().

UnsetSpawnHook

For Job::unset_spawn_hook().

SetSyncErrorHandler(Arc<dyn Fn(SyncIoError) + Send + Sync + 'static>)

For Job::set_error_handler().

SetAsyncErrorHandler(Arc<dyn Fn(SyncIoError) -> Box<dyn Future<Output = ()> + Send + Sync> + Send + Sync + 'static>)

For Job::set_async_error_handler().

UnsetErrorHandler

For Job::unset_error_handler().

Trait Implementations

impl Debug for Control

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

Formats the value using the given formatter.