ftsengine

Apr 6, 2026

Changes in this version

+ const ColNameExternalID

+ const ColNameRowID

+ const MemoryDBBaseDir

+ type Column struct

+ Name string

+ Unindexed bool

+ Weight float64

+ type Config struct

+ BaseDir string

+ Columns []Column

+ DBFileName string

+ Table string

+ type Engine struct

+ func NewEngine(cfg Config, opts ...Option) (*Engine, error)

+ func (e *Engine) BatchDelete(ctx context.Context, ids []string) error

+ func (e *Engine) BatchList(ctx context.Context, compareColumn string, wantedCols []string, ...) (rows []ListResult, nextToken string, err error)

+ func (e *Engine) BatchUpsert(ctx context.Context, docs map[string]map[string]string) error

+ func (e *Engine) Close() error

+ func (e *Engine) Delete(ctx context.Context, id string) error

+ func (e *Engine) IsEmpty(ctx context.Context) (bool, error)

+ func (e *Engine) Search(ctx context.Context, query string, pageToken string, pageSize int) (hits []SearchResult, nextToken string, err error)

+ func (e *Engine) Upsert(ctx context.Context, id string, vals map[string]string) error

+ type GetPrevCmp func(id string) string

+ type Iterate func(getPrev GetPrevCmp, emit func(SyncDecision) error) error

+ type ListResult struct

+ ID string

+ Values map[string]string

+ type Option func(*Engine)

+ func WithLogger(logger *slog.Logger) Option

+ type ProcessFile func(ctx context.Context, baseDir, fullPath string, getPrev GetPrevCmp) (SyncDecision, error)

+ type SearchResult struct

+ ID string

+ Score float64

+ type SyncDecision struct

+ CmpOut string

+ ID string

+ Skip bool

+ Unchanged bool

+ Vals map[string]string

+ type SyncStats struct

+ Deleted int

+ Processed int

+ Skipped int

+ TimeTaken time.Duration

+ Unchanged int

+ Upserted int

+ func SyncDirToFTS(ctx context.Context, engine *Engine, baseDir string, compareColumn string, ...) (stats *SyncStats, err error)

+ func SyncIterToFTS(ctx context.Context, engine *Engine, compareColumn string, batchSize int, ...) (stats *SyncStats, err error)