Documentation
¶
Index ¶
- Variables
- func Connect() (*sql.DB, error)
- func ConnectForRole(isPrimary bool) (*sql.DB, error)
- func ConnectRWSecondary() (*sql.DB, error)
- func ConnectReadOnly() (*sql.DB, error)
- type CreateFileParams
- type CreateGoalParams
- type CreateMessageParams
- type CreateProjectParams
- type CreateSessionParams
- type DBTX
- type File
- type GetEvaluatorStatsRow
- type GetFileByPathAndSessionParams
- type InsertPromptTemplateParams
- type InsertSessionScoreParams
- type InsertSkillParams
- type ListActiveSkillsByTypeParams
- type ListActiveTemplatesBySectionRow
- type ListUCBRankingRow
- type Message
- type Project
- type PromptTemplate
- type PromptUcbStat
- type Querier
- type Queries
- func (q *Queries) Close() error
- func (q *Queries) CountActiveSkills(ctx context.Context) (int64, error)
- func (q *Queries) CountPromptTemplates(ctx context.Context) (int64, error)
- func (q *Queries) CountSessionScores(ctx context.Context) (int64, error)
- func (q *Queries) CreateFile(ctx context.Context, arg CreateFileParams) (File, error)
- func (q *Queries) CreateGoal(ctx context.Context, arg CreateGoalParams) (SessionGoal, error)
- func (q *Queries) CreateMessage(ctx context.Context, arg CreateMessageParams) (Message, error)
- func (q *Queries) CreateProject(ctx context.Context, arg CreateProjectParams) (Project, error)
- func (q *Queries) CreateSession(ctx context.Context, arg CreateSessionParams) (Session, error)
- func (q *Queries) DeactivateLowestSkill(ctx context.Context) error
- func (q *Queries) DeleteFile(ctx context.Context, id string) error
- func (q *Queries) DeleteGoalsBySession(ctx context.Context, sessionID string) error
- func (q *Queries) DeleteMessage(ctx context.Context, id string) error
- func (q *Queries) DeleteProject(ctx context.Context, id string) error
- func (q *Queries) DeleteSession(ctx context.Context, id string) error
- func (q *Queries) DeleteSessionFiles(ctx context.Context, sessionID string) error
- func (q *Queries) DeleteSessionMessages(ctx context.Context, sessionID string) error
- func (q *Queries) GetActiveGoal(ctx context.Context, sessionID string) (SessionGoal, error)
- func (q *Queries) GetEvaluatorStats(ctx context.Context) (GetEvaluatorStatsRow, error)
- func (q *Queries) GetFile(ctx context.Context, id string) (File, error)
- func (q *Queries) GetFileByPathAndSession(ctx context.Context, arg GetFileByPathAndSessionParams) (File, error)
- func (q *Queries) GetGoalBySession(ctx context.Context, sessionID string) (SessionGoal, error)
- func (q *Queries) GetMessage(ctx context.Context, id string) (Message, error)
- func (q *Queries) GetProject(ctx context.Context, id string) (Project, error)
- func (q *Queries) GetProjectByPath(ctx context.Context, path string) (Project, error)
- func (q *Queries) GetPromptTemplate(ctx context.Context, id string) (PromptTemplate, error)
- func (q *Queries) GetSessionByID(ctx context.Context, id string) (Session, error)
- func (q *Queries) GetSessionScore(ctx context.Context, sessionID string) (SessionScore, error)
- func (q *Queries) GetTokenBaseline(ctx context.Context, limit int64) (float64, error)
- func (q *Queries) GetUCBStats(ctx context.Context, templateID string) (PromptUcbStat, error)
- func (q *Queries) IncrementSkillUsage(ctx context.Context, id string) error
- func (q *Queries) InsertPromptTemplate(ctx context.Context, arg InsertPromptTemplateParams) (PromptTemplate, error)
- func (q *Queries) InsertSessionScore(ctx context.Context, arg InsertSessionScoreParams) (SessionScore, error)
- func (q *Queries) InsertSkill(ctx context.Context, arg InsertSkillParams) (SkillLibrary, error)
- func (q *Queries) ListActiveSkillsByType(ctx context.Context, arg ListActiveSkillsByTypeParams) ([]SkillLibrary, error)
- func (q *Queries) ListActiveTemplatesBySection(ctx context.Context, section string) ([]ListActiveTemplatesBySectionRow, error)
- func (q *Queries) ListAllActiveSkills(ctx context.Context) ([]SkillLibrary, error)
- func (q *Queries) ListFilesByPath(ctx context.Context, path string) ([]File, error)
- func (q *Queries) ListFilesBySession(ctx context.Context, sessionID string) ([]File, error)
- func (q *Queries) ListLatestSessionFiles(ctx context.Context, sessionID string) ([]File, error)
- func (q *Queries) ListMessagesBySession(ctx context.Context, sessionID string) ([]Message, error)
- func (q *Queries) ListNewFiles(ctx context.Context) ([]File, error)
- func (q *Queries) ListProjects(ctx context.Context) ([]Project, error)
- func (q *Queries) ListSessionScores(ctx context.Context, limit int64) ([]SessionScore, error)
- func (q *Queries) ListSessions(ctx context.Context) ([]Session, error)
- func (q *Queries) ListUCBRanking(ctx context.Context) ([]ListUCBRankingRow, error)
- func (q *Queries) MarkProjectInitialized(ctx context.Context, id string) error
- func (q *Queries) UpdateFile(ctx context.Context, arg UpdateFileParams) (File, error)
- func (q *Queries) UpdateGoalProgress(ctx context.Context, arg UpdateGoalProgressParams) (SessionGoal, error)
- func (q *Queries) UpdateGoalStatus(ctx context.Context, arg UpdateGoalStatusParams) (SessionGoal, error)
- func (q *Queries) UpdateMessage(ctx context.Context, arg UpdateMessageParams) error
- func (q *Queries) UpdateProjectLastOpened(ctx context.Context, arg UpdateProjectLastOpenedParams) error
- func (q *Queries) UpdateProjectName(ctx context.Context, id, name string) error
- func (q *Queries) UpdateProjectStatus(ctx context.Context, arg UpdateProjectStatusParams) error
- func (q *Queries) UpdateSession(ctx context.Context, arg UpdateSessionParams) (Session, error)
- func (q *Queries) WithTx(tx *sql.Tx) *Queries
- type Session
- type SessionGoal
- type SessionScore
- type SkillLibrary
- type UpdateFileParams
- type UpdateGoalProgressParams
- type UpdateGoalStatusParams
- type UpdateMessageParams
- type UpdateProjectLastOpenedParams
- type UpdateProjectStatusParams
- type UpdateSessionParams
Constants ¶
This section is empty.
Variables ¶
var FS embed.FS
Functions ¶
func ConnectForRole ¶ added in v0.306.0
ConnectForRole opens the database in read-write mode when isPrimary is true, or via ConnectRWSecondary when false. This avoids duplicating the role branch in callers.
func ConnectRWSecondary ¶ added in v0.326.0
ConnectRWSecondary opens the SQLite database in read-write mode with WAL and a short busy_timeout (200 ms). It does NOT run migrations — the primary owns schema management. Secondary instances use this connection to attempt direct WAL writes; if they get SQLITE_BUSY/LOCKED they fall back to the IPC proxy.
func ConnectReadOnly ¶ added in v0.294.1
ConnectReadOnly opens the existing SQLite database in read-only mode. Secondary (non-primary) Pando instances use this so they never write directly; all writes are proxied through the primary via ZMQ RPC. The caller must NOT run migrations — the primary is responsible for that.
Types ¶
type CreateFileParams ¶
type CreateGoalParams ¶ added in v0.324.0
type CreateMessageParams ¶
type CreateProjectParams ¶ added in v0.240.0
type CreateProjectParams struct {
ID string `json:"id"`
Name string `json:"name"`
Path string `json:"path"`
Status string `json:"status"`
Initialized int64 `json:"initialized"`
AcpPid sql.NullInt64 `json:"acp_pid"`
AcpPort sql.NullInt64 `json:"acp_port"`
LastOpened sql.NullInt64 `json:"last_opened"`
}
type CreateSessionParams ¶
type CreateSessionParams struct {
ID string `json:"id"`
ParentSessionID sql.NullString `json:"parent_session_id"`
Title string `json:"title"`
MessageCount int64 `json:"message_count"`
PromptTokens int64 `json:"prompt_tokens"`
CompletionTokens int64 `json:"completion_tokens"`
Cost float64 `json:"cost"`
}
type GetEvaluatorStatsRow ¶ added in v0.26.2
type InsertPromptTemplateParams ¶ added in v0.26.2
type InsertSessionScoreParams ¶ added in v0.26.2
type InsertSessionScoreParams struct {
ID string `json:"id"`
SessionID string `json:"session_id"`
TemplateID sql.NullString `json:"template_id"`
Reward float64 `json:"reward"`
SuccessScore float64 `json:"success_score"`
EfficiencyScore float64 `json:"efficiency_score"`
JudgeAnalysis sql.NullString `json:"judge_analysis"`
JudgeModel sql.NullString `json:"judge_model"`
PromptTokens int64 `json:"prompt_tokens"`
CompletionTokens int64 `json:"completion_tokens"`
MessageCount int64 `json:"message_count"`
UserCorrections int64 `json:"user_corrections"`
}
type InsertSkillParams ¶ added in v0.26.2
type InsertSkillParams struct {
ID string `json:"id"`
Title string `json:"title"`
Content string `json:"content"`
SourceSessionID sql.NullString `json:"source_session_id"`
SourceTemplateID sql.NullString `json:"source_template_id"`
TaskType string `json:"task_type"`
}
type ListActiveSkillsByTypeParams ¶ added in v0.26.2
type ListActiveTemplatesBySectionRow ¶ added in v0.26.2
type ListActiveTemplatesBySectionRow struct {
ID string `json:"id"`
Name string `json:"name"`
Section string `json:"section"`
Content string `json:"content"`
Version int64 `json:"version"`
IsActive int64 `json:"is_active"`
IsDefault int64 `json:"is_default"`
CreatedAt int64 `json:"created_at"`
UpdatedAt int64 `json:"updated_at"`
AvgReward float64 `json:"avg_reward"`
TimesUsed int64 `json:"times_used"`
UcbScore float64 `json:"ucb_score"`
}
type ListUCBRankingRow ¶ added in v0.26.2
type ListUCBRankingRow struct {
ID string `json:"id"`
Name string `json:"name"`
Section string `json:"section"`
Version int64 `json:"version"`
IsDefault int64 `json:"is_default"`
TimesUsed int64 `json:"times_used"`
AvgReward float64 `json:"avg_reward"`
UcbScore float64 `json:"ucb_score"`
LastUsedAt int64 `json:"last_used_at"`
}
type Project ¶ added in v0.240.0
type Project struct {
ID string `json:"id"`
Name string `json:"name"`
Path string `json:"path"`
Status string `json:"status"`
Initialized int64 `json:"initialized"`
AcpPid sql.NullInt64 `json:"acp_pid"`
AcpPort sql.NullInt64 `json:"acp_port"`
LastOpened sql.NullInt64 `json:"last_opened"`
CreatedAt int64 `json:"created_at"`
UpdatedAt int64 `json:"updated_at"`
}
type PromptTemplate ¶ added in v0.26.2
type PromptTemplate struct {
ID string `json:"id"`
Name string `json:"name"`
Section string `json:"section"`
Content string `json:"content"`
Version int64 `json:"version"`
IsActive int64 `json:"is_active"`
IsDefault int64 `json:"is_default"`
CreatedAt int64 `json:"created_at"`
UpdatedAt int64 `json:"updated_at"`
}
type PromptUcbStat ¶ added in v0.26.2
type PromptUcbStat struct {
TemplateID string `json:"template_id"`
TimesUsed int64 `json:"times_used"`
TotalReward float64 `json:"total_reward"`
AvgReward float64 `json:"avg_reward"`
UcbScore float64 `json:"ucb_score"`
LastUsedAt sql.NullInt64 `json:"last_used_at"`
UpdatedAt int64 `json:"updated_at"`
}
type Querier ¶
type Querier interface {
CreateFile(ctx context.Context, arg CreateFileParams) (File, error)
CreateGoal(ctx context.Context, arg CreateGoalParams) (SessionGoal, error)
CreateMessage(ctx context.Context, arg CreateMessageParams) (Message, error)
CreateSession(ctx context.Context, arg CreateSessionParams) (Session, error)
DeleteFile(ctx context.Context, id string) error
DeleteGoalsBySession(ctx context.Context, sessionID string) error
DeleteMessage(ctx context.Context, id string) error
DeleteSession(ctx context.Context, id string) error
DeleteSessionFiles(ctx context.Context, sessionID string) error
DeleteSessionMessages(ctx context.Context, sessionID string) error
GetFile(ctx context.Context, id string) (File, error)
GetFileByPathAndSession(ctx context.Context, arg GetFileByPathAndSessionParams) (File, error)
GetActiveGoal(ctx context.Context, sessionID string) (SessionGoal, error)
GetGoalBySession(ctx context.Context, sessionID string) (SessionGoal, error)
GetMessage(ctx context.Context, id string) (Message, error)
GetSessionByID(ctx context.Context, id string) (Session, error)
ListFilesByPath(ctx context.Context, path string) ([]File, error)
ListFilesBySession(ctx context.Context, sessionID string) ([]File, error)
ListLatestSessionFiles(ctx context.Context, sessionID string) ([]File, error)
ListMessagesBySession(ctx context.Context, sessionID string) ([]Message, error)
ListNewFiles(ctx context.Context) ([]File, error)
ListSessions(ctx context.Context) ([]Session, error)
UpdateFile(ctx context.Context, arg UpdateFileParams) (File, error)
UpdateGoalProgress(ctx context.Context, arg UpdateGoalProgressParams) (SessionGoal, error)
UpdateGoalStatus(ctx context.Context, arg UpdateGoalStatusParams) (SessionGoal, error)
UpdateMessage(ctx context.Context, arg UpdateMessageParams) error
UpdateSession(ctx context.Context, arg UpdateSessionParams) (Session, error)
// Self-improvement queries
InsertPromptTemplate(ctx context.Context, arg InsertPromptTemplateParams) (PromptTemplate, error)
GetPromptTemplate(ctx context.Context, id string) (PromptTemplate, error)
ListActiveTemplatesBySection(ctx context.Context, section string) ([]ListActiveTemplatesBySectionRow, error)
CountPromptTemplates(ctx context.Context) (int64, error)
InsertSessionScore(ctx context.Context, arg InsertSessionScoreParams) (SessionScore, error)
GetSessionScore(ctx context.Context, sessionID string) (SessionScore, error)
CountSessionScores(ctx context.Context) (int64, error)
ListSessionScores(ctx context.Context, limit int64) ([]SessionScore, error)
GetTokenBaseline(ctx context.Context, limit int64) (float64, error)
GetUCBStats(ctx context.Context, templateID string) (PromptUcbStat, error)
InsertSkill(ctx context.Context, arg InsertSkillParams) (SkillLibrary, error)
ListActiveSkillsByType(ctx context.Context, arg ListActiveSkillsByTypeParams) ([]SkillLibrary, error)
ListAllActiveSkills(ctx context.Context) ([]SkillLibrary, error)
CountActiveSkills(ctx context.Context) (int64, error)
DeactivateLowestSkill(ctx context.Context) error
IncrementSkillUsage(ctx context.Context, id string) error
ListUCBRanking(ctx context.Context) ([]ListUCBRankingRow, error)
GetEvaluatorStats(ctx context.Context) (GetEvaluatorStatsRow, error)
// Project queries
CreateProject(ctx context.Context, arg CreateProjectParams) (Project, error)
GetProject(ctx context.Context, id string) (Project, error)
GetProjectByPath(ctx context.Context, path string) (Project, error)
ListProjects(ctx context.Context) ([]Project, error)
UpdateProjectStatus(ctx context.Context, arg UpdateProjectStatusParams) error
UpdateProjectLastOpened(ctx context.Context, arg UpdateProjectLastOpenedParams) error
MarkProjectInitialized(ctx context.Context, id string) error
DeleteProject(ctx context.Context, id string) error
}
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) CountActiveSkills ¶ added in v0.26.2
func (*Queries) CountPromptTemplates ¶ added in v0.26.2
func (*Queries) CountSessionScores ¶ added in v0.26.2
func (*Queries) CreateFile ¶
func (*Queries) CreateGoal ¶ added in v0.324.0
func (q *Queries) CreateGoal(ctx context.Context, arg CreateGoalParams) (SessionGoal, error)
func (*Queries) CreateMessage ¶
func (*Queries) CreateProject ¶ added in v0.240.0
func (*Queries) CreateSession ¶
func (*Queries) DeactivateLowestSkill ¶ added in v0.26.2
func (*Queries) DeleteGoalsBySession ¶ added in v0.324.0
func (*Queries) DeleteMessage ¶
func (*Queries) DeleteProject ¶ added in v0.240.0
func (*Queries) DeleteSession ¶
func (*Queries) DeleteSessionFiles ¶
func (*Queries) DeleteSessionMessages ¶
func (*Queries) GetActiveGoal ¶ added in v0.324.0
func (*Queries) GetEvaluatorStats ¶ added in v0.26.2
func (q *Queries) GetEvaluatorStats(ctx context.Context) (GetEvaluatorStatsRow, error)
func (*Queries) GetFileByPathAndSession ¶
func (*Queries) GetGoalBySession ¶ added in v0.324.0
func (*Queries) GetMessage ¶
func (*Queries) GetProject ¶ added in v0.240.0
func (*Queries) GetProjectByPath ¶ added in v0.240.0
func (*Queries) GetPromptTemplate ¶ added in v0.26.2
func (*Queries) GetSessionByID ¶
func (*Queries) GetSessionScore ¶ added in v0.26.2
func (*Queries) GetTokenBaseline ¶ added in v0.26.2
func (*Queries) GetUCBStats ¶ added in v0.26.2
func (*Queries) IncrementSkillUsage ¶ added in v0.26.2
func (*Queries) InsertPromptTemplate ¶ added in v0.26.2
func (q *Queries) InsertPromptTemplate(ctx context.Context, arg InsertPromptTemplateParams) (PromptTemplate, error)
func (*Queries) InsertSessionScore ¶ added in v0.26.2
func (q *Queries) InsertSessionScore(ctx context.Context, arg InsertSessionScoreParams) (SessionScore, error)
func (*Queries) InsertSkill ¶ added in v0.26.2
func (q *Queries) InsertSkill(ctx context.Context, arg InsertSkillParams) (SkillLibrary, error)
func (*Queries) ListActiveSkillsByType ¶ added in v0.26.2
func (q *Queries) ListActiveSkillsByType(ctx context.Context, arg ListActiveSkillsByTypeParams) ([]SkillLibrary, error)
func (*Queries) ListActiveTemplatesBySection ¶ added in v0.26.2
func (*Queries) ListAllActiveSkills ¶ added in v0.26.2
func (q *Queries) ListAllActiveSkills(ctx context.Context) ([]SkillLibrary, error)
func (*Queries) ListFilesByPath ¶
func (*Queries) ListFilesBySession ¶
func (*Queries) ListLatestSessionFiles ¶
func (*Queries) ListMessagesBySession ¶
func (*Queries) ListProjects ¶ added in v0.240.0
func (*Queries) ListSessionScores ¶ added in v0.244.0
func (*Queries) ListSessions ¶
func (*Queries) ListUCBRanking ¶ added in v0.26.2
func (q *Queries) ListUCBRanking(ctx context.Context) ([]ListUCBRankingRow, error)
func (*Queries) MarkProjectInitialized ¶ added in v0.240.0
func (*Queries) UpdateFile ¶
func (*Queries) UpdateGoalProgress ¶ added in v0.324.0
func (q *Queries) UpdateGoalProgress(ctx context.Context, arg UpdateGoalProgressParams) (SessionGoal, error)
func (*Queries) UpdateGoalStatus ¶ added in v0.324.0
func (q *Queries) UpdateGoalStatus(ctx context.Context, arg UpdateGoalStatusParams) (SessionGoal, error)
func (*Queries) UpdateMessage ¶
func (q *Queries) UpdateMessage(ctx context.Context, arg UpdateMessageParams) error
func (*Queries) UpdateProjectLastOpened ¶ added in v0.240.0
func (q *Queries) UpdateProjectLastOpened(ctx context.Context, arg UpdateProjectLastOpenedParams) error
func (*Queries) UpdateProjectName ¶ added in v0.290.1
func (*Queries) UpdateProjectStatus ¶ added in v0.240.0
func (q *Queries) UpdateProjectStatus(ctx context.Context, arg UpdateProjectStatusParams) error
func (*Queries) UpdateSession ¶
type Session ¶
type Session struct {
ID string `json:"id"`
ParentSessionID sql.NullString `json:"parent_session_id"`
Title string `json:"title"`
MessageCount int64 `json:"message_count"`
PromptTokens int64 `json:"prompt_tokens"`
CompletionTokens int64 `json:"completion_tokens"`
Cost float64 `json:"cost"`
UpdatedAt int64 `json:"updated_at"`
CreatedAt int64 `json:"created_at"`
SummaryMessageID sql.NullString `json:"summary_message_id"`
}
type SessionGoal ¶ added in v0.324.0
type SessionGoal struct {
ID string `json:"id"`
SessionID string `json:"session_id"`
Objective string `json:"objective"`
Status string `json:"status"`
Iteration int64 `json:"iteration"`
MaxIterations int64 `json:"max_iterations"`
MaxDurationSeconds int64 `json:"max_duration_seconds"`
StartedAt int64 `json:"started_at"`
CompletedAt sql.NullInt64 `json:"completed_at"`
LastProgress sql.NullString `json:"last_progress"`
NextStep sql.NullString `json:"next_step"`
BlockedReason sql.NullString `json:"blocked_reason"`
CreatedAt int64 `json:"created_at"`
}
type SessionScore ¶ added in v0.26.2
type SessionScore struct {
ID string `json:"id"`
SessionID string `json:"session_id"`
TemplateID sql.NullString `json:"template_id"`
Reward float64 `json:"reward"`
SuccessScore float64 `json:"success_score"`
EfficiencyScore float64 `json:"efficiency_score"`
JudgeAnalysis sql.NullString `json:"judge_analysis"`
JudgeModel sql.NullString `json:"judge_model"`
PromptTokens int64 `json:"prompt_tokens"`
CompletionTokens int64 `json:"completion_tokens"`
MessageCount int64 `json:"message_count"`
UserCorrections int64 `json:"user_corrections"`
EvaluatedAt int64 `json:"evaluated_at"`
CreatedAt int64 `json:"created_at"`
}
type SkillLibrary ¶ added in v0.26.2
type SkillLibrary struct {
ID string `json:"id"`
Title string `json:"title"`
Content string `json:"content"`
SourceSessionID sql.NullString `json:"source_session_id"`
SourceTemplateID sql.NullString `json:"source_template_id"`
TaskType string `json:"task_type"`
UsageCount int64 `json:"usage_count"`
SuccessRate float64 `json:"success_rate"`
IsActive int64 `json:"is_active"`
CreatedAt int64 `json:"created_at"`
UpdatedAt int64 `json:"updated_at"`
}
type UpdateFileParams ¶
type UpdateGoalProgressParams ¶ added in v0.324.0
type UpdateGoalProgressParams struct {
LastProgress sql.NullString `json:"last_progress"`
NextStep sql.NullString `json:"next_step"`
Iteration int64 `json:"iteration"`
ID string `json:"id"`
}
type UpdateGoalStatusParams ¶ added in v0.324.0
type UpdateGoalStatusParams struct {
Status string `json:"status"`
Iteration int64 `json:"iteration"`
LastProgress sql.NullString `json:"last_progress"`
NextStep sql.NullString `json:"next_step"`
BlockedReason sql.NullString `json:"blocked_reason"`
CompletedAt sql.NullInt64 `json:"completed_at"`
ID string `json:"id"`
}