checkpoint

type Checkpoint struct {
	ID         string          `json:"id"`
	ProjectID  string          `json:"project_id,omitempty"`
	WorkflowID string          `json:"workflow_id"`
	SessionID  string          `json:"session_id,omitempty"`
	RunID      string          `json:"run_id"`
	NodeID     string          `json:"node_id"`
	ParentID   string          `json:"parent_id,omitempty"`
	Sequence   int64           `json:"sequence"`
	State      json.RawMessage `json:"state"`
	CreatedAt  time.Time       `json:"created_at"`
}

type JSONSerializer[S any] struct{}

type MemoryStore struct {
	// contains filtered or unexported fields
}

type Serializer[S any] interface {
	Marshal(S) (json.RawMessage, error)
	Unmarshal(json.RawMessage) (S, error)
}

type Store interface {
	Save(context.Context, Checkpoint) (Checkpoint, error)
	Load(context.Context, string) (Checkpoint, error)
	List(context.Context, string) ([]Checkpoint, error)
	Latest(context.Context, string) (Checkpoint, bool, error)
}