postgres

package

Go to main page

Versions in this module

v0

v0.16.0

Apr 19, 2026

v0.15.0

Apr 16, 2026

v0.14.0

Apr 10, 2026

v0.13.0

Mar 29, 2026

v0.12.1

Mar 19, 2026

v0.12.0

Mar 19, 2026

v0.11.0

Mar 19, 2026

v0.10.0

Mar 5, 2026

Changes in this version

+ func ConfigurePoolConfig(cfg *pgxpool.Config, opts ...Option)

type Option

+ func WithLogger(l *slog.Logger) Option

type Store

+ func (s *Store) DeleteCheckpoint(ctx context.Context, id string) error

+ func (s *Store) GetBothEdges(ctx context.Context, chunkIDs []string) ([]oasis.ChunkEdge, error)

+ func (s *Store) GetChunksByDocument(ctx context.Context, docID string) ([]oasis.Chunk, error)

+ func (s *Store) GetDocumentsByIDs(ctx context.Context, ids []string) ([]oasis.Document, error)

+ func (s *Store) ListCheckpoints(ctx context.Context) ([]oasis.IngestCheckpoint, error)

+ func (s *Store) ListDocumentMeta(ctx context.Context, limit int) ([]oasis.Document, error)

+ func (s *Store) LoadCheckpoint(ctx context.Context, id string) (oasis.IngestCheckpoint, error)

+ func (s *Store) SaveCheckpoint(ctx context.Context, cp oasis.IngestCheckpoint) error

v0.9.0

Feb 25, 2026

v0.8.0

Feb 24, 2026

v0.7.0

Feb 22, 2026

v0.6.0

Feb 21, 2026

Changes in this version

type Store

+ func (s *Store) GetEdges(ctx context.Context, chunkIDs []string) ([]oasis.ChunkEdge, error)

+ func (s *Store) GetIncomingEdges(ctx context.Context, chunkIDs []string) ([]oasis.ChunkEdge, error)

+ func (s *Store) PruneOrphanEdges(ctx context.Context) (int, error)

+ func (s *Store) StoreEdges(ctx context.Context, edges []oasis.ChunkEdge) error

v0.5.0

Feb 19, 2026

Changes in this version

+ type Option func(*pgConfig)

+ func WithEFConstruction(ef int) Option

+ func WithEFSearch(ef int) Option

+ func WithEmbeddingDimension(dim int) Option

+ func WithHNSWM(m int) Option

type Store

+ func (s *Store) DeleteDocument(ctx context.Context, id string) error

+ func (s *Store) ListDocuments(ctx context.Context, limit int) ([]oasis.Document, error)

v0.4.0

Feb 19, 2026

v0.3.2

Feb 19, 2026

v0.3.1

Feb 19, 2026

v0.3.0

Feb 19, 2026

Changes in this version

+ type MemoryStore struct

+ func NewMemoryStore(pool *pgxpool.Pool) *MemoryStore

+ func (s *MemoryStore) BuildContext(ctx context.Context, queryEmbedding []float32) (string, error)

+ func (s *MemoryStore) DecayOldFacts(ctx context.Context) error

+ func (s *MemoryStore) DeleteFact(ctx context.Context, factID string) error

+ func (s *MemoryStore) DeleteMatchingFacts(ctx context.Context, pattern string) error

+ func (s *MemoryStore) Init(ctx context.Context) error

+ func (s *MemoryStore) SearchFacts(ctx context.Context, embedding []float32, topK int) ([]oasis.ScoredFact, error)

+ func (s *MemoryStore) UpsertFact(ctx context.Context, fact, category string, embedding []float32) error

+ type Store struct

+ func New(pool *pgxpool.Pool) *Store

+ func (s *Store) Close() error

+ func (s *Store) CreateScheduledAction(ctx context.Context, action oasis.ScheduledAction) error

+ func (s *Store) CreateSkill(ctx context.Context, skill oasis.Skill) error

+ func (s *Store) CreateThread(ctx context.Context, thread oasis.Thread) error

+ func (s *Store) DeleteAllScheduledActions(ctx context.Context) (int, error)

+ func (s *Store) DeleteScheduledAction(ctx context.Context, id string) error

+ func (s *Store) DeleteSkill(ctx context.Context, id string) error

+ func (s *Store) DeleteThread(ctx context.Context, id string) error

+ func (s *Store) FindScheduledActionsByDescription(ctx context.Context, pattern string) ([]oasis.ScheduledAction, error)

+ func (s *Store) GetChunksByIDs(ctx context.Context, ids []string) ([]oasis.Chunk, error)

+ func (s *Store) GetConfig(ctx context.Context, key string) (string, error)

+ func (s *Store) GetDueScheduledActions(ctx context.Context, now int64) ([]oasis.ScheduledAction, error)

+ func (s *Store) GetMessages(ctx context.Context, threadID string, limit int) ([]oasis.Message, error)

+ func (s *Store) GetSkill(ctx context.Context, id string) (oasis.Skill, error)

+ func (s *Store) GetThread(ctx context.Context, id string) (oasis.Thread, error)

+ func (s *Store) Init(ctx context.Context) error

+ func (s *Store) ListScheduledActions(ctx context.Context) ([]oasis.ScheduledAction, error)

+ func (s *Store) ListSkills(ctx context.Context) ([]oasis.Skill, error)

+ func (s *Store) ListThreads(ctx context.Context, chatID string, limit int) ([]oasis.Thread, error)

+ func (s *Store) SearchChunks(ctx context.Context, embedding []float32, topK int) ([]oasis.ScoredChunk, error)

+ func (s *Store) SearchChunksKeyword(ctx context.Context, query string, topK int) ([]oasis.ScoredChunk, error)

+ func (s *Store) SearchMessages(ctx context.Context, embedding []float32, topK int) ([]oasis.ScoredMessage, error)

+ func (s *Store) SearchSkills(ctx context.Context, embedding []float32, topK int) ([]oasis.ScoredSkill, error)

+ func (s *Store) SetConfig(ctx context.Context, key, value string) error

+ func (s *Store) StoreDocument(ctx context.Context, doc oasis.Document, chunks []oasis.Chunk) error

+ func (s *Store) StoreMessage(ctx context.Context, msg oasis.Message) error

+ func (s *Store) UpdateScheduledAction(ctx context.Context, action oasis.ScheduledAction) error

+ func (s *Store) UpdateScheduledActionEnabled(ctx context.Context, id string, enabled bool) error

+ func (s *Store) UpdateSkill(ctx context.Context, skill oasis.Skill) error

+ func (s *Store) UpdateThread(ctx context.Context, thread oasis.Thread) error

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