Struct SerdeCheckpointCodec 

pub struct SerdeCheckpointCodec<S: WorkflowState = State> { /* private fields */ }

基于 Serde + JSON 的默认 Codec 实现。

使用 serde_json 进行序列化，适用于大多数场景。 对于性能敏感场景，可替换为 Bincode 或 MessagePack。

Implementations

impl<S: WorkflowState> SerdeCheckpointCodec<S>

pub fn new() -> Self

Trait Implementations

impl<S> CheckpointCodec<S> for SerdeCheckpointCodec<S>

where S: WorkflowState + Serialize + for<'de> Deserialize<'de>,

fn serialize( &self, cp: &Checkpoint<S>, graph_hash: u64, ) -> Result<CheckpointBlob, CheckpointStoreError>

将 Checkpoint 序列化为二进制 Blob。

fn deserialize( &self, blob: &CheckpointBlob, expected_hash: u64, ) -> Result<Checkpoint<S>, CheckpointStoreError>

从二进制 Blob 反序列化为 Checkpoint。

impl<S: Debug + WorkflowState> Debug for SerdeCheckpointCodec<S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<S: Default + WorkflowState> Default for SerdeCheckpointCodec<S>

fn default() -> SerdeCheckpointCodec<S>

Returns the “default value” for a type.