redis

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 1, 2025 License: MIT Imports: 6 Imported by: 0

Documentation

Index

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

type RedisOptions

type RedisOptions struct {
	Addr     string
	Password string
	DB       int
	Prefix   string        // Key prefix, default "langgraph:"
	TTL      time.Duration // Expiration for checkpoints, default 0 (no expiration)
}

RedisOptions configuration for Redis connection

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL