1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37
use crate::compat::boxed::Box;
use crate::{async_trait, Result};
/// Defines an interface for Ockam Workers that need to continuously
/// perform background operations.
#[async_trait]
pub trait Processor: Send + 'static {
/// The Ockam API Context and other resources available for the
/// processor during processing.
type Context: Send + 'static;
/// Define the Processor Worker initialisation behaviour.
async fn initialize(&mut self, _context: &mut Self::Context) -> Result<()> {
Ok(())
}
/// Define the Processor Worker shutdown behaviour.
async fn shutdown(&mut self, _context: &mut Self::Context) -> Result<()> {
Ok(())
}
/// Define the Processor Worker background execution behaviour.
///
/// The `process()` callback function allows you to define worker
/// behaviour that will be executed at regular intervals.
///
/// It's important to not block this function for long periods of
/// time as it is co-operatively scheduled by the underlying async
/// runtime and will block all other Ockam Node operations until
/// it returns.
///
/// When in doubt, prefer async `.await` operations where they are
/// available.
async fn process(&mut self, _context: &mut Self::Context) -> Result<bool> {
Ok(false)
}
}