1 个不稳定版本
| 0.0.3 | 2022年6月14日 |
|---|
#7 在 #key-id
17KB
254 代码行
etcdmq
基于 etcd 的简单消息队列
两个输入-观察者和列表器。观察者订阅键空间中的事件，并将键 ID 添加到队列列表器列出键空间中的所有键，并将每个项目添加到队列中
- 循环读取队列。选择一个作业 ID
- 客户端开始事务
- 检查键是否存在
- 如果存在，则删除键
- 如果不存在，则列出键，并尝试随机键
- 从 /job 读取作业数据
- 返回任务对象
- 在释放时，Task 将任务状态从 TaskState::CONSUMED 移动到 TaskState::COMPLETED
依赖项
~8–17MB
~207K SLoC