platform_runtime/queues.rs
1#[derive(Debug, Clone, PartialEq, Eq, PartialOrd, Ord, Hash)]
2pub struct QueueName(pub &'static str);
3
4#[derive(Debug, Clone)]
5pub struct Queue {
6 pub name: QueueName,
7 pub concurrency: usize,
8}
9
10impl Queue {
11 pub fn new(name: &'static str, concurrency: usize) -> Self {
12 Self {
13 name: QueueName(name),
14 concurrency,
15 }
16 }
17}