Documentation
¶
Overview ¶
Package file provides file-based checkpoint storage implementation.
Index ¶
- func NewFileCheckpointStore(path string) (store.CheckpointStore, error)
- type FileCheckpointStore
- func (f *FileCheckpointStore) Clear(ctx context.Context, executionID string) error
- func (f *FileCheckpointStore) Delete(_ context.Context, checkpointID string) error
- func (f *FileCheckpointStore) GetLatestByThread(ctx context.Context, threadID string) (*store.Checkpoint, error)
- func (f *FileCheckpointStore) List(_ context.Context, executionID string) ([]*store.Checkpoint, error)
- func (f *FileCheckpointStore) ListByThread(_ context.Context, threadID string) ([]*store.Checkpoint, error)
- func (f *FileCheckpointStore) Load(_ context.Context, checkpointID string) (*store.Checkpoint, error)
- func (f *FileCheckpointStore) Save(_ context.Context, checkpoint *store.Checkpoint) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewFileCheckpointStore ¶
func NewFileCheckpointStore(path string) (store.CheckpointStore, error)
NewFileCheckpointStore creates a new file-based checkpoint store
Types ¶
type FileCheckpointStore ¶
type FileCheckpointStore struct {
// contains filtered or unexported fields
}
FileCheckpointStore provides file-based checkpoint storage
func (*FileCheckpointStore) Clear ¶
func (f *FileCheckpointStore) Clear(ctx context.Context, executionID string) error
Clear implements CheckpointStore interface for file storage
func (*FileCheckpointStore) Delete ¶
func (f *FileCheckpointStore) Delete(_ context.Context, checkpointID string) error
Delete implements CheckpointStore interface for file storage
func (*FileCheckpointStore) GetLatestByThread ¶ added in v0.8.2
func (f *FileCheckpointStore) GetLatestByThread(ctx context.Context, threadID string) (*store.Checkpoint, error)
GetLatestByThread returns the latest checkpoint for a thread_id
func (*FileCheckpointStore) List ¶
func (f *FileCheckpointStore) List(_ context.Context, executionID string) ([]*store.Checkpoint, error)
List implements CheckpointStore interface for file storage
func (*FileCheckpointStore) ListByThread ¶ added in v0.8.2
func (f *FileCheckpointStore) ListByThread(_ context.Context, threadID string) ([]*store.Checkpoint, error)
ListByThread returns all checkpoints for a specific thread_id using index
func (*FileCheckpointStore) Load ¶
func (f *FileCheckpointStore) Load(_ context.Context, checkpointID string) (*store.Checkpoint, error)
Load implements CheckpointStore interface for file storage
func (*FileCheckpointStore) Save ¶
func (f *FileCheckpointStore) Save(_ context.Context, checkpoint *store.Checkpoint) error
Save implements CheckpointStore interface for file storage
Source Files
Click to show internal directories.
Click to hide internal directories.