Documentation
¶
Overview ¶
Package pgstore owns the shared pgwire vector-store execution boundary.
Index ¶
- type Config
- type Store
- func (s *Store) CheckDocuments(ctx context.Context, space vectorstore.SpaceID, docs []*document.Document) error
- func (s *Store) CheckQuery(ctx context.Context, space vectorstore.SpaceID, ...) error
- func (s *Store) DeleteIDs(ctx context.Context, ids []string) (err error)
- func (s *Store) Query(ctx context.Context, request *vectorstore.Query) (response *vectorstore.SearchResponse, err error)
- func (s *Store) Scan(ctx context.Context, request vectorstore.ScanRequest) (result []*document.Document, err error)
- func (s *Store) Upsert(ctx context.Context, batch *vectorstore.Batch) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
Provider string
Pool *pgxpool.Pool
SchemaName string
TableName string
MetadataColumn string
Space vectorstore.SpaceID
DistanceMetric postgres.DistanceMetric
}
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
func (*Store) CheckDocuments ¶ added in v0.59.0
func (*Store) CheckQuery ¶ added in v0.59.0
func (s *Store) CheckQuery(ctx context.Context, space vectorstore.SpaceID, options vectorstore.SearchOptions) error
Metadata is stored as opaque Core JSON bytes. Without an equivalent native predicate, rejecting the request preserves tenant isolation and global top K.
func (*Store) Query ¶ added in v0.59.0
func (s *Store) Query(ctx context.Context, request *vectorstore.Query) (response *vectorstore.SearchResponse, err error)
func (*Store) Scan ¶ added in v0.59.0
func (s *Store) Scan(ctx context.Context, request vectorstore.ScanRequest) (result []*document.Document, err error)
Scan never returns partial membership. Preflight is performed in the same snapshot as the read, before the client receives any document payload.
Source Files
Click to show internal directories.
Click to hide internal directories.