memorystore

package

Go to main page

Versions in this module

v0

v0.8.1

Jul 14, 2023

v0.8.0

Jul 8, 2023

Changes in this version

type PostgresMemoryStore

+ func (pms *PostgresMemoryStore) GetSession(ctx context.Context, _ *models.AppState, sessionID string) (*models.Session, error)

+ func (pms *PostgresMemoryStore) PutSession(ctx context.Context, _ *models.AppState, session *models.Session) error

v0.7.1

Jun 26, 2023

Changes in this version

type PostgresMemoryStore

+ func (pms *PostgresMemoryStore) PurgeDeleted(ctx context.Context) error

v0.7.0

Jun 21, 2023

v0.6.6

Jun 16, 2023

v0.6.5

Jun 16, 2023

v0.6.0

Jun 3, 2023

Changes in this version

+ type JSONQuery struct

+ And []*JSONQuery

+ JSONPath string

+ Or []*JSONQuery

v0.5.1

May 26, 2023

v0.5.0

May 26, 2023

Changes in this version

type PostgresMemoryStore

+ func (pms *PostgresMemoryStore) PutMessageMetadata(ctx context.Context, _ *models.AppState, sessionID string, ...) error

v0.4.6

May 24, 2023

v0.4.5

May 21, 2023

v0.4.4

May 18, 2023

v0.4.3

May 16, 2023

v0.4.2

May 15, 2023

Changes in this version

+ func CleanDB(t *testing.T, db *bun.DB)

+ func NewPostgresConn(dsn string) *bun.DB

+ type BaseMemoryStore struct

+ Client T

+ func (s *BaseMemoryStore[T]) Attach(observer models.Extractor)

+ func (s *BaseMemoryStore[T]) NotifyExtractors(ctx context.Context, appState *models.AppState, eventData *models.MessageEvent)

+ type PgMessageStore struct

+ Content string

+ CreatedAt time.Time

+ DeletedAt time.Time

+ ID int64

+ Metadata map[string]interface{}

+ Role string

+ Session *PgSession

+ SessionID string

+ TokenCount int

+ UUID uuid.UUID

+ UpdatedAt time.Time

+ func (*PgMessageStore) AfterCreateTable(ctx context.Context, query *bun.CreateTableQuery) error

+ func (s *PgMessageStore) BeforeCreateTable(_ context.Context, _ *bun.CreateTableQuery) error

+ type PgMessageVectorStore struct

+ CreatedAt time.Time

+ DeletedAt time.Time

+ Embedding pgvector.Vector

+ IsEmbedded bool

+ Message *PgMessageStore

+ MessageUUID uuid.UUID

+ Session *PgSession

+ SessionID string

+ UUID uuid.UUID

+ UpdatedAt time.Time

+ func (*PgMessageVectorStore) AfterCreateTable(ctx context.Context, query *bun.CreateTableQuery) error

+ func (s *PgMessageVectorStore) BeforeCreateTable(_ context.Context, _ *bun.CreateTableQuery) error

+ type PgSession struct

+ CreatedAt time.Time

+ DeletedAt time.Time

+ Metadata map[string]interface{}

+ SessionID string

+ UUID uuid.UUID

+ UpdatedAt time.Time

+ func (*PgSession) AfterCreateTable(ctx context.Context, query *bun.CreateTableQuery) error

+ func (s *PgSession) BeforeCreateTable(_ context.Context, _ *bun.CreateTableQuery) error

+ type PgSummaryStore struct

+ Content string

+ CreatedAt time.Time

+ DeletedAt time.Time

+ Message *PgMessageStore

+ Metadata map[string]interface{}

+ Session *PgSession

+ SessionID string

+ SummaryPointUUID uuid.UUID

+ TokenCount int

+ UUID uuid.UUID

+ UpdatedAt time.Time

+ func (*PgSummaryStore) AfterCreateTable(ctx context.Context, query *bun.CreateTableQuery) error

+ func (s *PgSummaryStore) BeforeCreateTable(_ context.Context, _ *bun.CreateTableQuery) error

+ type PostgresMemoryStore struct

+ func NewPostgresMemoryStore(appState *models.AppState, client *bun.DB) (*PostgresMemoryStore, error)

+ func (pms *PostgresMemoryStore) Close() error

+ func (pms *PostgresMemoryStore) DeleteSession(ctx context.Context, sessionID string) error

+ func (pms *PostgresMemoryStore) GetClient() *bun.DB

+ func (pms *PostgresMemoryStore) GetMemory(ctx context.Context, appState *models.AppState, sessionID string, ...) (*models.Memory, error)

+ func (pms *PostgresMemoryStore) GetMessageVectors(ctx context.Context, _ *models.AppState, sessionID string) ([]models.Embeddings, error)

+ func (pms *PostgresMemoryStore) GetSummary(ctx context.Context, _ *models.AppState, sessionID string) (*models.Summary, error)

+ func (pms *PostgresMemoryStore) OnStart(_ context.Context, _ *models.AppState) error

+ func (pms *PostgresMemoryStore) PutMemory(ctx context.Context, appState *models.AppState, sessionID string, ...) error

+ func (pms *PostgresMemoryStore) PutMessageVectors(ctx context.Context, _ *models.AppState, sessionID string, ...) error

+ func (pms *PostgresMemoryStore) PutSummary(ctx context.Context, _ *models.AppState, sessionID string, ...) error

+ func (pms *PostgresMemoryStore) SearchMemory(ctx context.Context, appState *models.AppState, sessionID string, ...) ([]models.SearchResult, error)

+ type StorageError struct

+ func NewStorageError(message string, originalError error) *StorageError

+ func (e *StorageError) Error() string

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