Documentation
¶
Index ¶
- type RedisCheckpointStore
- func (s *RedisCheckpointStore) Clear(ctx context.Context, executionID string) error
- func (s *RedisCheckpointStore) Delete(ctx context.Context, checkpointID string) error
- func (s *RedisCheckpointStore) List(ctx context.Context, executionID string) ([]*graph.Checkpoint, error)
- func (s *RedisCheckpointStore) Load(ctx context.Context, checkpointID string) (*graph.Checkpoint, error)
- func (s *RedisCheckpointStore) Save(ctx context.Context, checkpoint *graph.Checkpoint) error
- type RedisOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RedisCheckpointStore ¶
type RedisCheckpointStore struct {
// contains filtered or unexported fields
}
RedisCheckpointStore implements graph.CheckpointStore using Redis
func NewRedisCheckpointStore ¶
func NewRedisCheckpointStore(opts RedisOptions) *RedisCheckpointStore
NewRedisCheckpointStore creates a new Redis checkpoint store
func (*RedisCheckpointStore) Clear ¶
func (s *RedisCheckpointStore) Clear(ctx context.Context, executionID string) error
Clear removes all checkpoints for an execution
func (*RedisCheckpointStore) Delete ¶
func (s *RedisCheckpointStore) Delete(ctx context.Context, checkpointID string) error
Delete removes a checkpoint
func (*RedisCheckpointStore) List ¶
func (s *RedisCheckpointStore) List(ctx context.Context, executionID string) ([]*graph.Checkpoint, error)
List returns all checkpoints for a given execution
func (*RedisCheckpointStore) Load ¶
func (s *RedisCheckpointStore) Load(ctx context.Context, checkpointID string) (*graph.Checkpoint, error)
Load retrieves a checkpoint by ID
func (*RedisCheckpointStore) Save ¶
func (s *RedisCheckpointStore) Save(ctx context.Context, checkpoint *graph.Checkpoint) error
Save stores a checkpoint
Click to show internal directories.
Click to hide internal directories.