pub struct FrameInfo {
pub node_id: String,
pub step: usize,
}Expand description
Checkpoint 边界描述 — Engine 传递给 Sink 的最小上下文。
设计原则:极简。Engine 只传递“我到了哪里“,Sink 自行决定 是否记录、如何记录、记录多少。
- 想做节流?Sink 自己维护计数器。
- 想做脏检查?Sink 自己缓存上次 snapshot 的 hash。
- 想过滤特定节点?Sink 匹配
node_id。
Fields§
§node_id: String当前节点 ID(commit 刚完成的节点)
step: usize执行步数(从 run_inline 入口开始计数)
Implementations§
Trait Implementations§
Auto Trait Implementations§
impl Freeze for FrameInfo
impl RefUnwindSafe for FrameInfo
impl Send for FrameInfo
impl Sync for FrameInfo
impl Unpin for FrameInfo
impl UnsafeUnpin for FrameInfo
impl UnwindSafe for FrameInfo
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more