sqlc

package
v0.0.0-...-64f6608 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 9, 2025 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const AddTaskLabel = `` /* 236-byte string literal not displayed */
View Source
const AppendMemoryEvent = `` /* 152-byte string literal not displayed */
View Source
const ArchiveConversation = `` /* 210-byte string literal not displayed */
View Source
const ArchiveMemory = `-- name: ArchiveMemory :execresult
UPDATE memories
SET 
    status = $2,
    updated_at = $3,
    version = $4
WHERE id = $1
`
View Source
const ArchiveMemoryProjection = `` /* 137-byte string literal not displayed */
View Source
const ArchiveMemoryWithVersion = `-- name: ArchiveMemoryWithVersion :exec
UPDATE memories
SET status = $2, updated_at = $3, version = $4
WHERE id = $1
`
View Source
const ArchiveSourceMemories = `-- name: ArchiveSourceMemories :exec
UPDATE memories
SET status = $2, updated_at = $3
WHERE id = ANY($1::UUID[])
`
View Source
const BulkSetSystemSettings = `` /* 310-byte string literal not displayed */
View Source
const CancelPendingToolExecutions = `` /* 207-byte string literal not displayed */
View Source
const CompleteTask = `` /* 234-byte string literal not displayed */
View Source
const CompleteToolExecution = `` /* 356-byte string literal not displayed */
View Source
const CountEmbeddingsBySource = `` /* 129-byte string literal not displayed */
View Source
const CountMemoryBackups = `-- name: CountMemoryBackups :one
SELECT COUNT(*)::int as total_backups
FROM memory_backups
`
View Source
const CountMemoryEvents = `-- name: CountMemoryEvents :one
SELECT COUNT(*) FROM memory_events
`
View Source
const CountMessagesByRole = `` /* 134-byte string literal not displayed */
View Source
const CountSystemSettings = `-- name: CountSystemSettings :one
SELECT COUNT(*)::int as total_settings
FROM system_settings
`
View Source
const CreateConversation = `` /* 364-byte string literal not displayed */
View Source
const CreateEmbedding = `` /* 561-byte string literal not displayed */
View Source
const CreateMemoryBackup = `` /* 231-byte string literal not displayed */
View Source
const CreateMemoryProjection = `` /* 471-byte string literal not displayed */
View Source
const CreateMessage = `` /* 307-byte string literal not displayed */
View Source
const CreateTask = `` /* 428-byte string literal not displayed */
View Source
const CreateToolExecution = `` /* 345-byte string literal not displayed */
View Source
const DeleteConversation = `-- name: DeleteConversation :exec
DELETE FROM conversations
WHERE id = $1
`
View Source
const DeleteConversationMessages = `-- name: DeleteConversationMessages :exec
DELETE FROM messages
WHERE conversation_id = $1
`
View Source
const DeleteEmbedding = `-- name: DeleteEmbedding :exec
DELETE FROM embeddings
WHERE id = $1
`
View Source
const DeleteEmbeddingBySource = `-- name: DeleteEmbeddingBySource :exec
DELETE FROM embeddings
WHERE source_table = $1 AND source_id = $2
`
View Source
const DeleteMemoryBackup = `-- name: DeleteMemoryBackup :exec
DELETE FROM memory_backups
WHERE id = $1
`
View Source
const DeleteMessage = `-- name: DeleteMessage :exec
DELETE FROM messages
WHERE id = $1
`
View Source
const DeleteOldEmbeddings = `` /* 171-byte string literal not displayed */
View Source
const DeleteOldMemoryBackups = `` /* 227-byte string literal not displayed */
View Source
const DeleteOldToolExecutions = `` /* 184-byte string literal not displayed */
View Source
const DeleteSystemSetting = `-- name: DeleteSystemSetting :exec
DELETE FROM system_settings
WHERE key = $1
`
View Source
const DeleteTask = `-- name: DeleteTask :exec
DELETE FROM tasks
WHERE id = $1
`
View Source
const ExistsSystemSetting = `-- name: ExistsSystemSetting :one
SELECT EXISTS (
    SELECT 1 FROM system_settings
    WHERE key = $1
)
`
View Source
const FailToolExecution = `` /* 358-byte string literal not displayed */
View Source
const GetActiveMemories = `` /* 384-byte string literal not displayed */
View Source
const GetBackupStats = `` /* 269-byte string literal not displayed */
View Source
const GetBackupsWithinTimeRange = `` /* 183-byte string literal not displayed */
View Source
const GetConversation = `` /* 185-byte string literal not displayed */
View Source
const GetConversationStats = `` /* 324-byte string literal not displayed */
View Source
const GetConversationTokenUsage = `` /* 221-byte string literal not displayed */
View Source
const GetEmbedding = `` /* 149-byte string literal not displayed */
View Source
const GetEmbeddingBySource = `` /* 186-byte string literal not displayed */
View Source
const GetEmbeddingStats = `` /* 230-byte string literal not displayed */
View Source
const GetLastMessages = `` /* 183-byte string literal not displayed */
View Source
const GetLatestMemoryBackup = `` /* 133-byte string literal not displayed */
View Source
const GetLatestMemoryEvent = `` /* 158-byte string literal not displayed */
View Source
const GetMemoryBackup = `-- name: GetMemoryBackup :one
SELECT id, version, backup_data, created_at
FROM memory_backups
WHERE id = $1
LIMIT 1
`
View Source
const GetMemoryById = `` /* 361-byte string literal not displayed */
View Source
const GetMemoryEventsByType = `` /* 158-byte string literal not displayed */
View Source
const GetMemoryForMerge = `-- name: GetMemoryForMerge :one
SELECT 
    content, keywords, confidence
FROM memories
WHERE id = $1
`
View Source
const GetMemoryForMergeDecision = `` /* 150-byte string literal not displayed */
View Source
const GetMemoryProjection = `` /* 336-byte string literal not displayed */
View Source
const GetMemoryStreams = `-- name: GetMemoryStreams :many
SELECT stream_id, MAX(version) as latest_version
FROM memory_events
GROUP BY stream_id
`
View Source
const GetMessage = `` /* 138-byte string literal not displayed */
View Source
const GetMultipleSettings = `` /* 156-byte string literal not displayed */
View Source
const GetRecentConversationsWithMessageCount = `` /* 451-byte string literal not displayed */
View Source
const GetRecentMemories = `` /* 384-byte string literal not displayed */
View Source
const GetSettingHistory = `` /* 153-byte string literal not displayed */
View Source
const GetSystemSetting = `` /* 130-byte string literal not displayed */
View Source
const GetSystemSettingKeys = `-- name: GetSystemSettingKeys :many
SELECT key
FROM system_settings
ORDER BY key ASC
`
View Source
const GetTask = `` /* 169-byte string literal not displayed */
View Source
const GetTaskStats = `` /* 479-byte string literal not displayed */
View Source
const GetTasksByPriority = `` /* 313-byte string literal not displayed */
View Source
const GetToolExecution = `` /* 193-byte string literal not displayed */
View Source
const GetToolExecutionStats = `` /* 572-byte string literal not displayed */
View Source
const GetToolUsageByName = `` /* 386-byte string literal not displayed */
View Source
const ListActiveConversations = `` /* 257-byte string literal not displayed */
View Source
const ListConversations = `` /* 439-byte string literal not displayed */
View Source
const ListEmbeddingsBySource = `` /* 244-byte string literal not displayed */
View Source
const ListMemoryBackups = `` /* 178-byte string literal not displayed */
View Source
const ListMessages = `` /* 227-byte string literal not displayed */
View Source
const ListOverdueTasks = `` /* 244-byte string literal not displayed */
View Source
const ListPendingTasks = `` /* 433-byte string literal not displayed */
View Source
const ListPendingToolExecutions = `` /* 253-byte string literal not displayed */
View Source
const ListRecentMessages = `` /* 186-byte string literal not displayed */
View Source
const ListSystemSettings = `` /* 127-byte string literal not displayed */
View Source
const ListSystemSettingsByPrefix = `` /* 160-byte string literal not displayed */
View Source
const ListTasks = `` /* 634-byte string literal not displayed */
View Source
const ListTasksByLabel = `` /* 258-byte string literal not displayed */
View Source
const ListTasksDueToday = `` /* 307-byte string literal not displayed */
View Source
const ListToolExecutions = `` /* 360-byte string literal not displayed */
View Source
const ListToolExecutionsByConversation = `` /* 249-byte string literal not displayed */
View Source
const LoadMemoryEvents = `` /* 146-byte string literal not displayed */
View Source
const LoadMemoryEventsFromVersion = `` /* 175-byte string literal not displayed */
View Source
const MarkMemoryAsCorrected = `` /* 184-byte string literal not displayed */
View Source
const RemoveTaskLabel = `` /* 212-byte string literal not displayed */
View Source
const SearchConversationMessages = `` /* 500-byte string literal not displayed */
View Source
const SearchConversations = `` /* 442-byte string literal not displayed */
View Source
const SearchConversationsWithHighlight = `` /* 765-byte string literal not displayed */
View Source
const SearchMemoriesByText = `` /* 539-byte string literal not displayed */
View Source
const SearchMemoriesByTextFallback = `` /* 464-byte string literal not displayed */
View Source
const SearchMemoryProjections = `` /* 400-byte string literal not displayed */
View Source
const SearchMessages = `` /* 226-byte string literal not displayed */
View Source
const SearchSimilarEmbeddings = `` /* 300-byte string literal not displayed */
View Source
const SearchSimilarMemories = `` /* 483-byte string literal not displayed */
View Source
const SearchSimilarMemoriesForDedup = `` /* 351-byte string literal not displayed */
View Source
const SearchSimilarMemoriesForMerge = `` /* 253-byte string literal not displayed */
View Source
const SearchTasks = `` /* 360-byte string literal not displayed */
View Source
const SetSystemSetting = `` /* 330-byte string literal not displayed */
View Source
const StartToolExecution = `` /* 234-byte string literal not displayed */
View Source
const UpdateConversation = `` /* 372-byte string literal not displayed */
View Source
const UpdateEmbedding = `` /* 236-byte string literal not displayed */
View Source
const UpdateMemory = `` /* 337-byte string literal not displayed */
View Source
const UpdateMemoryAccess = `` /* 127-byte string literal not displayed */
View Source
const UpdateMemoryAfterMerge = `` /* 232-byte string literal not displayed */
View Source
const UpdateMemoryConfidence = `` /* 141-byte string literal not displayed */
View Source
const UpdateMemoryCorrected = `` /* 156-byte string literal not displayed */
View Source
const UpdateMemoryEmbedding = `-- name: UpdateMemoryEmbedding :exec
UPDATE memories
SET 
    embedding = $2::vector,
    updated_at = NOW()
WHERE id = $1
`
View Source
const UpdateMemoryMerged = `` /* 164-byte string literal not displayed */
View Source
const UpdateMemoryProjection = `` /* 246-byte string literal not displayed */
View Source
const UpdateMergedMemory = `` /* 223-byte string literal not displayed */
View Source
const UpdateSystemSetting = `` /* 145-byte string literal not displayed */
View Source
const UpdateTask = `` /* 692-byte string literal not displayed */
View Source
const UpdateTaskLabels = `` /* 191-byte string literal not displayed */
View Source
const UpdateToolExecution = `` /* 437-byte string literal not displayed */
View Source
const UpsertMemory = `` /* 407-byte string literal not displayed */

Variables

This section is empty.

Functions

This section is empty.

Types

type ActionType

type ActionType string
const (
	ActionTypeADD    ActionType = "ADD"
	ActionTypeUPDATE ActionType = "UPDATE"
	ActionTypeDELETE ActionType = "DELETE"
	ActionTypeSKIP   ActionType = "SKIP"
	ActionTypeMERGE  ActionType = "MERGE"
)

func AllActionTypeValues

func AllActionTypeValues() []ActionType

func (*ActionType) Scan

func (e *ActionType) Scan(src interface{}) error

func (ActionType) Valid

func (e ActionType) Valid() bool

type AddTaskLabelParams

type AddTaskLabelParams struct {
	Label interface{} `json:"label"`
	ID    pgtype.UUID `json:"id"`
}

type AppendMemoryEventParams

type AppendMemoryEventParams struct {
	ID        pgtype.UUID        `json:"id"`
	StreamID  pgtype.UUID        `json:"stream_id"`
	Type      string             `json:"type"`
	Version   int32              `json:"version"`
	Data      json.RawMessage    `json:"data"`
	Timestamp pgtype.Timestamptz `json:"timestamp"`
}

type ArchiveMemoryParams

type ArchiveMemoryParams struct {
	ID        pgtype.UUID  `json:"id"`
	Status    MemoryStatus `json:"status"`
	UpdatedAt time.Time    `json:"updated_at"`
	Version   pgtype.Int4  `json:"version"`
}

type ArchiveMemoryProjectionParams

type ArchiveMemoryProjectionParams struct {
	ID        pgtype.UUID `json:"id"`
	Version   pgtype.Int4 `json:"version"`
	UpdatedAt time.Time   `json:"updated_at"`
}

type ArchiveMemoryWithVersionParams

type ArchiveMemoryWithVersionParams struct {
	ID        pgtype.UUID  `json:"id"`
	Status    MemoryStatus `json:"status"`
	UpdatedAt time.Time    `json:"updated_at"`
	Version   pgtype.Int4  `json:"version"`
}

type ArchiveSourceMemoriesParams

type ArchiveSourceMemoriesParams struct {
	Column1   []pgtype.UUID `json:"column_1"`
	Status    MemoryStatus  `json:"status"`
	UpdatedAt time.Time     `json:"updated_at"`
}

type BulkSetSystemSettingsParams

type BulkSetSystemSettingsParams struct {
	Keys         []string `json:"keys"`
	Values       [][]byte `json:"values"`
	Descriptions []string `json:"descriptions"`
}

type CompleteToolExecutionParams

type CompleteToolExecutionParams struct {
	Output json.RawMessage `json:"output"`
	ID     pgtype.UUID     `json:"id"`
}

type Conversation

type Conversation struct {
	ID            pgtype.UUID        `json:"id"`
	Title         string             `json:"title"`
	Summary       pgtype.Text        `json:"summary"`
	Status        ConversationStatus `json:"status"`
	Metadata      json.RawMessage    `json:"metadata"`
	CreatedAt     time.Time          `json:"created_at"`
	UpdatedAt     time.Time          `json:"updated_at"`
	LastMessageAt sql.NullTime       `json:"last_message_at"`
	MessageCount  int32              `json:"message_count"`
	TotalTokens   int32              `json:"total_tokens"`
}

Conversation session records, tracking user and AI interaction history

type ConversationStatus

type ConversationStatus string
const (
	ConversationStatusActive   ConversationStatus = "active"
	ConversationStatusArchived ConversationStatus = "archived"
	ConversationStatusDeleted  ConversationStatus = "deleted"
)

func AllConversationStatusValues

func AllConversationStatusValues() []ConversationStatus

func (*ConversationStatus) Scan

func (e *ConversationStatus) Scan(src interface{}) error

func (ConversationStatus) Valid

func (e ConversationStatus) Valid() bool

type CountEmbeddingsBySourceRow

type CountEmbeddingsBySourceRow struct {
	SourceTable string `json:"source_table"`
	Count       int32  `json:"count"`
}

type CountMessagesByRoleRow

type CountMessagesByRoleRow struct {
	Role  MessageRole `json:"role"`
	Count int32       `json:"count"`
}

type CreateConversationParams

type CreateConversationParams struct {
	Title    string             `json:"title"`
	Summary  pgtype.Text        `json:"summary"`
	Status   ConversationStatus `json:"status"`
	Metadata []byte             `json:"metadata"`
}

type CreateEmbeddingParams

type CreateEmbeddingParams struct {
	SourceTable string              `json:"source_table"`
	SourceID    pgtype.UUID         `json:"source_id"`
	Content     string              `json:"content"`
	Embedding   *pgvector_go.Vector `json:"embedding"`
	Model       interface{}         `json:"model"`
	Metadata    []byte              `json:"metadata"`
}

type CreateMemoryBackupParams

type CreateMemoryBackupParams struct {
	BackupData json.RawMessage `json:"backup_data"`
	NodeCount  int32           `json:"node_count"`
	EdgeCount  int32           `json:"edge_count"`
	Version    interface{}     `json:"version"`
}

type CreateMemoryBackupRow

type CreateMemoryBackupRow struct {
	ID         pgtype.UUID     `json:"id"`
	Version    string          `json:"version"`
	BackupData json.RawMessage `json:"backup_data"`
	CreatedAt  time.Time       `json:"created_at"`
}

type CreateMemoryProjectionParams

type CreateMemoryProjectionParams struct {
	ID         pgtype.UUID         `json:"id"`
	SemanticID string              `json:"semantic_id"`
	Type       MemoryType          `json:"type"`
	Content    string              `json:"content"`
	Summary    pgtype.Text         `json:"summary"`
	Entities   json.RawMessage     `json:"entities"`
	Attributes json.RawMessage     `json:"attributes"`
	Context    json.RawMessage     `json:"context"`
	Embedding  *pgvector_go.Vector `json:"embedding"`
	Keywords   []string            `json:"keywords"`
	Confidence pgtype.Float4       `json:"confidence"`
	Version    pgtype.Int4         `json:"version"`
	Status     MemoryStatus        `json:"status"`
	CreatedAt  time.Time           `json:"created_at"`
	UpdatedAt  time.Time           `json:"updated_at"`
}

type CreateMemoryProjectionRow

type CreateMemoryProjectionRow struct {
	ID         pgtype.UUID         `json:"id"`
	SemanticID string              `json:"semantic_id"`
	Type       MemoryType          `json:"type"`
	Content    string              `json:"content"`
	Summary    pgtype.Text         `json:"summary"`
	Entities   json.RawMessage     `json:"entities"`
	Attributes json.RawMessage     `json:"attributes"`
	Context    json.RawMessage     `json:"context"`
	Embedding  *pgvector_go.Vector `json:"embedding"`
	Keywords   []string            `json:"keywords"`
	Confidence pgtype.Float4       `json:"confidence"`
	Version    pgtype.Int4         `json:"version"`
	Status     MemoryStatus        `json:"status"`
	CreatedAt  time.Time           `json:"created_at"`
	UpdatedAt  time.Time           `json:"updated_at"`
}

type CreateMessageParams

type CreateMessageParams struct {
	ConversationID pgtype.UUID `json:"conversation_id"`
	Role           MessageRole `json:"role"`
	Content        string      `json:"content"`
	TokensUsed     interface{} `json:"tokens_used"`
	Metadata       []byte      `json:"metadata"`
}

type CreateTaskParams

type CreateTaskParams struct {
	Title       string       `json:"title"`
	Description pgtype.Text  `json:"description"`
	Status      TaskStatus   `json:"status"`
	Priority    TaskPriority `json:"priority"`
	DueDate     sql.NullTime `json:"due_date"`
	Labels      interface{}  `json:"labels"`
	Metadata    []byte       `json:"metadata"`
}

type CreateToolExecutionParams

type CreateToolExecutionParams struct {
	ConversationID pgtype.UUID `json:"conversation_id"`
	ToolName       string      `json:"tool_name"`
	Input          []byte      `json:"input"`
	Status         ToolStatus  `json:"status"`
}

type DBTX

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type DeleteEmbeddingBySourceParams

type DeleteEmbeddingBySourceParams struct {
	SourceTable string      `json:"source_table"`
	SourceID    pgtype.UUID `json:"source_id"`
}

type DeleteOldEmbeddingsParams

type DeleteOldEmbeddingsParams struct {
	DaysOld     interface{} `json:"days_old"`
	SourceTable string      `json:"source_table"`
}

type DeleteOldMemoryBackupsParams

type DeleteOldMemoryBackupsParams struct {
	KeepCount int32       `json:"keep_count"`
	KeepDays  interface{} `json:"keep_days"`
}

type Embedding

type Embedding struct {
	ID          pgtype.UUID         `json:"id"`
	SourceTable string              `json:"source_table"`
	SourceID    pgtype.UUID         `json:"source_id"`
	Content     string              `json:"content"`
	Embedding   *pgvector_go.Vector `json:"embedding"`
	Model       string              `json:"model"`
	Metadata    json.RawMessage     `json:"metadata"`
	CreatedAt   time.Time           `json:"created_at"`
}

Unified vector embeddings table, supporting semantic search and similarity matching

type EntityRole

type EntityRole string
const (
	EntityRoleSubject  EntityRole = "subject"
	EntityRoleObject   EntityRole = "object"
	EntityRoleLocation EntityRole = "location"
	EntityRoleTime     EntityRole = "time"
	EntityRoleWith     EntityRole = "with"
)

func AllEntityRoleValues

func AllEntityRoleValues() []EntityRole

func (*EntityRole) Scan

func (e *EntityRole) Scan(src interface{}) error

func (EntityRole) Valid

func (e EntityRole) Valid() bool

type EntityType

type EntityType string
const (
	EntityTypePerson   EntityType = "person"
	EntityTypePlace    EntityType = "place"
	EntityTypeActivity EntityType = "activity"
	EntityTypeTime     EntityType = "time"
	EntityTypeThing    EntityType = "thing"
	EntityTypeConcept  EntityType = "concept"
)

func AllEntityTypeValues

func AllEntityTypeValues() []EntityType

func (*EntityType) Scan

func (e *EntityType) Scan(src interface{}) error

func (EntityType) Valid

func (e EntityType) Valid() bool

type FailToolExecutionParams

type FailToolExecutionParams struct {
	ErrorMessage pgtype.Text `json:"error_message"`
	ID           pgtype.UUID `json:"id"`
}

type GetBackupStatsRow

type GetBackupStatsRow struct {
	TotalBackups       int32       `json:"total_backups"`
	TotalNodesBackedUp int32       `json:"total_nodes_backed_up"`
	TotalEdgesBackedUp int32       `json:"total_edges_backed_up"`
	OldestBackup       interface{} `json:"oldest_backup"`
	NewestBackup       interface{} `json:"newest_backup"`
}

type GetBackupsWithinTimeRangeParams

type GetBackupsWithinTimeRangeParams struct {
	StartTime time.Time `json:"start_time"`
	EndTime   time.Time `json:"end_time"`
}

type GetBackupsWithinTimeRangeRow

type GetBackupsWithinTimeRangeRow struct {
	ID         pgtype.UUID     `json:"id"`
	Version    string          `json:"version"`
	BackupData json.RawMessage `json:"backup_data"`
	CreatedAt  time.Time       `json:"created_at"`
}

type GetConversationStatsRow

type GetConversationStatsRow struct {
	TotalConversations  int64 `json:"total_conversations"`
	ActiveConversations int64 `json:"active_conversations"`
	TotalMessages       int64 `json:"total_messages"`
	TotalTokens         int64 `json:"total_tokens"`
}

type GetConversationTokenUsageRow

type GetConversationTokenUsageRow struct {
	MessageCount        int32   `json:"message_count"`
	TotalTokens         int32   `json:"total_tokens"`
	AvgTokensPerMessage float64 `json:"avg_tokens_per_message"`
}

type GetEmbeddingBySourceParams

type GetEmbeddingBySourceParams struct {
	SourceTable string      `json:"source_table"`
	SourceID    pgtype.UUID `json:"source_id"`
}

type GetEmbeddingStatsRow

type GetEmbeddingStatsRow struct {
	TotalEmbeddings int32       `json:"total_embeddings"`
	SourceTypes     int32       `json:"source_types"`
	OldestEmbedding interface{} `json:"oldest_embedding"`
	NewestEmbedding interface{} `json:"newest_embedding"`
}

type GetLastMessagesParams

type GetLastMessagesParams struct {
	ConversationID pgtype.UUID `json:"conversation_id"`
	LimitCount     int32       `json:"limit_count"`
}

type GetLatestMemoryBackupRow

type GetLatestMemoryBackupRow struct {
	ID         pgtype.UUID     `json:"id"`
	Version    string          `json:"version"`
	BackupData json.RawMessage `json:"backup_data"`
	CreatedAt  time.Time       `json:"created_at"`
}

type GetMemoryBackupRow

type GetMemoryBackupRow struct {
	ID         pgtype.UUID     `json:"id"`
	Version    string          `json:"version"`
	BackupData json.RawMessage `json:"backup_data"`
	CreatedAt  time.Time       `json:"created_at"`
}

type GetMemoryEventsByTypeParams

type GetMemoryEventsByTypeParams struct {
	Type  string `json:"type"`
	Limit int32  `json:"limit"`
}

type GetMemoryForMergeDecisionRow

type GetMemoryForMergeDecisionRow struct {
	ID          pgtype.UUID     `json:"id"`
	Content     string          `json:"content"`
	Keywords    []string        `json:"keywords"`
	Entities    json.RawMessage `json:"entities"`
	Attributes  json.RawMessage `json:"attributes"`
	Confidence  pgtype.Float4   `json:"confidence"`
	AccessCount pgtype.Int4     `json:"access_count"`
}

type GetMemoryForMergeRow

type GetMemoryForMergeRow struct {
	Content    string        `json:"content"`
	Keywords   []string      `json:"keywords"`
	Confidence pgtype.Float4 `json:"confidence"`
}

type GetMemoryStreamsRow

type GetMemoryStreamsRow struct {
	StreamID      pgtype.UUID `json:"stream_id"`
	LatestVersion interface{} `json:"latest_version"`
}

type GetRecentConversationsWithMessageCountRow

type GetRecentConversationsWithMessageCountRow struct {
	ID              pgtype.UUID        `json:"id"`
	Title           string             `json:"title"`
	Summary         pgtype.Text        `json:"summary"`
	Status          ConversationStatus `json:"status"`
	Metadata        json.RawMessage    `json:"metadata"`
	CreatedAt       time.Time          `json:"created_at"`
	UpdatedAt       time.Time          `json:"updated_at"`
	LastMessageAt   sql.NullTime       `json:"last_message_at"`
	MessageCount    int32              `json:"message_count"`
	TotalTokens     int32              `json:"total_tokens"`
	MessageCount_2  int32              `json:"message_count_2"`
	LastMessageTime interface{}        `json:"last_message_time"`
}

type GetSettingHistoryRow

type GetSettingHistoryRow struct {
	Key       string          `json:"key"`
	Value     json.RawMessage `json:"value"`
	CreatedAt time.Time       `json:"created_at"`
	UpdatedAt time.Time       `json:"updated_at"`
}

type GetTaskStatsRow

type GetTaskStatsRow struct {
	TotalTasks      int32 `json:"total_tasks"`
	TodoCount       int32 `json:"todo_count"`
	InProgressCount int32 `json:"in_progress_count"`
	DoneCount       int32 `json:"done_count"`
	CancelledCount  int32 `json:"cancelled_count"`
	OverdueCount    int32 `json:"overdue_count"`
}

type GetTasksByPriorityRow

type GetTasksByPriorityRow struct {
	Priority TaskPriority `json:"priority"`
	Count    int32        `json:"count"`
}

type GetToolExecutionStatsParams

type GetToolExecutionStatsParams struct {
	Since    pgtype.Timestamptz `json:"since"`
	ToolName string             `json:"tool_name"`
}

type GetToolExecutionStatsRow

type GetToolExecutionStatsRow struct {
	TotalExecutions int32   `json:"total_executions"`
	SuccessCount    int32   `json:"success_count"`
	FailedCount     int32   `json:"failed_count"`
	TimeoutCount    int32   `json:"timeout_count"`
	AvgDurationMs   float64 `json:"avg_duration_ms"`
	MaxDurationMs   int32   `json:"max_duration_ms"`
}

type GetToolUsageByNameRow

type GetToolUsageByNameRow struct {
	ToolName       string  `json:"tool_name"`
	ExecutionCount int32   `json:"execution_count"`
	SuccessCount   int32   `json:"success_count"`
	AvgDurationMs  float64 `json:"avg_duration_ms"`
}

type History

type History struct {
	ID         pgtype.UUID     `json:"id"`
	MemoryID   pgtype.UUID     `json:"memory_id"`
	Action     ActionType      `json:"action"`
	Version    int32           `json:"version"`
	Content    string          `json:"content"`
	Entities   json.RawMessage `json:"entities"`
	Attributes json.RawMessage `json:"attributes"`
	Context    json.RawMessage `json:"context"`
	Reason     pgtype.Text     `json:"reason"`
	CreatedBy  pgtype.Text     `json:"created_by"`
	CreatedAt  time.Time       `json:"created_at"`
}

Change history for memories

type ListConversationsParams

type ListConversationsParams struct {
	Status      ConversationStatus `json:"status"`
	OrderBy     interface{}        `json:"order_by"`
	OffsetCount int32              `json:"offset_count"`
	LimitCount  int32              `json:"limit_count"`
}

type ListEmbeddingsBySourceParams

type ListEmbeddingsBySourceParams struct {
	SourceTable string `json:"source_table"`
	OffsetCount int32  `json:"offset_count"`
	LimitCount  int32  `json:"limit_count"`
}

type ListMemoryBackupsParams

type ListMemoryBackupsParams struct {
	OffsetCount int32 `json:"offset_count"`
	LimitCount  int32 `json:"limit_count"`
}

type ListMemoryBackupsRow

type ListMemoryBackupsRow struct {
	ID         pgtype.UUID     `json:"id"`
	Version    string          `json:"version"`
	BackupData json.RawMessage `json:"backup_data"`
	CreatedAt  time.Time       `json:"created_at"`
}

type ListMessagesParams

type ListMessagesParams struct {
	ConversationID pgtype.UUID `json:"conversation_id"`
	OffsetCount    int32       `json:"offset_count"`
	LimitCount     int32       `json:"limit_count"`
}

type ListRecentMessagesParams

type ListRecentMessagesParams struct {
	ConversationID pgtype.UUID `json:"conversation_id"`
	LimitCount     int32       `json:"limit_count"`
}

type ListTasksByLabelParams

type ListTasksByLabelParams struct {
	Label            []string `json:"label"`
	IncludeCompleted bool     `json:"include_completed"`
	LimitCount       int32    `json:"limit_count"`
}

type ListTasksParams

type ListTasksParams struct {
	Status           TaskStatus   `json:"status"`
	Priority         TaskPriority `json:"priority"`
	IncludeCompleted bool         `json:"include_completed"`
	OffsetCount      int32        `json:"offset_count"`
	LimitCount       int32        `json:"limit_count"`
}

type ListToolExecutionsByConversationParams

type ListToolExecutionsByConversationParams struct {
	ConversationID pgtype.UUID `json:"conversation_id"`
	LimitCount     int32       `json:"limit_count"`
}

type ListToolExecutionsParams

type ListToolExecutionsParams struct {
	ToolName    string     `json:"tool_name"`
	Status      ToolStatus `json:"status"`
	OffsetCount int32      `json:"offset_count"`
	LimitCount  int32      `json:"limit_count"`
}

type LoadMemoryEventsFromVersionParams

type LoadMemoryEventsFromVersionParams struct {
	StreamID pgtype.UUID `json:"stream_id"`
	Version  int32       `json:"version"`
}

type MarkMemoryAsCorrectedParams

type MarkMemoryAsCorrectedParams struct {
	ID               pgtype.UUID `json:"id"`
	CorrectedBy      pgtype.UUID `json:"corrected_by"`
	CorrectionReason pgtype.Text `json:"correction_reason"`
	UpdatedAt        time.Time   `json:"updated_at"`
}

type Memory

type Memory struct {
	ID pgtype.UUID `json:"id"`
	// Semantic ID for updates (e.g., schedule_thai_boxing_20250714)
	SemanticID string      `json:"semantic_id"`
	Type       MemoryType  `json:"type"`
	Content    string      `json:"content"`
	Summary    pgtype.Text `json:"summary"`
	// Entities with types and roles
	Entities json.RawMessage `json:"entities"`
	// Key-value attributes
	Attributes json.RawMessage `json:"attributes"`
	// Temporal and spatial context
	Context json.RawMessage `json:"context"`
	// Vector embedding for semantic similarity search
	Embedding  *pgvector_go.Vector `json:"embedding"`
	Keywords   []string            `json:"keywords"`
	Confidence pgtype.Float4       `json:"confidence"`
	// Current version from event stream for optimistic locking
	Version     pgtype.Int4  `json:"version"`
	AccessCount pgtype.Int4  `json:"access_count"`
	CreatedAt   time.Time    `json:"created_at"`
	UpdatedAt   time.Time    `json:"updated_at"`
	AccessedAt  sql.NullTime `json:"accessed_at"`
	// Memory status: active, archived, or deleted
	Status     MemoryStatus       `json:"status"`
	ArchivedAt pgtype.Timestamptz `json:"archived_at"`
	MergedFrom []uuid.UUID        `json:"merged_from"`
	// The source of this memory - who said it and how certain we are
	Source NullMemorySource `json:"source"`
	// Array of memory IDs that this memory replaces or overrides
	Supersedes []uuid.UUID `json:"supersedes"`
	// ID of the memory that corrected this one
	CorrectedBy pgtype.UUID `json:"corrected_by"`
	// Explanation of why this memory was corrected
	CorrectionReason pgtype.Text `json:"correction_reason"`
}

Structured memory system with semantic IDs and embeddings

type MemoryBackup

type MemoryBackup struct {
	ID         pgtype.UUID     `json:"id"`
	BackupData json.RawMessage `json:"backup_data"`
	NodeCount  int32           `json:"node_count"`
	EdgeCount  int32           `json:"edge_count"`
	Version    string          `json:"version"`
	CreatedAt  time.Time       `json:"created_at"`
}

Knowledge graph backups, ensuring memory persistence

type MemoryEvent

type MemoryEvent struct {
	ID pgtype.UUID `json:"id"`
	// The memory ID this event belongs to
	StreamID pgtype.UUID `json:"stream_id"`
	// Event type: created, updated, archived, or merged
	Type string `json:"type"`
	// Sequential version number within the stream
	Version   int32              `json:"version"`
	Timestamp pgtype.Timestamptz `json:"timestamp"`
	// Event-specific data in JSON format
	Data json.RawMessage `json:"data"`
}

Event store for memory system - append-only log of all changes

type MemorySource

type MemorySource string
const (
	MemorySourceUserDirect     MemorySource = "user_direct"
	MemorySourceUserConfirm    MemorySource = "user_confirm"
	MemorySourceUserCorrection MemorySource = "user_correction"
	MemorySourceAssistantInfer MemorySource = "assistant_infer"
)

func AllMemorySourceValues

func AllMemorySourceValues() []MemorySource

func (*MemorySource) Scan

func (e *MemorySource) Scan(src interface{}) error

func (MemorySource) Valid

func (e MemorySource) Valid() bool

type MemoryStatus

type MemoryStatus string
const (
	MemoryStatusActive   MemoryStatus = "active"
	MemoryStatusArchived MemoryStatus = "archived"
	MemoryStatusDeleted  MemoryStatus = "deleted"
)

func AllMemoryStatusValues

func AllMemoryStatusValues() []MemoryStatus

func (*MemoryStatus) Scan

func (e *MemoryStatus) Scan(src interface{}) error

func (MemoryStatus) Valid

func (e MemoryStatus) Valid() bool

type MemoryType

type MemoryType string
const (
	MemoryTypeFact         MemoryType = "fact"
	MemoryTypePreference   MemoryType = "preference"
	MemoryTypeSchedule     MemoryType = "schedule"
	MemoryTypeRelationship MemoryType = "relationship"
	MemoryTypeGoal         MemoryType = "goal"
	MemoryTypeSkill        MemoryType = "skill"
)

func AllMemoryTypeValues

func AllMemoryTypeValues() []MemoryType

func (*MemoryType) Scan

func (e *MemoryType) Scan(src interface{}) error

func (MemoryType) Valid

func (e MemoryType) Valid() bool

type Message

type Message struct {
	ID             pgtype.UUID     `json:"id"`
	ConversationID pgtype.UUID     `json:"conversation_id"`
	Role           MessageRole     `json:"role"`
	Content        string          `json:"content"`
	TokensUsed     int32           `json:"tokens_used"`
	Metadata       json.RawMessage `json:"metadata"`
	CreatedAt      time.Time       `json:"created_at"`
}

Messages within conversations, including user input and AI responses

type MessageRole

type MessageRole string
const (
	MessageRoleUser      MessageRole = "user"
	MessageRoleAssistant MessageRole = "assistant"
	MessageRoleSystem    MessageRole = "system"
	MessageRoleTool      MessageRole = "tool"
	MessageRoleError     MessageRole = "error"
)

func AllMessageRoleValues

func AllMessageRoleValues() []MessageRole

func (*MessageRole) Scan

func (e *MessageRole) Scan(src interface{}) error

func (MessageRole) Valid

func (e MessageRole) Valid() bool

type NullActionType

type NullActionType struct {
	ActionType ActionType `json:"action_type"`
	Valid      bool       `json:"valid"` // Valid is true if ActionType is not NULL
}

func (*NullActionType) Scan

func (ns *NullActionType) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullActionType) Value

func (ns NullActionType) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullConversationStatus

type NullConversationStatus struct {
	ConversationStatus ConversationStatus `json:"conversation_status"`
	Valid              bool               `json:"valid"` // Valid is true if ConversationStatus is not NULL
}

func (*NullConversationStatus) Scan

func (ns *NullConversationStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullConversationStatus) Value

func (ns NullConversationStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullEntityRole

type NullEntityRole struct {
	EntityRole EntityRole `json:"entity_role"`
	Valid      bool       `json:"valid"` // Valid is true if EntityRole is not NULL
}

func (*NullEntityRole) Scan

func (ns *NullEntityRole) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullEntityRole) Value

func (ns NullEntityRole) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullEntityType

type NullEntityType struct {
	EntityType EntityType `json:"entity_type"`
	Valid      bool       `json:"valid"` // Valid is true if EntityType is not NULL
}

func (*NullEntityType) Scan

func (ns *NullEntityType) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullEntityType) Value

func (ns NullEntityType) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullMemorySource

type NullMemorySource struct {
	MemorySource MemorySource `json:"memory_source"`
	Valid        bool         `json:"valid"` // Valid is true if MemorySource is not NULL
}

func (*NullMemorySource) Scan

func (ns *NullMemorySource) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullMemorySource) Value

func (ns NullMemorySource) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullMemoryStatus

type NullMemoryStatus struct {
	MemoryStatus MemoryStatus `json:"memory_status"`
	Valid        bool         `json:"valid"` // Valid is true if MemoryStatus is not NULL
}

func (*NullMemoryStatus) Scan

func (ns *NullMemoryStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullMemoryStatus) Value

func (ns NullMemoryStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullMemoryType

type NullMemoryType struct {
	MemoryType MemoryType `json:"memory_type"`
	Valid      bool       `json:"valid"` // Valid is true if MemoryType is not NULL
}

func (*NullMemoryType) Scan

func (ns *NullMemoryType) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullMemoryType) Value

func (ns NullMemoryType) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullMessageRole

type NullMessageRole struct {
	MessageRole MessageRole `json:"message_role"`
	Valid       bool        `json:"valid"` // Valid is true if MessageRole is not NULL
}

func (*NullMessageRole) Scan

func (ns *NullMessageRole) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullMessageRole) Value

func (ns NullMessageRole) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullRecurrencePattern

type NullRecurrencePattern struct {
	RecurrencePattern RecurrencePattern `json:"recurrence_pattern"`
	Valid             bool              `json:"valid"` // Valid is true if RecurrencePattern is not NULL
}

func (*NullRecurrencePattern) Scan

func (ns *NullRecurrencePattern) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullRecurrencePattern) Value

func (ns NullRecurrencePattern) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullRelationType

type NullRelationType struct {
	RelationType RelationType `json:"relation_type"`
	Valid        bool         `json:"valid"` // Valid is true if RelationType is not NULL
}

func (*NullRelationType) Scan

func (ns *NullRelationType) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullRelationType) Value

func (ns NullRelationType) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullTaskPriority

type NullTaskPriority struct {
	TaskPriority TaskPriority `json:"task_priority"`
	Valid        bool         `json:"valid"` // Valid is true if TaskPriority is not NULL
}

func (*NullTaskPriority) Scan

func (ns *NullTaskPriority) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullTaskPriority) Value

func (ns NullTaskPriority) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullTaskStatus

type NullTaskStatus struct {
	TaskStatus TaskStatus `json:"task_status"`
	Valid      bool       `json:"valid"` // Valid is true if TaskStatus is not NULL
}

func (*NullTaskStatus) Scan

func (ns *NullTaskStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullTaskStatus) Value

func (ns NullTaskStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullToolStatus

type NullToolStatus struct {
	ToolStatus ToolStatus `json:"tool_status"`
	Valid      bool       `json:"valid"` // Valid is true if ToolStatus is not NULL
}

func (*NullToolStatus) Scan

func (ns *NullToolStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullToolStatus) Value

func (ns NullToolStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type Querier

type Querier interface {
	AddTaskLabel(ctx context.Context, arg AddTaskLabelParams) (*Task, error)
	// Memory Event Sourcing Queries
	AppendMemoryEvent(ctx context.Context, arg AppendMemoryEventParams) error
	ArchiveConversation(ctx context.Context, id pgtype.UUID) (*Conversation, error)
	// Archive a memory by setting status to archived
	ArchiveMemory(ctx context.Context, arg ArchiveMemoryParams) (pgconn.CommandTag, error)
	ArchiveMemoryProjection(ctx context.Context, arg ArchiveMemoryProjectionParams) error
	// Archive a memory with version check
	ArchiveMemoryWithVersion(ctx context.Context, arg ArchiveMemoryWithVersionParams) error
	// Archive multiple source memories after merge
	ArchiveSourceMemories(ctx context.Context, arg ArchiveSourceMemoriesParams) error
	BulkSetSystemSettings(ctx context.Context, arg BulkSetSystemSettingsParams) error
	CancelPendingToolExecutions(ctx context.Context, conversationID pgtype.UUID) error
	CompleteTask(ctx context.Context, id pgtype.UUID) (*Task, error)
	CompleteToolExecution(ctx context.Context, arg CompleteToolExecutionParams) (*ToolExecution, error)
	CountEmbeddingsBySource(ctx context.Context) ([]*CountEmbeddingsBySourceRow, error)
	CountMemoryBackups(ctx context.Context) (int32, error)
	CountMemoryEvents(ctx context.Context) (int64, error)
	CountMessagesByRole(ctx context.Context, conversationID pgtype.UUID) ([]*CountMessagesByRoleRow, error)
	CountSystemSettings(ctx context.Context) (int32, error)
	CreateConversation(ctx context.Context, arg CreateConversationParams) (*Conversation, error)
	CreateEmbedding(ctx context.Context, arg CreateEmbeddingParams) (*Embedding, error)
	CreateMemoryBackup(ctx context.Context, arg CreateMemoryBackupParams) (*CreateMemoryBackupRow, error)
	// Memory Projection Queries (for read model)
	CreateMemoryProjection(ctx context.Context, arg CreateMemoryProjectionParams) (*CreateMemoryProjectionRow, error)
	CreateMessage(ctx context.Context, arg CreateMessageParams) (*Message, error)
	CreateTask(ctx context.Context, arg CreateTaskParams) (*Task, error)
	CreateToolExecution(ctx context.Context, arg CreateToolExecutionParams) (*ToolExecution, error)
	DeleteConversation(ctx context.Context, id pgtype.UUID) error
	DeleteConversationMessages(ctx context.Context, conversationID pgtype.UUID) error
	DeleteEmbedding(ctx context.Context, id pgtype.UUID) error
	DeleteEmbeddingBySource(ctx context.Context, arg DeleteEmbeddingBySourceParams) error
	DeleteMemoryBackup(ctx context.Context, id pgtype.UUID) error
	DeleteMessage(ctx context.Context, id pgtype.UUID) error
	DeleteOldEmbeddings(ctx context.Context, arg DeleteOldEmbeddingsParams) error
	DeleteOldMemoryBackups(ctx context.Context, arg DeleteOldMemoryBackupsParams) error
	DeleteOldToolExecutions(ctx context.Context, daysOld interface{}) error
	DeleteSystemSetting(ctx context.Context, key string) error
	DeleteTask(ctx context.Context, id pgtype.UUID) error
	ExistsSystemSetting(ctx context.Context, key string) (bool, error)
	FailToolExecution(ctx context.Context, arg FailToolExecutionParams) (*ToolExecution, error)
	GetActiveMemories(ctx context.Context, limit int32) ([]*Memory, error)
	GetBackupStats(ctx context.Context) (*GetBackupStatsRow, error)
	GetBackupsWithinTimeRange(ctx context.Context, arg GetBackupsWithinTimeRangeParams) ([]*GetBackupsWithinTimeRangeRow, error)
	GetConversation(ctx context.Context, id pgtype.UUID) (*Conversation, error)
	GetConversationStats(ctx context.Context) (*GetConversationStatsRow, error)
	GetConversationTokenUsage(ctx context.Context, conversationID pgtype.UUID) (*GetConversationTokenUsageRow, error)
	GetEmbedding(ctx context.Context, id pgtype.UUID) (*Embedding, error)
	GetEmbeddingBySource(ctx context.Context, arg GetEmbeddingBySourceParams) (*Embedding, error)
	GetEmbeddingStats(ctx context.Context) (*GetEmbeddingStatsRow, error)
	GetLastMessages(ctx context.Context, arg GetLastMessagesParams) ([]*Message, error)
	GetLatestMemoryBackup(ctx context.Context) (*GetLatestMemoryBackupRow, error)
	GetLatestMemoryEvent(ctx context.Context, streamID pgtype.UUID) (*MemoryEvent, error)
	GetMemoryBackup(ctx context.Context, id pgtype.UUID) (*GetMemoryBackupRow, error)
	// Memory Event Sourcing Read Model Queries
	// These queries are used by the Reader to query the projected memories
	GetMemoryById(ctx context.Context, id pgtype.UUID) (*Memory, error)
	GetMemoryEventsByType(ctx context.Context, arg GetMemoryEventsByTypeParams) ([]*MemoryEvent, error)
	// Get memory details for merge operation
	GetMemoryForMerge(ctx context.Context, id pgtype.UUID) (*GetMemoryForMergeRow, error)
	// Get full memory details for merge decision
	GetMemoryForMergeDecision(ctx context.Context, id pgtype.UUID) (*GetMemoryForMergeDecisionRow, error)
	GetMemoryProjection(ctx context.Context, id pgtype.UUID) (*Memory, error)
	GetMemoryStreams(ctx context.Context) ([]*GetMemoryStreamsRow, error)
	GetMessage(ctx context.Context, id pgtype.UUID) (*Message, error)
	GetMultipleSettings(ctx context.Context, keys []string) ([]*SystemSetting, error)
	GetRecentConversationsWithMessageCount(ctx context.Context, limitCount int32) ([]*GetRecentConversationsWithMessageCountRow, error)
	GetRecentMemories(ctx context.Context, limit int32) ([]*Memory, error)
	GetSettingHistory(ctx context.Context, key string) ([]*GetSettingHistoryRow, error)
	GetSystemSetting(ctx context.Context, key string) (*SystemSetting, error)
	GetSystemSettingKeys(ctx context.Context) ([]string, error)
	GetTask(ctx context.Context, id pgtype.UUID) (*Task, error)
	GetTaskStats(ctx context.Context) (*GetTaskStatsRow, error)
	GetTasksByPriority(ctx context.Context) ([]*GetTasksByPriorityRow, error)
	GetToolExecution(ctx context.Context, id pgtype.UUID) (*ToolExecution, error)
	GetToolExecutionStats(ctx context.Context, arg GetToolExecutionStatsParams) (*GetToolExecutionStatsRow, error)
	GetToolUsageByName(ctx context.Context, since pgtype.Timestamptz) ([]*GetToolUsageByNameRow, error)
	ListActiveConversations(ctx context.Context, limitCount int32) ([]*Conversation, error)
	ListConversations(ctx context.Context, arg ListConversationsParams) ([]*Conversation, error)
	ListEmbeddingsBySource(ctx context.Context, arg ListEmbeddingsBySourceParams) ([]*Embedding, error)
	ListMemoryBackups(ctx context.Context, arg ListMemoryBackupsParams) ([]*ListMemoryBackupsRow, error)
	ListMessages(ctx context.Context, arg ListMessagesParams) ([]*Message, error)
	ListOverdueTasks(ctx context.Context) ([]*Task, error)
	ListPendingTasks(ctx context.Context, limitCount int32) ([]*Task, error)
	ListPendingToolExecutions(ctx context.Context, limitCount int32) ([]*ToolExecution, error)
	ListRecentMessages(ctx context.Context, arg ListRecentMessagesParams) ([]*Message, error)
	ListSystemSettings(ctx context.Context) ([]*SystemSetting, error)
	ListSystemSettingsByPrefix(ctx context.Context, prefix pgtype.Text) ([]*SystemSetting, error)
	ListTasks(ctx context.Context, arg ListTasksParams) ([]*Task, error)
	ListTasksByLabel(ctx context.Context, arg ListTasksByLabelParams) ([]*Task, error)
	ListTasksDueToday(ctx context.Context) ([]*Task, error)
	ListToolExecutions(ctx context.Context, arg ListToolExecutionsParams) ([]*ToolExecution, error)
	ListToolExecutionsByConversation(ctx context.Context, arg ListToolExecutionsByConversationParams) ([]*ToolExecution, error)
	LoadMemoryEvents(ctx context.Context, streamID pgtype.UUID) ([]*MemoryEvent, error)
	LoadMemoryEventsFromVersion(ctx context.Context, arg LoadMemoryEventsFromVersionParams) ([]*MemoryEvent, error)
	// Mark a memory as corrected by another memory
	MarkMemoryAsCorrected(ctx context.Context, arg MarkMemoryAsCorrectedParams) (pgconn.CommandTag, error)
	RemoveTaskLabel(ctx context.Context, arg RemoveTaskLabelParams) (*Task, error)
	// Search messages within conversations
	SearchConversationMessages(ctx context.Context, arg SearchConversationMessagesParams) ([]*SearchConversationMessagesRow, error)
	// Search conversations using full-text search
	SearchConversations(ctx context.Context, arg SearchConversationsParams) ([]*SearchConversationsRow, error)
	// Search with highlighted results
	SearchConversationsWithHighlight(ctx context.Context, arg SearchConversationsWithHighlightParams) ([]*SearchConversationsWithHighlightRow, error)
	// Uses full-text search for better performance than ILIKE
	SearchMemoriesByText(ctx context.Context, arg SearchMemoriesByTextParams) ([]*Memory, error)
	// Fallback query using ILIKE if full-text search column doesn't exist yet
	SearchMemoriesByTextFallback(ctx context.Context, arg SearchMemoriesByTextFallbackParams) ([]*Memory, error)
	SearchMemoryProjections(ctx context.Context, arg SearchMemoryProjectionsParams) ([]*SearchMemoryProjectionsRow, error)
	SearchMessages(ctx context.Context, arg SearchMessagesParams) ([]*Message, error)
	SearchSimilarEmbeddings(ctx context.Context, arg SearchSimilarEmbeddingsParams) ([]*SearchSimilarEmbeddingsRow, error)
	SearchSimilarMemories(ctx context.Context, arg SearchSimilarMemoriesParams) ([]*SearchSimilarMemoriesRow, error)
	// Search for similar memories for deduplication
	// @embedding is a vector, @threshold is a float
	SearchSimilarMemoriesForDedup(ctx context.Context, arg SearchSimilarMemoriesForDedupParams) ([]*SearchSimilarMemoriesForDedupRow, error)
	// Search for similar memories above a threshold for merge decisions
	SearchSimilarMemoriesForMerge(ctx context.Context, arg SearchSimilarMemoriesForMergeParams) ([]*SearchSimilarMemoriesForMergeRow, error)
	SearchTasks(ctx context.Context, arg SearchTasksParams) ([]*Task, error)
	SetSystemSetting(ctx context.Context, arg SetSystemSettingParams) (*SystemSetting, error)
	StartToolExecution(ctx context.Context, id pgtype.UUID) (*ToolExecution, error)
	UpdateConversation(ctx context.Context, arg UpdateConversationParams) (*Conversation, error)
	UpdateEmbedding(ctx context.Context, arg UpdateEmbeddingParams) (*Embedding, error)
	UpdateMemory(ctx context.Context, arg UpdateMemoryParams) error
	// Update memory access timestamp and count
	UpdateMemoryAccess(ctx context.Context, arg UpdateMemoryAccessParams) error
	// Update memory with merged data
	UpdateMemoryAfterMerge(ctx context.Context, arg UpdateMemoryAfterMergeParams) error
	// Update memory confidence
	UpdateMemoryConfidence(ctx context.Context, arg UpdateMemoryConfidenceParams) error
	// Update memory as corrected
	UpdateMemoryCorrected(ctx context.Context, arg UpdateMemoryCorrectedParams) error
	UpdateMemoryEmbedding(ctx context.Context, arg UpdateMemoryEmbeddingParams) error
	// Update memory after merge
	UpdateMemoryMerged(ctx context.Context, arg UpdateMemoryMergedParams) error
	UpdateMemoryProjection(ctx context.Context, arg UpdateMemoryProjectionParams) error
	// Update a memory after merging with another
	UpdateMergedMemory(ctx context.Context, arg UpdateMergedMemoryParams) error
	UpdateSystemSetting(ctx context.Context, arg UpdateSystemSettingParams) (*SystemSetting, error)
	UpdateTask(ctx context.Context, arg UpdateTaskParams) (*Task, error)
	UpdateTaskLabels(ctx context.Context, arg UpdateTaskLabelsParams) (*Task, error)
	UpdateToolExecution(ctx context.Context, arg UpdateToolExecutionParams) (*ToolExecution, error)
	// Projector-specific queries for event projection
	// These queries are used by the Projector to write memory projections
	// Insert or update memory with optimistic locking on version
	UpsertMemory(ctx context.Context, arg UpsertMemoryParams) error
}

type Queries

type Queries struct {
	// contains filtered or unexported fields
}

func New

func New(db DBTX) *Queries

func (*Queries) AddTaskLabel

func (q *Queries) AddTaskLabel(ctx context.Context, arg AddTaskLabelParams) (*Task, error)

func (*Queries) AppendMemoryEvent

func (q *Queries) AppendMemoryEvent(ctx context.Context, arg AppendMemoryEventParams) error

Memory Event Sourcing Queries

func (*Queries) ArchiveConversation

func (q *Queries) ArchiveConversation(ctx context.Context, id pgtype.UUID) (*Conversation, error)

func (*Queries) ArchiveMemory

func (q *Queries) ArchiveMemory(ctx context.Context, arg ArchiveMemoryParams) (pgconn.CommandTag, error)

Archive a memory by setting status to archived

func (*Queries) ArchiveMemoryProjection

func (q *Queries) ArchiveMemoryProjection(ctx context.Context, arg ArchiveMemoryProjectionParams) error

func (*Queries) ArchiveMemoryWithVersion

func (q *Queries) ArchiveMemoryWithVersion(ctx context.Context, arg ArchiveMemoryWithVersionParams) error

Archive a memory with version check

func (*Queries) ArchiveSourceMemories

func (q *Queries) ArchiveSourceMemories(ctx context.Context, arg ArchiveSourceMemoriesParams) error

Archive multiple source memories after merge

func (*Queries) BulkSetSystemSettings

func (q *Queries) BulkSetSystemSettings(ctx context.Context, arg BulkSetSystemSettingsParams) error

func (*Queries) CancelPendingToolExecutions

func (q *Queries) CancelPendingToolExecutions(ctx context.Context, conversationID pgtype.UUID) error

func (*Queries) CompleteTask

func (q *Queries) CompleteTask(ctx context.Context, id pgtype.UUID) (*Task, error)

func (*Queries) CompleteToolExecution

func (q *Queries) CompleteToolExecution(ctx context.Context, arg CompleteToolExecutionParams) (*ToolExecution, error)

func (*Queries) CountEmbeddingsBySource

func (q *Queries) CountEmbeddingsBySource(ctx context.Context) ([]*CountEmbeddingsBySourceRow, error)

func (*Queries) CountMemoryBackups

func (q *Queries) CountMemoryBackups(ctx context.Context) (int32, error)

func (*Queries) CountMemoryEvents

func (q *Queries) CountMemoryEvents(ctx context.Context) (int64, error)

func (*Queries) CountMessagesByRole

func (q *Queries) CountMessagesByRole(ctx context.Context, conversationID pgtype.UUID) ([]*CountMessagesByRoleRow, error)

func (*Queries) CountSystemSettings

func (q *Queries) CountSystemSettings(ctx context.Context) (int32, error)

func (*Queries) CreateConversation

func (q *Queries) CreateConversation(ctx context.Context, arg CreateConversationParams) (*Conversation, error)

func (*Queries) CreateEmbedding

func (q *Queries) CreateEmbedding(ctx context.Context, arg CreateEmbeddingParams) (*Embedding, error)

func (*Queries) CreateMemoryBackup

func (q *Queries) CreateMemoryBackup(ctx context.Context, arg CreateMemoryBackupParams) (*CreateMemoryBackupRow, error)

func (*Queries) CreateMemoryProjection

func (q *Queries) CreateMemoryProjection(ctx context.Context, arg CreateMemoryProjectionParams) (*CreateMemoryProjectionRow, error)

Memory Projection Queries (for read model)

func (*Queries) CreateMessage

func (q *Queries) CreateMessage(ctx context.Context, arg CreateMessageParams) (*Message, error)

func (*Queries) CreateTask

func (q *Queries) CreateTask(ctx context.Context, arg CreateTaskParams) (*Task, error)

func (*Queries) CreateToolExecution

func (q *Queries) CreateToolExecution(ctx context.Context, arg CreateToolExecutionParams) (*ToolExecution, error)

func (*Queries) DeleteConversation

func (q *Queries) DeleteConversation(ctx context.Context, id pgtype.UUID) error

func (*Queries) DeleteConversationMessages

func (q *Queries) DeleteConversationMessages(ctx context.Context, conversationID pgtype.UUID) error

func (*Queries) DeleteEmbedding

func (q *Queries) DeleteEmbedding(ctx context.Context, id pgtype.UUID) error

func (*Queries) DeleteEmbeddingBySource

func (q *Queries) DeleteEmbeddingBySource(ctx context.Context, arg DeleteEmbeddingBySourceParams) error

func (*Queries) DeleteMemoryBackup

func (q *Queries) DeleteMemoryBackup(ctx context.Context, id pgtype.UUID) error

func (*Queries) DeleteMessage

func (q *Queries) DeleteMessage(ctx context.Context, id pgtype.UUID) error

func (*Queries) DeleteOldEmbeddings

func (q *Queries) DeleteOldEmbeddings(ctx context.Context, arg DeleteOldEmbeddingsParams) error

func (*Queries) DeleteOldMemoryBackups

func (q *Queries) DeleteOldMemoryBackups(ctx context.Context, arg DeleteOldMemoryBackupsParams) error

func (*Queries) DeleteOldToolExecutions

func (q *Queries) DeleteOldToolExecutions(ctx context.Context, daysOld interface{}) error

func (*Queries) DeleteSystemSetting

func (q *Queries) DeleteSystemSetting(ctx context.Context, key string) error

func (*Queries) DeleteTask

func (q *Queries) DeleteTask(ctx context.Context, id pgtype.UUID) error

func (*Queries) ExistsSystemSetting

func (q *Queries) ExistsSystemSetting(ctx context.Context, key string) (bool, error)

func (*Queries) FailToolExecution

func (q *Queries) FailToolExecution(ctx context.Context, arg FailToolExecutionParams) (*ToolExecution, error)

func (*Queries) GetActiveMemories

func (q *Queries) GetActiveMemories(ctx context.Context, limit int32) ([]*Memory, error)

func (*Queries) GetBackupStats

func (q *Queries) GetBackupStats(ctx context.Context) (*GetBackupStatsRow, error)

func (*Queries) GetBackupsWithinTimeRange

func (q *Queries) GetBackupsWithinTimeRange(ctx context.Context, arg GetBackupsWithinTimeRangeParams) ([]*GetBackupsWithinTimeRangeRow, error)

func (*Queries) GetConversation

func (q *Queries) GetConversation(ctx context.Context, id pgtype.UUID) (*Conversation, error)

func (*Queries) GetConversationStats

func (q *Queries) GetConversationStats(ctx context.Context) (*GetConversationStatsRow, error)

func (*Queries) GetConversationTokenUsage

func (q *Queries) GetConversationTokenUsage(ctx context.Context, conversationID pgtype.UUID) (*GetConversationTokenUsageRow, error)

func (*Queries) GetEmbedding

func (q *Queries) GetEmbedding(ctx context.Context, id pgtype.UUID) (*Embedding, error)

func (*Queries) GetEmbeddingBySource

func (q *Queries) GetEmbeddingBySource(ctx context.Context, arg GetEmbeddingBySourceParams) (*Embedding, error)

func (*Queries) GetEmbeddingStats

func (q *Queries) GetEmbeddingStats(ctx context.Context) (*GetEmbeddingStatsRow, error)

func (*Queries) GetLastMessages

func (q *Queries) GetLastMessages(ctx context.Context, arg GetLastMessagesParams) ([]*Message, error)

func (*Queries) GetLatestMemoryBackup

func (q *Queries) GetLatestMemoryBackup(ctx context.Context) (*GetLatestMemoryBackupRow, error)

func (*Queries) GetLatestMemoryEvent

func (q *Queries) GetLatestMemoryEvent(ctx context.Context, streamID pgtype.UUID) (*MemoryEvent, error)

func (*Queries) GetMemoryBackup

func (q *Queries) GetMemoryBackup(ctx context.Context, id pgtype.UUID) (*GetMemoryBackupRow, error)

func (*Queries) GetMemoryById

func (q *Queries) GetMemoryById(ctx context.Context, id pgtype.UUID) (*Memory, error)

Memory Event Sourcing Read Model Queries These queries are used by the Reader to query the projected memories

func (*Queries) GetMemoryEventsByType

func (q *Queries) GetMemoryEventsByType(ctx context.Context, arg GetMemoryEventsByTypeParams) ([]*MemoryEvent, error)

func (*Queries) GetMemoryForMerge

func (q *Queries) GetMemoryForMerge(ctx context.Context, id pgtype.UUID) (*GetMemoryForMergeRow, error)

Get memory details for merge operation

func (*Queries) GetMemoryForMergeDecision

func (q *Queries) GetMemoryForMergeDecision(ctx context.Context, id pgtype.UUID) (*GetMemoryForMergeDecisionRow, error)

Get full memory details for merge decision

func (*Queries) GetMemoryProjection

func (q *Queries) GetMemoryProjection(ctx context.Context, id pgtype.UUID) (*Memory, error)

func (*Queries) GetMemoryStreams

func (q *Queries) GetMemoryStreams(ctx context.Context) ([]*GetMemoryStreamsRow, error)

func (*Queries) GetMessage

func (q *Queries) GetMessage(ctx context.Context, id pgtype.UUID) (*Message, error)

func (*Queries) GetMultipleSettings

func (q *Queries) GetMultipleSettings(ctx context.Context, keys []string) ([]*SystemSetting, error)

func (*Queries) GetRecentConversationsWithMessageCount

func (q *Queries) GetRecentConversationsWithMessageCount(ctx context.Context, limitCount int32) ([]*GetRecentConversationsWithMessageCountRow, error)

func (*Queries) GetRecentMemories

func (q *Queries) GetRecentMemories(ctx context.Context, limit int32) ([]*Memory, error)

func (*Queries) GetSettingHistory

func (q *Queries) GetSettingHistory(ctx context.Context, key string) ([]*GetSettingHistoryRow, error)

func (*Queries) GetSystemSetting

func (q *Queries) GetSystemSetting(ctx context.Context, key string) (*SystemSetting, error)

func (*Queries) GetSystemSettingKeys

func (q *Queries) GetSystemSettingKeys(ctx context.Context) ([]string, error)

func (*Queries) GetTask

func (q *Queries) GetTask(ctx context.Context, id pgtype.UUID) (*Task, error)

func (*Queries) GetTaskStats

func (q *Queries) GetTaskStats(ctx context.Context) (*GetTaskStatsRow, error)

func (*Queries) GetTasksByPriority

func (q *Queries) GetTasksByPriority(ctx context.Context) ([]*GetTasksByPriorityRow, error)

func (*Queries) GetToolExecution

func (q *Queries) GetToolExecution(ctx context.Context, id pgtype.UUID) (*ToolExecution, error)

func (*Queries) GetToolExecutionStats

func (q *Queries) GetToolExecutionStats(ctx context.Context, arg GetToolExecutionStatsParams) (*GetToolExecutionStatsRow, error)

func (*Queries) GetToolUsageByName

func (q *Queries) GetToolUsageByName(ctx context.Context, since pgtype.Timestamptz) ([]*GetToolUsageByNameRow, error)

func (*Queries) ListActiveConversations

func (q *Queries) ListActiveConversations(ctx context.Context, limitCount int32) ([]*Conversation, error)

func (*Queries) ListConversations

func (q *Queries) ListConversations(ctx context.Context, arg ListConversationsParams) ([]*Conversation, error)

func (*Queries) ListEmbeddingsBySource

func (q *Queries) ListEmbeddingsBySource(ctx context.Context, arg ListEmbeddingsBySourceParams) ([]*Embedding, error)

func (*Queries) ListMemoryBackups

func (q *Queries) ListMemoryBackups(ctx context.Context, arg ListMemoryBackupsParams) ([]*ListMemoryBackupsRow, error)

func (*Queries) ListMessages

func (q *Queries) ListMessages(ctx context.Context, arg ListMessagesParams) ([]*Message, error)

func (*Queries) ListOverdueTasks

func (q *Queries) ListOverdueTasks(ctx context.Context) ([]*Task, error)

func (*Queries) ListPendingTasks

func (q *Queries) ListPendingTasks(ctx context.Context, limitCount int32) ([]*Task, error)

func (*Queries) ListPendingToolExecutions

func (q *Queries) ListPendingToolExecutions(ctx context.Context, limitCount int32) ([]*ToolExecution, error)

func (*Queries) ListRecentMessages

func (q *Queries) ListRecentMessages(ctx context.Context, arg ListRecentMessagesParams) ([]*Message, error)

func (*Queries) ListSystemSettings

func (q *Queries) ListSystemSettings(ctx context.Context) ([]*SystemSetting, error)

func (*Queries) ListSystemSettingsByPrefix

func (q *Queries) ListSystemSettingsByPrefix(ctx context.Context, prefix pgtype.Text) ([]*SystemSetting, error)

func (*Queries) ListTasks

func (q *Queries) ListTasks(ctx context.Context, arg ListTasksParams) ([]*Task, error)

func (*Queries) ListTasksByLabel

func (q *Queries) ListTasksByLabel(ctx context.Context, arg ListTasksByLabelParams) ([]*Task, error)

func (*Queries) ListTasksDueToday

func (q *Queries) ListTasksDueToday(ctx context.Context) ([]*Task, error)

func (*Queries) ListToolExecutions

func (q *Queries) ListToolExecutions(ctx context.Context, arg ListToolExecutionsParams) ([]*ToolExecution, error)

func (*Queries) ListToolExecutionsByConversation

func (q *Queries) ListToolExecutionsByConversation(ctx context.Context, arg ListToolExecutionsByConversationParams) ([]*ToolExecution, error)

func (*Queries) LoadMemoryEvents

func (q *Queries) LoadMemoryEvents(ctx context.Context, streamID pgtype.UUID) ([]*MemoryEvent, error)

func (*Queries) LoadMemoryEventsFromVersion

func (q *Queries) LoadMemoryEventsFromVersion(ctx context.Context, arg LoadMemoryEventsFromVersionParams) ([]*MemoryEvent, error)

func (*Queries) MarkMemoryAsCorrected

func (q *Queries) MarkMemoryAsCorrected(ctx context.Context, arg MarkMemoryAsCorrectedParams) (pgconn.CommandTag, error)

Mark a memory as corrected by another memory

func (*Queries) RemoveTaskLabel

func (q *Queries) RemoveTaskLabel(ctx context.Context, arg RemoveTaskLabelParams) (*Task, error)

func (*Queries) SearchConversationMessages

func (q *Queries) SearchConversationMessages(ctx context.Context, arg SearchConversationMessagesParams) ([]*SearchConversationMessagesRow, error)

Search messages within conversations

func (*Queries) SearchConversations

func (q *Queries) SearchConversations(ctx context.Context, arg SearchConversationsParams) ([]*SearchConversationsRow, error)

Search conversations using full-text search

func (*Queries) SearchConversationsWithHighlight

func (q *Queries) SearchConversationsWithHighlight(ctx context.Context, arg SearchConversationsWithHighlightParams) ([]*SearchConversationsWithHighlightRow, error)

Search with highlighted results

func (*Queries) SearchMemoriesByText

func (q *Queries) SearchMemoriesByText(ctx context.Context, arg SearchMemoriesByTextParams) ([]*Memory, error)

Uses full-text search for better performance than ILIKE

func (*Queries) SearchMemoriesByTextFallback

func (q *Queries) SearchMemoriesByTextFallback(ctx context.Context, arg SearchMemoriesByTextFallbackParams) ([]*Memory, error)

Fallback query using ILIKE if full-text search column doesn't exist yet

func (*Queries) SearchMemoryProjections

func (q *Queries) SearchMemoryProjections(ctx context.Context, arg SearchMemoryProjectionsParams) ([]*SearchMemoryProjectionsRow, error)

func (*Queries) SearchMessages

func (q *Queries) SearchMessages(ctx context.Context, arg SearchMessagesParams) ([]*Message, error)

func (*Queries) SearchSimilarEmbeddings

func (q *Queries) SearchSimilarEmbeddings(ctx context.Context, arg SearchSimilarEmbeddingsParams) ([]*SearchSimilarEmbeddingsRow, error)

func (*Queries) SearchSimilarMemories

func (q *Queries) SearchSimilarMemories(ctx context.Context, arg SearchSimilarMemoriesParams) ([]*SearchSimilarMemoriesRow, error)

func (*Queries) SearchSimilarMemoriesForDedup

func (q *Queries) SearchSimilarMemoriesForDedup(ctx context.Context, arg SearchSimilarMemoriesForDedupParams) ([]*SearchSimilarMemoriesForDedupRow, error)

Search for similar memories for deduplication @embedding is a vector, @threshold is a float

func (*Queries) SearchSimilarMemoriesForMerge

func (q *Queries) SearchSimilarMemoriesForMerge(ctx context.Context, arg SearchSimilarMemoriesForMergeParams) ([]*SearchSimilarMemoriesForMergeRow, error)

Search for similar memories above a threshold for merge decisions

func (*Queries) SearchTasks

func (q *Queries) SearchTasks(ctx context.Context, arg SearchTasksParams) ([]*Task, error)

func (*Queries) SetSystemSetting

func (q *Queries) SetSystemSetting(ctx context.Context, arg SetSystemSettingParams) (*SystemSetting, error)

func (*Queries) StartToolExecution

func (q *Queries) StartToolExecution(ctx context.Context, id pgtype.UUID) (*ToolExecution, error)

func (*Queries) UpdateConversation

func (q *Queries) UpdateConversation(ctx context.Context, arg UpdateConversationParams) (*Conversation, error)

func (*Queries) UpdateEmbedding

func (q *Queries) UpdateEmbedding(ctx context.Context, arg UpdateEmbeddingParams) (*Embedding, error)

func (*Queries) UpdateMemory

func (q *Queries) UpdateMemory(ctx context.Context, arg UpdateMemoryParams) error

func (*Queries) UpdateMemoryAccess

func (q *Queries) UpdateMemoryAccess(ctx context.Context, arg UpdateMemoryAccessParams) error

Update memory access timestamp and count

func (*Queries) UpdateMemoryAfterMerge

func (q *Queries) UpdateMemoryAfterMerge(ctx context.Context, arg UpdateMemoryAfterMergeParams) error

Update memory with merged data

func (*Queries) UpdateMemoryConfidence

func (q *Queries) UpdateMemoryConfidence(ctx context.Context, arg UpdateMemoryConfidenceParams) error

Update memory confidence

func (*Queries) UpdateMemoryCorrected

func (q *Queries) UpdateMemoryCorrected(ctx context.Context, arg UpdateMemoryCorrectedParams) error

Update memory as corrected

func (*Queries) UpdateMemoryEmbedding

func (q *Queries) UpdateMemoryEmbedding(ctx context.Context, arg UpdateMemoryEmbeddingParams) error

func (*Queries) UpdateMemoryMerged

func (q *Queries) UpdateMemoryMerged(ctx context.Context, arg UpdateMemoryMergedParams) error

Update memory after merge

func (*Queries) UpdateMemoryProjection

func (q *Queries) UpdateMemoryProjection(ctx context.Context, arg UpdateMemoryProjectionParams) error

func (*Queries) UpdateMergedMemory

func (q *Queries) UpdateMergedMemory(ctx context.Context, arg UpdateMergedMemoryParams) error

Update a memory after merging with another

func (*Queries) UpdateSystemSetting

func (q *Queries) UpdateSystemSetting(ctx context.Context, arg UpdateSystemSettingParams) (*SystemSetting, error)

func (*Queries) UpdateTask

func (q *Queries) UpdateTask(ctx context.Context, arg UpdateTaskParams) (*Task, error)

func (*Queries) UpdateTaskLabels

func (q *Queries) UpdateTaskLabels(ctx context.Context, arg UpdateTaskLabelsParams) (*Task, error)

func (*Queries) UpdateToolExecution

func (q *Queries) UpdateToolExecution(ctx context.Context, arg UpdateToolExecutionParams) (*ToolExecution, error)

func (*Queries) UpsertMemory

func (q *Queries) UpsertMemory(ctx context.Context, arg UpsertMemoryParams) error

Projector-specific queries for event projection These queries are used by the Projector to write memory projections Insert or update memory with optimistic locking on version

func (*Queries) WithTx

func (q *Queries) WithTx(tx pgx.Tx) *Queries

type Queue

type Queue struct {
	ID             pgtype.UUID        `json:"id"`
	ConversationID pgtype.UUID        `json:"conversation_id"`
	Messages       []byte             `json:"messages"`
	Status         pgtype.Text        `json:"status"`
	Error          pgtype.Text        `json:"error"`
	CreatedAt      time.Time          `json:"created_at"`
	ProcessedAt    pgtype.Timestamptz `json:"processed_at"`
}

Async processing queue for memory operations

type RecurrencePattern

type RecurrencePattern string
const (
	RecurrencePatternDaily   RecurrencePattern = "daily"
	RecurrencePatternWeekly  RecurrencePattern = "weekly"
	RecurrencePatternMonthly RecurrencePattern = "monthly"
	RecurrencePatternYearly  RecurrencePattern = "yearly"
)

func AllRecurrencePatternValues

func AllRecurrencePatternValues() []RecurrencePattern

func (*RecurrencePattern) Scan

func (e *RecurrencePattern) Scan(src interface{}) error

func (RecurrencePattern) Valid

func (e RecurrencePattern) Valid() bool

type Relation

type Relation struct {
	ID        pgtype.UUID     `json:"id"`
	FromID    pgtype.UUID     `json:"from_id"`
	ToID      pgtype.UUID     `json:"to_id"`
	Type      RelationType    `json:"type"`
	Strength  pgtype.Float4   `json:"strength"`
	Metadata  json.RawMessage `json:"metadata"`
	CreatedAt time.Time       `json:"created_at"`
}

Memory relationships

type RelationType

type RelationType string
const (
	RelationTypeUpdates     RelationType = "updates"
	RelationTypeContradicts RelationType = "contradicts"
	RelationTypeRelatesTo   RelationType = "relates_to"
	RelationTypeFollows     RelationType = "follows"
	RelationTypePrecedes    RelationType = "precedes"
	RelationTypePartOf      RelationType = "part_of"
)

func AllRelationTypeValues

func AllRelationTypeValues() []RelationType

func (*RelationType) Scan

func (e *RelationType) Scan(src interface{}) error

func (RelationType) Valid

func (e RelationType) Valid() bool

type RemoveTaskLabelParams

type RemoveTaskLabelParams struct {
	Label interface{} `json:"label"`
	ID    pgtype.UUID `json:"id"`
}

type SearchConversationMessagesParams

type SearchConversationMessagesParams struct {
	SearchQuery    string      `json:"search_query"`
	ConversationID pgtype.UUID `json:"conversation_id"`
	OffsetCount    int32       `json:"offset_count"`
	LimitCount     int32       `json:"limit_count"`
}

type SearchConversationMessagesRow

type SearchConversationMessagesRow struct {
	ID                pgtype.UUID     `json:"id"`
	ConversationID    pgtype.UUID     `json:"conversation_id"`
	Role              MessageRole     `json:"role"`
	Content           string          `json:"content"`
	TokensUsed        int32           `json:"tokens_used"`
	Metadata          json.RawMessage `json:"metadata"`
	CreatedAt         time.Time       `json:"created_at"`
	ConversationTitle string          `json:"conversation_title"`
	Rank              float32         `json:"rank"`
}

type SearchConversationsParams

type SearchConversationsParams struct {
	SearchQuery string             `json:"search_query"`
	Status      ConversationStatus `json:"status"`
	OffsetCount int32              `json:"offset_count"`
	LimitCount  int32              `json:"limit_count"`
}

type SearchConversationsRow

type SearchConversationsRow struct {
	ID            pgtype.UUID        `json:"id"`
	Title         string             `json:"title"`
	Summary       pgtype.Text        `json:"summary"`
	Status        ConversationStatus `json:"status"`
	Metadata      json.RawMessage    `json:"metadata"`
	CreatedAt     time.Time          `json:"created_at"`
	UpdatedAt     time.Time          `json:"updated_at"`
	LastMessageAt sql.NullTime       `json:"last_message_at"`
	MessageCount  int32              `json:"message_count"`
	TotalTokens   int32              `json:"total_tokens"`
	Rank          float32            `json:"rank"`
}

type SearchConversationsWithHighlightParams

type SearchConversationsWithHighlightParams struct {
	SearchQuery string             `json:"search_query"`
	Status      ConversationStatus `json:"status"`
	LimitCount  int32              `json:"limit_count"`
}

type SearchConversationsWithHighlightRow

type SearchConversationsWithHighlightRow struct {
	ID                 pgtype.UUID        `json:"id"`
	Title              string             `json:"title"`
	Summary            pgtype.Text        `json:"summary"`
	Status             ConversationStatus `json:"status"`
	Metadata           json.RawMessage    `json:"metadata"`
	CreatedAt          time.Time          `json:"created_at"`
	UpdatedAt          time.Time          `json:"updated_at"`
	LastMessageAt      sql.NullTime       `json:"last_message_at"`
	MessageCount       int32              `json:"message_count"`
	TotalTokens        int32              `json:"total_tokens"`
	HighlightedTitle   []byte             `json:"highlighted_title"`
	HighlightedSummary []byte             `json:"highlighted_summary"`
	Rank               float32            `json:"rank"`
}

type SearchMemoriesByTextFallbackParams

type SearchMemoriesByTextFallbackParams struct {
	Column1 pgtype.Text `json:"column_1"`
	Limit   int32       `json:"limit"`
}

type SearchMemoriesByTextParams

type SearchMemoriesByTextParams struct {
	PlaintoTsquery string `json:"plainto_tsquery"`
	Limit          int32  `json:"limit"`
}

type SearchMemoryProjectionsParams

type SearchMemoryProjectionsParams struct {
	Column1 pgvector.Vector `json:"column_1"`
	Limit   int32           `json:"limit"`
}

type SearchMemoryProjectionsRow

type SearchMemoryProjectionsRow struct {
	ID          pgtype.UUID     `json:"id"`
	SemanticID  string          `json:"semantic_id"`
	Type        MemoryType      `json:"type"`
	Content     string          `json:"content"`
	Summary     pgtype.Text     `json:"summary"`
	Entities    json.RawMessage `json:"entities"`
	Attributes  json.RawMessage `json:"attributes"`
	Context     json.RawMessage `json:"context"`
	Keywords    []string        `json:"keywords"`
	Confidence  pgtype.Float4   `json:"confidence"`
	Version     pgtype.Int4     `json:"version"`
	AccessCount pgtype.Int4     `json:"access_count"`
	CreatedAt   time.Time       `json:"created_at"`
	UpdatedAt   time.Time       `json:"updated_at"`
	AccessedAt  sql.NullTime    `json:"accessed_at"`
	Status      MemoryStatus    `json:"status"`
	Similarity  float32         `json:"similarity"`
}

type SearchMessagesParams

type SearchMessagesParams struct {
	ConversationID pgtype.UUID `json:"conversation_id"`
	Query          pgtype.Text `json:"query"`
	LimitCount     int32       `json:"limit_count"`
}

type SearchSimilarEmbeddingsParams

type SearchSimilarEmbeddingsParams struct {
	QueryEmbedding      *pgvector_go.Vector `json:"query_embedding"`
	SimilarityThreshold *pgvector_go.Vector `json:"similarity_threshold"`
	SourceTable         string              `json:"source_table"`
	LimitCount          int32               `json:"limit_count"`
}

type SearchSimilarEmbeddingsRow

type SearchSimilarEmbeddingsRow struct {
	ID          pgtype.UUID     `json:"id"`
	SourceTable string          `json:"source_table"`
	SourceID    pgtype.UUID     `json:"source_id"`
	Content     string          `json:"content"`
	Similarity  int32           `json:"similarity"`
	Metadata    json.RawMessage `json:"metadata"`
}

type SearchSimilarMemoriesForDedupParams

type SearchSimilarMemoriesForDedupParams struct {
	Embedding pgvector.Vector `json:"embedding"`
	Threshold float32         `json:"threshold"`
}

type SearchSimilarMemoriesForDedupRow

type SearchSimilarMemoriesForDedupRow struct {
	ID          pgtype.UUID     `json:"id"`
	Content     string          `json:"content"`
	Keywords    []string        `json:"keywords"`
	Entities    json.RawMessage `json:"entities"`
	Attributes  json.RawMessage `json:"attributes"`
	Confidence  pgtype.Float4   `json:"confidence"`
	AccessCount pgtype.Int4     `json:"access_count"`
	Similarity  float32         `json:"similarity"`
}

type SearchSimilarMemoriesForMergeParams

type SearchSimilarMemoriesForMergeParams struct {
	Column1   pgvector.Vector     `json:"column_1"`
	Embedding *pgvector_go.Vector `json:"embedding"`
}

type SearchSimilarMemoriesForMergeRow

type SearchSimilarMemoriesForMergeRow struct {
	ID         pgtype.UUID   `json:"id"`
	Content    string        `json:"content"`
	Keywords   []string      `json:"keywords"`
	Confidence pgtype.Float4 `json:"confidence"`
}

type SearchSimilarMemoriesParams

type SearchSimilarMemoriesParams struct {
	Column1 pgvector.Vector `json:"column_1"`
	Limit   int32           `json:"limit"`
}

type SearchSimilarMemoriesRow

type SearchSimilarMemoriesRow struct {
	ID               pgtype.UUID         `json:"id"`
	SemanticID       string              `json:"semantic_id"`
	Type             MemoryType          `json:"type"`
	Content          string              `json:"content"`
	Summary          pgtype.Text         `json:"summary"`
	Entities         json.RawMessage     `json:"entities"`
	Attributes       json.RawMessage     `json:"attributes"`
	Context          json.RawMessage     `json:"context"`
	Embedding        *pgvector_go.Vector `json:"embedding"`
	Keywords         []string            `json:"keywords"`
	Confidence       pgtype.Float4       `json:"confidence"`
	Version          pgtype.Int4         `json:"version"`
	AccessCount      pgtype.Int4         `json:"access_count"`
	CreatedAt        time.Time           `json:"created_at"`
	UpdatedAt        time.Time           `json:"updated_at"`
	AccessedAt       sql.NullTime        `json:"accessed_at"`
	Status           MemoryStatus        `json:"status"`
	ArchivedAt       pgtype.Timestamptz  `json:"archived_at"`
	MergedFrom       []uuid.UUID         `json:"merged_from"`
	Source           NullMemorySource    `json:"source"`
	Supersedes       []uuid.UUID         `json:"supersedes"`
	CorrectedBy      pgtype.UUID         `json:"corrected_by"`
	CorrectionReason pgtype.Text         `json:"correction_reason"`
	Similarity       float32             `json:"similarity"`
}

type SearchTasksParams

type SearchTasksParams struct {
	Query            pgtype.Text `json:"query"`
	IncludeCompleted bool        `json:"include_completed"`
	LimitCount       int32       `json:"limit_count"`
}

type SetSystemSettingParams

type SetSystemSettingParams struct {
	Key         string          `json:"key"`
	Value       json.RawMessage `json:"value"`
	Description pgtype.Text     `json:"description"`
}

type SystemSetting

type SystemSetting struct {
	Key         string          `json:"key"`
	Value       json.RawMessage `json:"value"`
	Description pgtype.Text     `json:"description"`
	CreatedAt   time.Time       `json:"created_at"`
	UpdatedAt   time.Time       `json:"updated_at"`
}

System settings key-value pairs, storing application configuration

type Task

type Task struct {
	ID          pgtype.UUID     `json:"id"`
	Title       string          `json:"title"`
	Description pgtype.Text     `json:"description"`
	Status      TaskStatus      `json:"status"`
	Priority    TaskPriority    `json:"priority"`
	DueDate     sql.NullTime    `json:"due_date"`
	CompletedAt sql.NullTime    `json:"completed_at"`
	Labels      []string        `json:"labels"`
	Metadata    json.RawMessage `json:"metadata"`
	CreatedAt   time.Time       `json:"created_at"`
	UpdatedAt   time.Time       `json:"updated_at"`
}

Task management system, tracking to-do items

type TaskPriority

type TaskPriority string
const (
	TaskPriorityLow      TaskPriority = "low"
	TaskPriorityMedium   TaskPriority = "medium"
	TaskPriorityHigh     TaskPriority = "high"
	TaskPriorityUrgent   TaskPriority = "urgent"
	TaskPriorityCritical TaskPriority = "critical"
)

func AllTaskPriorityValues

func AllTaskPriorityValues() []TaskPriority

func (*TaskPriority) Scan

func (e *TaskPriority) Scan(src interface{}) error

func (TaskPriority) Valid

func (e TaskPriority) Valid() bool

type TaskStatus

type TaskStatus string
const (
	TaskStatusTodo       TaskStatus = "todo"
	TaskStatusInProgress TaskStatus = "in_progress"
	TaskStatusDone       TaskStatus = "done"
	TaskStatusCancelled  TaskStatus = "cancelled"
	TaskStatusDeferred   TaskStatus = "deferred"
)

func AllTaskStatusValues

func AllTaskStatusValues() []TaskStatus

func (*TaskStatus) Scan

func (e *TaskStatus) Scan(src interface{}) error

func (TaskStatus) Valid

func (e TaskStatus) Valid() bool

type ToolExecution

type ToolExecution struct {
	ID             pgtype.UUID     `json:"id"`
	ConversationID pgtype.UUID     `json:"conversation_id"`
	ToolName       string          `json:"tool_name"`
	Input          json.RawMessage `json:"input"`
	Output         json.RawMessage `json:"output"`
	Status         ToolStatus      `json:"status"`
	ErrorMessage   pgtype.Text     `json:"error_message"`
	DurationMs     pgtype.Int4     `json:"duration_ms"`
	CreatedAt      time.Time       `json:"created_at"`
	CompletedAt    sql.NullTime    `json:"completed_at"`
}

Tool execution history, recording AI tool usage

type ToolStatus

type ToolStatus string
const (
	ToolStatusPending   ToolStatus = "pending"
	ToolStatusRunning   ToolStatus = "running"
	ToolStatusSuccess   ToolStatus = "success"
	ToolStatusFailed    ToolStatus = "failed"
	ToolStatusTimeout   ToolStatus = "timeout"
	ToolStatusCancelled ToolStatus = "cancelled"
)

func AllToolStatusValues

func AllToolStatusValues() []ToolStatus

func (*ToolStatus) Scan

func (e *ToolStatus) Scan(src interface{}) error

func (ToolStatus) Valid

func (e ToolStatus) Valid() bool

type UpdateConversationParams

type UpdateConversationParams struct {
	Title    string             `json:"title"`
	Summary  string             `json:"summary"`
	Status   ConversationStatus `json:"status"`
	Metadata []byte             `json:"metadata"`
	ID       pgtype.UUID        `json:"id"`
}

type UpdateEmbeddingParams

type UpdateEmbeddingParams struct {
	Content   string              `json:"content"`
	Embedding *pgvector_go.Vector `json:"embedding"`
	Metadata  []byte              `json:"metadata"`
	ID        pgtype.UUID         `json:"id"`
}

type UpdateMemoryAccessParams

type UpdateMemoryAccessParams struct {
	ID         pgtype.UUID  `json:"id"`
	AccessedAt sql.NullTime `json:"accessed_at"`
}

type UpdateMemoryAfterMergeParams

type UpdateMemoryAfterMergeParams struct {
	ID         pgtype.UUID   `json:"id"`
	Content    string        `json:"content"`
	Keywords   []string      `json:"keywords"`
	Confidence pgtype.Float4 `json:"confidence"`
	AccessedAt sql.NullTime  `json:"accessed_at"`
}

type UpdateMemoryConfidenceParams

type UpdateMemoryConfidenceParams struct {
	ID         pgtype.UUID   `json:"id"`
	Confidence pgtype.Float4 `json:"confidence"`
	UpdatedAt  time.Time     `json:"updated_at"`
}

type UpdateMemoryCorrectedParams

type UpdateMemoryCorrectedParams struct {
	ID               pgtype.UUID `json:"id"`
	CorrectedBy      pgtype.UUID `json:"corrected_by"`
	CorrectionReason pgtype.Text `json:"correction_reason"`
	UpdatedAt        time.Time   `json:"updated_at"`
	Version          pgtype.Int4 `json:"version"`
}

type UpdateMemoryEmbeddingParams

type UpdateMemoryEmbeddingParams struct {
	ID      pgtype.UUID     `json:"id"`
	Column2 pgvector.Vector `json:"column_2"`
}

type UpdateMemoryMergedParams

type UpdateMemoryMergedParams struct {
	ID         pgtype.UUID     `json:"id"`
	Content    string          `json:"content"`
	Keywords   []string        `json:"keywords"`
	Entities   json.RawMessage `json:"entities"`
	UpdatedAt  time.Time       `json:"updated_at"`
	Version    pgtype.Int4     `json:"version"`
	MergedFrom []uuid.UUID     `json:"merged_from"`
}

type UpdateMemoryParams

type UpdateMemoryParams struct {
	ID         pgtype.UUID      `json:"id"`
	Content    string           `json:"content"`
	Keywords   []string         `json:"keywords"`
	Entities   json.RawMessage  `json:"entities"`
	Attributes json.RawMessage  `json:"attributes"`
	Confidence pgtype.Float4    `json:"confidence"`
	Source     NullMemorySource `json:"source"`
	UpdatedAt  time.Time        `json:"updated_at"`
	Version    pgtype.Int4      `json:"version"`
}

type UpdateMemoryProjectionParams

type UpdateMemoryProjectionParams struct {
	ID         pgtype.UUID     `json:"id"`
	Content    string          `json:"content"`
	Summary    pgtype.Text     `json:"summary"`
	Entities   json.RawMessage `json:"entities"`
	Attributes json.RawMessage `json:"attributes"`
	Context    json.RawMessage `json:"context"`
	Keywords   []string        `json:"keywords"`
	Confidence pgtype.Float4   `json:"confidence"`
	Version    pgtype.Int4     `json:"version"`
	UpdatedAt  time.Time       `json:"updated_at"`
}

type UpdateMergedMemoryParams

type UpdateMergedMemoryParams struct {
	ID          pgtype.UUID   `json:"id"`
	Content     string        `json:"content"`
	Keywords    []string      `json:"keywords"`
	Confidence  pgtype.Float4 `json:"confidence"`
	ArrayAppend interface{}   `json:"array_append"`
	UpdatedAt   time.Time     `json:"updated_at"`
}

type UpdateSystemSettingParams

type UpdateSystemSettingParams struct {
	Value json.RawMessage `json:"value"`
	Key   string          `json:"key"`
}

type UpdateTaskLabelsParams

type UpdateTaskLabelsParams struct {
	Labels []string    `json:"labels"`
	ID     pgtype.UUID `json:"id"`
}

type UpdateTaskParams

type UpdateTaskParams struct {
	Title       string             `json:"title"`
	Description string             `json:"description"`
	Status      TaskStatus         `json:"status"`
	Priority    TaskPriority       `json:"priority"`
	DueDate     pgtype.Timestamptz `json:"due_date"`
	Labels      []string           `json:"labels"`
	Metadata    []byte             `json:"metadata"`
	ID          pgtype.UUID        `json:"id"`
}

type UpdateToolExecutionParams

type UpdateToolExecutionParams struct {
	Output       json.RawMessage `json:"output"`
	Status       ToolStatus      `json:"status"`
	ErrorMessage pgtype.Text     `json:"error_message"`
	DurationMs   pgtype.Int4     `json:"duration_ms"`
	ID           pgtype.UUID     `json:"id"`
}

type UpsertMemoryParams

type UpsertMemoryParams struct {
	ID         pgtype.UUID         `json:"id"`
	SemanticID string              `json:"semantic_id"`
	Type       MemoryType          `json:"type"`
	Content    string              `json:"content"`
	Keywords   []string            `json:"keywords"`
	Entities   json.RawMessage     `json:"entities"`
	Confidence pgtype.Float4       `json:"confidence"`
	Status     MemoryStatus        `json:"status"`
	Version    pgtype.Int4         `json:"version"`
	CreatedAt  time.Time           `json:"created_at"`
	UpdatedAt  time.Time           `json:"updated_at"`
	Attributes json.RawMessage     `json:"attributes"`
	Embedding  *pgvector_go.Vector `json:"embedding"`
	Source     NullMemorySource    `json:"source"`
	Supersedes []uuid.UUID         `json:"supersedes"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL