Documentation
¶
Index ¶
- type AcceptGoalParams
- type AddDigestArticleParams
- type AddGroupMemberParams
- type AdvanceMemorySnapshotParams
- type Agent
- type AgentGoal
- type AgentGoalAcceptanceEvent
- type AgentGoalAttempt
- type AgentGoalEdge
- type AppSetting
- type AppendAcceptanceEventParams
- type AppendContextItemParams
- type ArchiveProjectParams
- type AssignUserAgentParams
- type AuthCredential
- type AuthIdentity
- type AuthPolicy
- type AuthSession
- type AuthUser
- type AuthUserAgent
- type AuthUserToken
- type BlockGoalParams
- type Channel
- type ChannelAgent
- type ChannelGroupMember
- type ChannelIdentity
- type ClaimExpiredGroupDispatchParams
- type ClaimExpiredGroupOutboxParams
- type ClaimGoalParams
- type ClaimPendingGroupDispatchParams
- type ClaimPendingGroupOutboxParams
- type ConsumeDispatchHintParams
- type CountArticlesByStatusParams
- type CountRootGoalParams
- type CreateAgentParams
- type CreateArticleParams
- type CreateAttemptParams
- type CreateAuthPolicyParams
- type CreateAuthUserTokenParams
- type CreateConversationParams
- type CreateDigestParams
- type CreateEdgeParams
- type CreateFeedEntryParams
- type CreateFeedParams
- type CreateGoalParams
- type CreateGroupDispatchParams
- type CreateGroupMessageParams
- type CreateGroupOutboxParams
- type CreateGroupStateParams
- type CreateIngestErrorParams
- type CreateMemorySnapshotParams
- type CreateMessageParams
- type CreateMessagePartParams
- type CreateProjectParams
- type CreateProviderParams
- type CreateSchedJobRunParams
- type CreateSchedulerJobParams
- type CreateShareParams
- type CreateSkillParams
- type CreateSummaryParams
- type CreateWebChannelIfNotExistsParams
- type CtxAgentMemory
- type CtxAgentMemoryChangelog
- type CtxAgentMemorySnapshot
- type CtxConversation
- type CtxGroupDispatch
- type CtxGroupIngestCursor
- type CtxGroupIngestError
- type CtxGroupMemory
- type CtxGroupMessage
- type CtxGroupOutbox
- type CtxGroupState
- type CtxItem
- type CtxMessage
- type CtxMessageEmbedding
- type CtxMessagePart
- type CtxSummary
- type CtxSummaryEmbedding
- type CtxSummaryMessage
- type CtxSummaryParent
- type DBTX
- type DeleteArticleParams
- type DeleteChatAgentParams
- type DeleteContextItemsInRangeParams
- type DeleteDigestArticlesParams
- type DeleteEdgeParams
- type DeleteFeedParams
- type DeletePluginStateEntryParams
- type DeleteProjectParams
- type DeleteShareByUserParams
- type DeleteSkillFileParams
- type DeleteSkillParams
- type DeleteUserAgentMemoryParams
- type DeleteVaultEntryByScopeParams
- type DeleteVaultEntryParams
- type ExpireKnowledgeDraftsByTypeParams
- type ExtendRunningGroupDispatchLeaseParams
- type ExtendRunningGroupOutboxLeaseParams
- type FinalizeAttemptParams
- type GetActiveAttemptParams
- type GetArticleByCanonicalURLParams
- type GetArticleParams
- type GetChatAgentParams
- type GetContextMessageItemsRow
- type GetContextStatsRow
- type GetConversationAgentBySessionIDParams
- type GetConversationBySessionIDParams
- type GetConversationParams
- type GetConversationTimeBoundsRow
- type GetDigestByDateParams
- type GetEdgeParams
- type GetFeedByURLParams
- type GetFeedEntryParams
- type GetFeedParams
- type GetFreshTailMessageIDsParams
- type GetGroupMemberParams
- type GetGroupMessageByPlatformIDParams
- type GetGroupStateByTripleParams
- type GetIngestCursorParams
- type GetMainConversationByProjectParams
- type GetMaxAttemptNoParams
- type GetMemoryChangelogAtVersionParams
- type GetMemorySnapshotParams
- type GetMessageParams
- type GetMessageScopedParams
- type GetMessageScopedRow
- type GetMessagesByConversationRangeParams
- type GetMessagesSinceParams
- type GetPluginStateEntryParams
- type GetProjectByNameParams
- type GetProjectParams
- type GetSchedJobRunParams
- type GetSkillFileParams
- type GetSkillParams
- type GetSummariesByDepthParams
- type GetSummaryMessageSeqRangeRow
- type GetSummaryParams
- type GetSystemAgentSkillByNameParams
- type GetUserAgentMemoryParams
- type GetUserSkillByNameParams
- type GetVaultEntryByScopeParams
- type GetVaultEntryParams
- type HeartbeatAttemptParams
- type InsertMemoryChangelogParams
- type IsIngestErrorParams
- type LinkSummaryToMessageParams
- type LinkSummaryToParentParams
- type ListActiveKnowledgeByTypeParams
- type ListAgentConversationLastActiveRow
- type ListArticlesNeedingEmbeddingParams
- type ListArticlesNeedingEmbeddingRow
- type ListArticlesParams
- type ListAttemptByGoalParams
- type ListContextItemsPageParams
- type ListContextItemsPageRow
- type ListConversationsAllParams
- type ListConversationsByKindParams
- type ListConversationsFilteredParams
- type ListConversationsForReviewFilteredParams
- type ListConversationsParams
- type ListDigestArticlesParams
- type ListDigestsParams
- type ListEdgeWithUpstreamStateRow
- type ListExistingUserMessageContentParams
- type ListExpiredRunningGroupDispatchParams
- type ListExpiredRunningGroupOutboxParams
- type ListFailedInboxSchedulerRunsParams
- type ListFailedInboxSchedulerRunsRow
- type ListFeedEntriesParams
- type ListFeedsParams
- type ListGroupMessagesAfterSeqParams
- type ListGroupMessagesBetweenSeqsParams
- type ListGroupMessagesPaginatedParams
- type ListGroupsByUserParams
- type ListGroupsByUserRow
- type ListGroupsWithPendingIngestRow
- type ListInboxGoalsParams
- type ListInboxGoalsRow
- type ListMemoryChangelogParams
- type ListMessagesByIDsParams
- type ListMessagesByLogicalPageParams
- type ListMessagesByLogicalPageRow
- type ListMessagesNeedingEmbeddingParams
- type ListMessagesNeedingEmbeddingRow
- type ListPendingEntriesParams
- type ListPendingGroupDispatchByMessageParams
- type ListPendingGroupDispatchParams
- type ListPendingGroupOutboxParams
- type ListProjectsAllParams
- type ListProjectsParams
- type ListRecentGroupMessagesBeforeSeqParams
- type ListRecentGroupMessagesParams
- type ListRootGoalParams
- type ListSchedJobRunsParams
- type ListSchedulerJobsByAgentParams
- type ListSharesByUserParams
- type ListSharesByUserRow
- type ListSkillsByScopeParams
- type ListSkillsForAgentContextParams
- type ListSkillsForUserParams
- type ListSkillsVisibleParams
- type ListStaleAttemptsParams
- type ListSummariesByIDsParams
- type ListSummariesNeedingEmbeddingParams
- type ListSummariesNeedingEmbeddingRow
- type ListUnreadArticlesOlderThanParams
- type ListVaultEntriesByScopeParams
- type ListVaultEntriesForRuntimeParams
- type MarkGroupDispatchCompletedParams
- type MarkGroupDispatchFailedParams
- type MarkGroupOutboxCompletedParams
- type MarkGroupOutboxFailedParams
- type Plugin
- type PluginOauthProvider
- type PluginOverride
- type PluginState
- type Project
- type PromoteAttemptParams
- type Provider
- type Queries
- func (q *Queries) AcceptGoal(ctx context.Context, arg AcceptGoalParams) (int64, error)
- func (q *Queries) AddDigestArticle(ctx context.Context, arg AddDigestArticleParams) error
- func (q *Queries) AddGroupMember(ctx context.Context, arg AddGroupMemberParams) (ChannelGroupMember, error)
- func (q *Queries) AdvanceMemorySnapshot(ctx context.Context, arg AdvanceMemorySnapshotParams) error
- func (q *Queries) AppendAcceptanceEvent(ctx context.Context, arg AppendAcceptanceEventParams) (AgentGoalAcceptanceEvent, error)
- func (q *Queries) AppendContextItem(ctx context.Context, arg AppendContextItemParams) error
- func (q *Queries) ArchiveGoal(ctx context.Context, id string) error
- func (q *Queries) ArchiveProject(ctx context.Context, arg ArchiveProjectParams) error
- func (q *Queries) AssignUserAgent(ctx context.Context, arg AssignUserAgentParams) error
- func (q *Queries) BlockGoal(ctx context.Context, arg BlockGoalParams) (int64, error)
- func (q *Queries) BumpGroupSeq(ctx context.Context, id string) (int64, error)
- func (q *Queries) CancelGoal(ctx context.Context, id string) error
- func (q *Queries) ClaimExpiredGroupDispatch(ctx context.Context, arg ClaimExpiredGroupDispatchParams) (CtxGroupDispatch, error)
- func (q *Queries) ClaimExpiredGroupOutbox(ctx context.Context, arg ClaimExpiredGroupOutboxParams) (CtxGroupOutbox, error)
- func (q *Queries) ClaimGoal(ctx context.Context, arg ClaimGoalParams) (int64, error)
- func (q *Queries) ClaimPendingGroupDispatch(ctx context.Context, arg ClaimPendingGroupDispatchParams) (CtxGroupDispatch, error)
- func (q *Queries) ClaimPendingGroupOutbox(ctx context.Context, arg ClaimPendingGroupOutboxParams) (CtxGroupOutbox, error)
- func (q *Queries) ClearGoalActiveAttempt(ctx context.Context, id string) error
- func (q *Queries) ConsumeDispatchHint(ctx context.Context, arg ConsumeDispatchHintParams) error
- func (q *Queries) CountArticlesByStatus(ctx context.Context, arg CountArticlesByStatusParams) (int64, error)
- func (q *Queries) CountDigests(ctx context.Context, userID string) (int64, error)
- func (q *Queries) CountGroupDispatchByMessage(ctx context.Context, groupMessageID string) (int64, error)
- func (q *Queries) CountGroupMembers(ctx context.Context, groupID string) (int64, error)
- func (q *Queries) CountInflightAttemptsByRoot(ctx context.Context, rootID string) (int64, error)
- func (q *Queries) CountInflightAttemptsByUser(ctx context.Context, userID string) (int64, error)
- func (q *Queries) CountNonTerminalGroupDispatchByMessage(ctx context.Context, groupMessageID string) (int64, error)
- func (q *Queries) CountRootGoal(ctx context.Context, arg CountRootGoalParams) (int64, error)
- func (q *Queries) CountRunningSchedJobRuns(ctx context.Context, jobID string) (int64, error)
- func (q *Queries) CountStarredArticles(ctx context.Context, userID string) (int64, error)
- func (q *Queries) CreateAgent(ctx context.Context, arg CreateAgentParams) (Agent, error)
- func (q *Queries) CreateArticle(ctx context.Context, arg CreateArticleParams) (RecallyArticle, error)
- func (q *Queries) CreateAttempt(ctx context.Context, arg CreateAttemptParams) (AgentGoalAttempt, error)
- func (q *Queries) CreateAuthPolicy(ctx context.Context, arg CreateAuthPolicyParams) (AuthPolicy, error)
- func (q *Queries) CreateAuthUserToken(ctx context.Context, arg CreateAuthUserTokenParams) (AuthUserToken, error)
- func (q *Queries) CreateConversation(ctx context.Context, arg CreateConversationParams) (CtxConversation, error)
- func (q *Queries) CreateDigest(ctx context.Context, arg CreateDigestParams) (RecallyDigest, error)
- func (q *Queries) CreateEdge(ctx context.Context, arg CreateEdgeParams) (AgentGoalEdge, error)
- func (q *Queries) CreateFeed(ctx context.Context, arg CreateFeedParams) (RecallyFeed, error)
- func (q *Queries) CreateFeedEntry(ctx context.Context, arg CreateFeedEntryParams) (RecallyFeedEntry, error)
- func (q *Queries) CreateGoal(ctx context.Context, arg CreateGoalParams) (AgentGoal, error)
- func (q *Queries) CreateGroupDispatch(ctx context.Context, arg CreateGroupDispatchParams) error
- func (q *Queries) CreateGroupMessage(ctx context.Context, arg CreateGroupMessageParams) (CtxGroupMessage, error)
- func (q *Queries) CreateGroupOutbox(ctx context.Context, arg CreateGroupOutboxParams) (CtxGroupOutbox, error)
- func (q *Queries) CreateGroupState(ctx context.Context, arg CreateGroupStateParams) (CtxGroupState, error)
- func (q *Queries) CreateIngestError(ctx context.Context, arg CreateIngestErrorParams) error
- func (q *Queries) CreateMemorySnapshot(ctx context.Context, arg CreateMemorySnapshotParams) (CtxAgentMemorySnapshot, error)
- func (q *Queries) CreateMessage(ctx context.Context, arg CreateMessageParams) (CtxMessage, error)
- func (q *Queries) CreateMessagePart(ctx context.Context, arg CreateMessagePartParams) error
- func (q *Queries) CreateProject(ctx context.Context, arg CreateProjectParams) (Project, error)
- func (q *Queries) CreateProvider(ctx context.Context, arg CreateProviderParams) (Provider, error)
- func (q *Queries) CreateSchedJobRun(ctx context.Context, arg CreateSchedJobRunParams) (SchedJobRun, error)
- func (q *Queries) CreateSchedulerJob(ctx context.Context, arg CreateSchedulerJobParams) (SchedJob, error)
- func (q *Queries) CreateShare(ctx context.Context, arg CreateShareParams) (Share, error)
- func (q *Queries) CreateSkill(ctx context.Context, arg CreateSkillParams) (Skill, error)
- func (q *Queries) CreateSummary(ctx context.Context, arg CreateSummaryParams) error
- func (q *Queries) CreateWebChannelIfNotExists(ctx context.Context, arg CreateWebChannelIfNotExistsParams) error
- func (q *Queries) DecrGoalRequiredBlocked(ctx context.Context, id string) error
- func (q *Queries) DeleteAgent(ctx context.Context, id string) error
- func (q *Queries) DeleteAllContextItems(ctx context.Context, conversationID string) error
- func (q *Queries) DeleteAllVaultEntriesByUser(ctx context.Context, userID pgtype.Text) error
- func (q *Queries) DeleteArticle(ctx context.Context, arg DeleteArticleParams) error
- func (q *Queries) DeleteAuthOAuthProvider(ctx context.Context, providerID string) error
- func (q *Queries) DeleteAuthPolicy(ctx context.Context, id string) error
- func (q *Queries) DeleteChannel(ctx context.Context, id string) error
- func (q *Queries) DeleteChatAgent(ctx context.Context, arg DeleteChatAgentParams) error
- func (q *Queries) DeleteContextItemsInRange(ctx context.Context, arg DeleteContextItemsInRangeParams) error
- func (q *Queries) DeleteDigestArticles(ctx context.Context, arg DeleteDigestArticlesParams) error
- func (q *Queries) DeleteEdge(ctx context.Context, arg DeleteEdgeParams) error
- func (q *Queries) DeleteFeed(ctx context.Context, arg DeleteFeedParams) error
- func (q *Queries) DeleteGroupMemory(ctx context.Context, groupID string) error
- func (q *Queries) DeleteGroupState(ctx context.Context, id string) error
- func (q *Queries) DeleteManifestPluginOverride(ctx context.Context, pluginID string) error
- func (q *Queries) DeleteOldEntries(ctx context.Context, feedID string) error
- func (q *Queries) DeletePlugin(ctx context.Context, id string) error
- func (q *Queries) DeletePluginStateEntry(ctx context.Context, arg DeletePluginStateEntryParams) error
- func (q *Queries) DeleteProject(ctx context.Context, arg DeleteProjectParams) error
- func (q *Queries) DeleteProvider(ctx context.Context, id string) error
- func (q *Queries) DeleteSchedulerJob(ctx context.Context, id string) error
- func (q *Queries) DeleteSetting(ctx context.Context, key string) error
- func (q *Queries) DeleteShareByUser(ctx context.Context, arg DeleteShareByUserParams) (int64, error)
- func (q *Queries) DeleteSkill(ctx context.Context, arg DeleteSkillParams) error
- func (q *Queries) DeleteSkillFile(ctx context.Context, arg DeleteSkillFileParams) error
- func (q *Queries) DeleteSystemSkill(ctx context.Context, id string) error
- func (q *Queries) DeleteUserAgentMemory(ctx context.Context, arg DeleteUserAgentMemoryParams) error
- func (q *Queries) DeleteVaultEntry(ctx context.Context, arg DeleteVaultEntryParams) error
- func (q *Queries) DeleteVaultEntryByScope(ctx context.Context, arg DeleteVaultEntryByScopeParams) error
- func (q *Queries) DeprecateExpiredDrafts(ctx context.Context, cutoff string) error
- func (q *Queries) ExpireKnowledgeDraftsByType(ctx context.Context, arg ExpireKnowledgeDraftsByTypeParams) error
- func (q *Queries) ExtendRunningGroupDispatchLease(ctx context.Context, arg ExtendRunningGroupDispatchLeaseParams) (int64, error)
- func (q *Queries) ExtendRunningGroupOutboxLease(ctx context.Context, arg ExtendRunningGroupOutboxLeaseParams) (int64, error)
- func (q *Queries) FinalizeAttempt(ctx context.Context, arg FinalizeAttemptParams) (int64, error)
- func (q *Queries) GetActiveAttempt(ctx context.Context, arg GetActiveAttemptParams) (AgentGoalAttempt, error)
- func (q *Queries) GetActiveAuthUserTokenByHash(ctx context.Context, tokenHash string) (AuthUserToken, error)
- func (q *Queries) GetActiveAutoAuthUserTokenByUser(ctx context.Context, userID string) (AuthUserToken, error)
- func (q *Queries) GetAgent(ctx context.Context, id string) (Agent, error)
- func (q *Queries) GetArticle(ctx context.Context, arg GetArticleParams) (RecallyArticle, error)
- func (q *Queries) GetArticleByCanonicalURL(ctx context.Context, arg GetArticleByCanonicalURLParams) (RecallyArticle, error)
- func (q *Queries) GetArticlesSavedThisWeek(ctx context.Context, userID string) ([]RecallyArticle, error)
- func (q *Queries) GetAttempt(ctx context.Context, id string) (AgentGoalAttempt, error)
- func (q *Queries) GetAuthOAuthProvider(ctx context.Context, providerID string) (PluginOauthProvider, error)
- func (q *Queries) GetAuthPolicy(ctx context.Context, id string) (AuthPolicy, error)
- func (q *Queries) GetAuthUserTokenByHash(ctx context.Context, tokenHash string) (AuthUserToken, error)
- func (q *Queries) GetChannel(ctx context.Context, id string) (Channel, error)
- func (q *Queries) GetChatAgent(ctx context.Context, arg GetChatAgentParams) (ChannelAgent, error)
- func (q *Queries) GetContextItemCount(ctx context.Context, conversationID string) (int64, error)
- func (q *Queries) GetContextItems(ctx context.Context, conversationID string) ([]CtxItem, error)
- func (q *Queries) GetContextMessageItems(ctx context.Context, conversationID string) ([]GetContextMessageItemsRow, error)
- func (q *Queries) GetContextStats(ctx context.Context, conversationID string) (GetContextStatsRow, error)
- func (q *Queries) GetContextTokenCount(ctx context.Context, conversationID string) (int64, error)
- func (q *Queries) GetConversation(ctx context.Context, arg GetConversationParams) (CtxConversation, error)
- func (q *Queries) GetConversationAgentBySessionID(ctx context.Context, arg GetConversationAgentBySessionIDParams) (pgtype.Text, error)
- func (q *Queries) GetConversationBySessionID(ctx context.Context, arg GetConversationBySessionIDParams) (CtxConversation, error)
- func (q *Queries) GetConversationTimeBounds(ctx context.Context, conversationID string) (GetConversationTimeBoundsRow, error)
- func (q *Queries) GetDigestByDate(ctx context.Context, arg GetDigestByDateParams) (RecallyDigest, error)
- func (q *Queries) GetEdge(ctx context.Context, arg GetEdgeParams) (AgentGoalEdge, error)
- func (q *Queries) GetFeed(ctx context.Context, arg GetFeedParams) (RecallyFeed, error)
- func (q *Queries) GetFeedByURL(ctx context.Context, arg GetFeedByURLParams) (RecallyFeed, error)
- func (q *Queries) GetFeedEntry(ctx context.Context, arg GetFeedEntryParams) (RecallyFeedEntry, error)
- func (q *Queries) GetFreshTailMessageIDs(ctx context.Context, arg GetFreshTailMessageIDsParams) ([]pgtype.Text, error)
- func (q *Queries) GetGoal(ctx context.Context, id string) (AgentGoal, error)
- func (q *Queries) GetGroupDispatch(ctx context.Context, id string) (CtxGroupDispatch, error)
- func (q *Queries) GetGroupLastActive(ctx context.Context, id string) (time.Time, error)
- func (q *Queries) GetGroupMember(ctx context.Context, arg GetGroupMemberParams) (ChannelGroupMember, error)
- func (q *Queries) GetGroupMemory(ctx context.Context, groupID string) (CtxGroupMemory, error)
- func (q *Queries) GetGroupMessage(ctx context.Context, id string) (CtxGroupMessage, error)
- func (q *Queries) GetGroupMessageByIdempotencyKey(ctx context.Context, idempotencyKey pgtype.Text) (CtxGroupMessage, error)
- func (q *Queries) GetGroupMessageByPlatformID(ctx context.Context, arg GetGroupMessageByPlatformIDParams) (CtxGroupMessage, error)
- func (q *Queries) GetGroupOutbox(ctx context.Context, id string) (CtxGroupOutbox, error)
- func (q *Queries) GetGroupOutboxByMessage(ctx context.Context, groupMessageID string) (CtxGroupOutbox, error)
- func (q *Queries) GetGroupStateByID(ctx context.Context, id string) (CtxGroupState, error)
- func (q *Queries) GetGroupStateByTriple(ctx context.Context, arg GetGroupStateByTripleParams) (CtxGroupState, error)
- func (q *Queries) GetIngestCursor(ctx context.Context, arg GetIngestCursorParams) (CtxGroupIngestCursor, error)
- func (q *Queries) GetMainConversationByProject(ctx context.Context, arg GetMainConversationByProjectParams) (CtxConversation, error)
- func (q *Queries) GetManifestPluginOverride(ctx context.Context, pluginID string) (PluginOverride, error)
- func (q *Queries) GetMaxAcceptanceSeq(ctx context.Context, goalID string) (int64, error)
- func (q *Queries) GetMaxAttemptNo(ctx context.Context, arg GetMaxAttemptNoParams) (int64, error)
- func (q *Queries) GetMaxContextOrdinal(ctx context.Context, conversationID string) (int64, error)
- func (q *Queries) GetMaxSeq(ctx context.Context, conversationID string) (int64, error)
- func (q *Queries) GetMemoryChangelogAtVersion(ctx context.Context, arg GetMemoryChangelogAtVersionParams) (CtxAgentMemoryChangelog, error)
- func (q *Queries) GetMemorySnapshot(ctx context.Context, arg GetMemorySnapshotParams) (CtxAgentMemorySnapshot, error)
- func (q *Queries) GetMessage(ctx context.Context, arg GetMessageParams) (CtxMessage, error)
- func (q *Queries) GetMessageCount(ctx context.Context, conversationID string) (int64, error)
- func (q *Queries) GetMessageParts(ctx context.Context, messageID string) ([]CtxMessagePart, error)
- func (q *Queries) GetMessagePartsByMessages(ctx context.Context, messageIds []string) ([]CtxMessagePart, error)
- func (q *Queries) GetMessageScoped(ctx context.Context, arg GetMessageScopedParams) (GetMessageScopedRow, error)
- func (q *Queries) GetMessagesByConversation(ctx context.Context, conversationID string) ([]CtxMessage, error)
- func (q *Queries) GetMessagesByConversationRange(ctx context.Context, arg GetMessagesByConversationRangeParams) ([]CtxMessage, error)
- func (q *Queries) GetMessagesSince(ctx context.Context, arg GetMessagesSinceParams) ([]CtxMessage, error)
- func (q *Queries) GetPlugin(ctx context.Context, id string) (Plugin, error)
- func (q *Queries) GetPluginStateEntry(ctx context.Context, arg GetPluginStateEntryParams) (json.RawMessage, error)
- func (q *Queries) GetProject(ctx context.Context, arg GetProjectParams) (Project, error)
- func (q *Queries) GetProjectByName(ctx context.Context, arg GetProjectByNameParams) (Project, error)
- func (q *Queries) GetProvider(ctx context.Context, id string) (Provider, error)
- func (q *Queries) GetSchedJobRun(ctx context.Context, arg GetSchedJobRunParams) (SchedJobRun, error)
- func (q *Queries) GetSchedulerJob(ctx context.Context, id string) (SchedJob, error)
- func (q *Queries) GetSetting(ctx context.Context, key string) (AppSetting, error)
- func (q *Queries) GetShareByTokenHash(ctx context.Context, tokenHash string) (Share, error)
- func (q *Queries) GetSkill(ctx context.Context, arg GetSkillParams) (Skill, error)
- func (q *Queries) GetSkillByID(ctx context.Context, id string) (Skill, error)
- func (q *Queries) GetSkillFile(ctx context.Context, arg GetSkillFileParams) (SkillFile, error)
- func (q *Queries) GetSummariesByConversation(ctx context.Context, conversationID string) ([]CtxSummary, error)
- func (q *Queries) GetSummariesByDepth(ctx context.Context, arg GetSummariesByDepthParams) ([]CtxSummary, error)
- func (q *Queries) GetSummary(ctx context.Context, arg GetSummaryParams) (CtxSummary, error)
- func (q *Queries) GetSummaryByID(ctx context.Context, id string) (CtxSummary, error)
- func (q *Queries) GetSummaryChildren(ctx context.Context, parentSummaryID string) ([]CtxSummary, error)
- func (q *Queries) GetSummaryMessageSeqRange(ctx context.Context, summaryID string) (GetSummaryMessageSeqRangeRow, error)
- func (q *Queries) GetSummaryMessages(ctx context.Context, summaryID string) ([]CtxMessage, error)
- func (q *Queries) GetSummaryParents(ctx context.Context, summaryID string) ([]CtxSummary, error)
- func (q *Queries) GetSystemAgentSkillByName(ctx context.Context, arg GetSystemAgentSkillByNameParams) (Skill, error)
- func (q *Queries) GetSystemSkillByName(ctx context.Context, name string) (Skill, error)
- func (q *Queries) GetUserAgentMemory(ctx context.Context, arg GetUserAgentMemoryParams) (CtxAgentMemory, error)
- func (q *Queries) GetUserSkillByName(ctx context.Context, arg GetUserSkillByNameParams) (Skill, error)
- func (q *Queries) GetVaultEntry(ctx context.Context, arg GetVaultEntryParams) (VaultEntry, error)
- func (q *Queries) GetVaultEntryByScope(ctx context.Context, arg GetVaultEntryByScopeParams) (VaultEntry, error)
- func (q *Queries) GetVaultUser(ctx context.Context, id string) (VaultUser, error)
- func (q *Queries) HeartbeatAttempt(ctx context.Context, arg HeartbeatAttemptParams) (int64, error)
- func (q *Queries) IncrGoalRequiredAccepted(ctx context.Context, id string) error
- func (q *Queries) IncrGoalRequiredBlocked(ctx context.Context, id string) error
- func (q *Queries) IncrGoalRequiredFailed(ctx context.Context, id string) error
- func (q *Queries) InsertMemoryChangelog(ctx context.Context, arg InsertMemoryChangelogParams) error
- func (q *Queries) IsIngestError(ctx context.Context, arg IsIngestErrorParams) (bool, error)
- func (q *Queries) LinkSummaryToMessage(ctx context.Context, arg LinkSummaryToMessageParams) error
- func (q *Queries) LinkSummaryToParent(ctx context.Context, arg LinkSummaryToParentParams) error
- func (q *Queries) ListAcceptanceEventByAttempt(ctx context.Context, attemptID pgtype.Text) ([]AgentGoalAcceptanceEvent, error)
- func (q *Queries) ListAcceptanceEventByGoal(ctx context.Context, goalID string) ([]AgentGoalAcceptanceEvent, error)
- func (q *Queries) ListAccessibleAgents(ctx context.Context, userID string) ([]Agent, error)
- func (q *Queries) ListActiveKnowledgeByType(ctx context.Context, arg ListActiveKnowledgeByTypeParams) ([]Skill, error)
- func (q *Queries) ListAgentConversationLastActive(ctx context.Context, userID pgtype.Text) ([]ListAgentConversationLastActiveRow, error)
- func (q *Queries) ListAgentUsers(ctx context.Context, agentID string) ([]string, error)
- func (q *Queries) ListAgents(ctx context.Context) ([]Agent, error)
- func (q *Queries) ListAllSchedulerJobs(ctx context.Context) ([]SchedJob, error)
- func (q *Queries) ListAllSkills(ctx context.Context) ([]Skill, error)
- func (q *Queries) ListArticles(ctx context.Context, arg ListArticlesParams) ([]RecallyArticle, error)
- func (q *Queries) ListArticlesNeedingEmbedding(ctx context.Context, arg ListArticlesNeedingEmbeddingParams) ([]ListArticlesNeedingEmbeddingRow, error)
- func (q *Queries) ListArticlesSavedYesterday(ctx context.Context, userID string) ([]RecallyArticle, error)
- func (q *Queries) ListAttemptByGoal(ctx context.Context, arg ListAttemptByGoalParams) ([]AgentGoalAttempt, error)
- func (q *Queries) ListAuthPolicies(ctx context.Context) ([]AuthPolicy, error)
- func (q *Queries) ListAuthUsersByIDs(ctx context.Context, ids []string) ([]AuthUser, error)
- func (q *Queries) ListBlockedDepComposites(ctx context.Context, limit int32) ([]AgentGoal, error)
- func (q *Queries) ListChannels(ctx context.Context) ([]Channel, error)
- func (q *Queries) ListChannelsByType(ctx context.Context, type_ string) ([]Channel, error)
- func (q *Queries) ListChatAgents(ctx context.Context) ([]ChannelAgent, error)
- func (q *Queries) ListContextItemsPage(ctx context.Context, arg ListContextItemsPageParams) ([]ListContextItemsPageRow, error)
- func (q *Queries) ListConversations(ctx context.Context, arg ListConversationsParams) ([]CtxConversation, error)
- func (q *Queries) ListConversationsAll(ctx context.Context, arg ListConversationsAllParams) ([]CtxConversation, error)
- func (q *Queries) ListConversationsByKind(ctx context.Context, arg ListConversationsByKindParams) ([]CtxConversation, error)
- func (q *Queries) ListConversationsFiltered(ctx context.Context, arg ListConversationsFilteredParams) ([]CtxConversation, error)
- func (q *Queries) ListConversationsForReviewByAgent(ctx context.Context, agentID pgtype.Text) ([]CtxConversation, error)
- func (q *Queries) ListConversationsForReviewFiltered(ctx context.Context, arg ListConversationsForReviewFilteredParams) ([]CtxConversation, error)
- func (q *Queries) ListDecomposableComposites(ctx context.Context, limit int32) ([]AgentGoal, error)
- func (q *Queries) ListDigestArticles(ctx context.Context, arg ListDigestArticlesParams) ([]RecallyArticle, error)
- func (q *Queries) ListDigests(ctx context.Context, arg ListDigestsParams) ([]RecallyDigest, error)
- func (q *Queries) ListDispatchableLeaves(ctx context.Context, limit int32) ([]AgentGoal, error)
- func (q *Queries) ListEdgeByGoal(ctx context.Context, goalID string) ([]AgentGoalEdge, error)
- func (q *Queries) ListEdgeByUpstream(ctx context.Context, upstreamID string) ([]AgentGoalEdge, error)
- func (q *Queries) ListEdgeWithUpstreamState(ctx context.Context, goalID string) ([]ListEdgeWithUpstreamStateRow, error)
- func (q *Queries) ListEnabledAgents(ctx context.Context) ([]Agent, error)
- func (q *Queries) ListEnabledAuthPolicies(ctx context.Context) ([]AuthPolicy, error)
- func (q *Queries) ListEnabledPlugins(ctx context.Context) ([]Plugin, error)
- func (q *Queries) ListEnabledProviders(ctx context.Context) ([]Provider, error)
- func (q *Queries) ListExistingUserMessageContent(ctx context.Context, arg ListExistingUserMessageContentParams) ([]string, error)
- func (q *Queries) ListExpiredRunningGroupDispatch(ctx context.Context, arg ListExpiredRunningGroupDispatchParams) ([]CtxGroupDispatch, error)
- func (q *Queries) ListExpiredRunningGroupOutbox(ctx context.Context, arg ListExpiredRunningGroupOutboxParams) ([]CtxGroupOutbox, error)
- func (q *Queries) ListFailedInboxSchedulerRuns(ctx context.Context, arg ListFailedInboxSchedulerRunsParams) ([]ListFailedInboxSchedulerRunsRow, error)
- func (q *Queries) ListFeedEntries(ctx context.Context, arg ListFeedEntriesParams) ([]RecallyFeedEntry, error)
- func (q *Queries) ListFeeds(ctx context.Context, arg ListFeedsParams) ([]RecallyFeed, error)
- func (q *Queries) ListGoalByRoot(ctx context.Context, rootID string) ([]AgentGoal, error)
- func (q *Queries) ListGoalChildren(ctx context.Context, parentID pgtype.Text) ([]AgentGoal, error)
- func (q *Queries) ListGoalSubtree(ctx context.Context, id string) ([]AgentGoal, error)
- func (q *Queries) ListGroupMembers(ctx context.Context, groupID string) ([]ChannelGroupMember, error)
- func (q *Queries) ListGroupMessagesAfterSeq(ctx context.Context, arg ListGroupMessagesAfterSeqParams) ([]CtxGroupMessage, error)
- func (q *Queries) ListGroupMessagesBetweenSeqs(ctx context.Context, arg ListGroupMessagesBetweenSeqsParams) ([]CtxGroupMessage, error)
- func (q *Queries) ListGroupMessagesPaginated(ctx context.Context, arg ListGroupMessagesPaginatedParams) ([]CtxGroupMessage, error)
- func (q *Queries) ListGroupsByAgent(ctx context.Context, agentID string) ([]ChannelGroupMember, error)
- func (q *Queries) ListGroupsByReplyChannel(ctx context.Context, replyChannelID string) ([]ChannelGroupMember, error)
- func (q *Queries) ListGroupsByUser(ctx context.Context, arg ListGroupsByUserParams) ([]ListGroupsByUserRow, error)
- func (q *Queries) ListGroupsWithPendingIngest(ctx context.Context, pipeline string) ([]ListGroupsWithPendingIngestRow, error)
- func (q *Queries) ListInboxGoals(ctx context.Context, arg ListInboxGoalsParams) ([]ListInboxGoalsRow, error)
- func (q *Queries) ListManifestPluginOverrides(ctx context.Context) ([]PluginOverride, error)
- func (q *Queries) ListMemoryChangelog(ctx context.Context, arg ListMemoryChangelogParams) ([]CtxAgentMemoryChangelog, error)
- func (q *Queries) ListMessagesByIDs(ctx context.Context, arg ListMessagesByIDsParams) ([]CtxMessage, error)
- func (q *Queries) ListMessagesByLogicalPage(ctx context.Context, arg ListMessagesByLogicalPageParams) ([]ListMessagesByLogicalPageRow, error)
- func (q *Queries) ListMessagesNeedingEmbedding(ctx context.Context, arg ListMessagesNeedingEmbeddingParams) ([]ListMessagesNeedingEmbeddingRow, error)
- func (q *Queries) ListPendingEntries(ctx context.Context, arg ListPendingEntriesParams) ([]RecallyFeedEntry, error)
- func (q *Queries) ListPendingGroupDispatch(ctx context.Context, arg ListPendingGroupDispatchParams) ([]CtxGroupDispatch, error)
- func (q *Queries) ListPendingGroupDispatchByMessage(ctx context.Context, arg ListPendingGroupDispatchByMessageParams) ([]CtxGroupDispatch, error)
- func (q *Queries) ListPendingGroupOutbox(ctx context.Context, arg ListPendingGroupOutboxParams) ([]CtxGroupOutbox, error)
- func (q *Queries) ListPluginOverrides(ctx context.Context) ([]Plugin, error)
- func (q *Queries) ListPlugins(ctx context.Context) ([]Plugin, error)
- func (q *Queries) ListPluginsByKind(ctx context.Context, kind string) ([]Plugin, error)
- func (q *Queries) ListProjects(ctx context.Context, arg ListProjectsParams) ([]Project, error)
- func (q *Queries) ListProjectsAll(ctx context.Context, arg ListProjectsAllParams) ([]Project, error)
- func (q *Queries) ListProviders(ctx context.Context) ([]Provider, error)
- func (q *Queries) ListRecentGroupMessages(ctx context.Context, arg ListRecentGroupMessagesParams) ([]CtxGroupMessage, error)
- func (q *Queries) ListRecentGroupMessagesBeforeSeq(ctx context.Context, arg ListRecentGroupMessagesBeforeSeqParams) ([]CtxGroupMessage, error)
- func (q *Queries) ListRollupCandidates(ctx context.Context, limit int32) ([]AgentGoal, error)
- func (q *Queries) ListRootGoal(ctx context.Context, arg ListRootGoalParams) ([]AgentGoal, error)
- func (q *Queries) ListSchedJobRuns(ctx context.Context, arg ListSchedJobRunsParams) ([]SchedJobRun, error)
- func (q *Queries) ListSchedulerJobs(ctx context.Context) ([]SchedJob, error)
- func (q *Queries) ListSchedulerJobsByAgent(ctx context.Context, arg ListSchedulerJobsByAgentParams) ([]SchedJob, error)
- func (q *Queries) ListSettings(ctx context.Context) ([]AppSetting, error)
- func (q *Queries) ListSharesByUser(ctx context.Context, arg ListSharesByUserParams) ([]ListSharesByUserRow, error)
- func (q *Queries) ListSkillFiles(ctx context.Context, skillID string) ([]SkillFile, error)
- func (q *Queries) ListSkillsByScope(ctx context.Context, arg ListSkillsByScopeParams) ([]Skill, error)
- func (q *Queries) ListSkillsForAdmin(ctx context.Context, userID pgtype.Text) ([]Skill, error)
- func (q *Queries) ListSkillsForAgentContext(ctx context.Context, arg ListSkillsForAgentContextParams) ([]Skill, error)
- func (q *Queries) ListSkillsForUser(ctx context.Context, arg ListSkillsForUserParams) ([]Skill, error)
- func (q *Queries) ListSkillsVisible(ctx context.Context, arg ListSkillsVisibleParams) ([]Skill, error)
- func (q *Queries) ListStaleAttempts(ctx context.Context, arg ListStaleAttemptsParams) ([]AgentGoalAttempt, error)
- func (q *Queries) ListStalledComposites(ctx context.Context, limit int32) ([]AgentGoal, error)
- func (q *Queries) ListSummariesByIDs(ctx context.Context, arg ListSummariesByIDsParams) ([]CtxSummary, error)
- func (q *Queries) ListSummariesNeedingEmbedding(ctx context.Context, arg ListSummariesNeedingEmbeddingParams) ([]ListSummariesNeedingEmbeddingRow, error)
- func (q *Queries) ListSummaryParentsBySummaryIDs(ctx context.Context, summaryIds []string) ([]CtxSummaryParent, error)
- func (q *Queries) ListUnreadArticlesOlderThan(ctx context.Context, arg ListUnreadArticlesOlderThanParams) ([]RecallyArticle, error)
- func (q *Queries) ListUserAgentMemoriesByUser(ctx context.Context, userID string) ([]CtxAgentMemory, error)
- func (q *Queries) ListUserAgents(ctx context.Context, userID string) ([]string, error)
- func (q *Queries) ListVaultEntriesByScope(ctx context.Context, arg ListVaultEntriesByScopeParams) ([]VaultEntry, error)
- func (q *Queries) ListVaultEntriesByUser(ctx context.Context, userID pgtype.Text) ([]VaultEntry, error)
- func (q *Queries) ListVaultEntriesForRuntime(ctx context.Context, arg ListVaultEntriesForRuntimeParams) ([]VaultEntry, error)
- func (q *Queries) LockConversationForWrite(ctx context.Context, conversationID string) error
- func (q *Queries) LockGoalForWrite(ctx context.Context, goalID string) error
- func (q *Queries) LockSchedJobForRun(ctx context.Context, jobID string) error
- func (q *Queries) MarkGoalPlanned(ctx context.Context, id string) (int64, error)
- func (q *Queries) MarkGroupDispatchCompleted(ctx context.Context, arg MarkGroupDispatchCompletedParams) (int64, error)
- func (q *Queries) MarkGroupDispatchFailed(ctx context.Context, arg MarkGroupDispatchFailedParams) (int64, error)
- func (q *Queries) MarkGroupOutboxCompleted(ctx context.Context, arg MarkGroupOutboxCompletedParams) (int64, error)
- func (q *Queries) MarkGroupOutboxFailed(ctx context.Context, arg MarkGroupOutboxFailedParams) (int64, error)
- func (q *Queries) ProbeCheckCache(ctx context.Context, cacheKey string) (AgentGoalAcceptanceEvent, error)
- func (q *Queries) PromoteAttempt(ctx context.Context, arg PromoteAttemptParams) (int64, error)
- func (q *Queries) ReconcileGoalCounters(ctx context.Context, id string) error
- func (q *Queries) RecordSchedulerJobRun(ctx context.Context, arg RecordSchedulerJobRunParams) error
- func (q *Queries) RemoveGroupMember(ctx context.Context, arg RemoveGroupMemberParams) error
- func (q *Queries) RemoveUserAgent(ctx context.Context, arg RemoveUserAgentParams) error
- func (q *Queries) RequeueGroupDispatch(ctx context.Context, arg RequeueGroupDispatchParams) (int64, error)
- func (q *Queries) RequeueGroupOutbox(ctx context.Context, arg RequeueGroupOutboxParams) (int64, error)
- func (q *Queries) ResolveSkill(ctx context.Context, arg ResolveSkillParams) (Skill, error)
- func (q *Queries) RevokeAuthUserToken(ctx context.Context, id string) (int64, error)
- func (q *Queries) RotateAuthUserToken(ctx context.Context, id string) (int64, error)
- func (q *Queries) SearchArticleEmbeddings(ctx context.Context, arg SearchArticleEmbeddingsParams) ([]SearchArticleEmbeddingsRow, error)
- func (q *Queries) SearchArticles(ctx context.Context, arg SearchArticlesParams) ([]SearchArticlesRow, error)
- func (q *Queries) SearchMessageEmbeddings(ctx context.Context, arg SearchMessageEmbeddingsParams) ([]SearchMessageEmbeddingsRow, error)
- func (q *Queries) SearchMessages(ctx context.Context, arg SearchMessagesParams) ([]SearchMessagesRow, error)
- func (q *Queries) SearchSummaries(ctx context.Context, arg SearchSummariesParams) ([]SearchSummariesRow, error)
- func (q *Queries) SearchSummaryEmbeddings(ctx context.Context, arg SearchSummaryEmbeddingsParams) ([]SearchSummaryEmbeddingsRow, error)
- func (q *Queries) SeedProvider(ctx context.Context, arg SeedProviderParams) error
- func (q *Queries) SetAttemptExecutor(ctx context.Context, arg SetAttemptExecutorParams) error
- func (q *Queries) SetAttemptGaps(ctx context.Context, arg SetAttemptGapsParams) error
- func (q *Queries) SetGoalAcceptanceState(ctx context.Context, arg SetGoalAcceptanceStateParams) (int64, error)
- func (q *Queries) SetGoalPlan(ctx context.Context, arg SetGoalPlanParams) error
- func (q *Queries) SetGoalRequiredTotal(ctx context.Context, arg SetGoalRequiredTotalParams) error
- func (q *Queries) SetGroupDispatchResultMessage(ctx context.Context, arg SetGroupDispatchResultMessageParams) (int64, error)
- func (q *Queries) SubmitAttempt(ctx context.Context, arg SubmitAttemptParams) (int64, error)
- func (q *Queries) TransitionGoalLifecycle(ctx context.Context, arg TransitionGoalLifecycleParams) (int64, error)
- func (q *Queries) UnarchiveGoal(ctx context.Context, id string) error
- func (q *Queries) UpdateAgent(ctx context.Context, arg UpdateAgentParams) error
- func (q *Queries) UpdateArticle(ctx context.Context, arg UpdateArticleParams) (RecallyArticle, error)
- func (q *Queries) UpdateAuthPolicy(ctx context.Context, arg UpdateAuthPolicyParams) error
- func (q *Queries) UpdateAuthUserTokenLastUsed(ctx context.Context, id string) (int64, error)
- func (q *Queries) UpdateConversationArchived(ctx context.Context, arg UpdateConversationArchivedParams) error
- func (q *Queries) UpdateConversationBootstrapped(ctx context.Context, arg UpdateConversationBootstrappedParams) error
- func (q *Queries) UpdateConversationInfoBySessionID(ctx context.Context, arg UpdateConversationInfoBySessionIDParams) error
- func (q *Queries) UpdateConversationKindProject(ctx context.Context, arg UpdateConversationKindProjectParams) error
- func (q *Queries) UpdateConversationLastActive(ctx context.Context, arg UpdateConversationLastActiveParams) error
- func (q *Queries) UpdateConversationTitle(ctx context.Context, arg UpdateConversationTitleParams) error
- func (q *Queries) UpdateConversationTitleBySessionID(ctx context.Context, arg UpdateConversationTitleBySessionIDParams) error
- func (q *Queries) UpdateFeed(ctx context.Context, arg UpdateFeedParams) (RecallyFeed, error)
- func (q *Queries) UpdateFeedEntry(ctx context.Context, arg UpdateFeedEntryParams) (RecallyFeedEntry, error)
- func (q *Queries) UpdateGoalIntent(ctx context.Context, arg UpdateGoalIntentParams) error
- func (q *Queries) UpdateGroupName(ctx context.Context, arg UpdateGroupNameParams) (CtxGroupState, error)
- func (q *Queries) UpdateProject(ctx context.Context, arg UpdateProjectParams) (Project, error)
- func (q *Queries) UpdateProvider(ctx context.Context, arg UpdateProviderParams) error
- func (q *Queries) UpdateSchedJobRun(ctx context.Context, arg UpdateSchedJobRunParams) error
- func (q *Queries) UpdateSchedulerJob(ctx context.Context, arg UpdateSchedulerJobParams) error
- func (q *Queries) UpdateSkillMetadata(ctx context.Context, arg UpdateSkillMetadataParams) error
- func (q *Queries) UpdateSystemSkillMetadata(ctx context.Context, arg UpdateSystemSkillMetadataParams) error
- func (q *Queries) UpdateUserActive(ctx context.Context, arg UpdateUserActiveParams) error
- func (q *Queries) UpdateUserRole(ctx context.Context, arg UpdateUserRoleParams) error
- func (q *Queries) UpsertAgentConstraints(ctx context.Context, arg UpsertAgentConstraintsParams) (CtxAgentMemory, error)
- func (q *Queries) UpsertAgentSoul(ctx context.Context, arg UpsertAgentSoulParams) error
- func (q *Queries) UpsertAgentSoulVersioned(ctx context.Context, arg UpsertAgentSoulVersionedParams) (CtxAgentMemory, error)
- func (q *Queries) UpsertArticleEmbedding(ctx context.Context, arg UpsertArticleEmbeddingParams) error
- func (q *Queries) UpsertAuthOAuthProvider(ctx context.Context, arg UpsertAuthOAuthProviderParams) error
- func (q *Queries) UpsertChannel(ctx context.Context, arg UpsertChannelParams) error
- func (q *Queries) UpsertChatAgent(ctx context.Context, arg UpsertChatAgentParams) error
- func (q *Queries) UpsertDigest(ctx context.Context, arg UpsertDigestParams) (RecallyDigest, error)
- func (q *Queries) UpsertGroupMemoryVersioned(ctx context.Context, arg UpsertGroupMemoryVersionedParams) (CtxGroupMemory, error)
- func (q *Queries) UpsertIngestCursor(ctx context.Context, arg UpsertIngestCursorParams) error
- func (q *Queries) UpsertManifestPluginOverride(ctx context.Context, arg UpsertManifestPluginOverrideParams) error
- func (q *Queries) UpsertMessageEmbedding(ctx context.Context, arg UpsertMessageEmbeddingParams) error
- func (q *Queries) UpsertPlugin(ctx context.Context, arg UpsertPluginParams) error
- func (q *Queries) UpsertPluginStateEntry(ctx context.Context, arg UpsertPluginStateEntryParams) error
- func (q *Queries) UpsertProfileEntries(ctx context.Context, arg UpsertProfileEntriesParams) (CtxAgentMemory, error)
- func (q *Queries) UpsertSetting(ctx context.Context, arg UpsertSettingParams) error
- func (q *Queries) UpsertSkillFile(ctx context.Context, arg UpsertSkillFileParams) error
- func (q *Queries) UpsertSummaryEmbedding(ctx context.Context, arg UpsertSummaryEmbeddingParams) error
- func (q *Queries) UpsertUserAgentMemory(ctx context.Context, arg UpsertUserAgentMemoryParams) error
- func (q *Queries) UpsertUserAgentMemoryVersioned(ctx context.Context, arg UpsertUserAgentMemoryVersionedParams) (CtxAgentMemory, error)
- func (q *Queries) UpsertVaultEntry(ctx context.Context, arg UpsertVaultEntryParams) error
- func (q *Queries) UpsertVaultEntryByScope(ctx context.Context, arg UpsertVaultEntryByScopeParams) error
- func (q *Queries) WaiveEdge(ctx context.Context, arg WaiveEdgeParams) error
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
- type RecallyArticle
- type RecallyArticleEmbedding
- type RecallyDigest
- type RecallyDigestArticle
- type RecallyFeed
- type RecallyFeedEntry
- type RecordSchedulerJobRunParams
- type RemoveGroupMemberParams
- type RemoveUserAgentParams
- type RequeueGroupDispatchParams
- type RequeueGroupOutboxParams
- type ResolveSkillParams
- type SchedJob
- type SchedJobRun
- type SearchArticleEmbeddingsParams
- type SearchArticleEmbeddingsRow
- type SearchArticlesParams
- type SearchArticlesRow
- type SearchMessageEmbeddingsParams
- type SearchMessageEmbeddingsRow
- type SearchMessagesParams
- type SearchMessagesRow
- type SearchSummariesParams
- type SearchSummariesRow
- type SearchSummaryEmbeddingsParams
- type SearchSummaryEmbeddingsRow
- type SeedProviderParams
- type SetAttemptExecutorParams
- type SetAttemptGapsParams
- type SetGoalAcceptanceStateParams
- type SetGoalPlanParams
- type SetGoalRequiredTotalParams
- type SetGroupDispatchResultMessageParams
- type Share
- type Skill
- type SkillFile
- type SubmitAttemptParams
- type TransitionGoalLifecycleParams
- type UpdateAgentParams
- type UpdateArticleParams
- type UpdateAuthPolicyParams
- type UpdateConversationArchivedParams
- type UpdateConversationBootstrappedParams
- type UpdateConversationInfoBySessionIDParams
- type UpdateConversationKindProjectParams
- type UpdateConversationLastActiveParams
- type UpdateConversationTitleBySessionIDParams
- type UpdateConversationTitleParams
- type UpdateFeedEntryParams
- type UpdateFeedParams
- type UpdateGoalIntentParams
- type UpdateGroupNameParams
- type UpdateProjectParams
- type UpdateProviderParams
- type UpdateSchedJobRunParams
- type UpdateSchedulerJobParams
- type UpdateSkillMetadataParams
- type UpdateSystemSkillMetadataParams
- type UpdateUserActiveParams
- type UpdateUserRoleParams
- type UpsertAgentConstraintsParams
- type UpsertAgentSoulParams
- type UpsertAgentSoulVersionedParams
- type UpsertArticleEmbeddingParams
- type UpsertAuthOAuthProviderParams
- type UpsertChannelParams
- type UpsertChatAgentParams
- type UpsertDigestParams
- type UpsertGroupMemoryVersionedParams
- type UpsertIngestCursorParams
- type UpsertManifestPluginOverrideParams
- type UpsertMessageEmbeddingParams
- type UpsertPluginParams
- type UpsertPluginStateEntryParams
- type UpsertProfileEntriesParams
- type UpsertSettingParams
- type UpsertSkillFileParams
- type UpsertSummaryEmbeddingParams
- type UpsertUserAgentMemoryParams
- type UpsertUserAgentMemoryVersionedParams
- type UpsertVaultEntryByScopeParams
- type UpsertVaultEntryParams
- type VaultEntry
- type VaultUser
- type WaiveEdgeParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AcceptGoalParams ¶ added in v0.49.4
type AddDigestArticleParams ¶ added in v0.30.0
type AddGroupMemberParams ¶ added in v0.42.0
type Agent ¶ added in v0.38.0
type Agent struct {
ID string `json:"id"`
Name string `json:"name"`
Model string `json:"model"`
ModelThinking string `json:"model_thinking"`
ModelStrong string `json:"model_strong"`
ModelStrongThinking string `json:"model_strong_thinking"`
ModelFast string `json:"model_fast"`
ModelFastThinking string `json:"model_fast_thinking"`
SystemPrompt string `json:"system_prompt"`
Soul string `json:"soul"`
Workspace string `json:"workspace"`
Sandbox json.RawMessage `json:"sandbox"`
EnabledBuiltinSkills json.RawMessage `json:"enabled_builtin_skills"`
Scope string `json:"scope"`
CreatorID string `json:"creator_id"`
Enabled bool `json:"enabled"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
type AgentGoal ¶ added in v0.38.0
type AgentGoal struct {
ID string `json:"id"`
UserID string `json:"user_id"`
AgentID string `json:"agent_id"`
ProjectID pgtype.Text `json:"project_id"`
ParentID pgtype.Text `json:"parent_id"`
RootID string `json:"root_id"`
Depth int64 `json:"depth"`
Position int64 `json:"position"`
SessionID string `json:"session_id"`
Title string `json:"title"`
Intent string `json:"intent"`
Kind string `json:"kind"`
Priority string `json:"priority"`
Required bool `json:"required"`
AcceptanceContract json.RawMessage `json:"acceptance_contract"`
ConvergencePolicy json.RawMessage `json:"convergence_policy"`
ReviewPolicy string `json:"review_policy"`
Lifecycle string `json:"lifecycle"`
BlockReason string `json:"block_reason"`
AcceptanceState string `json:"acceptance_state"`
AcceptedOutput pgtype.Text `json:"accepted_output"`
AcceptanceSeq int64 `json:"acceptance_seq"`
ActiveAttemptID pgtype.Text `json:"active_attempt_id"`
AttemptCount int64 `json:"attempt_count"`
RequiredTotal int64 `json:"required_total"`
RequiredAccepted int64 `json:"required_accepted"`
RequiredFailed int64 `json:"required_failed"`
RequiredBlocked int64 `json:"required_blocked"`
Context json.RawMessage `json:"context"`
DispatchHint json.RawMessage `json:"dispatch_hint"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
AcceptedAt pgtype.Timestamptz `json:"accepted_at"`
CancelledAt pgtype.Timestamptz `json:"cancelled_at"`
ArchivedAt pgtype.Timestamptz `json:"archived_at"`
Plan json.RawMessage `json:"plan"`
PlannedAt pgtype.Timestamptz `json:"planned_at"`
}
type AgentGoalAcceptanceEvent ¶ added in v0.49.4
type AgentGoalAcceptanceEvent struct {
ID string `json:"id"`
GoalID string `json:"goal_id"`
AttemptID pgtype.Text `json:"attempt_id"`
Seq int64 `json:"seq"`
ItemID string `json:"item_id"`
ItemKind string `json:"item_kind"`
Result string `json:"result"`
Command string `json:"command"`
ExitCode pgtype.Int8 `json:"exit_code"`
CacheKey string `json:"cache_key"`
Authority string `json:"authority"`
ReviewerUserID pgtype.Text `json:"reviewer_user_id"`
ReviewerAttemptID pgtype.Text `json:"reviewer_attempt_id"`
Rationale string `json:"rationale"`
Scope string `json:"scope"`
ScopeHash string `json:"scope_hash"`
Detail json.RawMessage `json:"detail"`
CreatedAt time.Time `json:"created_at"`
}
type AgentGoalAttempt ¶ added in v0.49.4
type AgentGoalAttempt struct {
ID string `json:"id"`
GoalID string `json:"goal_id"`
UserID string `json:"user_id"`
AgentID pgtype.Text `json:"agent_id"`
ExecutorAgentID pgtype.Text `json:"executor_agent_id"`
SessionID string `json:"session_id"`
Purpose string `json:"purpose"`
AttemptNo int64 `json:"attempt_no"`
Status string `json:"status"`
InputContext json.RawMessage `json:"input_context"`
Evidence json.RawMessage `json:"evidence"`
Output json.RawMessage `json:"output"`
Gaps json.RawMessage `json:"gaps"`
Error string `json:"error"`
HeartbeatAt pgtype.Timestamptz `json:"heartbeat_at"`
LeaseExpiresAt pgtype.Timestamptz `json:"lease_expires_at"`
WorkerID string `json:"worker_id"`
StartedAt pgtype.Timestamptz `json:"started_at"`
FinishedAt pgtype.Timestamptz `json:"finished_at"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
type AgentGoalEdge ¶ added in v0.49.4
type AgentGoalEdge struct {
GoalID string `json:"goal_id"`
UpstreamID string `json:"upstream_id"`
EdgeKind string `json:"edge_kind"`
OnFailure string `json:"on_failure"`
WaivedAt pgtype.Timestamptz `json:"waived_at"`
WaivedByUser pgtype.Text `json:"waived_by_user"`
WaiverReason string `json:"waiver_reason"`
CreatedAt time.Time `json:"created_at"`
}
type AppSetting ¶ added in v0.38.0
type AppendAcceptanceEventParams ¶ added in v0.49.4
type AppendAcceptanceEventParams struct {
ID string `json:"id"`
GoalID string `json:"goal_id"`
AttemptID pgtype.Text `json:"attempt_id"`
Seq int64 `json:"seq"`
ItemID string `json:"item_id"`
ItemKind string `json:"item_kind"`
Result string `json:"result"`
Command string `json:"command"`
ExitCode pgtype.Int8 `json:"exit_code"`
CacheKey string `json:"cache_key"`
Authority string `json:"authority"`
ReviewerUserID pgtype.Text `json:"reviewer_user_id"`
ReviewerAttemptID pgtype.Text `json:"reviewer_attempt_id"`
Rationale string `json:"rationale"`
Scope string `json:"scope"`
ScopeHash string `json:"scope_hash"`
Detail json.RawMessage `json:"detail"`
}
type AppendContextItemParams ¶
type ArchiveProjectParams ¶ added in v0.34.0
type AssignUserAgentParams ¶
type AuthCredential ¶ added in v0.38.0
type AuthIdentity ¶
type AuthIdentity struct {
ID string `json:"id"`
UserID string `json:"user_id"`
Provider string `json:"provider"`
ProviderSubject string `json:"provider_subject"`
Email string `json:"email"`
Name string `json:"name"`
AvatarUrl string `json:"avatar_url"`
RawClaims json.RawMessage `json:"raw_claims"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
type AuthPolicy ¶
type AuthPolicy struct {
ID string `json:"id"`
Name string `json:"name"`
Effect string `json:"effect"`
Subjects string `json:"subjects"`
Actions string `json:"actions"`
Resources string `json:"resources"`
Conditions string `json:"conditions"`
Priority int64 `json:"priority"`
IsSystem bool `json:"is_system"`
Enabled bool `json:"enabled"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
type AuthSession ¶
type AuthUser ¶
type AuthUser struct {
ID string `json:"id"`
Email string `json:"email"`
Name string `json:"name"`
AvatarUrl string `json:"avatar_url"`
Role string `json:"role"`
IsActive bool `json:"is_active"`
DefaultAgentID pgtype.Text `json:"default_agent_id"`
NotifyIdentityID pgtype.Text `json:"notify_identity_id"`
AgePublicKey string `json:"age_public_key"`
AgePrivateKey string `json:"age_private_key"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
type AuthUserAgent ¶
type AuthUserToken ¶
type AuthUserToken struct {
ID string `json:"id"`
UserID string `json:"user_id"`
Name string `json:"name"`
TokenHash string `json:"token_hash"`
TokenPrefix string `json:"token_prefix"`
AutoGenerated bool `json:"auto_generated"`
LastUsedAt pgtype.Timestamptz `json:"last_used_at"`
ExpiresAt pgtype.Timestamptz `json:"expires_at"`
RotatedAt pgtype.Timestamptz `json:"rotated_at"`
RevokedAt pgtype.Timestamptz `json:"revoked_at"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
type BlockGoalParams ¶ added in v0.49.4
type ChannelAgent ¶ added in v0.38.0
type ChannelGroupMember ¶ added in v0.42.0
type ChannelIdentity ¶ added in v0.38.0
type ClaimExpiredGroupDispatchParams ¶ added in v0.43.0
type ClaimExpiredGroupDispatchParams struct {
LeaseUntil pgtype.Timestamptz `json:"lease_until"`
ID string `json:"id"`
Now pgtype.Timestamptz `json:"now"`
}
type ClaimExpiredGroupOutboxParams ¶ added in v0.43.0
type ClaimExpiredGroupOutboxParams struct {
LeaseUntil pgtype.Timestamptz `json:"lease_until"`
ID string `json:"id"`
Now pgtype.Timestamptz `json:"now"`
}
type ClaimGoalParams ¶ added in v0.49.4
type ClaimPendingGroupDispatchParams ¶ added in v0.43.0
type ClaimPendingGroupDispatchParams struct {
LeaseUntil pgtype.Timestamptz `json:"lease_until"`
ID string `json:"id"`
Now pgtype.Timestamptz `json:"now"`
}
type ClaimPendingGroupOutboxParams ¶ added in v0.43.0
type ClaimPendingGroupOutboxParams struct {
LeaseUntil pgtype.Timestamptz `json:"lease_until"`
ID string `json:"id"`
Now pgtype.Timestamptz `json:"now"`
}
type ConsumeDispatchHintParams ¶ added in v0.38.0
type ConsumeDispatchHintParams struct {
DispatchHint json.RawMessage `json:"dispatch_hint"`
ID string `json:"id"`
}
type CountRootGoalParams ¶ added in v0.49.4
type CreateAgentParams ¶
type CreateAgentParams struct {
ID string `json:"id"`
Name string `json:"name"`
Model string `json:"model"`
ModelThinking string `json:"model_thinking"`
ModelStrong string `json:"model_strong"`
ModelStrongThinking string `json:"model_strong_thinking"`
ModelFast string `json:"model_fast"`
ModelFastThinking string `json:"model_fast_thinking"`
SystemPrompt string `json:"system_prompt"`
Soul string `json:"soul"`
Workspace string `json:"workspace"`
Sandbox json.RawMessage `json:"sandbox"`
EnabledBuiltinSkills json.RawMessage `json:"enabled_builtin_skills"`
Scope string `json:"scope"`
CreatorID string `json:"creator_id"`
Enabled bool `json:"enabled"`
}
type CreateArticleParams ¶
type CreateArticleParams struct {
ID string `json:"id"`
UserID string `json:"user_id"`
AgentID pgtype.Text `json:"agent_id"`
Url string `json:"url"`
CanonicalUrl string `json:"canonical_url"`
SourceType string `json:"source_type"`
Title string `json:"title"`
Author string `json:"author"`
Summary string `json:"summary"`
Tags string `json:"tags"`
Status string `json:"status"`
Starred bool `json:"starred"`
FilePath string `json:"file_path"`
Metadata json.RawMessage `json:"metadata"`
PublishedAt pgtype.Timestamptz `json:"published_at"`
SavedAt time.Time `json:"saved_at"`
ReadAt pgtype.Timestamptz `json:"read_at"`
}
type CreateAttemptParams ¶ added in v0.49.4
type CreateAttemptParams struct {
ID string `json:"id"`
GoalID string `json:"goal_id"`
UserID string `json:"user_id"`
AgentID pgtype.Text `json:"agent_id"`
ExecutorAgentID pgtype.Text `json:"executor_agent_id"`
SessionID string `json:"session_id"`
Purpose string `json:"purpose"`
AttemptNo int64 `json:"attempt_no"`
Status string `json:"status"`
InputContext json.RawMessage `json:"input_context"`
LeaseExpiresAt pgtype.Timestamptz `json:"lease_expires_at"`
}
type CreateAuthPolicyParams ¶
type CreateAuthPolicyParams struct {
ID string `json:"id"`
Name string `json:"name"`
Effect string `json:"effect"`
Subjects string `json:"subjects"`
Actions string `json:"actions"`
Resources string `json:"resources"`
Conditions string `json:"conditions"`
Priority int64 `json:"priority"`
IsSystem bool `json:"is_system"`
Enabled bool `json:"enabled"`
}
type CreateConversationParams ¶
type CreateConversationParams struct {
ID string `json:"id"`
SessionID string `json:"session_id"`
Title pgtype.Text `json:"title"`
Channel string `json:"channel"`
Kind string `json:"kind"`
ProjectID pgtype.Text `json:"project_id"`
Archived bool `json:"archived"`
LastActive time.Time `json:"last_active"`
AgentID pgtype.Text `json:"agent_id"`
UserID pgtype.Text `json:"user_id"`
}
type CreateDigestParams ¶ added in v0.30.0
type CreateDigestParams struct {
ID string `json:"id"`
UserID string `json:"user_id"`
Date string `json:"date"`
Narrative string `json:"narrative"`
SavedYesterdayCount int64 `json:"saved_yesterday_count"`
UnreadCount int64 `json:"unread_count"`
ReadCount int64 `json:"read_count"`
ArchivedCount int64 `json:"archived_count"`
StarredCount int64 `json:"starred_count"`
WorthRevisitingCount int64 `json:"worth_revisiting_count"`
TotalArticles int64 `json:"total_articles"`
TopTags json.RawMessage `json:"top_tags"`
}
type CreateEdgeParams ¶ added in v0.49.4
type CreateFeedEntryParams ¶ added in v0.43.0
type CreateFeedEntryParams struct {
ID string `json:"id"`
FeedID string `json:"feed_id"`
Guid string `json:"guid"`
Url string `json:"url"`
Title string `json:"title"`
Status string `json:"status"`
ArticleID pgtype.Text `json:"article_id"`
Attempts int64 `json:"attempts"`
ErrorMsg string `json:"error_msg"`
DiscoveredAt time.Time `json:"discovered_at"`
ProcessedAt pgtype.Timestamptz `json:"processed_at"`
}
type CreateFeedParams ¶ added in v0.43.0
type CreateFeedParams struct {
ID string `json:"id"`
UserID string `json:"user_id"`
AgentID pgtype.Text `json:"agent_id"`
Url string `json:"url"`
Kind string `json:"kind"`
Metadata json.RawMessage `json:"metadata"`
Title string `json:"title"`
Description string `json:"description"`
CheckInterval string `json:"check_interval"`
LastCheckedAt pgtype.Timestamptz `json:"last_checked_at"`
LastEtag string `json:"last_etag"`
LastModified string `json:"last_modified"`
Enabled bool `json:"enabled"`
}
type CreateGoalParams ¶ added in v0.49.4
type CreateGoalParams struct {
ID string `json:"id"`
UserID string `json:"user_id"`
AgentID string `json:"agent_id"`
ProjectID pgtype.Text `json:"project_id"`
ParentID pgtype.Text `json:"parent_id"`
RootID string `json:"root_id"`
Depth int64 `json:"depth"`
Position int64 `json:"position"`
SessionID string `json:"session_id"`
Title string `json:"title"`
Intent string `json:"intent"`
Kind string `json:"kind"`
Priority string `json:"priority"`
Required bool `json:"required"`
AcceptanceContract json.RawMessage `json:"acceptance_contract"`
ConvergencePolicy json.RawMessage `json:"convergence_policy"`
ReviewPolicy string `json:"review_policy"`
Lifecycle string `json:"lifecycle"`
Context json.RawMessage `json:"context"`
DispatchHint json.RawMessage `json:"dispatch_hint"`
}
type CreateGroupDispatchParams ¶ added in v0.43.0
type CreateGroupDispatchParams struct {
ID string `json:"id"`
GroupMessageID string `json:"group_message_id"`
GroupID string `json:"group_id"`
AgentID string `json:"agent_id"`
ReplyChannelID string `json:"reply_channel_id"`
Status string `json:"status"`
AttemptCount int64 `json:"attempt_count"`
LeaseUntil pgtype.Timestamptz `json:"lease_until"`
NextAttemptAt pgtype.Timestamptz `json:"next_attempt_at"`
LastError string `json:"last_error"`
}
type CreateGroupMessageParams ¶ added in v0.42.0
type CreateGroupMessageParams struct {
ID string `json:"id"`
GroupID string `json:"group_id"`
Seq int64 `json:"seq"`
SourceChannelID pgtype.Text `json:"source_channel_id"`
ActorType string `json:"actor_type"`
ActorID string `json:"actor_id"`
PlatformMessageID pgtype.Text `json:"platform_message_id"`
ReplyTo pgtype.Text `json:"reply_to"`
PlatformTimestamp pgtype.Timestamptz `json:"platform_timestamp"`
IdempotencyKey pgtype.Text `json:"idempotency_key"`
Content string `json:"content"`
Reasoning string `json:"reasoning"`
AgentSessionID string `json:"agent_session_id"`
}
type CreateGroupOutboxParams ¶ added in v0.43.0
type CreateGroupOutboxParams struct {
ID string `json:"id"`
GroupMessageID string `json:"group_message_id"`
GroupID string `json:"group_id"`
Envelope string `json:"envelope"`
Status string `json:"status"`
AttemptCount int64 `json:"attempt_count"`
LeaseUntil pgtype.Timestamptz `json:"lease_until"`
NextAttemptAt pgtype.Timestamptz `json:"next_attempt_at"`
LastError string `json:"last_error"`
}
type CreateGroupStateParams ¶ added in v0.42.0
type CreateIngestErrorParams ¶ added in v0.42.0
type CreateMessageParams ¶
type CreateMessagePartParams ¶
type CreateMessagePartParams struct {
ID string `json:"id"`
MessageID string `json:"message_id"`
PartType string `json:"part_type"`
Ordinal int64 `json:"ordinal"`
TextContent pgtype.Text `json:"text_content"`
ToolCallID pgtype.Text `json:"tool_call_id"`
ToolName pgtype.Text `json:"tool_name"`
ToolInput pgtype.Text `json:"tool_input"`
ToolOutput pgtype.Text `json:"tool_output"`
Metadata pgtype.Text `json:"metadata"`
}
type CreateProjectParams ¶ added in v0.34.0
type CreateProviderParams ¶
type CreateSchedJobRunParams ¶
type CreateSchedJobRunParams struct {
ID string `json:"id"`
JobID string `json:"job_id"`
SessionID string `json:"session_id"`
Status string `json:"status"`
StartedAt time.Time `json:"started_at"`
FinishedAt pgtype.Timestamptz `json:"finished_at"`
Error string `json:"error"`
UserID pgtype.Text `json:"user_id"`
}
type CreateSchedulerJobParams ¶
type CreateSchedulerJobParams struct {
ID string `json:"id"`
OwnerKind string `json:"owner_kind"`
ExecScope string `json:"exec_scope"`
PluginID string `json:"plugin_id"`
JobKey string `json:"job_key"`
RuntimeName string `json:"runtime_name"`
Name string `json:"name"`
Description string `json:"description"`
ScheduleCron string `json:"schedule_cron"`
ScheduleEvery string `json:"schedule_every"`
ScheduleAt string `json:"schedule_at"`
Message string `json:"message"`
Payload json.RawMessage `json:"payload"`
SessionMode string `json:"session_mode"`
Enabled bool `json:"enabled"`
AgentID pgtype.Text `json:"agent_id"`
UserID pgtype.Text `json:"user_id"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
LastRunAt pgtype.Timestamptz `json:"last_run_at"`
LastError string `json:"last_error"`
}
type CreateShareParams ¶ added in v0.35.0
type CreateShareParams struct {
}
type CreateSkillParams ¶
type CreateSkillParams struct {
ID string `json:"id"`
Scope string `json:"scope"`
UserID pgtype.Text `json:"user_id"`
AgentID pgtype.Text `json:"agent_id"`
Name string `json:"name"`
Description string `json:"description"`
Status string `json:"status"`
DisableModelInvocation bool `json:"disable_model_invocation"`
Metadata json.RawMessage `json:"metadata"`
}
type CreateSummaryParams ¶
type CreateSummaryParams struct {
ID string `json:"id"`
ConversationID string `json:"conversation_id"`
Kind string `json:"kind"`
Depth int64 `json:"depth"`
Content string `json:"content"`
TokenCount int64 `json:"token_count"`
EarliestAt pgtype.Timestamptz `json:"earliest_at"`
LatestAt pgtype.Timestamptz `json:"latest_at"`
DescendantCount int64 `json:"descendant_count"`
DescendantTokenCount int64 `json:"descendant_token_count"`
SourceMessageTokenCount int64 `json:"source_message_token_count"`
}
type CreateWebChannelIfNotExistsParams ¶ added in v0.43.0
type CtxAgentMemory ¶
type CtxAgentMemory struct {
UserID string `json:"user_id"`
AgentID string `json:"agent_id"`
Content string `json:"content"`
Soul string `json:"soul"`
Version int64 `json:"version"`
Constraints json.RawMessage `json:"constraints"`
ProfileEntries json.RawMessage `json:"profile_entries"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
type CtxAgentMemoryChangelog ¶ added in v0.38.0
type CtxAgentMemoryChangelog struct {
ID string `json:"id"`
UserID string `json:"user_id"`
AgentID string `json:"agent_id"`
SessionID pgtype.Text `json:"session_id"`
EntityID pgtype.Text `json:"entity_id"`
Scope string `json:"scope"`
Action string `json:"action"`
Source string `json:"source"`
MemoryVersionBefore pgtype.Int8 `json:"memory_version_before"`
MemoryVersionAfter pgtype.Int8 `json:"memory_version_after"`
BeforeText pgtype.Text `json:"before_text"`
AfterText pgtype.Text `json:"after_text"`
Metadata pgtype.Text `json:"metadata"`
CreatedAt time.Time `json:"created_at"`
}
type CtxAgentMemorySnapshot ¶ added in v0.38.0
type CtxConversation ¶
type CtxConversation struct {
ID string `json:"id"`
SessionID string `json:"session_id"`
Title pgtype.Text `json:"title"`
Channel string `json:"channel"`
Kind string `json:"kind"`
ProjectID pgtype.Text `json:"project_id"`
Archived bool `json:"archived"`
LastActive time.Time `json:"last_active"`
BootstrappedAt pgtype.Timestamptz `json:"bootstrapped_at"`
AgentID pgtype.Text `json:"agent_id"`
UserID pgtype.Text `json:"user_id"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
type CtxGroupDispatch ¶ added in v0.43.0
type CtxGroupDispatch struct {
ID string `json:"id"`
GroupMessageID string `json:"group_message_id"`
GroupID string `json:"group_id"`
AgentID string `json:"agent_id"`
ReplyChannelID string `json:"reply_channel_id"`
Status string `json:"status"`
AttemptCount int64 `json:"attempt_count"`
LeaseUntil pgtype.Timestamptz `json:"lease_until"`
NextAttemptAt pgtype.Timestamptz `json:"next_attempt_at"`
LastError string `json:"last_error"`
ResultMessageID string `json:"result_message_id"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
type CtxGroupIngestCursor ¶ added in v0.42.0
type CtxGroupIngestError ¶ added in v0.42.0
type CtxGroupMemory ¶ added in v0.42.0
type CtxGroupMessage ¶ added in v0.42.0
type CtxGroupMessage struct {
ID string `json:"id"`
GroupID string `json:"group_id"`
Seq int64 `json:"seq"`
SourceChannelID pgtype.Text `json:"source_channel_id"`
ActorType string `json:"actor_type"`
ActorID string `json:"actor_id"`
PlatformMessageID pgtype.Text `json:"platform_message_id"`
ReplyTo pgtype.Text `json:"reply_to"`
PlatformTimestamp pgtype.Timestamptz `json:"platform_timestamp"`
IdempotencyKey pgtype.Text `json:"idempotency_key"`
Content string `json:"content"`
Reasoning string `json:"reasoning"`
AgentSessionID string `json:"agent_session_id"`
CreatedAt time.Time `json:"created_at"`
}
type CtxGroupOutbox ¶ added in v0.43.0
type CtxGroupOutbox struct {
ID string `json:"id"`
GroupMessageID string `json:"group_message_id"`
GroupID string `json:"group_id"`
Envelope string `json:"envelope"`
Status string `json:"status"`
AttemptCount int64 `json:"attempt_count"`
LeaseUntil pgtype.Timestamptz `json:"lease_until"`
NextAttemptAt pgtype.Timestamptz `json:"next_attempt_at"`
LastError string `json:"last_error"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
type CtxGroupState ¶ added in v0.42.0
type CtxGroupState struct {
ID string `json:"id"`
Platform string `json:"platform"`
PlatformGroupID string `json:"platform_group_id"`
PlatformThreadID string `json:"platform_thread_id"`
NextSeq int64 `json:"next_seq"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
GroupName string `json:"group_name"`
CreatedByUserID pgtype.Text `json:"created_by_user_id"`
}
type CtxItem ¶
type CtxItem struct {
ConversationID string `json:"conversation_id"`
Ordinal int64 `json:"ordinal"`
ItemType string `json:"item_type"`
MessageID pgtype.Text `json:"message_id"`
SummaryID pgtype.Text `json:"summary_id"`
EventType string `json:"event_type"`
Role string `json:"role"`
CreatedAt time.Time `json:"created_at"`
}
type CtxMessage ¶
type CtxMessageEmbedding ¶ added in v0.50.0
type CtxMessagePart ¶
type CtxMessagePart struct {
ID string `json:"id"`
MessageID string `json:"message_id"`
PartType string `json:"part_type"`
Ordinal int64 `json:"ordinal"`
TextContent pgtype.Text `json:"text_content"`
ToolCallID pgtype.Text `json:"tool_call_id"`
ToolName pgtype.Text `json:"tool_name"`
ToolInput pgtype.Text `json:"tool_input"`
ToolOutput pgtype.Text `json:"tool_output"`
Metadata pgtype.Text `json:"metadata"`
}
type CtxSummary ¶
type CtxSummary struct {
ID string `json:"id"`
ConversationID string `json:"conversation_id"`
Kind string `json:"kind"`
Depth int64 `json:"depth"`
Content string `json:"content"`
TokenCount int64 `json:"token_count"`
EarliestAt pgtype.Timestamptz `json:"earliest_at"`
LatestAt pgtype.Timestamptz `json:"latest_at"`
DescendantCount int64 `json:"descendant_count"`
DescendantTokenCount int64 `json:"descendant_token_count"`
SourceMessageTokenCount int64 `json:"source_message_token_count"`
CreatedAt time.Time `json:"created_at"`
}
type CtxSummaryEmbedding ¶ added in v0.50.0
type CtxSummaryMessage ¶
type CtxSummaryParent ¶
type DeleteArticleParams ¶ added in v0.35.3
type DeleteChatAgentParams ¶
type DeleteDigestArticlesParams ¶ added in v0.30.0
type DeleteEdgeParams ¶ added in v0.49.4
type DeleteFeedParams ¶ added in v0.43.0
type DeleteProjectParams ¶ added in v0.34.0
type DeleteShareByUserParams ¶ added in v0.35.0
type DeleteShareByUserParams struct {
}
type DeleteSkillFileParams ¶
type DeleteSkillParams ¶ added in v0.35.3
type DeleteVaultEntryByScopeParams ¶ added in v0.48.0
type DeleteVaultEntryParams ¶
type ExtendRunningGroupDispatchLeaseParams ¶ added in v0.43.0
type ExtendRunningGroupDispatchLeaseParams struct {
LeaseUntil pgtype.Timestamptz `json:"lease_until"`
ID string `json:"id"`
AttemptCount int64 `json:"attempt_count"`
}
type ExtendRunningGroupOutboxLeaseParams ¶ added in v0.43.0
type ExtendRunningGroupOutboxLeaseParams struct {
LeaseUntil pgtype.Timestamptz `json:"lease_until"`
ID string `json:"id"`
AttemptCount int64 `json:"attempt_count"`
}
type FinalizeAttemptParams ¶ added in v0.49.4
type GetActiveAttemptParams ¶ added in v0.49.4
type GetArticleParams ¶ added in v0.35.3
type GetChatAgentParams ¶
type GetContextMessageItemsRow ¶
type GetContextMessageItemsRow struct {
ConversationID string `json:"conversation_id"`
Ordinal int64 `json:"ordinal"`
ItemType string `json:"item_type"`
MessageID pgtype.Text `json:"message_id"`
SummaryID pgtype.Text `json:"summary_id"`
EventType string `json:"event_type"`
Role string `json:"role"`
CreatedAt time.Time `json:"created_at"`
MsgTokenCount int64 `json:"msg_token_count"`
}
type GetContextStatsRow ¶ added in v0.46.0
type GetConversationAgentBySessionIDParams ¶ added in v0.46.0
type GetConversationBySessionIDParams ¶ added in v0.35.3
type GetConversationParams ¶ added in v0.35.3
type GetConversationTimeBoundsRow ¶ added in v0.46.0
type GetConversationTimeBoundsRow struct {
EarliestAt interface{} `json:"earliest_at"`
LatestAt interface{} `json:"latest_at"`
}
type GetDigestByDateParams ¶ added in v0.30.0
type GetEdgeParams ¶ added in v0.49.4
type GetFeedByURLParams ¶ added in v0.43.0
type GetFeedEntryParams ¶ added in v0.43.0
type GetFeedParams ¶ added in v0.43.0
type GetGroupMemberParams ¶ added in v0.42.0
type GetGroupMessageByPlatformIDParams ¶ added in v0.42.0
type GetGroupStateByTripleParams ¶ added in v0.42.0
type GetIngestCursorParams ¶ added in v0.42.0
type GetMainConversationByProjectParams ¶ added in v0.35.3
type GetMaxAttemptNoParams ¶ added in v0.49.4
type GetMemorySnapshotParams ¶
type GetMessageParams ¶ added in v0.38.0
type GetMessageScopedParams ¶ added in v0.49.0
type GetMessageScopedRow ¶ added in v0.49.0
type GetMessageScopedRow struct {
ID string `json:"id"`
ConversationID string `json:"conversation_id"`
Seq int64 `json:"seq"`
Role string `json:"role"`
EventType string `json:"event_type"`
Content string `json:"content"`
TokenCount int64 `json:"token_count"`
CreatedAt time.Time `json:"created_at"`
SessionID string `json:"session_id"`
ConversationTitle pgtype.Text `json:"conversation_title"`
}
type GetMessagesSinceParams ¶
type GetProjectByNameParams ¶ added in v0.34.0
type GetProjectParams ¶ added in v0.34.0
type GetSchedJobRunParams ¶ added in v0.38.0
type GetSkillFileParams ¶
type GetSkillParams ¶ added in v0.35.3
type GetSummaryMessageSeqRangeRow ¶ added in v0.46.0
type GetSummaryParams ¶ added in v0.38.0
type GetSystemAgentSkillByNameParams ¶ added in v0.48.0
type GetVaultEntryByScopeParams ¶ added in v0.48.0
type GetVaultEntryParams ¶
type HeartbeatAttemptParams ¶ added in v0.49.4
type HeartbeatAttemptParams struct {
LeaseExpiresAt pgtype.Timestamptz `json:"lease_expires_at"`
ID string `json:"id"`
}
type InsertMemoryChangelogParams ¶
type InsertMemoryChangelogParams struct {
ID string `json:"id"`
UserID string `json:"user_id"`
AgentID string `json:"agent_id"`
SessionID pgtype.Text `json:"session_id"`
EntityID pgtype.Text `json:"entity_id"`
Scope string `json:"scope"`
Action string `json:"action"`
Source string `json:"source"`
MemoryVersionBefore pgtype.Int8 `json:"memory_version_before"`
MemoryVersionAfter pgtype.Int8 `json:"memory_version_after"`
BeforeText pgtype.Text `json:"before_text"`
AfterText pgtype.Text `json:"after_text"`
Metadata pgtype.Text `json:"metadata"`
}
type IsIngestErrorParams ¶ added in v0.42.0
type ListAgentConversationLastActiveRow ¶ added in v0.46.0
type ListArticlesNeedingEmbeddingParams ¶ added in v0.50.3
type ListArticlesNeedingEmbeddingRow ¶ added in v0.50.3
type ListArticlesParams ¶
type ListAttemptByGoalParams ¶ added in v0.49.4
type ListContextItemsPageParams ¶ added in v0.46.0
type ListContextItemsPageRow ¶ added in v0.46.0
type ListContextItemsPageRow struct {
Ordinal int64 `json:"ordinal"`
ItemType string `json:"item_type"`
EventType string `json:"event_type"`
Role string `json:"role"`
MessageID pgtype.Text `json:"message_id"`
MessageSeq pgtype.Int8 `json:"message_seq"`
MessageRole pgtype.Text `json:"message_role"`
MessageEventType pgtype.Text `json:"message_event_type"`
MessageContent pgtype.Text `json:"message_content"`
MessageTokenCount pgtype.Int8 `json:"message_token_count"`
MessageCreatedAt pgtype.Timestamptz `json:"message_created_at"`
SummaryID pgtype.Text `json:"summary_id"`
SummaryKind pgtype.Text `json:"summary_kind"`
SummaryDepth pgtype.Int8 `json:"summary_depth"`
SummaryContent pgtype.Text `json:"summary_content"`
SummaryTokenCount pgtype.Int8 `json:"summary_token_count"`
SummaryEarliestAt pgtype.Timestamptz `json:"summary_earliest_at"`
SummaryLatestAt pgtype.Timestamptz `json:"summary_latest_at"`
SummaryDescendantCount pgtype.Int8 `json:"summary_descendant_count"`
SummaryDescendantTokenCount pgtype.Int8 `json:"summary_descendant_token_count"`
SummarySourceMessageTokenCount pgtype.Int8 `json:"summary_source_message_token_count"`
SummaryCreatedAt pgtype.Timestamptz `json:"summary_created_at"`
}
type ListConversationsAllParams ¶ added in v0.35.3
type ListConversationsByKindParams ¶ added in v0.34.0
type ListConversationsFilteredParams ¶ added in v0.46.0
type ListConversationsFilteredParams struct {
UserID pgtype.Text `json:"user_id"`
AgentID pgtype.Text `json:"agent_id"`
IncludeArchived interface{} `json:"include_archived"`
Kind pgtype.Text `json:"kind"`
ProjectIDIsNull interface{} `json:"project_id_is_null"`
ProjectID pgtype.Text `json:"project_id"`
Offset int32 `json:"offset"`
Limit interface{} `json:"limit"`
}
type ListConversationsForReviewFilteredParams ¶ added in v0.46.0
type ListConversationsParams ¶ added in v0.35.3
type ListDigestArticlesParams ¶ added in v0.30.0
type ListDigestsParams ¶ added in v0.30.0
type ListEdgeWithUpstreamStateRow ¶ added in v0.49.4
type ListEdgeWithUpstreamStateRow struct {
GoalID string `json:"goal_id"`
UpstreamID string `json:"upstream_id"`
EdgeKind string `json:"edge_kind"`
OnFailure string `json:"on_failure"`
WaivedAt pgtype.Timestamptz `json:"waived_at"`
WaivedByUser pgtype.Text `json:"waived_by_user"`
WaiverReason string `json:"waiver_reason"`
CreatedAt time.Time `json:"created_at"`
UpstreamLifecycle string `json:"upstream_lifecycle"`
UpstreamOutput pgtype.Text `json:"upstream_output"`
}
type ListExistingUserMessageContentParams ¶ added in v0.47.0
type ListExpiredRunningGroupDispatchParams ¶ added in v0.43.0
type ListExpiredRunningGroupDispatchParams struct {
Now pgtype.Timestamptz `json:"now"`
LimitCount int32 `json:"limit_count"`
}
type ListExpiredRunningGroupOutboxParams ¶ added in v0.43.0
type ListExpiredRunningGroupOutboxParams struct {
Now pgtype.Timestamptz `json:"now"`
LimitCount int32 `json:"limit_count"`
}
type ListFailedInboxSchedulerRunsParams ¶ added in v0.46.0
type ListFailedInboxSchedulerRunsRow ¶ added in v0.46.0
type ListFeedEntriesParams ¶ added in v0.43.0
type ListFeedsParams ¶ added in v0.43.0
type ListGroupMessagesAfterSeqParams ¶ added in v0.42.0
type ListGroupMessagesBetweenSeqsParams ¶ added in v0.42.0
type ListGroupMessagesPaginatedParams ¶ added in v0.43.0
type ListGroupsByUserParams ¶ added in v0.43.0
type ListGroupsByUserRow ¶ added in v0.46.0
type ListGroupsByUserRow struct {
ID string `json:"id"`
Platform string `json:"platform"`
PlatformGroupID string `json:"platform_group_id"`
PlatformThreadID string `json:"platform_thread_id"`
NextSeq int64 `json:"next_seq"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
GroupName string `json:"group_name"`
CreatedByUserID pgtype.Text `json:"created_by_user_id"`
LastActive time.Time `json:"last_active"`
}
type ListGroupsWithPendingIngestRow ¶ added in v0.42.0
type ListInboxGoalsParams ¶ added in v0.49.4
type ListInboxGoalsRow ¶ added in v0.49.4
type ListInboxGoalsRow struct {
ID string `json:"id"`
AgentID string `json:"agent_id"`
ProjectID pgtype.Text `json:"project_id"`
Title string `json:"title"`
Intent string `json:"intent"`
Lifecycle string `json:"lifecycle"`
BlockReason string `json:"block_reason"`
UpdatedAt time.Time `json:"updated_at"`
CreatedAt time.Time `json:"created_at"`
}
type ListMessagesByIDsParams ¶ added in v0.41.0
type ListMessagesByLogicalPageParams ¶ added in v0.41.0
type ListMessagesByLogicalPageParams struct {
ConversationID string `json:"conversation_id"`
After pgtype.Timestamptz `json:"after"`
Before pgtype.Timestamptz `json:"before"`
Offset int32 `json:"offset"`
Limit int32 `json:"limit"`
}
type ListMessagesByLogicalPageRow ¶ added in v0.41.0
type ListMessagesByLogicalPageRow struct {
ID string `json:"id"`
ConversationID string `json:"conversation_id"`
Seq int64 `json:"seq"`
Role string `json:"role"`
EventType string `json:"event_type"`
Content string `json:"content"`
TokenCount int64 `json:"token_count"`
CreatedAt time.Time `json:"created_at"`
}
type ListMessagesNeedingEmbeddingParams ¶ added in v0.50.3
type ListMessagesNeedingEmbeddingRow ¶ added in v0.50.3
type ListPendingEntriesParams ¶ added in v0.43.0
type ListPendingGroupDispatchByMessageParams ¶ added in v0.43.0
type ListPendingGroupDispatchByMessageParams struct {
GroupMessageID string `json:"group_message_id"`
Now pgtype.Timestamptz `json:"now"`
}
type ListPendingGroupDispatchParams ¶ added in v0.43.0
type ListPendingGroupDispatchParams struct {
Now pgtype.Timestamptz `json:"now"`
LimitCount int32 `json:"limit_count"`
}
type ListPendingGroupOutboxParams ¶ added in v0.43.0
type ListPendingGroupOutboxParams struct {
Now pgtype.Timestamptz `json:"now"`
LimitCount int32 `json:"limit_count"`
}
type ListProjectsAllParams ¶ added in v0.34.0
type ListProjectsParams ¶ added in v0.34.0
type ListRecentGroupMessagesBeforeSeqParams ¶ added in v0.43.0
type ListRecentGroupMessagesParams ¶ added in v0.42.0
type ListRootGoalParams ¶ added in v0.49.4
type ListRootGoalParams struct {
UserID string `json:"user_id"`
AgentID pgtype.Text `json:"agent_id"`
ProjectID pgtype.Text `json:"project_id"`
Lifecycle pgtype.Text `json:"lifecycle"`
Terminal pgtype.Bool `json:"terminal"`
Q pgtype.Text `json:"q"`
IncludeArchived bool `json:"include_archived"`
Offset int32 `json:"offset"`
Limit int32 `json:"limit"`
}
type ListSchedJobRunsParams ¶
type ListSchedulerJobsByAgentParams ¶ added in v0.36.0
type ListSharesByUserParams ¶ added in v0.38.0
type ListSharesByUserParams struct {
}
type ListSharesByUserRow ¶ added in v0.35.0
type ListSharesByUserRow struct {
}
type ListSkillsByScopeParams ¶ added in v0.48.0
type ListSkillsForAgentContextParams ¶ added in v0.36.0
type ListSkillsForUserParams ¶ added in v0.36.0
type ListSkillsVisibleParams ¶
type ListStaleAttemptsParams ¶ added in v0.49.4
type ListStaleAttemptsParams struct {
Now pgtype.Timestamptz `json:"now"`
Limit int32 `json:"limit"`
}
type ListSummariesByIDsParams ¶ added in v0.41.0
type ListSummariesNeedingEmbeddingParams ¶ added in v0.50.3
type ListSummariesNeedingEmbeddingRow ¶ added in v0.50.3
type ListVaultEntriesByScopeParams ¶ added in v0.48.0
type ListVaultEntriesForRuntimeParams ¶ added in v0.48.0
type MarkGroupDispatchCompletedParams ¶ added in v0.43.0
type MarkGroupDispatchFailedParams ¶ added in v0.43.0
type MarkGroupOutboxCompletedParams ¶ added in v0.43.0
type MarkGroupOutboxFailedParams ¶ added in v0.43.0
type PluginOauthProvider ¶ added in v0.38.0
type PluginOauthProvider struct {
ID string `json:"id"`
ProviderID string `json:"provider_id"`
ClientID string `json:"client_id"`
ClientSecretEnc string `json:"client_secret_enc"`
RedirectUrl string `json:"redirect_url"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
type PluginOverride ¶ added in v0.38.0
type PluginState ¶ added in v0.38.0
type Project ¶ added in v0.34.0
type Project struct {
ID string `json:"id"`
AgentID string `json:"agent_id"`
UserID string `json:"user_id"`
Name string `json:"name"`
BaseDir string `json:"base_dir"`
Description pgtype.Text `json:"description"`
Archived bool `json:"archived"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
type PromoteAttemptParams ¶ added in v0.49.4
type PromoteAttemptParams struct {
LeaseExpiresAt pgtype.Timestamptz `json:"lease_expires_at"`
ID string `json:"id"`
}
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) AcceptGoal ¶ added in v0.49.4
func (*Queries) AddDigestArticle ¶ added in v0.30.0
func (q *Queries) AddDigestArticle(ctx context.Context, arg AddDigestArticleParams) error
func (*Queries) AddGroupMember ¶ added in v0.42.0
func (q *Queries) AddGroupMember(ctx context.Context, arg AddGroupMemberParams) (ChannelGroupMember, error)
func (*Queries) AdvanceMemorySnapshot ¶
func (q *Queries) AdvanceMemorySnapshot(ctx context.Context, arg AdvanceMemorySnapshotParams) error
func (*Queries) AppendAcceptanceEvent ¶ added in v0.49.4
func (q *Queries) AppendAcceptanceEvent(ctx context.Context, arg AppendAcceptanceEventParams) (AgentGoalAcceptanceEvent, error)
Append-only ledger row: a deterministic check result or a judgment verdict. Never updated/deleted in normal operation. The natural key (goal, attempt, item, cache_key) is unique, so a re-submitted verdict or a re-run check on identical inputs is a no-op (DO NOTHING): appending is idempotent and returns pgx.ErrNoRows on the duplicate, which the caller swallows.
func (*Queries) AppendContextItem ¶
func (q *Queries) AppendContextItem(ctx context.Context, arg AppendContextItemParams) error
func (*Queries) ArchiveGoal ¶ added in v0.49.4
func (*Queries) ArchiveProject ¶ added in v0.34.0
func (q *Queries) ArchiveProject(ctx context.Context, arg ArchiveProjectParams) error
func (*Queries) AssignUserAgent ¶
func (q *Queries) AssignUserAgent(ctx context.Context, arg AssignUserAgentParams) error
func (*Queries) BumpGroupSeq ¶ added in v0.42.0
func (*Queries) CancelGoal ¶ added in v0.49.4
func (*Queries) ClaimExpiredGroupDispatch ¶ added in v0.43.0
func (q *Queries) ClaimExpiredGroupDispatch(ctx context.Context, arg ClaimExpiredGroupDispatchParams) (CtxGroupDispatch, error)
func (*Queries) ClaimExpiredGroupOutbox ¶ added in v0.43.0
func (q *Queries) ClaimExpiredGroupOutbox(ctx context.Context, arg ClaimExpiredGroupOutboxParams) (CtxGroupOutbox, error)
func (*Queries) ClaimPendingGroupDispatch ¶ added in v0.43.0
func (q *Queries) ClaimPendingGroupDispatch(ctx context.Context, arg ClaimPendingGroupDispatchParams) (CtxGroupDispatch, error)
func (*Queries) ClaimPendingGroupOutbox ¶ added in v0.43.0
func (q *Queries) ClaimPendingGroupOutbox(ctx context.Context, arg ClaimPendingGroupOutboxParams) (CtxGroupOutbox, error)
func (*Queries) ClearGoalActiveAttempt ¶ added in v0.49.4
func (*Queries) ConsumeDispatchHint ¶ added in v0.38.0
func (q *Queries) ConsumeDispatchHint(ctx context.Context, arg ConsumeDispatchHintParams) error
func (*Queries) CountArticlesByStatus ¶
func (*Queries) CountDigests ¶ added in v0.30.0
func (*Queries) CountGroupDispatchByMessage ¶ added in v0.43.0
func (*Queries) CountGroupMembers ¶ added in v0.43.0
func (*Queries) CountInflightAttemptsByRoot ¶ added in v0.49.4
func (*Queries) CountInflightAttemptsByUser ¶ added in v0.49.4
func (*Queries) CountNonTerminalGroupDispatchByMessage ¶ added in v0.47.0
func (*Queries) CountRootGoal ¶ added in v0.49.4
CountRootGoal mirrors ListRootGoal's filter so a list's reported total is exact, and the active/history/archived header badges are three cheap counts that vary only their terminal/include_archived args.
func (*Queries) CountRunningSchedJobRuns ¶
func (*Queries) CountStarredArticles ¶
func (*Queries) CreateAgent ¶
func (*Queries) CreateArticle ¶
func (q *Queries) CreateArticle(ctx context.Context, arg CreateArticleParams) (RecallyArticle, error)
func (*Queries) CreateAttempt ¶ added in v0.49.4
func (q *Queries) CreateAttempt(ctx context.Context, arg CreateAttemptParams) (AgentGoalAttempt, error)
func (*Queries) CreateAuthPolicy ¶
func (q *Queries) CreateAuthPolicy(ctx context.Context, arg CreateAuthPolicyParams) (AuthPolicy, error)
func (*Queries) CreateAuthUserToken ¶
func (q *Queries) CreateAuthUserToken(ctx context.Context, arg CreateAuthUserTokenParams) (AuthUserToken, error)
func (*Queries) CreateConversation ¶
func (q *Queries) CreateConversation(ctx context.Context, arg CreateConversationParams) (CtxConversation, error)
func (*Queries) CreateDigest ¶ added in v0.30.0
func (q *Queries) CreateDigest(ctx context.Context, arg CreateDigestParams) (RecallyDigest, error)
func (*Queries) CreateEdge ¶ added in v0.49.4
func (q *Queries) CreateEdge(ctx context.Context, arg CreateEdgeParams) (AgentGoalEdge, error)
func (*Queries) CreateFeed ¶ added in v0.43.0
func (q *Queries) CreateFeed(ctx context.Context, arg CreateFeedParams) (RecallyFeed, error)
func (*Queries) CreateFeedEntry ¶ added in v0.43.0
func (q *Queries) CreateFeedEntry(ctx context.Context, arg CreateFeedEntryParams) (RecallyFeedEntry, error)
func (*Queries) CreateGoal ¶ added in v0.49.4
func (*Queries) CreateGroupDispatch ¶ added in v0.43.0
func (q *Queries) CreateGroupDispatch(ctx context.Context, arg CreateGroupDispatchParams) error
func (*Queries) CreateGroupMessage ¶ added in v0.42.0
func (q *Queries) CreateGroupMessage(ctx context.Context, arg CreateGroupMessageParams) (CtxGroupMessage, error)
func (*Queries) CreateGroupOutbox ¶ added in v0.43.0
func (q *Queries) CreateGroupOutbox(ctx context.Context, arg CreateGroupOutboxParams) (CtxGroupOutbox, error)
func (*Queries) CreateGroupState ¶ added in v0.42.0
func (q *Queries) CreateGroupState(ctx context.Context, arg CreateGroupStateParams) (CtxGroupState, error)
func (*Queries) CreateIngestError ¶ added in v0.42.0
func (q *Queries) CreateIngestError(ctx context.Context, arg CreateIngestErrorParams) error
func (*Queries) CreateMemorySnapshot ¶
func (q *Queries) CreateMemorySnapshot(ctx context.Context, arg CreateMemorySnapshotParams) (CtxAgentMemorySnapshot, error)
func (*Queries) CreateMessage ¶
func (q *Queries) CreateMessage(ctx context.Context, arg CreateMessageParams) (CtxMessage, error)
func (*Queries) CreateMessagePart ¶
func (q *Queries) CreateMessagePart(ctx context.Context, arg CreateMessagePartParams) error
func (*Queries) CreateProject ¶ added in v0.34.0
func (*Queries) CreateProvider ¶
func (*Queries) CreateSchedJobRun ¶
func (q *Queries) CreateSchedJobRun(ctx context.Context, arg CreateSchedJobRunParams) (SchedJobRun, error)
func (*Queries) CreateSchedulerJob ¶
func (*Queries) CreateShare ¶ added in v0.35.0
func (*Queries) CreateSkill ¶
func (*Queries) CreateSummary ¶
func (q *Queries) CreateSummary(ctx context.Context, arg CreateSummaryParams) error
func (*Queries) CreateWebChannelIfNotExists ¶ added in v0.43.0
func (q *Queries) CreateWebChannelIfNotExists(ctx context.Context, arg CreateWebChannelIfNotExistsParams) error
func (*Queries) DecrGoalRequiredBlocked ¶ added in v0.49.4
func (*Queries) DeleteAllContextItems ¶
func (*Queries) DeleteAllVaultEntriesByUser ¶
func (*Queries) DeleteArticle ¶
func (q *Queries) DeleteArticle(ctx context.Context, arg DeleteArticleParams) error
func (*Queries) DeleteAuthOAuthProvider ¶ added in v0.27.0
func (*Queries) DeleteAuthPolicy ¶
func (*Queries) DeleteChannel ¶
func (*Queries) DeleteChatAgent ¶
func (q *Queries) DeleteChatAgent(ctx context.Context, arg DeleteChatAgentParams) error
func (*Queries) DeleteContextItemsInRange ¶
func (q *Queries) DeleteContextItemsInRange(ctx context.Context, arg DeleteContextItemsInRangeParams) error
func (*Queries) DeleteDigestArticles ¶ added in v0.30.0
func (q *Queries) DeleteDigestArticles(ctx context.Context, arg DeleteDigestArticlesParams) error
func (*Queries) DeleteEdge ¶ added in v0.49.4
func (q *Queries) DeleteEdge(ctx context.Context, arg DeleteEdgeParams) error
func (*Queries) DeleteFeed ¶ added in v0.43.0
func (q *Queries) DeleteFeed(ctx context.Context, arg DeleteFeedParams) error
func (*Queries) DeleteGroupMemory ¶ added in v0.42.0
func (*Queries) DeleteGroupState ¶ added in v0.43.0
func (*Queries) DeleteManifestPluginOverride ¶ added in v0.38.0
func (*Queries) DeleteOldEntries ¶ added in v0.43.0
func (*Queries) DeletePluginStateEntry ¶
func (q *Queries) DeletePluginStateEntry(ctx context.Context, arg DeletePluginStateEntryParams) error
func (*Queries) DeleteProject ¶ added in v0.34.0
func (q *Queries) DeleteProject(ctx context.Context, arg DeleteProjectParams) error
func (*Queries) DeleteProvider ¶
func (*Queries) DeleteSchedulerJob ¶
func (*Queries) DeleteSetting ¶
func (*Queries) DeleteShareByUser ¶ added in v0.35.0
func (*Queries) DeleteSkill ¶
func (q *Queries) DeleteSkill(ctx context.Context, arg DeleteSkillParams) error
func (*Queries) DeleteSkillFile ¶
func (q *Queries) DeleteSkillFile(ctx context.Context, arg DeleteSkillFileParams) error
func (*Queries) DeleteSystemSkill ¶ added in v0.35.3
func (*Queries) DeleteUserAgentMemory ¶
func (q *Queries) DeleteUserAgentMemory(ctx context.Context, arg DeleteUserAgentMemoryParams) error
func (*Queries) DeleteVaultEntry ¶
func (q *Queries) DeleteVaultEntry(ctx context.Context, arg DeleteVaultEntryParams) error
func (*Queries) DeleteVaultEntryByScope ¶ added in v0.48.0
func (q *Queries) DeleteVaultEntryByScope(ctx context.Context, arg DeleteVaultEntryByScopeParams) error
func (*Queries) DeprecateExpiredDrafts ¶
func (*Queries) ExpireKnowledgeDraftsByType ¶
func (q *Queries) ExpireKnowledgeDraftsByType(ctx context.Context, arg ExpireKnowledgeDraftsByTypeParams) error
func (*Queries) ExtendRunningGroupDispatchLease ¶ added in v0.43.0
func (*Queries) ExtendRunningGroupOutboxLease ¶ added in v0.43.0
func (*Queries) FinalizeAttempt ¶ added in v0.49.4
func (*Queries) GetActiveAttempt ¶ added in v0.49.4
func (q *Queries) GetActiveAttempt(ctx context.Context, arg GetActiveAttemptParams) (AgentGoalAttempt, error)
func (*Queries) GetActiveAuthUserTokenByHash ¶
func (*Queries) GetActiveAutoAuthUserTokenByUser ¶
func (q *Queries) GetActiveAutoAuthUserTokenByUser(ctx context.Context, userID string) (AuthUserToken, error)
expires_at is intentionally not filtered here: TokenService rotates at autoTokenRotateAfter (60 days), which is always before autoTokenTTL (90 days), so an auto token is replaced before it can expire. The Go layer handles time-based rotation rather than relying on the DB expiry column.
func (*Queries) GetArticle ¶
func (q *Queries) GetArticle(ctx context.Context, arg GetArticleParams) (RecallyArticle, error)
func (*Queries) GetArticleByCanonicalURL ¶
func (q *Queries) GetArticleByCanonicalURL(ctx context.Context, arg GetArticleByCanonicalURLParams) (RecallyArticle, error)
func (*Queries) GetArticlesSavedThisWeek ¶
func (*Queries) GetAttempt ¶ added in v0.49.4
func (*Queries) GetAuthOAuthProvider ¶ added in v0.27.0
func (*Queries) GetAuthPolicy ¶
func (*Queries) GetAuthUserTokenByHash ¶
func (*Queries) GetChannel ¶
func (*Queries) GetChatAgent ¶
func (q *Queries) GetChatAgent(ctx context.Context, arg GetChatAgentParams) (ChannelAgent, error)
func (*Queries) GetContextItemCount ¶
func (*Queries) GetContextItems ¶
func (*Queries) GetContextMessageItems ¶
func (*Queries) GetContextStats ¶ added in v0.46.0
func (*Queries) GetContextTokenCount ¶
func (*Queries) GetConversation ¶
func (q *Queries) GetConversation(ctx context.Context, arg GetConversationParams) (CtxConversation, error)
func (*Queries) GetConversationAgentBySessionID ¶ added in v0.46.0
func (*Queries) GetConversationBySessionID ¶
func (q *Queries) GetConversationBySessionID(ctx context.Context, arg GetConversationBySessionIDParams) (CtxConversation, error)
func (*Queries) GetConversationTimeBounds ¶ added in v0.46.0
func (*Queries) GetDigestByDate ¶ added in v0.30.0
func (q *Queries) GetDigestByDate(ctx context.Context, arg GetDigestByDateParams) (RecallyDigest, error)
func (*Queries) GetEdge ¶ added in v0.49.4
func (q *Queries) GetEdge(ctx context.Context, arg GetEdgeParams) (AgentGoalEdge, error)
func (*Queries) GetFeed ¶ added in v0.43.0
func (q *Queries) GetFeed(ctx context.Context, arg GetFeedParams) (RecallyFeed, error)
func (*Queries) GetFeedByURL ¶ added in v0.43.0
func (q *Queries) GetFeedByURL(ctx context.Context, arg GetFeedByURLParams) (RecallyFeed, error)
func (*Queries) GetFeedEntry ¶ added in v0.43.0
func (q *Queries) GetFeedEntry(ctx context.Context, arg GetFeedEntryParams) (RecallyFeedEntry, error)
func (*Queries) GetFreshTailMessageIDs ¶
func (*Queries) GetGroupDispatch ¶ added in v0.43.0
func (*Queries) GetGroupLastActive ¶ added in v0.46.0
func (*Queries) GetGroupMember ¶ added in v0.42.0
func (q *Queries) GetGroupMember(ctx context.Context, arg GetGroupMemberParams) (ChannelGroupMember, error)
func (*Queries) GetGroupMemory ¶ added in v0.42.0
func (*Queries) GetGroupMessage ¶ added in v0.43.0
func (*Queries) GetGroupMessageByIdempotencyKey ¶ added in v0.42.0
func (*Queries) GetGroupMessageByPlatformID ¶ added in v0.42.0
func (q *Queries) GetGroupMessageByPlatformID(ctx context.Context, arg GetGroupMessageByPlatformIDParams) (CtxGroupMessage, error)
func (*Queries) GetGroupOutbox ¶ added in v0.43.0
func (*Queries) GetGroupOutboxByMessage ¶ added in v0.43.0
func (*Queries) GetGroupStateByID ¶ added in v0.43.0
func (*Queries) GetGroupStateByTriple ¶ added in v0.42.0
func (q *Queries) GetGroupStateByTriple(ctx context.Context, arg GetGroupStateByTripleParams) (CtxGroupState, error)
func (*Queries) GetIngestCursor ¶ added in v0.42.0
func (q *Queries) GetIngestCursor(ctx context.Context, arg GetIngestCursorParams) (CtxGroupIngestCursor, error)
func (*Queries) GetMainConversationByProject ¶ added in v0.34.0
func (q *Queries) GetMainConversationByProject(ctx context.Context, arg GetMainConversationByProjectParams) (CtxConversation, error)
func (*Queries) GetManifestPluginOverride ¶ added in v0.38.0
func (*Queries) GetMaxAcceptanceSeq ¶ added in v0.49.4
Highest seq for a goal; -1 when no rows so next seq = result+1 = 0.
func (*Queries) GetMaxAttemptNo ¶ added in v0.49.4
Highest attempt_no for a goal within one purpose; 0 when none exist. The next attempt_no is this + 1 (decomposition cannot derive it from attempt_count, which only tracks execution attempts).
func (*Queries) GetMaxContextOrdinal ¶
func (*Queries) GetMemoryChangelogAtVersion ¶
func (q *Queries) GetMemoryChangelogAtVersion(ctx context.Context, arg GetMemoryChangelogAtVersionParams) (CtxAgentMemoryChangelog, error)
func (*Queries) GetMemorySnapshot ¶
func (q *Queries) GetMemorySnapshot(ctx context.Context, arg GetMemorySnapshotParams) (CtxAgentMemorySnapshot, error)
func (*Queries) GetMessage ¶
func (q *Queries) GetMessage(ctx context.Context, arg GetMessageParams) (CtxMessage, error)
func (*Queries) GetMessageCount ¶
func (*Queries) GetMessageParts ¶
func (*Queries) GetMessagePartsByMessages ¶
func (*Queries) GetMessageScoped ¶ added in v0.49.0
func (q *Queries) GetMessageScoped(ctx context.Context, arg GetMessageScopedParams) (GetMessageScopedRow, error)
Fetch one message in full by ID, scoped to (user_id, agent_id) across every session: the read-in-full companion to cross-session SearchMessages. Joins ctx_conversation for the same isolation filter plus provenance. Keep this doc comment ASCII; multibyte chars corrupt sqlc's query rewriter offsets.
func (*Queries) GetMessagesByConversation ¶
func (*Queries) GetMessagesByConversationRange ¶
func (q *Queries) GetMessagesByConversationRange(ctx context.Context, arg GetMessagesByConversationRangeParams) ([]CtxMessage, error)
func (*Queries) GetMessagesSince ¶
func (q *Queries) GetMessagesSince(ctx context.Context, arg GetMessagesSinceParams) ([]CtxMessage, error)
func (*Queries) GetPluginStateEntry ¶
func (q *Queries) GetPluginStateEntry(ctx context.Context, arg GetPluginStateEntryParams) (json.RawMessage, error)
func (*Queries) GetProject ¶ added in v0.34.0
func (*Queries) GetProjectByName ¶ added in v0.34.0
func (*Queries) GetProvider ¶
func (*Queries) GetSchedJobRun ¶
func (q *Queries) GetSchedJobRun(ctx context.Context, arg GetSchedJobRunParams) (SchedJobRun, error)
func (*Queries) GetSchedulerJob ¶
func (*Queries) GetSetting ¶
func (*Queries) GetShareByTokenHash ¶ added in v0.35.0
func (*Queries) GetSkillByID ¶ added in v0.48.0
func (*Queries) GetSkillFile ¶
func (*Queries) GetSummariesByConversation ¶
func (*Queries) GetSummariesByDepth ¶
func (q *Queries) GetSummariesByDepth(ctx context.Context, arg GetSummariesByDepthParams) ([]CtxSummary, error)
func (*Queries) GetSummary ¶
func (q *Queries) GetSummary(ctx context.Context, arg GetSummaryParams) (CtxSummary, error)
func (*Queries) GetSummaryByID ¶ added in v0.38.0
func (*Queries) GetSummaryChildren ¶
func (*Queries) GetSummaryMessageSeqRange ¶ added in v0.46.0
func (*Queries) GetSummaryMessages ¶
func (*Queries) GetSummaryParents ¶
func (*Queries) GetSystemAgentSkillByName ¶ added in v0.48.0
func (*Queries) GetSystemSkillByName ¶
func (*Queries) GetUserAgentMemory ¶
func (q *Queries) GetUserAgentMemory(ctx context.Context, arg GetUserAgentMemoryParams) (CtxAgentMemory, error)
func (*Queries) GetUserSkillByName ¶
func (*Queries) GetVaultEntry ¶
func (q *Queries) GetVaultEntry(ctx context.Context, arg GetVaultEntryParams) (VaultEntry, error)
func (*Queries) GetVaultEntryByScope ¶ added in v0.48.0
func (q *Queries) GetVaultEntryByScope(ctx context.Context, arg GetVaultEntryByScopeParams) (VaultEntry, error)
func (*Queries) GetVaultUser ¶ added in v0.38.0
GetVaultUser returns the age key fields for a user. Satisfies vault.UserKeyReader.
func (*Queries) HeartbeatAttempt ¶ added in v0.49.4
func (*Queries) IncrGoalRequiredAccepted ¶ added in v0.49.4
func (*Queries) IncrGoalRequiredBlocked ¶ added in v0.49.4
func (*Queries) IncrGoalRequiredFailed ¶ added in v0.49.4
func (*Queries) InsertMemoryChangelog ¶
func (q *Queries) InsertMemoryChangelog(ctx context.Context, arg InsertMemoryChangelogParams) error
func (*Queries) IsIngestError ¶ added in v0.42.0
func (*Queries) LinkSummaryToMessage ¶
func (q *Queries) LinkSummaryToMessage(ctx context.Context, arg LinkSummaryToMessageParams) error
func (*Queries) LinkSummaryToParent ¶
func (q *Queries) LinkSummaryToParent(ctx context.Context, arg LinkSummaryToParentParams) error
func (*Queries) ListAcceptanceEventByAttempt ¶ added in v0.49.4
func (*Queries) ListAcceptanceEventByGoal ¶ added in v0.49.4
func (q *Queries) ListAcceptanceEventByGoal(ctx context.Context, goalID string) ([]AgentGoalAcceptanceEvent, error)
The projection fold: replay every event for a goal in seq order.
func (*Queries) ListAccessibleAgents ¶ added in v0.38.0
func (*Queries) ListActiveKnowledgeByType ¶
func (*Queries) ListAgentConversationLastActive ¶ added in v0.46.0
func (*Queries) ListAgentUsers ¶
func (*Queries) ListAllSchedulerJobs ¶ added in v0.38.0
func (*Queries) ListAllSkills ¶
func (*Queries) ListArticles ¶
func (q *Queries) ListArticles(ctx context.Context, arg ListArticlesParams) ([]RecallyArticle, error)
func (*Queries) ListArticlesNeedingEmbedding ¶ added in v0.50.3
func (q *Queries) ListArticlesNeedingEmbedding(ctx context.Context, arg ListArticlesNeedingEmbeddingParams) ([]ListArticlesNeedingEmbeddingRow, error)
Backfill candidates for articles. Unlike messages, articles are mutable, so a row whose embedding predates the article's last update (e.updated_at < a.updated_at) is a candidate too; the writer then compares content_hash to skip non-content edits (e.g. marking read). content is title + summary, the fields worth embedding. Keep ASCII.
func (*Queries) ListArticlesSavedYesterday ¶
func (*Queries) ListAttemptByGoal ¶ added in v0.49.4
func (q *Queries) ListAttemptByGoal(ctx context.Context, arg ListAttemptByGoalParams) ([]AgentGoalAttempt, error)
func (*Queries) ListAuthPolicies ¶
func (q *Queries) ListAuthPolicies(ctx context.Context) ([]AuthPolicy, error)
func (*Queries) ListAuthUsersByIDs ¶ added in v0.41.0
func (*Queries) ListBlockedDepComposites ¶ added in v0.50.0
Composites parked blocked(dep) by the rollup because a required child was blocked. The rollup scans (ListRollupCandidates/ListStalledComposites) only see active composites, so a parent driven here never re-enters rollup on its own. The dispatcher re-evaluates each: once its blocking children clear, it is woken back to active so the rollup resumes (see RecoverBlockedComposite).
func (*Queries) ListChannels ¶
func (*Queries) ListChannelsByType ¶
func (*Queries) ListChatAgents ¶
func (q *Queries) ListChatAgents(ctx context.Context) ([]ChannelAgent, error)
func (*Queries) ListContextItemsPage ¶ added in v0.46.0
func (q *Queries) ListContextItemsPage(ctx context.Context, arg ListContextItemsPageParams) ([]ListContextItemsPageRow, error)
func (*Queries) ListConversations ¶
func (q *Queries) ListConversations(ctx context.Context, arg ListConversationsParams) ([]CtxConversation, error)
func (*Queries) ListConversationsAll ¶
func (q *Queries) ListConversationsAll(ctx context.Context, arg ListConversationsAllParams) ([]CtxConversation, error)
func (*Queries) ListConversationsByKind ¶ added in v0.34.0
func (q *Queries) ListConversationsByKind(ctx context.Context, arg ListConversationsByKindParams) ([]CtxConversation, error)
func (*Queries) ListConversationsFiltered ¶ added in v0.46.0
func (q *Queries) ListConversationsFiltered(ctx context.Context, arg ListConversationsFilteredParams) ([]CtxConversation, error)
func (*Queries) ListConversationsForReviewByAgent ¶ added in v0.40.0
func (*Queries) ListConversationsForReviewFiltered ¶ added in v0.46.0
func (q *Queries) ListConversationsForReviewFiltered(ctx context.Context, arg ListConversationsForReviewFilteredParams) ([]CtxConversation, error)
func (*Queries) ListDecomposableComposites ¶ added in v0.50.0
Composites awaiting autonomous decomposition: freshly created (draft) and not planned yet. Both review policies are auto-driven: the planner always produces the plan; review_policy='human' only adds an approval gate after the plan is proposed (the goal parks blocked(needs_plan_approval)), it does not stop the planner from running. The dispatcher mints + enqueues a decomposition attempt for each, moving it draft->active so it is not re-picked.
func (*Queries) ListDigestArticles ¶ added in v0.30.0
func (q *Queries) ListDigestArticles(ctx context.Context, arg ListDigestArticlesParams) ([]RecallyArticle, error)
func (*Queries) ListDigests ¶ added in v0.30.0
func (q *Queries) ListDigests(ctx context.Context, arg ListDigestsParams) ([]RecallyDigest, error)
func (*Queries) ListDispatchableLeaves ¶ added in v0.49.4
func (*Queries) ListEdgeByGoal ¶ added in v0.49.4
func (*Queries) ListEdgeByUpstream ¶ added in v0.49.4
func (*Queries) ListEdgeWithUpstreamState ¶ added in v0.49.4
func (*Queries) ListEnabledAgents ¶
func (*Queries) ListEnabledAuthPolicies ¶
func (q *Queries) ListEnabledAuthPolicies(ctx context.Context) ([]AuthPolicy, error)
func (*Queries) ListEnabledPlugins ¶
func (*Queries) ListEnabledProviders ¶
func (*Queries) ListExistingUserMessageContent ¶ added in v0.47.0
func (*Queries) ListExpiredRunningGroupDispatch ¶ added in v0.43.0
func (q *Queries) ListExpiredRunningGroupDispatch(ctx context.Context, arg ListExpiredRunningGroupDispatchParams) ([]CtxGroupDispatch, error)
func (*Queries) ListExpiredRunningGroupOutbox ¶ added in v0.43.0
func (q *Queries) ListExpiredRunningGroupOutbox(ctx context.Context, arg ListExpiredRunningGroupOutboxParams) ([]CtxGroupOutbox, error)
func (*Queries) ListFailedInboxSchedulerRuns ¶ added in v0.46.0
func (q *Queries) ListFailedInboxSchedulerRuns(ctx context.Context, arg ListFailedInboxSchedulerRunsParams) ([]ListFailedInboxSchedulerRunsRow, error)
func (*Queries) ListFeedEntries ¶ added in v0.43.0
func (q *Queries) ListFeedEntries(ctx context.Context, arg ListFeedEntriesParams) ([]RecallyFeedEntry, error)
func (*Queries) ListFeeds ¶ added in v0.43.0
func (q *Queries) ListFeeds(ctx context.Context, arg ListFeedsParams) ([]RecallyFeed, error)
func (*Queries) ListGoalByRoot ¶ added in v0.49.4
func (*Queries) ListGoalChildren ¶ added in v0.49.4
func (*Queries) ListGoalSubtree ¶ added in v0.49.4
func (*Queries) ListGroupMembers ¶ added in v0.42.0
func (*Queries) ListGroupMessagesAfterSeq ¶ added in v0.42.0
func (q *Queries) ListGroupMessagesAfterSeq(ctx context.Context, arg ListGroupMessagesAfterSeqParams) ([]CtxGroupMessage, error)
func (*Queries) ListGroupMessagesBetweenSeqs ¶ added in v0.42.0
func (q *Queries) ListGroupMessagesBetweenSeqs(ctx context.Context, arg ListGroupMessagesBetweenSeqsParams) ([]CtxGroupMessage, error)
func (*Queries) ListGroupMessagesPaginated ¶ added in v0.43.0
func (q *Queries) ListGroupMessagesPaginated(ctx context.Context, arg ListGroupMessagesPaginatedParams) ([]CtxGroupMessage, error)
func (*Queries) ListGroupsByAgent ¶ added in v0.42.0
func (*Queries) ListGroupsByReplyChannel ¶ added in v0.42.0
func (*Queries) ListGroupsByUser ¶ added in v0.43.0
func (q *Queries) ListGroupsByUser(ctx context.Context, arg ListGroupsByUserParams) ([]ListGroupsByUserRow, error)
func (*Queries) ListGroupsWithPendingIngest ¶ added in v0.42.0
func (*Queries) ListInboxGoals ¶ added in v0.49.4
func (q *Queries) ListInboxGoals(ctx context.Context, arg ListInboxGoalsParams) ([]ListInboxGoalsRow, error)
Goals needing user attention, for the inbox. Open blocks surface at any age (they wait on the user); terminal failures are windowed like failed runs. The handler splits rows into inbox kinds by lifecycle/block_reason.
func (*Queries) ListManifestPluginOverrides ¶ added in v0.38.0
func (q *Queries) ListManifestPluginOverrides(ctx context.Context) ([]PluginOverride, error)
func (*Queries) ListMemoryChangelog ¶
func (q *Queries) ListMemoryChangelog(ctx context.Context, arg ListMemoryChangelogParams) ([]CtxAgentMemoryChangelog, error)
func (*Queries) ListMessagesByIDs ¶ added in v0.41.0
func (q *Queries) ListMessagesByIDs(ctx context.Context, arg ListMessagesByIDsParams) ([]CtxMessage, error)
func (*Queries) ListMessagesByLogicalPage ¶ added in v0.41.0
func (q *Queries) ListMessagesByLogicalPage(ctx context.Context, arg ListMessagesByLogicalPageParams) ([]ListMessagesByLogicalPageRow, error)
Keep this logical-message boundary in sync with serializeDBMessages in internal/server/sessions.go: consecutive assistant rows render as one response message, so SQL pagination must count them as one too.
func (*Queries) ListMessagesNeedingEmbedding ¶ added in v0.50.3
func (q *Queries) ListMessagesNeedingEmbedding(ctx context.Context, arg ListMessagesNeedingEmbeddingParams) ([]ListMessagesNeedingEmbeddingRow, error)
Backfill candidates: messages with no embedding, or one produced by a different model (a model switch invalidates the old vector space). Messages are immutable, so a row whose model already matches is never stale and is not returned. embedded_model/embedded_hash carry existing provenance so the writer can skip rows already current. Keep ASCII.
func (*Queries) ListPendingEntries ¶ added in v0.43.0
func (q *Queries) ListPendingEntries(ctx context.Context, arg ListPendingEntriesParams) ([]RecallyFeedEntry, error)
func (*Queries) ListPendingGroupDispatch ¶ added in v0.43.0
func (q *Queries) ListPendingGroupDispatch(ctx context.Context, arg ListPendingGroupDispatchParams) ([]CtxGroupDispatch, error)
func (*Queries) ListPendingGroupDispatchByMessage ¶ added in v0.43.0
func (q *Queries) ListPendingGroupDispatchByMessage(ctx context.Context, arg ListPendingGroupDispatchByMessageParams) ([]CtxGroupDispatch, error)
func (*Queries) ListPendingGroupOutbox ¶ added in v0.43.0
func (q *Queries) ListPendingGroupOutbox(ctx context.Context, arg ListPendingGroupOutboxParams) ([]CtxGroupOutbox, error)
func (*Queries) ListPluginOverrides ¶ added in v0.38.0
func (*Queries) ListPluginsByKind ¶
func (*Queries) ListProjects ¶ added in v0.34.0
func (*Queries) ListProjectsAll ¶ added in v0.34.0
func (*Queries) ListProviders ¶
func (*Queries) ListRecentGroupMessages ¶ added in v0.42.0
func (q *Queries) ListRecentGroupMessages(ctx context.Context, arg ListRecentGroupMessagesParams) ([]CtxGroupMessage, error)
func (*Queries) ListRecentGroupMessagesBeforeSeq ¶ added in v0.43.0
func (q *Queries) ListRecentGroupMessagesBeforeSeq(ctx context.Context, arg ListRecentGroupMessagesBeforeSeqParams) ([]CtxGroupMessage, error)
func (*Queries) ListRollupCandidates ¶ added in v0.49.4
func (*Queries) ListRootGoal ¶ added in v0.49.4
Root goals (goals: parent_id IS NULL) for a user, scoped to an agent and narrowed by lifecycle / terminal-ness / project / free-text. Every narg is optional: NULL matches all. terminal: false = active (non-terminal) only, true = history (terminal) only, NULL = both. The terminal set is the four end states.
func (*Queries) ListSchedJobRuns ¶
func (q *Queries) ListSchedJobRuns(ctx context.Context, arg ListSchedJobRunsParams) ([]SchedJobRun, error)
func (*Queries) ListSchedulerJobs ¶
func (*Queries) ListSchedulerJobsByAgent ¶ added in v0.36.0
func (*Queries) ListSettings ¶
func (q *Queries) ListSettings(ctx context.Context) ([]AppSetting, error)
func (*Queries) ListSharesByUser ¶ added in v0.35.0
func (q *Queries) ListSharesByUser(ctx context.Context, arg ListSharesByUserParams) ([]ListSharesByUserRow, error)
func (*Queries) ListSkillFiles ¶
func (*Queries) ListSkillsByScope ¶ added in v0.48.0
func (*Queries) ListSkillsForAdmin ¶ added in v0.36.0
func (*Queries) ListSkillsForAgentContext ¶ added in v0.36.0
func (q *Queries) ListSkillsForAgentContext(ctx context.Context, arg ListSkillsForAgentContextParams) ([]Skill, error)
ListSkillsForAgentContext returns the visible skills for one (user, agent), ordered most-specific-first so a name-dedup downstream keeps the effective skill: user_agent > user > system_agent > system.
func (*Queries) ListSkillsForUser ¶ added in v0.36.0
func (*Queries) ListSkillsVisible ¶
func (q *Queries) ListSkillsVisible(ctx context.Context, arg ListSkillsVisibleParams) ([]Skill, error)
ListSkillsVisible returns the effective skill set for a (user, agent) context, ordered most-specific-first so a name-dedup keeps the highest-precedence skill: user_agent > user > system_agent > system.
func (*Queries) ListStaleAttempts ¶ added in v0.49.4
func (q *Queries) ListStaleAttempts(ctx context.Context, arg ListStaleAttemptsParams) ([]AgentGoalAttempt, error)
Lease-expired attempts whose lease is a liveness signal. An attempt heartbeated by a River worker (every execution attempt, and an autonomous decomposition attempt) carries a forward-moving lease, so an expired lease means a genuine orphan. Interactive decomposition attempts (planned in a session, never enqueued/heartbeated) carry a NULL lease and are skipped by the IS NOT NULL guard, so the reaper never bounces an active composite back to draft mid-planning.
func (*Queries) ListStalledComposites ¶ added in v0.49.4
func (*Queries) ListSummariesByIDs ¶ added in v0.41.0
func (q *Queries) ListSummariesByIDs(ctx context.Context, arg ListSummariesByIDsParams) ([]CtxSummary, error)
func (*Queries) ListSummariesNeedingEmbedding ¶ added in v0.50.3
func (q *Queries) ListSummariesNeedingEmbedding(ctx context.Context, arg ListSummariesNeedingEmbeddingParams) ([]ListSummariesNeedingEmbeddingRow, error)
Backfill candidates for summaries; see ListMessagesNeedingEmbedding. Summary content is immutable, so missing or model-mismatch are the only cases. ASCII.
func (*Queries) ListSummaryParentsBySummaryIDs ¶ added in v0.46.0
func (*Queries) ListUnreadArticlesOlderThan ¶
func (q *Queries) ListUnreadArticlesOlderThan(ctx context.Context, arg ListUnreadArticlesOlderThanParams) ([]RecallyArticle, error)
func (*Queries) ListUserAgentMemoriesByUser ¶
func (*Queries) ListUserAgents ¶
func (*Queries) ListVaultEntriesByScope ¶ added in v0.48.0
func (q *Queries) ListVaultEntriesByScope(ctx context.Context, arg ListVaultEntriesByScopeParams) ([]VaultEntry, error)
func (*Queries) ListVaultEntriesByUser ¶
func (*Queries) ListVaultEntriesForRuntime ¶ added in v0.48.0
func (q *Queries) ListVaultEntriesForRuntime(ctx context.Context, arg ListVaultEntriesForRuntimeParams) ([]VaultEntry, error)
Keep this precedence in sync with internal/vault envPrecedence.
func (*Queries) LockConversationForWrite ¶ added in v0.50.0
Transaction-scoped advisory lock serializing per-conversation context writes: the message seq + context-item ordinal allocation in Append, and the compaction writeback that rewrites context items. Those are GetMax->++->insert under Read Committed, which PostgreSQL runs in parallel across writers (and nodes); the in-process striped mutex only serializes within one process. Held until the enclosing tx ends. The 'ctxconv:' prefix keeps unrelated entities out of this conversation's slot in the shared 64-bit lock space.
func (*Queries) LockGoalForWrite ¶ added in v0.50.0
Transaction-scoped advisory lock serializing read-modify-write sequence allocation for one goal. The acceptance ledger seq and attempt_no are each GetMax->+1->insert under Read Committed, which PostgreSQL runs in parallel across writers (and nodes): without this, two writers read the same max and compute the same next value, silently duplicating the acceptance seq (no unique backstop) or colliding on the attempt_no unique index. Held until the enclosing tx ends. The 'goal:' prefix keeps unrelated entities out of this goal's slot in the shared 64-bit lock space (matching AdvisoryXactLock / LockSchedJobForRun).
func (*Queries) LockSchedJobForRun ¶ added in v0.50.0
Transaction-scoped advisory lock keyed on a hash of the job ID. Held until the enclosing transaction ends, it serializes concurrent tryStartJobRun calls for the same job so the running-run check and insert below are atomic under Read Committed without a schema-level unique constraint. hashtextextended maps the text id straight to the 64-bit key pg_advisory_xact_lock expects (matching AdvisoryXactLock); a hash collision only serializes two unrelated jobs occasionally, which is harmless.
func (*Queries) MarkGoalPlanned ¶ added in v0.50.0
The materialize fence (CAS): stamp planned_at exactly once. A second concurrent materialize gets 0 rows and must treat it as an idempotent no-op, so children are never double-created. Replaces the old materialized revision unique index.
func (*Queries) MarkGroupDispatchCompleted ¶ added in v0.43.0
func (*Queries) MarkGroupDispatchFailed ¶ added in v0.43.0
func (*Queries) MarkGroupOutboxCompleted ¶ added in v0.43.0
func (*Queries) MarkGroupOutboxFailed ¶ added in v0.43.0
func (*Queries) ProbeCheckCache ¶ added in v0.49.4
func (q *Queries) ProbeCheckCache(ctx context.Context, cacheKey string) (AgentGoalAcceptanceEvent, error)
Check-result cache hit: the latest passing deterministic result for a cache_key. Returns pgx.ErrNoRows on a forced miss (no cached pass).
func (*Queries) PromoteAttempt ¶ added in v0.49.4
func (*Queries) ReconcileGoalCounters ¶ added in v0.49.4
func (*Queries) RecordSchedulerJobRun ¶
func (q *Queries) RecordSchedulerJobRun(ctx context.Context, arg RecordSchedulerJobRunParams) error
func (*Queries) RemoveGroupMember ¶ added in v0.42.0
func (q *Queries) RemoveGroupMember(ctx context.Context, arg RemoveGroupMemberParams) error
func (*Queries) RemoveUserAgent ¶
func (q *Queries) RemoveUserAgent(ctx context.Context, arg RemoveUserAgentParams) error
func (*Queries) RequeueGroupDispatch ¶ added in v0.43.0
func (*Queries) RequeueGroupOutbox ¶ added in v0.43.0
func (*Queries) ResolveSkill ¶
ResolveSkill returns the single effective skill for a name in a (user, agent) context. Precedence: user_agent > user > system_agent > system.
func (*Queries) RevokeAuthUserToken ¶
func (*Queries) RotateAuthUserToken ¶
func (*Queries) SearchArticleEmbeddings ¶ added in v0.50.3
func (q *Queries) SearchArticleEmbeddings(ctx context.Context, arg SearchArticleEmbeddingsParams) ([]SearchArticleEmbeddingsRow, error)
Vector KNN over article embeddings, scoped to user_id (articles carry user_id directly, no conversation join). WHERE model pins the vector space; ORDER BY the <=> operator drives the HNSW cosine index. score is cosine similarity (1 - distance), higher is better. saved_at, id break ties. Keep ASCII.
func (*Queries) SearchArticles ¶
func (q *Queries) SearchArticles(ctx context.Context, arg SearchArticlesParams) ([]SearchArticlesRow, error)
Multi-field BM25 search over title/summary/tags/author via pg_search. Each field is matched with paradedb.match, which tokenizes the raw user text with the jieba tokenizer (dictionary + statistical CJK word segmentation, CJK matches natively with no fallback tier) and never errors on punctuation. Per-field relevance is weighted natively with paradedb.boost (title 3x, tags 2x, summary/author 1x): boost scales each field's BM25 contribution to the row score, so a title hit outranks a tags hit outranks a body/author hit, with no CASE multiplier on the whole row. snippet highlights the title. match is raw user text. saved_at, id break score ties deterministically so identical queries return a stable order.
func (*Queries) SearchMessageEmbeddings ¶ added in v0.50.3
func (q *Queries) SearchMessageEmbeddings(ctx context.Context, arg SearchMessageEmbeddingsParams) ([]SearchMessageEmbeddingsRow, error)
Vector KNN over message embeddings, scoped to (user_id, agent_id) across every session like SearchMessages. WHERE model pins the query to a single vector space so a vector produced by a different model never matches; ORDER BY the <=> operator lets the HNSW cosine index drive the scan. score is cosine similarity (1 - distance), higher is better, matching the BM25 lane's score orientation for fusion. created_at, id break ties deterministically.
func (*Queries) SearchMessages ¶
func (q *Queries) SearchMessages(ctx context.Context, arg SearchMessagesParams) ([]SearchMessagesRow, error)
Spans every conversation of the current (user_id, agent_id) so memory recall survives across sessions. Joins ctx_conversation to pin the scope and surface provenance (session_id, title). Global ORDER BY score + LIMIT keeps the best matches across the merged corpus, not per-conversation truncations. Lexical ranking is pg_search BM25; paradedb.match tokenizes the raw user text with the jieba tokenizer (dictionary + statistical CJK word segmentation, so CJK matches natively with no fallback tier) and never errors on punctuation or query-syntax characters. The match arg is the raw user text. Multi-term queries are OR'd and ranked by BM25, which sinks weak partial matches below strong full matches. created_at, id break score ties deterministically: cross-source RRF uses each row's rank, so a stable order keeps the same query from reshuffling the merge.
func (*Queries) SearchSummaries ¶
func (q *Queries) SearchSummaries(ctx context.Context, arg SearchSummariesParams) ([]SearchSummariesRow, error)
Spans every conversation of the current (user_id, agent_id); see SearchMessages. Lexical ranking is pg_search BM25; paradedb.match tokenizes the raw user text with the jieba tokenizer (dictionary + statistical CJK word segmentation, CJK matches natively) and never errors on punctuation. The match arg is the raw user text. Stable score tie-break (see SearchMessages): content time, then id, so the per-source rank that cross-source RRF consumes is deterministic.
func (*Queries) SearchSummaryEmbeddings ¶ added in v0.50.3
func (q *Queries) SearchSummaryEmbeddings(ctx context.Context, arg SearchSummaryEmbeddingsParams) ([]SearchSummaryEmbeddingsRow, error)
Vector KNN over summary embeddings; mirror of SearchMessageEmbeddings (same space + scope guards, cosine similarity score). Tie-break by content time then id. Keep ASCII.
func (*Queries) SeedProvider ¶
func (q *Queries) SeedProvider(ctx context.Context, arg SeedProviderParams) error
func (*Queries) SetAttemptExecutor ¶ added in v0.49.4
func (q *Queries) SetAttemptExecutor(ctx context.Context, arg SetAttemptExecutorParams) error
func (*Queries) SetAttemptGaps ¶ added in v0.49.4
func (q *Queries) SetAttemptGaps(ctx context.Context, arg SetAttemptGapsParams) error
func (*Queries) SetGoalAcceptanceState ¶ added in v0.49.4
func (*Queries) SetGoalPlan ¶ added in v0.50.0
func (q *Queries) SetGoalPlan(ctx context.Context, arg SetGoalPlanParams) error
Write a composite's decomposition plan (children + edges). Set by a decomposition attempt before materialize; for review_policy='human' the plan sits here while the goal is blocked(needs_plan_approval) until a human acts.
func (*Queries) SetGoalRequiredTotal ¶ added in v0.49.4
func (q *Queries) SetGoalRequiredTotal(ctx context.Context, arg SetGoalRequiredTotalParams) error
func (*Queries) SetGroupDispatchResultMessage ¶ added in v0.47.0
func (*Queries) SubmitAttempt ¶ added in v0.49.4
func (*Queries) TransitionGoalLifecycle ¶ added in v0.49.4
func (*Queries) UnarchiveGoal ¶ added in v0.49.4
func (*Queries) UpdateAgent ¶
func (q *Queries) UpdateAgent(ctx context.Context, arg UpdateAgentParams) error
func (*Queries) UpdateArticle ¶
func (q *Queries) UpdateArticle(ctx context.Context, arg UpdateArticleParams) (RecallyArticle, error)
func (*Queries) UpdateAuthPolicy ¶
func (q *Queries) UpdateAuthPolicy(ctx context.Context, arg UpdateAuthPolicyParams) error
func (*Queries) UpdateAuthUserTokenLastUsed ¶
func (*Queries) UpdateConversationArchived ¶
func (q *Queries) UpdateConversationArchived(ctx context.Context, arg UpdateConversationArchivedParams) error
func (*Queries) UpdateConversationBootstrapped ¶
func (q *Queries) UpdateConversationBootstrapped(ctx context.Context, arg UpdateConversationBootstrappedParams) error
func (*Queries) UpdateConversationInfoBySessionID ¶ added in v0.46.0
func (q *Queries) UpdateConversationInfoBySessionID(ctx context.Context, arg UpdateConversationInfoBySessionIDParams) error
func (*Queries) UpdateConversationKindProject ¶ added in v0.34.0
func (q *Queries) UpdateConversationKindProject(ctx context.Context, arg UpdateConversationKindProjectParams) error
func (*Queries) UpdateConversationLastActive ¶
func (q *Queries) UpdateConversationLastActive(ctx context.Context, arg UpdateConversationLastActiveParams) error
func (*Queries) UpdateConversationTitle ¶
func (q *Queries) UpdateConversationTitle(ctx context.Context, arg UpdateConversationTitleParams) error
func (*Queries) UpdateConversationTitleBySessionID ¶
func (q *Queries) UpdateConversationTitleBySessionID(ctx context.Context, arg UpdateConversationTitleBySessionIDParams) error
func (*Queries) UpdateFeed ¶ added in v0.43.0
func (q *Queries) UpdateFeed(ctx context.Context, arg UpdateFeedParams) (RecallyFeed, error)
func (*Queries) UpdateFeedEntry ¶ added in v0.43.0
func (q *Queries) UpdateFeedEntry(ctx context.Context, arg UpdateFeedEntryParams) (RecallyFeedEntry, error)
func (*Queries) UpdateGoalIntent ¶ added in v0.49.4
func (q *Queries) UpdateGoalIntent(ctx context.Context, arg UpdateGoalIntentParams) error
func (*Queries) UpdateGroupName ¶ added in v0.43.0
func (q *Queries) UpdateGroupName(ctx context.Context, arg UpdateGroupNameParams) (CtxGroupState, error)
func (*Queries) UpdateProject ¶ added in v0.34.0
func (*Queries) UpdateProvider ¶
func (q *Queries) UpdateProvider(ctx context.Context, arg UpdateProviderParams) error
func (*Queries) UpdateSchedJobRun ¶
func (q *Queries) UpdateSchedJobRun(ctx context.Context, arg UpdateSchedJobRunParams) error
func (*Queries) UpdateSchedulerJob ¶
func (q *Queries) UpdateSchedulerJob(ctx context.Context, arg UpdateSchedulerJobParams) error
func (*Queries) UpdateSkillMetadata ¶
func (q *Queries) UpdateSkillMetadata(ctx context.Context, arg UpdateSkillMetadataParams) error
func (*Queries) UpdateSystemSkillMetadata ¶ added in v0.35.3
func (q *Queries) UpdateSystemSkillMetadata(ctx context.Context, arg UpdateSystemSkillMetadataParams) error
func (*Queries) UpdateUserActive ¶ added in v0.38.0
func (q *Queries) UpdateUserActive(ctx context.Context, arg UpdateUserActiveParams) error
func (*Queries) UpdateUserRole ¶ added in v0.38.0
func (q *Queries) UpdateUserRole(ctx context.Context, arg UpdateUserRoleParams) error
func (*Queries) UpsertAgentConstraints ¶
func (q *Queries) UpsertAgentConstraints(ctx context.Context, arg UpsertAgentConstraintsParams) (CtxAgentMemory, error)
func (*Queries) UpsertAgentSoul ¶
func (q *Queries) UpsertAgentSoul(ctx context.Context, arg UpsertAgentSoulParams) error
func (*Queries) UpsertAgentSoulVersioned ¶
func (q *Queries) UpsertAgentSoulVersioned(ctx context.Context, arg UpsertAgentSoulVersionedParams) (CtxAgentMemory, error)
func (*Queries) UpsertArticleEmbedding ¶ added in v0.50.3
func (q *Queries) UpsertArticleEmbedding(ctx context.Context, arg UpsertArticleEmbeddingParams) error
Semantic-search vector for one article; see UpsertMessageEmbedding. Keep ASCII.
func (*Queries) UpsertAuthOAuthProvider ¶ added in v0.27.0
func (q *Queries) UpsertAuthOAuthProvider(ctx context.Context, arg UpsertAuthOAuthProviderParams) error
func (*Queries) UpsertChannel ¶
func (q *Queries) UpsertChannel(ctx context.Context, arg UpsertChannelParams) error
func (*Queries) UpsertChatAgent ¶
func (q *Queries) UpsertChatAgent(ctx context.Context, arg UpsertChatAgentParams) error
func (*Queries) UpsertDigest ¶ added in v0.30.0
func (q *Queries) UpsertDigest(ctx context.Context, arg UpsertDigestParams) (RecallyDigest, error)
func (*Queries) UpsertGroupMemoryVersioned ¶ added in v0.42.0
func (q *Queries) UpsertGroupMemoryVersioned(ctx context.Context, arg UpsertGroupMemoryVersionedParams) (CtxGroupMemory, error)
func (*Queries) UpsertIngestCursor ¶ added in v0.42.0
func (q *Queries) UpsertIngestCursor(ctx context.Context, arg UpsertIngestCursorParams) error
func (*Queries) UpsertManifestPluginOverride ¶ added in v0.38.0
func (q *Queries) UpsertManifestPluginOverride(ctx context.Context, arg UpsertManifestPluginOverrideParams) error
func (*Queries) UpsertMessageEmbedding ¶ added in v0.50.3
func (q *Queries) UpsertMessageEmbedding(ctx context.Context, arg UpsertMessageEmbeddingParams) error
Write or replace the semantic-search vector for one message. model is the vector-space key every KNN query must filter on; content_hash is the hash of the embedded text so a later pass can spot rows whose source content changed. Keep this comment ASCII (sqlc rewriter offsets).
func (*Queries) UpsertPlugin ¶
func (q *Queries) UpsertPlugin(ctx context.Context, arg UpsertPluginParams) error
func (*Queries) UpsertPluginStateEntry ¶
func (q *Queries) UpsertPluginStateEntry(ctx context.Context, arg UpsertPluginStateEntryParams) error
func (*Queries) UpsertProfileEntries ¶ added in v0.42.0
func (q *Queries) UpsertProfileEntries(ctx context.Context, arg UpsertProfileEntriesParams) (CtxAgentMemory, error)
func (*Queries) UpsertSetting ¶
func (q *Queries) UpsertSetting(ctx context.Context, arg UpsertSettingParams) error
func (*Queries) UpsertSkillFile ¶
func (q *Queries) UpsertSkillFile(ctx context.Context, arg UpsertSkillFileParams) error
func (*Queries) UpsertSummaryEmbedding ¶ added in v0.50.3
func (q *Queries) UpsertSummaryEmbedding(ctx context.Context, arg UpsertSummaryEmbeddingParams) error
Semantic-search vector for one summary; see UpsertMessageEmbedding. Keep ASCII.
func (*Queries) UpsertUserAgentMemory ¶
func (q *Queries) UpsertUserAgentMemory(ctx context.Context, arg UpsertUserAgentMemoryParams) error
func (*Queries) UpsertUserAgentMemoryVersioned ¶
func (q *Queries) UpsertUserAgentMemoryVersioned(ctx context.Context, arg UpsertUserAgentMemoryVersionedParams) (CtxAgentMemory, error)
func (*Queries) UpsertVaultEntry ¶
func (q *Queries) UpsertVaultEntry(ctx context.Context, arg UpsertVaultEntryParams) error
func (*Queries) UpsertVaultEntryByScope ¶ added in v0.48.0
func (q *Queries) UpsertVaultEntryByScope(ctx context.Context, arg UpsertVaultEntryByScopeParams) error
type RecallyArticle ¶ added in v0.38.0
type RecallyArticle struct {
ID string `json:"id"`
UserID string `json:"user_id"`
AgentID pgtype.Text `json:"agent_id"`
Url string `json:"url"`
CanonicalUrl string `json:"canonical_url"`
SourceType string `json:"source_type"`
Title string `json:"title"`
Author string `json:"author"`
Summary string `json:"summary"`
Tags string `json:"tags"`
Status string `json:"status"`
Starred bool `json:"starred"`
FilePath string `json:"file_path"`
Metadata json.RawMessage `json:"metadata"`
PublishedAt pgtype.Timestamptz `json:"published_at"`
SavedAt time.Time `json:"saved_at"`
ReadAt pgtype.Timestamptz `json:"read_at"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
type RecallyArticleEmbedding ¶ added in v0.50.0
type RecallyDigest ¶ added in v0.30.0
type RecallyDigest struct {
ID string `json:"id"`
UserID string `json:"user_id"`
Date string `json:"date"`
Narrative string `json:"narrative"`
SavedYesterdayCount int64 `json:"saved_yesterday_count"`
UnreadCount int64 `json:"unread_count"`
ReadCount int64 `json:"read_count"`
ArchivedCount int64 `json:"archived_count"`
StarredCount int64 `json:"starred_count"`
WorthRevisitingCount int64 `json:"worth_revisiting_count"`
TotalArticles int64 `json:"total_articles"`
TopTags json.RawMessage `json:"top_tags"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
type RecallyDigestArticle ¶ added in v0.30.0
type RecallyFeed ¶ added in v0.43.0
type RecallyFeed struct {
ID string `json:"id"`
UserID string `json:"user_id"`
AgentID pgtype.Text `json:"agent_id"`
Url string `json:"url"`
Kind string `json:"kind"`
Metadata json.RawMessage `json:"metadata"`
Title string `json:"title"`
Description string `json:"description"`
CheckInterval string `json:"check_interval"`
LastCheckedAt pgtype.Timestamptz `json:"last_checked_at"`
LastEtag string `json:"last_etag"`
LastModified string `json:"last_modified"`
Enabled bool `json:"enabled"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
type RecallyFeedEntry ¶ added in v0.43.0
type RecallyFeedEntry struct {
ID string `json:"id"`
FeedID string `json:"feed_id"`
Guid string `json:"guid"`
Url string `json:"url"`
Title string `json:"title"`
Status string `json:"status"`
ArticleID pgtype.Text `json:"article_id"`
Attempts int64 `json:"attempts"`
ErrorMsg string `json:"error_msg"`
DiscoveredAt time.Time `json:"discovered_at"`
ProcessedAt pgtype.Timestamptz `json:"processed_at"`
}
type RemoveGroupMemberParams ¶ added in v0.42.0
type RemoveUserAgentParams ¶
type RequeueGroupDispatchParams ¶ added in v0.43.0
type RequeueGroupDispatchParams struct {
NextAttemptAt pgtype.Timestamptz `json:"next_attempt_at"`
LastError string `json:"last_error"`
ID string `json:"id"`
AttemptCount int64 `json:"attempt_count"`
}
type RequeueGroupOutboxParams ¶ added in v0.43.0
type RequeueGroupOutboxParams struct {
NextAttemptAt pgtype.Timestamptz `json:"next_attempt_at"`
LastError string `json:"last_error"`
ID string `json:"id"`
AttemptCount int64 `json:"attempt_count"`
}
type ResolveSkillParams ¶
type SchedJob ¶
type SchedJob struct {
ID string `json:"id"`
OwnerKind string `json:"owner_kind"`
ExecScope string `json:"exec_scope"`
PluginID string `json:"plugin_id"`
JobKey string `json:"job_key"`
RuntimeName string `json:"runtime_name"`
Name string `json:"name"`
Description string `json:"description"`
ScheduleCron string `json:"schedule_cron"`
ScheduleEvery string `json:"schedule_every"`
ScheduleAt string `json:"schedule_at"`
Message string `json:"message"`
Payload json.RawMessage `json:"payload"`
SessionMode string `json:"session_mode"`
Enabled bool `json:"enabled"`
AgentID pgtype.Text `json:"agent_id"`
UserID pgtype.Text `json:"user_id"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
LastRunAt pgtype.Timestamptz `json:"last_run_at"`
LastError string `json:"last_error"`
}
type SchedJobRun ¶
type SchedJobRun struct {
ID string `json:"id"`
JobID string `json:"job_id"`
SessionID string `json:"session_id"`
Status string `json:"status"`
StartedAt time.Time `json:"started_at"`
FinishedAt pgtype.Timestamptz `json:"finished_at"`
Error string `json:"error"`
Output string `json:"output"`
UserID pgtype.Text `json:"user_id"`
}
type SearchArticleEmbeddingsParams ¶ added in v0.50.3
type SearchArticleEmbeddingsParams struct {
Query pgvector_go.Vector `json:"query"`
Model string `json:"model"`
UserID string `json:"user_id"`
Limit int32 `json:"limit"`
}
type SearchArticleEmbeddingsRow ¶ added in v0.50.3
type SearchArticleEmbeddingsRow struct {
RecallyArticle RecallyArticle `json:"recally_article"`
Score float64 `json:"score"`
}
type SearchArticlesParams ¶
type SearchArticlesRow ¶ added in v0.46.0
type SearchArticlesRow struct {
RecallyArticle RecallyArticle `json:"recally_article"`
Snippet string `json:"snippet"`
Score float64 `json:"score"`
}
type SearchMessageEmbeddingsParams ¶ added in v0.50.3
type SearchMessageEmbeddingsRow ¶ added in v0.50.3
type SearchMessageEmbeddingsRow struct {
ID string `json:"id"`
ConversationID string `json:"conversation_id"`
Seq int64 `json:"seq"`
Role string `json:"role"`
EventType string `json:"event_type"`
Content string `json:"content"`
TokenCount int64 `json:"token_count"`
CreatedAt time.Time `json:"created_at"`
SessionID string `json:"session_id"`
ConversationTitle pgtype.Text `json:"conversation_title"`
Score float64 `json:"score"`
}
type SearchMessagesParams ¶
type SearchMessagesRow ¶ added in v0.46.0
type SearchMessagesRow struct {
ID string `json:"id"`
ConversationID string `json:"conversation_id"`
Seq int64 `json:"seq"`
Role string `json:"role"`
EventType string `json:"event_type"`
Content string `json:"content"`
TokenCount int64 `json:"token_count"`
CreatedAt time.Time `json:"created_at"`
SessionID string `json:"session_id"`
ConversationTitle pgtype.Text `json:"conversation_title"`
Snippet string `json:"snippet"`
Score float64 `json:"score"`
}
type SearchSummariesParams ¶
type SearchSummariesRow ¶ added in v0.46.0
type SearchSummariesRow struct {
ID string `json:"id"`
ConversationID string `json:"conversation_id"`
Kind string `json:"kind"`
Depth int64 `json:"depth"`
Content string `json:"content"`
TokenCount int64 `json:"token_count"`
EarliestAt pgtype.Timestamptz `json:"earliest_at"`
LatestAt pgtype.Timestamptz `json:"latest_at"`
DescendantCount int64 `json:"descendant_count"`
DescendantTokenCount int64 `json:"descendant_token_count"`
SourceMessageTokenCount int64 `json:"source_message_token_count"`
CreatedAt time.Time `json:"created_at"`
SessionID string `json:"session_id"`
ConversationTitle pgtype.Text `json:"conversation_title"`
Snippet string `json:"snippet"`
Score float64 `json:"score"`
}
type SearchSummaryEmbeddingsParams ¶ added in v0.50.3
type SearchSummaryEmbeddingsRow ¶ added in v0.50.3
type SearchSummaryEmbeddingsRow struct {
ID string `json:"id"`
ConversationID string `json:"conversation_id"`
Kind string `json:"kind"`
Depth int64 `json:"depth"`
Content string `json:"content"`
TokenCount int64 `json:"token_count"`
EarliestAt pgtype.Timestamptz `json:"earliest_at"`
LatestAt pgtype.Timestamptz `json:"latest_at"`
DescendantCount int64 `json:"descendant_count"`
DescendantTokenCount int64 `json:"descendant_token_count"`
SourceMessageTokenCount int64 `json:"source_message_token_count"`
CreatedAt time.Time `json:"created_at"`
SessionID string `json:"session_id"`
ConversationTitle pgtype.Text `json:"conversation_title"`
Score float64 `json:"score"`
}
type SeedProviderParams ¶
type SetAttemptExecutorParams ¶ added in v0.49.4
type SetAttemptGapsParams ¶ added in v0.49.4
type SetAttemptGapsParams struct {
Gaps json.RawMessage `json:"gaps"`
ID string `json:"id"`
}
type SetGoalAcceptanceStateParams ¶ added in v0.49.4
type SetGoalPlanParams ¶ added in v0.50.0
type SetGoalPlanParams struct {
Plan json.RawMessage `json:"plan"`
ID string `json:"id"`
}
type SetGoalRequiredTotalParams ¶ added in v0.49.4
type SetGroupDispatchResultMessageParams ¶ added in v0.47.0
type Skill ¶
type Skill struct {
ID string `json:"id"`
Scope string `json:"scope"`
UserID pgtype.Text `json:"user_id"`
AgentID pgtype.Text `json:"agent_id"`
Name string `json:"name"`
Description string `json:"description"`
Status string `json:"status"`
DisableModelInvocation bool `json:"disable_model_invocation"`
Metadata json.RawMessage `json:"metadata"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
type SubmitAttemptParams ¶ added in v0.49.4
type SubmitAttemptParams struct {
Evidence json.RawMessage `json:"evidence"`
Output json.RawMessage `json:"output"`
ID string `json:"id"`
}
type TransitionGoalLifecycleParams ¶ added in v0.49.4
type UpdateAgentParams ¶
type UpdateAgentParams struct {
Name string `json:"name"`
Model string `json:"model"`
ModelThinking string `json:"model_thinking"`
ModelStrong string `json:"model_strong"`
ModelStrongThinking string `json:"model_strong_thinking"`
ModelFast string `json:"model_fast"`
ModelFastThinking string `json:"model_fast_thinking"`
SystemPrompt string `json:"system_prompt"`
Soul string `json:"soul"`
Workspace string `json:"workspace"`
Sandbox json.RawMessage `json:"sandbox"`
EnabledBuiltinSkills json.RawMessage `json:"enabled_builtin_skills"`
Scope string `json:"scope"`
Enabled bool `json:"enabled"`
ID string `json:"id"`
}
type UpdateArticleParams ¶
type UpdateArticleParams struct {
Title string `json:"title"`
Author string `json:"author"`
Summary string `json:"summary"`
Tags string `json:"tags"`
Status string `json:"status"`
Starred bool `json:"starred"`
FilePath string `json:"file_path"`
Metadata json.RawMessage `json:"metadata"`
PublishedAt pgtype.Timestamptz `json:"published_at"`
ReadAt pgtype.Timestamptz `json:"read_at"`
ID string `json:"id"`
UserID string `json:"user_id"`
}
type UpdateAuthPolicyParams ¶
type UpdateAuthPolicyParams struct {
Name string `json:"name"`
Effect string `json:"effect"`
Subjects string `json:"subjects"`
Actions string `json:"actions"`
Resources string `json:"resources"`
Conditions string `json:"conditions"`
Priority int64 `json:"priority"`
Enabled bool `json:"enabled"`
ID string `json:"id"`
}
type UpdateConversationBootstrappedParams ¶ added in v0.35.3
type UpdateConversationInfoBySessionIDParams ¶ added in v0.46.0
type UpdateConversationInfoBySessionIDParams struct {
Title pgtype.Text `json:"title"`
Archived bool `json:"archived"`
Kind pgtype.Text `json:"kind"`
ProjectID pgtype.Text `json:"project_id"`
SessionID string `json:"session_id"`
UserID pgtype.Text `json:"user_id"`
AgentID pgtype.Text `json:"agent_id"`
}
type UpdateConversationKindProjectParams ¶ added in v0.34.0
type UpdateConversationLastActiveParams ¶ added in v0.35.3
type UpdateFeedEntryParams ¶ added in v0.43.0
type UpdateFeedParams ¶ added in v0.43.0
type UpdateFeedParams struct {
Title string `json:"title"`
Description string `json:"description"`
Metadata json.RawMessage `json:"metadata"`
CheckInterval string `json:"check_interval"`
LastCheckedAt pgtype.Timestamptz `json:"last_checked_at"`
LastEtag string `json:"last_etag"`
LastModified string `json:"last_modified"`
Enabled bool `json:"enabled"`
ID string `json:"id"`
UserID string `json:"user_id"`
}
type UpdateGoalIntentParams ¶ added in v0.49.4
type UpdateGoalIntentParams struct {
Title string `json:"title"`
Intent string `json:"intent"`
AcceptanceContract json.RawMessage `json:"acceptance_contract"`
ConvergencePolicy json.RawMessage `json:"convergence_policy"`
ReviewPolicy string `json:"review_policy"`
Priority string `json:"priority"`
ID string `json:"id"`
}
type UpdateGroupNameParams ¶ added in v0.43.0
type UpdateProjectParams ¶ added in v0.34.0
type UpdateProviderParams ¶
type UpdateSchedJobRunParams ¶
type UpdateSchedulerJobParams ¶
type UpdateSchedulerJobParams struct {
OwnerKind string `json:"owner_kind"`
ExecScope string `json:"exec_scope"`
PluginID string `json:"plugin_id"`
JobKey string `json:"job_key"`
RuntimeName string `json:"runtime_name"`
Name string `json:"name"`
Description string `json:"description"`
ScheduleCron string `json:"schedule_cron"`
ScheduleEvery string `json:"schedule_every"`
ScheduleAt string `json:"schedule_at"`
Message string `json:"message"`
Payload json.RawMessage `json:"payload"`
SessionMode string `json:"session_mode"`
Enabled bool `json:"enabled"`
AgentID pgtype.Text `json:"agent_id"`
UserID pgtype.Text `json:"user_id"`
UpdatedAt time.Time `json:"updated_at"`
LastRunAt pgtype.Timestamptz `json:"last_run_at"`
LastError string `json:"last_error"`
ID string `json:"id"`
}
type UpdateSkillMetadataParams ¶
type UpdateSkillMetadataParams struct {
Description string `json:"description"`
Status string `json:"status"`
DisableModelInvocation bool `json:"disable_model_invocation"`
Metadata json.RawMessage `json:"metadata"`
ID string `json:"id"`
AgentID pgtype.Text `json:"agent_id"`
UserID pgtype.Text `json:"user_id"`
}
type UpdateSystemSkillMetadataParams ¶ added in v0.35.3
type UpdateUserActiveParams ¶ added in v0.38.0
type UpdateUserRoleParams ¶ added in v0.38.0
type UpsertAgentConstraintsParams ¶
type UpsertAgentConstraintsParams struct {
UserID string `json:"user_id"`
AgentID string `json:"agent_id"`
Constraints json.RawMessage `json:"constraints"`
}
type UpsertAgentSoulParams ¶
type UpsertArticleEmbeddingParams ¶ added in v0.50.3
type UpsertArticleEmbeddingParams struct {
ArticleID string `json:"article_id"`
Model string `json:"model"`
ContentHash []byte `json:"content_hash"`
Embedding pgvector_go.Vector `json:"embedding"`
}
type UpsertAuthOAuthProviderParams ¶ added in v0.27.0
type UpsertChannelParams ¶
type UpsertChatAgentParams ¶
type UpsertDigestParams ¶ added in v0.30.0
type UpsertDigestParams struct {
ID string `json:"id"`
UserID string `json:"user_id"`
Date string `json:"date"`
Narrative string `json:"narrative"`
SavedYesterdayCount int64 `json:"saved_yesterday_count"`
UnreadCount int64 `json:"unread_count"`
ReadCount int64 `json:"read_count"`
ArchivedCount int64 `json:"archived_count"`
StarredCount int64 `json:"starred_count"`
WorthRevisitingCount int64 `json:"worth_revisiting_count"`
TotalArticles int64 `json:"total_articles"`
TopTags json.RawMessage `json:"top_tags"`
}
type UpsertGroupMemoryVersionedParams ¶ added in v0.42.0
type UpsertIngestCursorParams ¶ added in v0.42.0
type UpsertManifestPluginOverrideParams ¶ added in v0.38.0
type UpsertMessageEmbeddingParams ¶ added in v0.50.3
type UpsertMessageEmbeddingParams struct {
MessageID string `json:"message_id"`
Model string `json:"model"`
ContentHash []byte `json:"content_hash"`
Embedding pgvector_go.Vector `json:"embedding"`
}
type UpsertPluginParams ¶
type UpsertProfileEntriesParams ¶ added in v0.42.0
type UpsertProfileEntriesParams struct {
UserID string `json:"user_id"`
AgentID string `json:"agent_id"`
ProfileEntries json.RawMessage `json:"profile_entries"`
}
type UpsertSettingParams ¶
type UpsertSkillFileParams ¶
type UpsertSummaryEmbeddingParams ¶ added in v0.50.3
type UpsertSummaryEmbeddingParams struct {
SummaryID string `json:"summary_id"`
Model string `json:"model"`
ContentHash []byte `json:"content_hash"`
Embedding pgvector_go.Vector `json:"embedding"`
}
type UpsertVaultEntryByScopeParams ¶ added in v0.48.0
type UpsertVaultEntryParams ¶
type VaultEntry ¶
Source Files
¶
- agent.sql.go
- agent_goal.sql.go
- agent_goal_acceptance_event.sql.go
- agent_goal_attempt.sql.go
- agent_goal_edge.sql.go
- app_setting.sql.go
- auth_policy.sql.go
- auth_user.sql.go
- auth_user_agent.sql.go
- auth_user_token.sql.go
- channel.sql.go
- channel_agent.sql.go
- channel_group_member.sql.go
- ctx_agent_memory.sql.go
- ctx_agent_memory_changelog.sql.go
- ctx_agent_memory_snapshot.sql.go
- ctx_conversation.sql.go
- ctx_group.sql.go
- ctx_group_dispatch.sql.go
- ctx_group_ingest.sql.go
- ctx_group_memory.sql.go
- ctx_group_outbox.sql.go
- ctx_item.sql.go
- ctx_message.sql.go
- ctx_summary.sql.go
- db.go
- models.go
- plugin.sql.go
- plugin_oauth_provider.sql.go
- plugin_override.sql.go
- plugin_state.sql.go
- project.sql.go
- provider.sql.go
- recally_article.sql.go
- recally_digest.sql.go
- recally_feed.sql.go
- sched_job.sql.go
- sched_job_run.sql.go
- share.sql.go
- skill.sql.go
- vault_bridge.go
- vault_entry.sql.go