Documentation
¶
Index ¶
- type SQLiteContextManager
- func (m *SQLiteContextManager) Append(ctx context.Context, contextUID common.ContextUID, ...) error
- func (m *SQLiteContextManager) CommitFinal(ctx context.Context, contextUID common.ContextUID, ...) error
- func (m *SQLiteContextManager) CommitTurn(ctx context.Context, contextUID common.ContextUID, ...) (*contextmgr.TurnCommitResult, error)
- func (m *SQLiteContextManager) Delete(ctx context.Context, contextUID common.ContextUID) error
- func (m *SQLiteContextManager) EnqueuePendingMessages(ctx context.Context, contextUID common.ContextUID, ...) error
- func (m *SQLiteContextManager) GetAll(ctx context.Context, contextUID common.ContextUID) []*schema.AgenticMessage
- func (m *SQLiteContextManager) InitNew(ctx context.Context) common.ContextUID
- func (m *SQLiteContextManager) Len(ctx context.Context, contextUID common.ContextUID) int
- func (m *SQLiteContextManager) NewContextUID(_ context.Context) common.ContextUID
- func (m *SQLiteContextManager) Reset(ctx context.Context, contextUID common.ContextUID, ...)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SQLiteContextManager ¶
type SQLiteContextManager struct {
// contains filtered or unexported fields
}
SQLiteContextManager manages conversation context using local embedded SQLite through GORM.
func NewSQLiteContextManager ¶
func NewSQLiteContextManager(dbPath string) (*SQLiteContextManager, error)
NewSQLiteContextManager creates a local SQLite-backed context manager and migrates its tables. If dbPath is empty, data/goat_context.sqlite is used.
func (*SQLiteContextManager) Append ¶
func (m *SQLiteContextManager) Append(ctx context.Context, contextUID common.ContextUID, message *schema.AgenticMessage) error
func (*SQLiteContextManager) CommitFinal ¶
func (m *SQLiteContextManager) CommitFinal( ctx context.Context, contextUID common.ContextUID, message *schema.AgenticMessage, ) error
func (*SQLiteContextManager) CommitTurn ¶
func (m *SQLiteContextManager) CommitTurn( ctx context.Context, contextUID common.ContextUID, turnMessages []*schema.AgenticMessage, ) (*contextmgr.TurnCommitResult, error)
func (*SQLiteContextManager) Delete ¶
func (m *SQLiteContextManager) Delete(ctx context.Context, contextUID common.ContextUID) error
func (*SQLiteContextManager) EnqueuePendingMessages ¶
func (m *SQLiteContextManager) EnqueuePendingMessages( ctx context.Context, contextUID common.ContextUID, messages []*schema.AgenticMessage, ) error
func (*SQLiteContextManager) GetAll ¶
func (m *SQLiteContextManager) GetAll(ctx context.Context, contextUID common.ContextUID) []*schema.AgenticMessage
func (*SQLiteContextManager) InitNew ¶
func (m *SQLiteContextManager) InitNew(ctx context.Context) common.ContextUID
func (*SQLiteContextManager) Len ¶
func (m *SQLiteContextManager) Len(ctx context.Context, contextUID common.ContextUID) int
func (*SQLiteContextManager) NewContextUID ¶
func (m *SQLiteContextManager) NewContextUID(_ context.Context) common.ContextUID
func (*SQLiteContextManager) Reset ¶
func (m *SQLiteContextManager) Reset(ctx context.Context, contextUID common.ContextUID, messages []*schema.AgenticMessage)
Click to show internal directories.
Click to hide internal directories.