Skip to main content

Module queue

caravan_rpc::resources

Module queue 

Source
Expand description

MessageQueue seam + Redis / RabbitMQ / SQS impls.

Enums§

QueueError
Errors from the MessageQueue seam. Serde-serializable for over-the- wire dispatch; serde_json::Error is converted to Json(String) at construction time.

Traits§

MessageQueue
Caravan-owned seam for at-least-once message queues. Decorated with #[wagon] so callers dispatch via client::<dyn MessageQueue>().