Documentation
¶
Index ¶
- Constants
- type ActionType
- type AddTaskLabelParams
- type AppendMemoryEventParams
- type ArchiveMemoryParams
- type ArchiveMemoryProjectionParams
- type ArchiveMemoryWithVersionParams
- type ArchiveSourceMemoriesParams
- type BulkSetSystemSettingsParams
- type CompleteToolExecutionParams
- type Conversation
- type ConversationStatus
- type CountEmbeddingsBySourceRow
- type CountMessagesByRoleRow
- type CreateConversationParams
- type CreateEmbeddingParams
- type CreateMemoryBackupParams
- type CreateMemoryBackupRow
- type CreateMemoryProjectionParams
- type CreateMemoryProjectionRow
- type CreateMessageParams
- type CreateTaskParams
- type CreateToolExecutionParams
- type DBTX
- type DeleteEmbeddingBySourceParams
- type DeleteOldEmbeddingsParams
- type DeleteOldMemoryBackupsParams
- type Embedding
- type EntityRole
- type EntityType
- type FailToolExecutionParams
- type GetBackupStatsRow
- type GetBackupsWithinTimeRangeParams
- type GetBackupsWithinTimeRangeRow
- type GetConversationStatsRow
- type GetConversationTokenUsageRow
- type GetEmbeddingBySourceParams
- type GetEmbeddingStatsRow
- type GetLastMessagesParams
- type GetLatestMemoryBackupRow
- type GetMemoryBackupRow
- type GetMemoryEventsByTypeParams
- type GetMemoryForMergeDecisionRow
- type GetMemoryForMergeRow
- type GetMemoryStreamsRow
- type GetRecentConversationsWithMessageCountRow
- type GetSettingHistoryRow
- type GetTaskStatsRow
- type GetTasksByPriorityRow
- type GetToolExecutionStatsParams
- type GetToolExecutionStatsRow
- type GetToolUsageByNameRow
- type History
- type ListConversationsParams
- type ListEmbeddingsBySourceParams
- type ListMemoryBackupsParams
- type ListMemoryBackupsRow
- type ListMessagesParams
- type ListRecentMessagesParams
- type ListTasksByLabelParams
- type ListTasksParams
- type ListToolExecutionsByConversationParams
- type ListToolExecutionsParams
- type LoadMemoryEventsFromVersionParams
- type MarkMemoryAsCorrectedParams
- type Memory
- type MemoryBackup
- type MemoryEvent
- type MemorySource
- type MemoryStatus
- type MemoryType
- type Message
- type MessageRole
- type NullActionType
- type NullConversationStatus
- type NullEntityRole
- type NullEntityType
- type NullMemorySource
- type NullMemoryStatus
- type NullMemoryType
- type NullMessageRole
- type NullRecurrencePattern
- type NullRelationType
- type NullTaskPriority
- type NullTaskStatus
- type NullToolStatus
- type Querier
- type Queries
- func (q *Queries) AddTaskLabel(ctx context.Context, arg AddTaskLabelParams) (*Task, error)
- func (q *Queries) AppendMemoryEvent(ctx context.Context, arg AppendMemoryEventParams) error
- func (q *Queries) ArchiveConversation(ctx context.Context, id pgtype.UUID) (*Conversation, error)
- func (q *Queries) ArchiveMemory(ctx context.Context, arg ArchiveMemoryParams) (pgconn.CommandTag, error)
- func (q *Queries) ArchiveMemoryProjection(ctx context.Context, arg ArchiveMemoryProjectionParams) error
- func (q *Queries) ArchiveMemoryWithVersion(ctx context.Context, arg ArchiveMemoryWithVersionParams) error
- func (q *Queries) ArchiveSourceMemories(ctx context.Context, arg ArchiveSourceMemoriesParams) error
- func (q *Queries) BulkSetSystemSettings(ctx context.Context, arg BulkSetSystemSettingsParams) error
- func (q *Queries) CancelPendingToolExecutions(ctx context.Context, conversationID pgtype.UUID) error
- func (q *Queries) CompleteTask(ctx context.Context, id pgtype.UUID) (*Task, error)
- func (q *Queries) CompleteToolExecution(ctx context.Context, arg CompleteToolExecutionParams) (*ToolExecution, error)
- func (q *Queries) CountEmbeddingsBySource(ctx context.Context) ([]*CountEmbeddingsBySourceRow, error)
- func (q *Queries) CountMemoryBackups(ctx context.Context) (int32, error)
- func (q *Queries) CountMemoryEvents(ctx context.Context) (int64, error)
- func (q *Queries) CountMessagesByRole(ctx context.Context, conversationID pgtype.UUID) ([]*CountMessagesByRoleRow, error)
- func (q *Queries) CountSystemSettings(ctx context.Context) (int32, error)
- func (q *Queries) CreateConversation(ctx context.Context, arg CreateConversationParams) (*Conversation, error)
- func (q *Queries) CreateEmbedding(ctx context.Context, arg CreateEmbeddingParams) (*Embedding, error)
- func (q *Queries) CreateMemoryBackup(ctx context.Context, arg CreateMemoryBackupParams) (*CreateMemoryBackupRow, error)
- func (q *Queries) CreateMemoryProjection(ctx context.Context, arg CreateMemoryProjectionParams) (*CreateMemoryProjectionRow, error)
- func (q *Queries) CreateMessage(ctx context.Context, arg CreateMessageParams) (*Message, error)
- func (q *Queries) CreateTask(ctx context.Context, arg CreateTaskParams) (*Task, error)
- func (q *Queries) CreateToolExecution(ctx context.Context, arg CreateToolExecutionParams) (*ToolExecution, error)
- func (q *Queries) DeleteConversation(ctx context.Context, id pgtype.UUID) error
- func (q *Queries) DeleteConversationMessages(ctx context.Context, conversationID pgtype.UUID) error
- func (q *Queries) DeleteEmbedding(ctx context.Context, id pgtype.UUID) error
- func (q *Queries) DeleteEmbeddingBySource(ctx context.Context, arg DeleteEmbeddingBySourceParams) error
- func (q *Queries) DeleteMemoryBackup(ctx context.Context, id pgtype.UUID) error
- func (q *Queries) DeleteMessage(ctx context.Context, id pgtype.UUID) error
- func (q *Queries) DeleteOldEmbeddings(ctx context.Context, arg DeleteOldEmbeddingsParams) error
- func (q *Queries) DeleteOldMemoryBackups(ctx context.Context, arg DeleteOldMemoryBackupsParams) error
- func (q *Queries) DeleteOldToolExecutions(ctx context.Context, daysOld interface{}) error
- func (q *Queries) DeleteSystemSetting(ctx context.Context, key string) error
- func (q *Queries) DeleteTask(ctx context.Context, id pgtype.UUID) error
- func (q *Queries) ExistsSystemSetting(ctx context.Context, key string) (bool, error)
- func (q *Queries) FailToolExecution(ctx context.Context, arg FailToolExecutionParams) (*ToolExecution, error)
- func (q *Queries) GetActiveMemories(ctx context.Context, limit int32) ([]*Memory, error)
- func (q *Queries) GetBackupStats(ctx context.Context) (*GetBackupStatsRow, error)
- func (q *Queries) GetBackupsWithinTimeRange(ctx context.Context, arg GetBackupsWithinTimeRangeParams) ([]*GetBackupsWithinTimeRangeRow, error)
- func (q *Queries) GetConversation(ctx context.Context, id pgtype.UUID) (*Conversation, error)
- func (q *Queries) GetConversationStats(ctx context.Context) (*GetConversationStatsRow, error)
- func (q *Queries) GetConversationTokenUsage(ctx context.Context, conversationID pgtype.UUID) (*GetConversationTokenUsageRow, error)
- func (q *Queries) GetEmbedding(ctx context.Context, id pgtype.UUID) (*Embedding, error)
- func (q *Queries) GetEmbeddingBySource(ctx context.Context, arg GetEmbeddingBySourceParams) (*Embedding, error)
- func (q *Queries) GetEmbeddingStats(ctx context.Context) (*GetEmbeddingStatsRow, error)
- func (q *Queries) GetLastMessages(ctx context.Context, arg GetLastMessagesParams) ([]*Message, error)
- func (q *Queries) GetLatestMemoryBackup(ctx context.Context) (*GetLatestMemoryBackupRow, error)
- func (q *Queries) GetLatestMemoryEvent(ctx context.Context, streamID pgtype.UUID) (*MemoryEvent, error)
- func (q *Queries) GetMemoryBackup(ctx context.Context, id pgtype.UUID) (*GetMemoryBackupRow, error)
- func (q *Queries) GetMemoryById(ctx context.Context, id pgtype.UUID) (*Memory, error)
- func (q *Queries) GetMemoryEventsByType(ctx context.Context, arg GetMemoryEventsByTypeParams) ([]*MemoryEvent, error)
- func (q *Queries) GetMemoryForMerge(ctx context.Context, id pgtype.UUID) (*GetMemoryForMergeRow, error)
- func (q *Queries) GetMemoryForMergeDecision(ctx context.Context, id pgtype.UUID) (*GetMemoryForMergeDecisionRow, error)
- func (q *Queries) GetMemoryProjection(ctx context.Context, id pgtype.UUID) (*Memory, error)
- func (q *Queries) GetMemoryStreams(ctx context.Context) ([]*GetMemoryStreamsRow, error)
- func (q *Queries) GetMessage(ctx context.Context, id pgtype.UUID) (*Message, error)
- func (q *Queries) GetMultipleSettings(ctx context.Context, keys []string) ([]*SystemSetting, error)
- func (q *Queries) GetRecentConversationsWithMessageCount(ctx context.Context, limitCount int32) ([]*GetRecentConversationsWithMessageCountRow, error)
- func (q *Queries) GetRecentMemories(ctx context.Context, limit int32) ([]*Memory, error)
- func (q *Queries) GetSettingHistory(ctx context.Context, key string) ([]*GetSettingHistoryRow, error)
- func (q *Queries) GetSystemSetting(ctx context.Context, key string) (*SystemSetting, error)
- func (q *Queries) GetSystemSettingKeys(ctx context.Context) ([]string, error)
- func (q *Queries) GetTask(ctx context.Context, id pgtype.UUID) (*Task, error)
- func (q *Queries) GetTaskStats(ctx context.Context) (*GetTaskStatsRow, error)
- func (q *Queries) GetTasksByPriority(ctx context.Context) ([]*GetTasksByPriorityRow, error)
- func (q *Queries) GetToolExecution(ctx context.Context, id pgtype.UUID) (*ToolExecution, error)
- func (q *Queries) GetToolExecutionStats(ctx context.Context, arg GetToolExecutionStatsParams) (*GetToolExecutionStatsRow, error)
- func (q *Queries) GetToolUsageByName(ctx context.Context, since pgtype.Timestamptz) ([]*GetToolUsageByNameRow, error)
- func (q *Queries) ListActiveConversations(ctx context.Context, limitCount int32) ([]*Conversation, error)
- func (q *Queries) ListConversations(ctx context.Context, arg ListConversationsParams) ([]*Conversation, error)
- func (q *Queries) ListEmbeddingsBySource(ctx context.Context, arg ListEmbeddingsBySourceParams) ([]*Embedding, error)
- func (q *Queries) ListMemoryBackups(ctx context.Context, arg ListMemoryBackupsParams) ([]*ListMemoryBackupsRow, error)
- func (q *Queries) ListMessages(ctx context.Context, arg ListMessagesParams) ([]*Message, error)
- func (q *Queries) ListOverdueTasks(ctx context.Context) ([]*Task, error)
- func (q *Queries) ListPendingTasks(ctx context.Context, limitCount int32) ([]*Task, error)
- func (q *Queries) ListPendingToolExecutions(ctx context.Context, limitCount int32) ([]*ToolExecution, error)
- func (q *Queries) ListRecentMessages(ctx context.Context, arg ListRecentMessagesParams) ([]*Message, error)
- func (q *Queries) ListSystemSettings(ctx context.Context) ([]*SystemSetting, error)
- func (q *Queries) ListSystemSettingsByPrefix(ctx context.Context, prefix pgtype.Text) ([]*SystemSetting, error)
- func (q *Queries) ListTasks(ctx context.Context, arg ListTasksParams) ([]*Task, error)
- func (q *Queries) ListTasksByLabel(ctx context.Context, arg ListTasksByLabelParams) ([]*Task, error)
- func (q *Queries) ListTasksDueToday(ctx context.Context) ([]*Task, error)
- func (q *Queries) ListToolExecutions(ctx context.Context, arg ListToolExecutionsParams) ([]*ToolExecution, error)
- func (q *Queries) ListToolExecutionsByConversation(ctx context.Context, arg ListToolExecutionsByConversationParams) ([]*ToolExecution, error)
- func (q *Queries) LoadMemoryEvents(ctx context.Context, streamID pgtype.UUID) ([]*MemoryEvent, error)
- func (q *Queries) LoadMemoryEventsFromVersion(ctx context.Context, arg LoadMemoryEventsFromVersionParams) ([]*MemoryEvent, error)
- func (q *Queries) MarkMemoryAsCorrected(ctx context.Context, arg MarkMemoryAsCorrectedParams) (pgconn.CommandTag, error)
- func (q *Queries) RemoveTaskLabel(ctx context.Context, arg RemoveTaskLabelParams) (*Task, error)
- func (q *Queries) SearchConversationMessages(ctx context.Context, arg SearchConversationMessagesParams) ([]*SearchConversationMessagesRow, error)
- func (q *Queries) SearchConversations(ctx context.Context, arg SearchConversationsParams) ([]*SearchConversationsRow, error)
- func (q *Queries) SearchConversationsWithHighlight(ctx context.Context, arg SearchConversationsWithHighlightParams) ([]*SearchConversationsWithHighlightRow, error)
- func (q *Queries) SearchMemoriesByText(ctx context.Context, arg SearchMemoriesByTextParams) ([]*Memory, error)
- func (q *Queries) SearchMemoriesByTextFallback(ctx context.Context, arg SearchMemoriesByTextFallbackParams) ([]*Memory, error)
- func (q *Queries) SearchMemoryProjections(ctx context.Context, arg SearchMemoryProjectionsParams) ([]*SearchMemoryProjectionsRow, error)
- func (q *Queries) SearchMessages(ctx context.Context, arg SearchMessagesParams) ([]*Message, error)
- func (q *Queries) SearchSimilarEmbeddings(ctx context.Context, arg SearchSimilarEmbeddingsParams) ([]*SearchSimilarEmbeddingsRow, error)
- func (q *Queries) SearchSimilarMemories(ctx context.Context, arg SearchSimilarMemoriesParams) ([]*SearchSimilarMemoriesRow, error)
- func (q *Queries) SearchSimilarMemoriesForDedup(ctx context.Context, arg SearchSimilarMemoriesForDedupParams) ([]*SearchSimilarMemoriesForDedupRow, error)
- func (q *Queries) SearchSimilarMemoriesForMerge(ctx context.Context, arg SearchSimilarMemoriesForMergeParams) ([]*SearchSimilarMemoriesForMergeRow, error)
- func (q *Queries) SearchTasks(ctx context.Context, arg SearchTasksParams) ([]*Task, error)
- func (q *Queries) SetSystemSetting(ctx context.Context, arg SetSystemSettingParams) (*SystemSetting, error)
- func (q *Queries) StartToolExecution(ctx context.Context, id pgtype.UUID) (*ToolExecution, error)
- func (q *Queries) UpdateConversation(ctx context.Context, arg UpdateConversationParams) (*Conversation, error)
- func (q *Queries) UpdateEmbedding(ctx context.Context, arg UpdateEmbeddingParams) (*Embedding, error)
- func (q *Queries) UpdateMemory(ctx context.Context, arg UpdateMemoryParams) error
- func (q *Queries) UpdateMemoryAccess(ctx context.Context, arg UpdateMemoryAccessParams) error
- func (q *Queries) UpdateMemoryAfterMerge(ctx context.Context, arg UpdateMemoryAfterMergeParams) error
- func (q *Queries) UpdateMemoryConfidence(ctx context.Context, arg UpdateMemoryConfidenceParams) error
- func (q *Queries) UpdateMemoryCorrected(ctx context.Context, arg UpdateMemoryCorrectedParams) error
- func (q *Queries) UpdateMemoryEmbedding(ctx context.Context, arg UpdateMemoryEmbeddingParams) error
- func (q *Queries) UpdateMemoryMerged(ctx context.Context, arg UpdateMemoryMergedParams) error
- func (q *Queries) UpdateMemoryProjection(ctx context.Context, arg UpdateMemoryProjectionParams) error
- func (q *Queries) UpdateMergedMemory(ctx context.Context, arg UpdateMergedMemoryParams) error
- func (q *Queries) UpdateSystemSetting(ctx context.Context, arg UpdateSystemSettingParams) (*SystemSetting, error)
- func (q *Queries) UpdateTask(ctx context.Context, arg UpdateTaskParams) (*Task, error)
- func (q *Queries) UpdateTaskLabels(ctx context.Context, arg UpdateTaskLabelsParams) (*Task, error)
- func (q *Queries) UpdateToolExecution(ctx context.Context, arg UpdateToolExecutionParams) (*ToolExecution, error)
- func (q *Queries) UpsertMemory(ctx context.Context, arg UpsertMemoryParams) error
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
- type Queue
- type RecurrencePattern
- type Relation
- type RelationType
- type RemoveTaskLabelParams
- type SearchConversationMessagesParams
- type SearchConversationMessagesRow
- type SearchConversationsParams
- type SearchConversationsRow
- type SearchConversationsWithHighlightParams
- type SearchConversationsWithHighlightRow
- type SearchMemoriesByTextFallbackParams
- type SearchMemoriesByTextParams
- type SearchMemoryProjectionsParams
- type SearchMemoryProjectionsRow
- type SearchMessagesParams
- type SearchSimilarEmbeddingsParams
- type SearchSimilarEmbeddingsRow
- type SearchSimilarMemoriesForDedupParams
- type SearchSimilarMemoriesForDedupRow
- type SearchSimilarMemoriesForMergeParams
- type SearchSimilarMemoriesForMergeRow
- type SearchSimilarMemoriesParams
- type SearchSimilarMemoriesRow
- type SearchTasksParams
- type SetSystemSettingParams
- type SystemSetting
- type Task
- type TaskPriority
- type TaskStatus
- type ToolExecution
- type ToolStatus
- type UpdateConversationParams
- type UpdateEmbeddingParams
- type UpdateMemoryAccessParams
- type UpdateMemoryAfterMergeParams
- type UpdateMemoryConfidenceParams
- type UpdateMemoryCorrectedParams
- type UpdateMemoryEmbeddingParams
- type UpdateMemoryMergedParams
- type UpdateMemoryParams
- type UpdateMemoryProjectionParams
- type UpdateMergedMemoryParams
- type UpdateSystemSettingParams
- type UpdateTaskLabelsParams
- type UpdateTaskParams
- type UpdateToolExecutionParams
- type UpsertMemoryParams
Constants ¶
const AddTaskLabel = `` /* 236-byte string literal not displayed */
const AppendMemoryEvent = `` /* 152-byte string literal not displayed */
const ArchiveConversation = `` /* 210-byte string literal not displayed */
const ArchiveMemory = `-- name: ArchiveMemory :execresult
UPDATE memories
SET
status = $2,
updated_at = $3,
version = $4
WHERE id = $1
`
const ArchiveMemoryProjection = `` /* 137-byte string literal not displayed */
const ArchiveMemoryWithVersion = `-- name: ArchiveMemoryWithVersion :exec
UPDATE memories
SET status = $2, updated_at = $3, version = $4
WHERE id = $1
`
const ArchiveSourceMemories = `-- name: ArchiveSourceMemories :exec
UPDATE memories
SET status = $2, updated_at = $3
WHERE id = ANY($1::UUID[])
`
const BulkSetSystemSettings = `` /* 310-byte string literal not displayed */
const CancelPendingToolExecutions = `` /* 207-byte string literal not displayed */
const CompleteTask = `` /* 234-byte string literal not displayed */
const CompleteToolExecution = `` /* 356-byte string literal not displayed */
const CountEmbeddingsBySource = `` /* 129-byte string literal not displayed */
const CountMemoryBackups = `-- name: CountMemoryBackups :one
SELECT COUNT(*)::int as total_backups
FROM memory_backups
`
const CountMemoryEvents = `-- name: CountMemoryEvents :one
SELECT COUNT(*) FROM memory_events
`
const CountMessagesByRole = `` /* 134-byte string literal not displayed */
const CountSystemSettings = `-- name: CountSystemSettings :one
SELECT COUNT(*)::int as total_settings
FROM system_settings
`
const CreateConversation = `` /* 364-byte string literal not displayed */
const CreateEmbedding = `` /* 561-byte string literal not displayed */
const CreateMemoryBackup = `` /* 231-byte string literal not displayed */
const CreateMemoryProjection = `` /* 471-byte string literal not displayed */
const CreateMessage = `` /* 307-byte string literal not displayed */
const CreateTask = `` /* 428-byte string literal not displayed */
const CreateToolExecution = `` /* 345-byte string literal not displayed */
const DeleteConversation = `-- name: DeleteConversation :exec
DELETE FROM conversations
WHERE id = $1
`
const DeleteConversationMessages = `-- name: DeleteConversationMessages :exec
DELETE FROM messages
WHERE conversation_id = $1
`
const DeleteEmbedding = `-- name: DeleteEmbedding :exec
DELETE FROM embeddings
WHERE id = $1
`
const DeleteEmbeddingBySource = `-- name: DeleteEmbeddingBySource :exec
DELETE FROM embeddings
WHERE source_table = $1 AND source_id = $2
`
const DeleteMemoryBackup = `-- name: DeleteMemoryBackup :exec
DELETE FROM memory_backups
WHERE id = $1
`
const DeleteMessage = `-- name: DeleteMessage :exec
DELETE FROM messages
WHERE id = $1
`
const DeleteOldEmbeddings = `` /* 171-byte string literal not displayed */
const DeleteOldMemoryBackups = `` /* 227-byte string literal not displayed */
const DeleteOldToolExecutions = `` /* 184-byte string literal not displayed */
const DeleteSystemSetting = `-- name: DeleteSystemSetting :exec
DELETE FROM system_settings
WHERE key = $1
`
const DeleteTask = `-- name: DeleteTask :exec
DELETE FROM tasks
WHERE id = $1
`
const ExistsSystemSetting = `-- name: ExistsSystemSetting :one
SELECT EXISTS (
SELECT 1 FROM system_settings
WHERE key = $1
)
`
const FailToolExecution = `` /* 358-byte string literal not displayed */
const GetActiveMemories = `` /* 384-byte string literal not displayed */
const GetBackupStats = `` /* 269-byte string literal not displayed */
const GetBackupsWithinTimeRange = `` /* 183-byte string literal not displayed */
const GetConversation = `` /* 185-byte string literal not displayed */
const GetConversationStats = `` /* 324-byte string literal not displayed */
const GetConversationTokenUsage = `` /* 221-byte string literal not displayed */
const GetEmbedding = `` /* 149-byte string literal not displayed */
const GetEmbeddingBySource = `` /* 186-byte string literal not displayed */
const GetEmbeddingStats = `` /* 230-byte string literal not displayed */
const GetLastMessages = `` /* 183-byte string literal not displayed */
const GetLatestMemoryBackup = `` /* 133-byte string literal not displayed */
const GetLatestMemoryEvent = `` /* 158-byte string literal not displayed */
const GetMemoryBackup = `-- name: GetMemoryBackup :one
SELECT id, version, backup_data, created_at
FROM memory_backups
WHERE id = $1
LIMIT 1
`
const GetMemoryById = `` /* 361-byte string literal not displayed */
const GetMemoryEventsByType = `` /* 158-byte string literal not displayed */
const GetMemoryForMerge = `-- name: GetMemoryForMerge :one
SELECT
content, keywords, confidence
FROM memories
WHERE id = $1
`
const GetMemoryForMergeDecision = `` /* 150-byte string literal not displayed */
const GetMemoryProjection = `` /* 336-byte string literal not displayed */
const GetMemoryStreams = `-- name: GetMemoryStreams :many
SELECT stream_id, MAX(version) as latest_version
FROM memory_events
GROUP BY stream_id
`
const GetMessage = `` /* 138-byte string literal not displayed */
const GetMultipleSettings = `` /* 156-byte string literal not displayed */
const GetRecentConversationsWithMessageCount = `` /* 451-byte string literal not displayed */
const GetRecentMemories = `` /* 384-byte string literal not displayed */
const GetSettingHistory = `` /* 153-byte string literal not displayed */
const GetSystemSetting = `` /* 130-byte string literal not displayed */
const GetSystemSettingKeys = `-- name: GetSystemSettingKeys :many
SELECT key
FROM system_settings
ORDER BY key ASC
`
const GetTask = `` /* 169-byte string literal not displayed */
const GetTaskStats = `` /* 479-byte string literal not displayed */
const GetTasksByPriority = `` /* 313-byte string literal not displayed */
const GetToolExecution = `` /* 193-byte string literal not displayed */
const GetToolExecutionStats = `` /* 572-byte string literal not displayed */
const GetToolUsageByName = `` /* 386-byte string literal not displayed */
const ListActiveConversations = `` /* 257-byte string literal not displayed */
const ListConversations = `` /* 439-byte string literal not displayed */
const ListEmbeddingsBySource = `` /* 244-byte string literal not displayed */
const ListMemoryBackups = `` /* 178-byte string literal not displayed */
const ListMessages = `` /* 227-byte string literal not displayed */
const ListOverdueTasks = `` /* 244-byte string literal not displayed */
const ListPendingTasks = `` /* 433-byte string literal not displayed */
const ListPendingToolExecutions = `` /* 253-byte string literal not displayed */
const ListRecentMessages = `` /* 186-byte string literal not displayed */
const ListSystemSettings = `` /* 127-byte string literal not displayed */
const ListSystemSettingsByPrefix = `` /* 160-byte string literal not displayed */
const ListTasks = `` /* 634-byte string literal not displayed */
const ListTasksByLabel = `` /* 258-byte string literal not displayed */
const ListTasksDueToday = `` /* 307-byte string literal not displayed */
const ListToolExecutions = `` /* 360-byte string literal not displayed */
const ListToolExecutionsByConversation = `` /* 249-byte string literal not displayed */
const LoadMemoryEvents = `` /* 146-byte string literal not displayed */
const LoadMemoryEventsFromVersion = `` /* 175-byte string literal not displayed */
const MarkMemoryAsCorrected = `` /* 184-byte string literal not displayed */
const RemoveTaskLabel = `` /* 212-byte string literal not displayed */
const SearchConversationMessages = `` /* 500-byte string literal not displayed */
const SearchConversations = `` /* 442-byte string literal not displayed */
const SearchConversationsWithHighlight = `` /* 765-byte string literal not displayed */
const SearchMemoriesByText = `` /* 539-byte string literal not displayed */
const SearchMemoriesByTextFallback = `` /* 464-byte string literal not displayed */
const SearchMemoryProjections = `` /* 400-byte string literal not displayed */
const SearchMessages = `` /* 226-byte string literal not displayed */
const SearchSimilarEmbeddings = `` /* 300-byte string literal not displayed */
const SearchSimilarMemories = `` /* 483-byte string literal not displayed */
const SearchSimilarMemoriesForDedup = `` /* 351-byte string literal not displayed */
const SearchSimilarMemoriesForMerge = `` /* 253-byte string literal not displayed */
const SearchTasks = `` /* 360-byte string literal not displayed */
const SetSystemSetting = `` /* 330-byte string literal not displayed */
const StartToolExecution = `` /* 234-byte string literal not displayed */
const UpdateConversation = `` /* 372-byte string literal not displayed */
const UpdateEmbedding = `` /* 236-byte string literal not displayed */
const UpdateMemory = `` /* 337-byte string literal not displayed */
const UpdateMemoryAccess = `` /* 127-byte string literal not displayed */
const UpdateMemoryAfterMerge = `` /* 232-byte string literal not displayed */
const UpdateMemoryConfidence = `` /* 141-byte string literal not displayed */
const UpdateMemoryCorrected = `` /* 156-byte string literal not displayed */
const UpdateMemoryEmbedding = `-- name: UpdateMemoryEmbedding :exec
UPDATE memories
SET
embedding = $2::vector,
updated_at = NOW()
WHERE id = $1
`
const UpdateMemoryMerged = `` /* 164-byte string literal not displayed */
const UpdateMemoryProjection = `` /* 246-byte string literal not displayed */
const UpdateMergedMemory = `` /* 223-byte string literal not displayed */
const UpdateSystemSetting = `` /* 145-byte string literal not displayed */
const UpdateTask = `` /* 692-byte string literal not displayed */
const UpdateTaskLabels = `` /* 191-byte string literal not displayed */
const UpdateToolExecution = `` /* 437-byte string literal not displayed */
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 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 ArchiveSourceMemoriesParams ¶
type ArchiveSourceMemoriesParams struct { Column1 []pgtype.UUID `json:"column_1"` Status MemoryStatus `json:"status"` UpdatedAt time.Time `json:"updated_at"` }
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 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 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 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 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 GetBackupStatsRow ¶
type GetConversationStatsRow ¶
type GetEmbeddingStatsRow ¶
type GetLastMessagesParams ¶
type GetMemoryBackupRow ¶
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 GetMemoryStreamsRow ¶
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 GetTaskStatsRow ¶
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 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 ListMemoryBackupsParams ¶
type ListMemoryBackupsRow ¶
type ListMessagesParams ¶
type ListTasksByLabelParams ¶
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 ListToolExecutionsParams ¶
type ListToolExecutionsParams struct { ToolName string `json:"tool_name"` Status ToolStatus `json:"status"` OffsetCount int32 `json:"offset_count"` LimitCount int32 `json:"limit_count"` }
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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.
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 (*Queries) AddTaskLabel ¶
func (*Queries) AppendMemoryEvent ¶
func (q *Queries) AppendMemoryEvent(ctx context.Context, arg AppendMemoryEventParams) error
Memory Event Sourcing Queries
func (*Queries) ArchiveConversation ¶
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 (*Queries) CompleteTask ¶
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 (*Queries) CountMemoryEvents ¶
func (*Queries) CountMessagesByRole ¶
func (*Queries) CountSystemSettings ¶
func (*Queries) CreateConversation ¶
func (q *Queries) CreateConversation(ctx context.Context, arg CreateConversationParams) (*Conversation, error)
func (*Queries) CreateEmbedding ¶
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 (*Queries) CreateTask ¶
func (*Queries) CreateToolExecution ¶
func (q *Queries) CreateToolExecution(ctx context.Context, arg CreateToolExecutionParams) (*ToolExecution, error)
func (*Queries) DeleteConversation ¶
func (*Queries) DeleteConversationMessages ¶
func (*Queries) DeleteEmbedding ¶
func (*Queries) DeleteEmbeddingBySource ¶
func (q *Queries) DeleteEmbeddingBySource(ctx context.Context, arg DeleteEmbeddingBySourceParams) error
func (*Queries) DeleteMemoryBackup ¶
func (*Queries) DeleteMessage ¶
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 (*Queries) DeleteSystemSetting ¶
func (*Queries) DeleteTask ¶
func (*Queries) ExistsSystemSetting ¶
func (*Queries) FailToolExecution ¶
func (q *Queries) FailToolExecution(ctx context.Context, arg FailToolExecutionParams) (*ToolExecution, error)
func (*Queries) GetActiveMemories ¶
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 (*Queries) GetConversationStats ¶
func (q *Queries) GetConversationStats(ctx context.Context) (*GetConversationStatsRow, error)
func (*Queries) GetConversationTokenUsage ¶
func (*Queries) GetEmbedding ¶
func (*Queries) GetEmbeddingBySource ¶
func (*Queries) GetEmbeddingStats ¶
func (q *Queries) GetEmbeddingStats(ctx context.Context) (*GetEmbeddingStatsRow, error)
func (*Queries) GetLastMessages ¶
func (*Queries) GetLatestMemoryBackup ¶
func (q *Queries) GetLatestMemoryBackup(ctx context.Context) (*GetLatestMemoryBackupRow, error)
func (*Queries) GetLatestMemoryEvent ¶
func (*Queries) GetMemoryBackup ¶
func (*Queries) GetMemoryById ¶
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 (*Queries) GetMemoryStreams ¶
func (q *Queries) GetMemoryStreams(ctx context.Context) ([]*GetMemoryStreamsRow, error)
func (*Queries) GetMessage ¶
func (*Queries) GetMultipleSettings ¶
func (*Queries) GetRecentConversationsWithMessageCount ¶
func (*Queries) GetRecentMemories ¶
func (*Queries) GetSettingHistory ¶
func (*Queries) GetSystemSetting ¶
func (*Queries) GetSystemSettingKeys ¶
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 (*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 (*Queries) ListConversations ¶
func (q *Queries) ListConversations(ctx context.Context, arg ListConversationsParams) ([]*Conversation, error)
func (*Queries) ListEmbeddingsBySource ¶
func (*Queries) ListMemoryBackups ¶
func (q *Queries) ListMemoryBackups(ctx context.Context, arg ListMemoryBackupsParams) ([]*ListMemoryBackupsRow, error)
func (*Queries) ListMessages ¶
func (*Queries) ListOverdueTasks ¶
func (*Queries) ListPendingTasks ¶
func (*Queries) ListPendingToolExecutions ¶
func (*Queries) ListRecentMessages ¶
func (*Queries) ListSystemSettings ¶
func (q *Queries) ListSystemSettings(ctx context.Context) ([]*SystemSetting, error)
func (*Queries) ListSystemSettingsByPrefix ¶
func (*Queries) ListTasksByLabel ¶
func (*Queries) ListTasksDueToday ¶
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 (*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 (*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 (*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 (*Queries) SetSystemSetting ¶
func (q *Queries) SetSystemSetting(ctx context.Context, arg SetSystemSettingParams) (*SystemSetting, error)
func (*Queries) StartToolExecution ¶
func (*Queries) UpdateConversation ¶
func (q *Queries) UpdateConversation(ctx context.Context, arg UpdateConversationParams) (*Conversation, error)
func (*Queries) UpdateEmbedding ¶
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 (*Queries) UpdateTaskLabels ¶
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
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 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 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 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 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 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 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 UpdateEmbeddingParams ¶
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 UpdateSystemSettingParams ¶
type UpdateSystemSettingParams struct { Value json.RawMessage `json:"value"` Key string `json:"key"` }
type UpdateTaskLabelsParams ¶
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"` }