CreateSchema creates the db schema if it does not exist.

MigrateEmbeddingDims drops the old embedding column and creates a new one with the correct dimensions.

NewDocumentStore returns a new DocumentStore.

NewMemoryDAO creates a new MemoryDAO.

NewPostgresConn creates a new bun.DB connection to a postgres database using the provided DSN.

NewPostgresConnForQueue creates a new pgx connection to a postgres database using the provided DSN.

NewPostgresMemoryStore returns a new PostgresMemoryStore.

NewSessionDAO is a constructor for the SessionDAO struct.

NewSummaryDAO creates a new SummaryDAO.

MinRowsForIndex is the minimum number of rows required to create an index.

IndexMutexMap stores a mutex for each collection.

DocumentCollectionSchema represents the schema for the DocumentCollectionDAO table.

DocumentSchemaTemplate represents the schema template for Document tables.

MemoryDAO is a data access object for Memory.

MessageVectorStoreSchema stores the embeddings for a message.

SessionDAO implements the SessionManager interface.