memory

Documentation

Overview

Package memory provides in-memory checkpoint storage implementation.

Index

• func NewMemoryCheckpointStore() store.CheckpointStore
• type MemoryCheckpointStore
  • func (m *MemoryCheckpointStore) Clear(_ context.Context, executionID string) error
  • func (m *MemoryCheckpointStore) Delete(_ context.Context, checkpointID string) error
  • func (m *MemoryCheckpointStore) GetLatestByThread(_ context.Context, threadID string) (*store.Checkpoint, error)
  • func (m *MemoryCheckpointStore) List(_ context.Context, executionID string) ([]*store.Checkpoint, error)
  • func (m *MemoryCheckpointStore) ListByThread(_ context.Context, threadID string) ([]*store.Checkpoint, error)
  • func (m *MemoryCheckpointStore) Load(_ context.Context, checkpointID string) (*store.Checkpoint, error)
  • func (m *MemoryCheckpointStore) Save(_ context.Context, checkpoint *store.Checkpoint) error

Functions

func NewMemoryCheckpointStore

func NewMemoryCheckpointStore() store.CheckpointStore

NewMemoryCheckpointStore creates a new in-memory checkpoint store

Types

type MemoryCheckpointStore

type MemoryCheckpointStore struct {
	// contains filtered or unexported fields
}

MemoryCheckpointStore provides in-memory checkpoint storage

func (*MemoryCheckpointStore) Clear

func (m *MemoryCheckpointStore) Clear(_ context.Context, executionID string) error

Clear implements CheckpointStore interface

func (*MemoryCheckpointStore) Delete

func (m *MemoryCheckpointStore) Delete(_ context.Context, checkpointID string) error

Delete implements CheckpointStore interface

func (*MemoryCheckpointStore) GetLatestByThread

func (m *MemoryCheckpointStore) GetLatestByThread(_ context.Context, threadID string) (*store.Checkpoint, error)

GetLatestByThread returns the latest checkpoint for a thread_id

func (*MemoryCheckpointStore) List

func (m *MemoryCheckpointStore) List(_ context.Context, executionID string) ([]*store.Checkpoint, error)

List implements CheckpointStore interface

func (*MemoryCheckpointStore) ListByThread

func (m *MemoryCheckpointStore) ListByThread(_ context.Context, threadID string) ([]*store.Checkpoint, error)

ListByThread returns all checkpoints for a specific thread_id

func (*MemoryCheckpointStore) Load

func (m *MemoryCheckpointStore) Load(_ context.Context, checkpointID string) (*store.Checkpoint, error)

Load implements CheckpointStore interface

func (*MemoryCheckpointStore) Save

func (m *MemoryCheckpointStore) Save(_ context.Context, checkpoint *store.Checkpoint) error

Save implements CheckpointStore interface