upub-worker 0.3.1

upub background activity processing and dispatching workers
Documentation 
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

pub mod dispatcher;
pub mod inbound;
pub mod outbound;
pub mod delivery;

pub use dispatcher::{JobError, JobResult};

pub fn spawn(
	ctx: upub::Context,
	concurrency: usize,
	poll: u64,
	filter: Option<upub::model::job::JobType>,
	stop: impl StopToken,
	wake: impl WakeToken,
) -> tokio::task::JoinHandle<()> {
	use dispatcher::JobDispatcher;
	tokio::spawn(async move {
		tracing::info!("starting worker task");
		ctx.run(concurrency, poll, filter, stop, wake).await
	})
}

pub trait StopToken: Sync + Send + 'static {
	fn stop(&self) -> bool;
}

pub trait WakeToken: Sync + Send + 'static {
	//                    TODO this is bs...
	fn wait(&mut self) -> impl std::future::Future<Output = ()> + std::marker::Send;
}