kue 0.1.0

Kue is a job queue backed by pg/memory/redis
Documentation
1
2
3
4
5
6
use crate::{KueTask, KueError};

pub trait KueAdapter<R, T: KueTask<R>> {
  fn get_task(&mut self) -> Result<Option<T>, KueError>;
  fn register_result(&mut self, task: &T, result: &Result<R, KueError>) -> Result<(), KueError>;
}