Documentation
¶
Index ¶
- func ExtractIndexableMessages(events []agentkit.SessionEvent) []indexableMessage
- func NewSQLiteIndex(cfg SQLiteIndexConfig, deps SQLiteIndexDeps) (capsessionindex.Service, error)
- func SearchSyncedSessions(ctx context.Context, index capsessionindex.Service, sessionsDir, query string, ...) ([]capsessionindex.Hit, error)
- func SyncSessionIndex(ctx context.Context, index capsessionindex.Service, sessionsDir string) error
- type SQLiteIndex
- func (s *SQLiteIndex) ListSessions(ctx context.Context, limit int) ([]capsessionindex.SessionSummary, error)
- func (s *SQLiteIndex) ScrollMessages(ctx context.Context, sessionID string, anchorSeq int64, before, after int) ([]capsessionindex.MessageRow, error)
- func (s *SQLiteIndex) Search(ctx context.Context, query string, limit int) ([]capsessionindex.Hit, error)
- func (s *SQLiteIndex) SyncSessions(ctx context.Context, sessionsDir string) error
- type SQLiteIndexConfig
- type SQLiteIndexDeps
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ExtractIndexableMessages ¶
func ExtractIndexableMessages(events []agentkit.SessionEvent) []indexableMessage
ExtractIndexableMessages returns user/assistant text from session events.
func NewSQLiteIndex ¶
func NewSQLiteIndex(cfg SQLiteIndexConfig, deps SQLiteIndexDeps) (capsessionindex.Service, error)
NewSQLiteIndex registers session/sqlite-index: FTS index over session/store JSONL files.
func SearchSyncedSessions ¶
func SearchSyncedSessions(ctx context.Context, index capsessionindex.Service, sessionsDir, query string, limit int) ([]capsessionindex.Hit, error)
SearchSyncedSessions syncs then runs FTS over indexed messages.
func SyncSessionIndex ¶
SyncSessionIndex refreshes the SQLite FTS index from a sessions directory.
Types ¶
type SQLiteIndex ¶
type SQLiteIndex struct {
// contains filtered or unexported fields
}
SQLiteIndex persists FTS5 over session JSONL transcripts per tenant workspace.
func (*SQLiteIndex) ListSessions ¶
func (s *SQLiteIndex) ListSessions(ctx context.Context, limit int) ([]capsessionindex.SessionSummary, error)
func (*SQLiteIndex) ScrollMessages ¶
func (s *SQLiteIndex) ScrollMessages(ctx context.Context, sessionID string, anchorSeq int64, before, after int) ([]capsessionindex.MessageRow, error)
func (*SQLiteIndex) Search ¶
func (s *SQLiteIndex) Search(ctx context.Context, query string, limit int) ([]capsessionindex.Hit, error)
func (*SQLiteIndex) SyncSessions ¶
func (s *SQLiteIndex) SyncSessions(ctx context.Context, sessionsDir string) error
type SQLiteIndexConfig ¶
type SQLiteIndexConfig struct {
// IndexRel is the workspace-relative SQLite file path.
IndexRel string `json:"indexRel"`
}
type SQLiteIndexDeps ¶
Click to show internal directories.
Click to hide internal directories.