Get data from the bound MPSC channel. To cooperate with close(), hold MqShutdownCtl._op_lock before entering the underlying get_data

Create the requested number of shared store instances. Args: key_prefix: Prefix for store instance names. count: Number of s

Unified keepalive entrypoint: etcd leases go through the async keepalive pipeline; kvclient leases are registered into the same TTL actor with a Rust

Replace tokens inside values of nested (dict/list/str) structures. Keys are kept as-is. Token substitution inside keys is forbidden to avoid sche

Acquire a permit for the given key, creating the semaphore lazily if needed.

测试前清理 etcd key

Convert a standard exception to an ApiError.

Worker execution trusts the persisted manifest instead of rescanning the batch root. This keeps retries deterministic and aligned with what the schedu

Borrow the pointee behind a heap-backed stable owner. English note: - This is a tiny semantic helper, not a new execution primitive. - The returned `

获取 etcd endpoint（从项目根目录的 build_config_ext.yml 读取）

获取指定 key 的锁 # 参数 `key` - 锁的键值 # 返回值 返回 Arc<parking_lot::Mutex<()>>，可以在多个线程间共享