Versions in this module Expand all Collapse all v0 v0.1.0 Sep 1, 2026 Changes in this version + type FileSystemJSONStore struct + func NewFileSystemJSONStore(rootDir string) (*FileSystemJSONStore, error) + func (s *FileSystemJSONStore) Close() error + func (s *FileSystemJSONStore) CreateCheckpoint(_ context.Context, sessionID string, data json.RawMessage, ...) (workflow.CheckpointInfo, error) + func (s *FileSystemJSONStore) RetrieveCheckpoint(_ context.Context, sessionID string, info workflow.CheckpointInfo) (json.RawMessage, error) + func (s *FileSystemJSONStore) RetrieveIndex(_ context.Context, sessionID string, withParent *workflow.CheckpointInfo) ([]workflow.CheckpointInfo, error) + type Manager interface + LatestCheckpoint func(ctx context.Context, sessionID string) (*workflow.CheckpointInfo, error) + func NewInMemoryManager() Manager + func NewJSONManager(store Store[json.RawMessage]) Manager + type Store interface + CreateCheckpoint func(ctx context.Context, sessionID string, data T, parent *workflow.CheckpointInfo) (workflow.CheckpointInfo, error) + RetrieveCheckpoint func(ctx context.Context, sessionID string, info workflow.CheckpointInfo) (T, error) + RetrieveIndex func(ctx context.Context, sessionID string, withParent *workflow.CheckpointInfo) ([]workflow.CheckpointInfo, error)
Go to main page