Documentation
¶
Index ¶
- func NewSQLIndex(cfg SQLIndexConfig, _ SQLIndexDeps) (capsessionindex.Service, error)
- func NewSQLiteIndex(cfg SQLiteIndexConfig, deps SQLiteIndexDeps) (capsessionindex.Service, error)
- type SQLIndex
- func (s *SQLIndex) ListSessions(ctx context.Context, limit int) ([]capsessionindex.SessionSummary, error)
- func (s *SQLIndex) ScrollMessages(ctx context.Context, sessionID string, anchorSeq int64, before, after int) ([]capsessionindex.MessageRow, error)
- func (s *SQLIndex) Search(ctx context.Context, query string, limit int) ([]capsessionindex.Hit, error)
- func (s *SQLIndex) SyncSessions(ctx context.Context) error
- type SQLIndexConfig
- type SQLIndexDeps
- 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) error
- type SQLiteIndexConfig
- type SQLiteIndexDeps
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewSQLIndex ¶ added in v0.3.41
func NewSQLIndex(cfg SQLIndexConfig, _ SQLIndexDeps) (capsessionindex.Service, error)
NewSQLIndex registers session/sql-index: FTS over session/sql durable events.
func NewSQLiteIndex ¶
func NewSQLiteIndex(cfg SQLiteIndexConfig, deps SQLiteIndexDeps) (capsessionindex.Service, error)
NewSQLiteIndex registers session/sqlite-index: FTS index over session/store JSONL files.
Types ¶
type SQLIndex ¶ added in v0.3.41
type SQLIndex struct {
// contains filtered or unexported fields
}
SQLIndex derives a searchable transcript index from session/sql durable events.
func (*SQLIndex) ListSessions ¶ added in v0.3.41
func (s *SQLIndex) ListSessions(ctx context.Context, limit int) ([]capsessionindex.SessionSummary, error)
func (*SQLIndex) ScrollMessages ¶ added in v0.3.41
func (s *SQLIndex) ScrollMessages(ctx context.Context, sessionID string, anchorSeq int64, before, after int) ([]capsessionindex.MessageRow, error)
type SQLIndexConfig ¶ added in v0.3.41
type SQLIndexConfig struct {
// Driver is database/sql driver name: sqlite, pgx (postgres), or any registered driver.
Driver string `json:"driver"`
// DSN is the driver data source name; should match the session/sql store DSN.
DSN string `json:"dsn"`
}
SQLIndexConfig mirrors session/sql connection settings so the index lives in the same database as ak_session_events (one DSN to persist in Docker).
type SQLIndexDeps ¶ added in v0.3.41
type SQLIndexDeps struct{}
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) error
type SQLiteIndexConfig ¶
type SQLiteIndexDeps ¶
Click to show internal directories.
Click to hide internal directories.