Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNotFound = errors.New("checkpoint: not found")
Functions ¶
This section is empty.
Types ¶
type Entry ¶
type Entry struct {
ID string
SessionID string
Remaining *pipeline.Step
Input pipeline.Input
Result pipeline.Result
CreatedAt time.Time
}
Entry captures the resumable state after a pipeline interruption.
type FileStore ¶
type FileStore struct {
// contains filtered or unexported fields
}
FileStore persists checkpoint entries as JSON on disk.
func NewFileStore ¶
type MemoryStore ¶
type MemoryStore struct {
// contains filtered or unexported fields
}
MemoryStore keeps checkpoint state in memory for the lifetime of the runtime.
func NewMemoryStore ¶
func NewMemoryStore() *MemoryStore
Click to show internal directories.
Click to hide internal directories.