Struct Executor

pub struct Executor<C = Channel> { /* private fields */ }

An executor for running jobs.

Implementations

impl<C> Executor<C>

where C: GrpcService<BoxBody> + Clone, C::Error: Into<StdError>, C::ResponseBody: Body<Data = Bytes> + Send + 'static, <C::ResponseBody as Body>::Error: Into<StdError> + Send,

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

Run the executor until an error occurs.

The error includes any errors that would prevent the executor from running, e.g. network errors.

Individual task errors are not included as they are part of the job execution.

impl<C> Executor<C>

pub fn new(client: ExecutorServiceClient<C>) -> Self

Create a new executor.

pub fn with_options( client: ExecutorServiceClient<C>, options: ExecutorOptions, ) -> Self

Create a new executor with the given options.

pub fn options(&self) -> &ExecutorOptions

Get the options of the executor.

pub fn add_handler( &mut self, handler: Arc<dyn ExecutionHandlerRaw + Send + Sync>, )

Add a new handler to the executor.

Panics

Panics if a handler for the same job type is already registered.

pub fn try_add_handler( &mut self, handler: Arc<dyn ExecutionHandlerRaw + Send + Sync>, ) -> Result<()>

Try to add a new handler to the executor.

If a handler for the same job type is already registered, this function will return an error.