Struct fisher_processor::Processor
[−]
[src]
pub struct Processor<S: ScriptsRepositoryTrait + 'static> { /* fields omitted */ }
This struct allows you to spawn a new processor, stop it and get its
ProcessorApi.
Methods
impl<S: ScriptsRepositoryTrait> Processor<S>[src]
fn new(
max_threads: u16,
hooks: Arc<S>,
ctx: Arc<<<S as ScriptsRepositoryTrait>::Job as JobTrait<<S as ScriptsRepositoryTrait>::Script>>::Context>,
state: Arc<State>
) -> Result<Self>
max_threads: u16,
hooks: Arc<S>,
ctx: Arc<<<S as ScriptsRepositoryTrait>::Job as JobTrait<<S as ScriptsRepositoryTrait>::Script>>::Context>,
state: Arc<State>
) -> Result<Self>
Create a new processor with the provided configuration. The returned struct allows you to control it.
fn stop(self) -> Result<()>
Stop this processor, and return only when the processor is stopped.
fn api(&self) -> ProcessorApi<S>
Get a struct allowing you to control the processor.