Documentation
¶
Overview ¶
Package orchestration 提供任务编排与调度机制,解决"按时间/顺序/事务语义执行一组工作"的问题。
选包标准:
- 核心能力是编排多步骤/延时/定时任务
- 不涉及实时游戏逻辑(那属于 game/)
- 可依赖 foundation/、resilience/(如 backoff)、store/(如 dlock)
已有子包:
saga — Saga 模式(补偿事务编排) txn — 本地事务辅助 worker — 后台 Worker 池(依赖 store/dlock) scheduler — 异步任务调度器(Submit/Pause/Resume) timerqueue — 最小堆延时队列(beauty.Service 集成,适合大量倒计时) delayqueue — 精确 time.Timer 延时队列(一次性任务) jobqueue — 带优先级/进度/生命周期事件的任务队列(BullMQ 风格)
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package delayqueue 提供定点单次触发的延迟任务原语:注册一个未来时刻要执行的 回调,到点由后台 goroutine 触发;支持按 key 取消 / 改期。
|
Package delayqueue 提供定点单次触发的延迟任务原语:注册一个未来时刻要执行的 回调,到点由后台 goroutine 触发;支持按 key 取消 / 改期。 |
|
Package jobqueue 提供带优先级、进度上报、生命周期事件的任务队列。
|
Package jobqueue 提供带优先级、进度上报、生命周期事件的任务队列。 |
|
Package saga 提供跨服务 Saga 编排:按顺序执行一组"正向操作",任一步失败时 逆序执行已成功步骤的"补偿操作",达成最终一致。
|
Package saga 提供跨服务 Saga 编排:按顺序执行一组"正向操作",任一步失败时 逆序执行已成功步骤的"补偿操作",达成最终一致。 |
|
Package scheduler 提供工作池式任务调度器:生产者把任务投递到队列, N 个 worker goroutine 并发消费;支持运行时 Pause/Resume 与优雅停止。
|
Package scheduler 提供工作池式任务调度器:生产者把任务投递到队列, N 个 worker goroutine 并发消费;支持运行时 Pause/Resume 与优雅停止。 |
|
Package tcc 提供 TCC(Try-Confirm-Cancel)事务编排原语,用于涉及资金/道具的 强一致性分布式操作。
|
Package tcc 提供 TCC(Try-Confirm-Cancel)事务编排原语,用于涉及资金/道具的 强一致性分布式操作。 |
|
Package timerqueue 提供基于最小堆的延时任务队列,由单协程驱动,适用于海量 倒计时场景(如 SLG 建筑升级、科技研究、造兵、Buff 过期等)。
|
Package timerqueue 提供基于最小堆的延时任务队列,由单协程驱动,适用于海量 倒计时场景(如 SLG 建筑升级、科技研究、造兵、Buff 过期等)。 |
|
Package txn 提供跨域事务协调:让 wallet/storage/notification 等域包 在一个逻辑事务边界内原子提交或全部回滚。
|
Package txn 提供跨域事务协调:让 wallet/storage/notification 等域包 在一个逻辑事务边界内原子提交或全部回滚。 |
|
Package worker 提供可组合到 beauty.App 的后台工作者 Service 实现。
|
Package worker 提供可组合到 beauty.App 的后台工作者 Service 实现。 |
Click to show internal directories.
Click to hide internal directories.