Struct SimpleTaskApp

pub struct SimpleTaskApp {
    pub tasks: HandlerMap,
    /* private fields */
}

Fields

tasks: HandlerMap

Implementations

impl SimpleTaskApp

pub fn new(redis_client: Client, concurrency: usize) -> Self

pub fn gen_task_id() -> String

pub fn prepare_stop(&self)

pub fn should_stop(&self) -> bool

pub fn wait_shutdown_background(self: &Arc<Self>)

pub async fn send_task(&self, handler_name: &str, input: Value) -> Result<()>

pub async fn run_task( self: &Arc<Self>, task_id: &str, handler: &Arc<Handler>, input: Value, ) -> Result<()>

pub fn register_handler(&mut self, name: &str, func: HandlerFn)

pub fn log_for_start(&self)

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

Trait Implementations

impl Debug for SimpleTaskApp

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

Formats the value using the given formatter.