Documentation
¶
Index ¶
- type AcceptGoalParams
- type AddDigestArticleParams
- type AddGroupMemberParams
- type AdvanceMemorySnapshotParams
- type Agent
- type AgentGoal
- type AgentGoalAcceptanceEvent
- type AgentGoalAttempt
- type AgentGoalEdge
- type AgentGoalRevision
- 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 CreateRevisionParams
- 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 CtxMessageFt
- type CtxMessagePart
- type CtxSummary
- type CtxSummaryFt
- 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 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 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 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) AcceptRevision(ctx context.Context, id string) (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) CreateRevision(ctx context.Context, arg CreateRevisionParams) (AgentGoalRevision, 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 sql.NullString) 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, metadata 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) (sql.NullString, 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) ([]sql.NullString, 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) (string, 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 sql.NullString) (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) GetMaterializedRevision(ctx context.Context, goalID string) (AgentGoalRevision, 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) GetMaxRevisionNo(ctx context.Context, goalID 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) GetOpenRevision(ctx context.Context, goalID string) (AgentGoalRevision, error)
- func (q *Queries) GetPlugin(ctx context.Context, id string) (Plugin, error)
- func (q *Queries) GetPluginStateEntry(ctx context.Context, arg GetPluginStateEntryParams) (string, 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) GetRevision(ctx context.Context, id string) (AgentGoalRevision, 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 sql.NullString) ([]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 sql.NullString) ([]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) 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) 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 sql.NullString) ([]CtxConversation, error)
- func (q *Queries) ListConversationsForReviewFiltered(ctx context.Context, arg ListConversationsForReviewFilteredParams) ([]CtxConversation, 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 int64) ([]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 sql.NullString) ([]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) 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) ListRevisionByGoal(ctx context.Context, goalID string) ([]AgentGoalRevision, error)
- func (q *Queries) ListRollupCandidates(ctx context.Context, limit int64) ([]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 sql.NullString) ([]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 int64) ([]AgentGoal, error)
- func (q *Queries) ListSummariesByIDs(ctx context.Context, arg ListSummariesByIDsParams) ([]CtxSummary, 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 sql.NullString) ([]VaultEntry, error)
- func (q *Queries) ListVaultEntriesForRuntime(ctx context.Context, arg ListVaultEntriesForRuntimeParams) ([]VaultEntry, 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) MaterializeRevision(ctx context.Context, id string) (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) SearchArticles(ctx context.Context, arg SearchArticlesParams) ([]SearchArticlesRow, error)
- func (q *Queries) SearchArticlesLike(ctx context.Context, arg SearchArticlesLikeParams) ([]RecallyArticle, error)
- func (q *Queries) SearchMessages(ctx context.Context, arg SearchMessagesParams) ([]SearchMessagesRow, error)
- func (q *Queries) SearchMessagesLike(ctx context.Context, arg SearchMessagesLikeParams) ([]SearchMessagesLikeRow, error)
- func (q *Queries) SearchSummaries(ctx context.Context, arg SearchSummariesParams) ([]SearchSummariesRow, error)
- func (q *Queries) SearchSummariesLike(ctx context.Context, arg SearchSummariesLikeParams) ([]SearchSummariesLikeRow, 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) SetGoalAcceptedRevision(ctx context.Context, arg SetGoalAcceptedRevisionParams) 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) SetRevisionPlanningSession(ctx context.Context, arg SetRevisionPlanningSessionParams) (int64, error)
- func (q *Queries) SubmitAttempt(ctx context.Context, arg SubmitAttemptParams) (int64, error)
- func (q *Queries) SupersedeOpenRevisions(ctx context.Context, goalID string) 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) UpdateRevisionContent(ctx context.Context, arg UpdateRevisionContentParams) error
- func (q *Queries) UpdateRevisionStatus(ctx context.Context, arg UpdateRevisionStatusParams) (int64, 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) 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) 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) 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 *sql.Tx) *Queries
- type RecallyArticle
- type RecallyArticleFt
- 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 SearchArticlesLikeParams
- type SearchArticlesParams
- type SearchArticlesRow
- type SearchMessagesLikeParams
- type SearchMessagesLikeRow
- type SearchMessagesParams
- type SearchMessagesRow
- type SearchSummariesLikeParams
- type SearchSummariesLikeRow
- type SearchSummariesParams
- type SearchSummariesRow
- type SeedProviderParams
- type SetAttemptExecutorParams
- type SetAttemptGapsParams
- type SetGoalAcceptanceStateParams
- type SetGoalAcceptedRevisionParams
- type SetGoalRequiredTotalParams
- type SetGroupDispatchResultMessageParams
- type SetRevisionPlanningSessionParams
- 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 UpdateRevisionContentParams
- type UpdateRevisionStatusParams
- type UpdateSchedJobRunParams
- type UpdateSchedulerJobParams
- type UpdateSkillMetadataParams
- type UpdateSystemSkillMetadataParams
- type UpdateUserActiveParams
- type UpdateUserRoleParams
- type UpsertAgentConstraintsParams
- type UpsertAgentSoulParams
- type UpsertAgentSoulVersionedParams
- type UpsertAuthOAuthProviderParams
- type UpsertChannelParams
- type UpsertChatAgentParams
- type UpsertDigestParams
- type UpsertGroupMemoryVersionedParams
- type UpsertIngestCursorParams
- type UpsertManifestPluginOverrideParams
- type UpsertPluginParams
- type UpsertPluginStateEntryParams
- type UpsertProfileEntriesParams
- type UpsertSettingParams
- type UpsertSkillFileParams
- 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 AcceptGoalParams struct {
AcceptedOutput sql.NullString `json:"accepted_output"`
ID string `json:"id"`
}
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 string `json:"sandbox"`
EnabledBuiltinSkills string `json:"enabled_builtin_skills"`
Scope string `json:"scope"`
CreatorID string `json:"creator_id"`
Enabled int64 `json:"enabled"`
CreatedAt string `json:"created_at"`
UpdatedAt string `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 sql.NullString `json:"project_id"`
ParentID sql.NullString `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 int64 `json:"required"`
AcceptanceContract string `json:"acceptance_contract"`
ConvergencePolicy string `json:"convergence_policy"`
ReviewPolicy string `json:"review_policy"`
Lifecycle string `json:"lifecycle"`
BlockReason string `json:"block_reason"`
AcceptanceState string `json:"acceptance_state"`
AcceptedOutput sql.NullString `json:"accepted_output"`
AcceptanceSeq int64 `json:"acceptance_seq"`
ActiveAttemptID sql.NullString `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"`
AcceptedRevisionID sql.NullString `json:"accepted_revision_id"`
Context string `json:"context"`
DispatchHint string `json:"dispatch_hint"`
CreatedAt string `json:"created_at"`
UpdatedAt string `json:"updated_at"`
AcceptedAt sql.NullString `json:"accepted_at"`
CancelledAt sql.NullString `json:"cancelled_at"`
ArchivedAt sql.NullString `json:"archived_at"`
}
type AgentGoalAcceptanceEvent ¶ added in v0.49.4
type AgentGoalAcceptanceEvent struct {
ID string `json:"id"`
GoalID string `json:"goal_id"`
AttemptID sql.NullString `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 sql.NullInt64 `json:"exit_code"`
CacheKey string `json:"cache_key"`
Authority string `json:"authority"`
ReviewerUserID sql.NullString `json:"reviewer_user_id"`
ReviewerAttemptID sql.NullString `json:"reviewer_attempt_id"`
Rationale string `json:"rationale"`
Scope string `json:"scope"`
ScopeHash string `json:"scope_hash"`
Detail string `json:"detail"`
CreatedAt string `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 sql.NullString `json:"agent_id"`
ExecutorAgentID sql.NullString `json:"executor_agent_id"`
SessionID string `json:"session_id"`
Purpose string `json:"purpose"`
AttemptNo int64 `json:"attempt_no"`
Status string `json:"status"`
InputContext string `json:"input_context"`
Evidence string `json:"evidence"`
Output string `json:"output"`
RevisionID sql.NullString `json:"revision_id"`
Gaps string `json:"gaps"`
Error string `json:"error"`
HeartbeatAt sql.NullString `json:"heartbeat_at"`
LeaseExpiresAt sql.NullString `json:"lease_expires_at"`
WorkerID string `json:"worker_id"`
StartedAt sql.NullString `json:"started_at"`
FinishedAt sql.NullString `json:"finished_at"`
CreatedAt string `json:"created_at"`
UpdatedAt string `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 sql.NullString `json:"waived_at"`
WaivedByUser sql.NullString `json:"waived_by_user"`
WaiverReason string `json:"waiver_reason"`
CreatedAt string `json:"created_at"`
}
type AgentGoalRevision ¶ added in v0.49.4
type AgentGoalRevision struct {
ID string `json:"id"`
GoalID string `json:"goal_id"`
RevisionNo int64 `json:"revision_no"`
Status string `json:"status"`
ReviewPolicy string `json:"review_policy"`
Content string `json:"content"`
SourceAttemptID sql.NullString `json:"source_attempt_id"`
PlanningSessionID sql.NullString `json:"planning_session_id"`
AcceptedAt sql.NullString `json:"accepted_at"`
MaterializedAt sql.NullString `json:"materialized_at"`
CreatedAt string `json:"created_at"`
UpdatedAt string `json:"updated_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 sql.NullString `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 sql.NullInt64 `json:"exit_code"`
CacheKey string `json:"cache_key"`
Authority string `json:"authority"`
ReviewerUserID sql.NullString `json:"reviewer_user_id"`
ReviewerAttemptID sql.NullString `json:"reviewer_attempt_id"`
Rationale string `json:"rationale"`
Scope string `json:"scope"`
ScopeHash string `json:"scope_hash"`
Detail string `json:"detail"`
}
type AppendContextItemParams ¶
type AppendContextItemParams struct {
ConversationID string `json:"conversation_id"`
Ordinal int64 `json:"ordinal"`
ItemType string `json:"item_type"`
MessageID sql.NullString `json:"message_id"`
SummaryID sql.NullString `json:"summary_id"`
EventType string `json:"event_type"`
Role string `json:"role"`
}
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 string `json:"raw_claims"`
CreatedAt string `json:"created_at"`
UpdatedAt string `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 int64 `json:"is_system"`
Enabled int64 `json:"enabled"`
CreatedAt string `json:"created_at"`
UpdatedAt string `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 int64 `json:"is_active"`
DefaultAgentID sql.NullString `json:"default_agent_id"`
NotifyIdentityID sql.NullString `json:"notify_identity_id"`
AgePublicKey string `json:"age_public_key"`
AgePrivateKey string `json:"age_private_key"`
CreatedAt string `json:"created_at"`
UpdatedAt string `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 int64 `json:"auto_generated"`
LastUsedAt sql.NullString `json:"last_used_at"`
ExpiresAt sql.NullString `json:"expires_at"`
RotatedAt sql.NullString `json:"rotated_at"`
RevokedAt sql.NullString `json:"revoked_at"`
CreatedAt string `json:"created_at"`
UpdatedAt string `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 sql.NullString `json:"lease_until"`
ID string `json:"id"`
Now sql.NullString `json:"now"`
}
type ClaimExpiredGroupOutboxParams ¶ added in v0.43.0
type ClaimExpiredGroupOutboxParams struct {
LeaseUntil sql.NullString `json:"lease_until"`
ID string `json:"id"`
Now sql.NullString `json:"now"`
}
type ClaimGoalParams ¶ added in v0.49.4
type ClaimGoalParams struct {
ActiveAttemptID sql.NullString `json:"active_attempt_id"`
ID string `json:"id"`
}
type ClaimPendingGroupDispatchParams ¶ added in v0.43.0
type ClaimPendingGroupDispatchParams struct {
LeaseUntil sql.NullString `json:"lease_until"`
ID string `json:"id"`
Now sql.NullString `json:"now"`
}
type ClaimPendingGroupOutboxParams ¶ added in v0.43.0
type ClaimPendingGroupOutboxParams struct {
LeaseUntil sql.NullString `json:"lease_until"`
ID string `json:"id"`
Now sql.NullString `json:"now"`
}
type ConsumeDispatchHintParams ¶ added in v0.38.0
type CountRootGoalParams ¶ added in v0.49.4
type CountRootGoalParams struct {
UserID string `json:"user_id"`
AgentID interface{} `json:"agent_id"`
ProjectID interface{} `json:"project_id"`
Lifecycle interface{} `json:"lifecycle"`
Terminal interface{} `json:"terminal"`
Q interface{} `json:"q"`
IncludeArchived interface{} `json:"include_archived"`
}
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 string `json:"sandbox"`
EnabledBuiltinSkills string `json:"enabled_builtin_skills"`
Scope string `json:"scope"`
CreatorID string `json:"creator_id"`
Enabled int64 `json:"enabled"`
}
type CreateArticleParams ¶
type CreateArticleParams struct {
ID string `json:"id"`
UserID string `json:"user_id"`
AgentID sql.NullString `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 int64 `json:"starred"`
FilePath string `json:"file_path"`
Metadata string `json:"metadata"`
PublishedAt sql.NullString `json:"published_at"`
SavedAt string `json:"saved_at"`
ReadAt sql.NullString `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 sql.NullString `json:"agent_id"`
ExecutorAgentID sql.NullString `json:"executor_agent_id"`
SessionID string `json:"session_id"`
Purpose string `json:"purpose"`
AttemptNo int64 `json:"attempt_no"`
Status string `json:"status"`
InputContext string `json:"input_context"`
LeaseExpiresAt sql.NullString `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 int64 `json:"is_system"`
Enabled int64 `json:"enabled"`
}
type CreateConversationParams ¶
type CreateConversationParams struct {
ID string `json:"id"`
SessionID string `json:"session_id"`
Title sql.NullString `json:"title"`
Channel string `json:"channel"`
Kind string `json:"kind"`
ProjectID sql.NullString `json:"project_id"`
Archived int64 `json:"archived"`
LastActive string `json:"last_active"`
AgentID sql.NullString `json:"agent_id"`
UserID sql.NullString `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 string `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 sql.NullString `json:"article_id"`
Attempts int64 `json:"attempts"`
ErrorMsg string `json:"error_msg"`
DiscoveredAt string `json:"discovered_at"`
ProcessedAt sql.NullString `json:"processed_at"`
}
type CreateFeedParams ¶ added in v0.43.0
type CreateFeedParams struct {
ID string `json:"id"`
UserID string `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
Url string `json:"url"`
Kind string `json:"kind"`
Metadata string `json:"metadata"`
Title string `json:"title"`
Description string `json:"description"`
CheckInterval string `json:"check_interval"`
LastCheckedAt sql.NullString `json:"last_checked_at"`
LastEtag string `json:"last_etag"`
LastModified string `json:"last_modified"`
Enabled int64 `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 sql.NullString `json:"project_id"`
ParentID sql.NullString `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 int64 `json:"required"`
AcceptanceContract string `json:"acceptance_contract"`
ConvergencePolicy string `json:"convergence_policy"`
ReviewPolicy string `json:"review_policy"`
Lifecycle string `json:"lifecycle"`
Context string `json:"context"`
DispatchHint string `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 sql.NullString `json:"lease_until"`
NextAttemptAt sql.NullString `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 sql.NullString `json:"source_channel_id"`
ActorType string `json:"actor_type"`
ActorID string `json:"actor_id"`
PlatformMessageID sql.NullString `json:"platform_message_id"`
ReplyTo sql.NullString `json:"reply_to"`
PlatformTimestamp sql.NullString `json:"platform_timestamp"`
IdempotencyKey sql.NullString `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 sql.NullString `json:"lease_until"`
NextAttemptAt sql.NullString `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 sql.NullString `json:"text_content"`
ToolCallID sql.NullString `json:"tool_call_id"`
ToolName sql.NullString `json:"tool_name"`
ToolInput sql.NullString `json:"tool_input"`
ToolOutput sql.NullString `json:"tool_output"`
Metadata sql.NullString `json:"metadata"`
}
type CreateProjectParams ¶ added in v0.34.0
type CreateProviderParams ¶
type CreateRevisionParams ¶ added in v0.49.4
type CreateRevisionParams struct {
ID string `json:"id"`
GoalID string `json:"goal_id"`
RevisionNo int64 `json:"revision_no"`
Status string `json:"status"`
ReviewPolicy string `json:"review_policy"`
Content string `json:"content"`
SourceAttemptID sql.NullString `json:"source_attempt_id"`
PlanningSessionID sql.NullString `json:"planning_session_id"`
}
type CreateSchedJobRunParams ¶
type CreateSchedJobRunParams struct {
ID string `json:"id"`
JobID string `json:"job_id"`
SessionID string `json:"session_id"`
Status string `json:"status"`
StartedAt string `json:"started_at"`
FinishedAt sql.NullString `json:"finished_at"`
Error string `json:"error"`
UserID sql.NullString `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 string `json:"payload"`
SessionMode string `json:"session_mode"`
Enabled int64 `json:"enabled"`
AgentID sql.NullString `json:"agent_id"`
UserID sql.NullString `json:"user_id"`
CreatedAt string `json:"created_at"`
UpdatedAt string `json:"updated_at"`
LastRunAt sql.NullString `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 sql.NullString `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
Name string `json:"name"`
Description string `json:"description"`
Status string `json:"status"`
DisableModelInvocation int64 `json:"disable_model_invocation"`
Metadata string `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 sql.NullString `json:"earliest_at"`
LatestAt sql.NullString `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 CreateWebChannelIfNotExistsParams struct {
ID string `json:"id"`
AgentID sql.NullString `json:"agent_id"`
}
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 string `json:"constraints"`
ProfileEntries string `json:"profile_entries"`
CreatedAt string `json:"created_at"`
UpdatedAt string `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 sql.NullString `json:"session_id"`
EntityID sql.NullString `json:"entity_id"`
Scope string `json:"scope"`
Action string `json:"action"`
Source string `json:"source"`
MemoryVersionBefore sql.NullInt64 `json:"memory_version_before"`
MemoryVersionAfter sql.NullInt64 `json:"memory_version_after"`
BeforeText sql.NullString `json:"before_text"`
AfterText sql.NullString `json:"after_text"`
Metadata sql.NullString `json:"metadata"`
CreatedAt string `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 sql.NullString `json:"title"`
Channel string `json:"channel"`
Kind string `json:"kind"`
ProjectID sql.NullString `json:"project_id"`
Archived int64 `json:"archived"`
LastActive string `json:"last_active"`
BootstrappedAt sql.NullString `json:"bootstrapped_at"`
AgentID sql.NullString `json:"agent_id"`
UserID sql.NullString `json:"user_id"`
CreatedAt string `json:"created_at"`
UpdatedAt string `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 sql.NullString `json:"lease_until"`
NextAttemptAt sql.NullString `json:"next_attempt_at"`
LastError string `json:"last_error"`
ResultMessageID string `json:"result_message_id"`
CreatedAt string `json:"created_at"`
UpdatedAt string `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 sql.NullString `json:"source_channel_id"`
ActorType string `json:"actor_type"`
ActorID string `json:"actor_id"`
PlatformMessageID sql.NullString `json:"platform_message_id"`
ReplyTo sql.NullString `json:"reply_to"`
PlatformTimestamp sql.NullString `json:"platform_timestamp"`
IdempotencyKey sql.NullString `json:"idempotency_key"`
Content string `json:"content"`
Reasoning string `json:"reasoning"`
AgentSessionID string `json:"agent_session_id"`
CreatedAt string `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 sql.NullString `json:"lease_until"`
NextAttemptAt sql.NullString `json:"next_attempt_at"`
LastError string `json:"last_error"`
CreatedAt string `json:"created_at"`
UpdatedAt string `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 string `json:"created_at"`
UpdatedAt string `json:"updated_at"`
GroupName string `json:"group_name"`
CreatedByUserID sql.NullString `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 sql.NullString `json:"message_id"`
SummaryID sql.NullString `json:"summary_id"`
EventType string `json:"event_type"`
Role string `json:"role"`
CreatedAt string `json:"created_at"`
}
type CtxMessage ¶
type CtxMessageFt ¶ added in v0.46.0
type CtxMessageFt struct {
Content string `json:"content"`
}
type CtxMessagePart ¶
type CtxMessagePart struct {
ID string `json:"id"`
MessageID string `json:"message_id"`
PartType string `json:"part_type"`
Ordinal int64 `json:"ordinal"`
TextContent sql.NullString `json:"text_content"`
ToolCallID sql.NullString `json:"tool_call_id"`
ToolName sql.NullString `json:"tool_name"`
ToolInput sql.NullString `json:"tool_input"`
ToolOutput sql.NullString `json:"tool_output"`
Metadata sql.NullString `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 sql.NullString `json:"earliest_at"`
LatestAt sql.NullString `json:"latest_at"`
DescendantCount int64 `json:"descendant_count"`
DescendantTokenCount int64 `json:"descendant_token_count"`
SourceMessageTokenCount int64 `json:"source_message_token_count"`
CreatedAt string `json:"created_at"`
}
type CtxSummaryFt ¶ added in v0.46.0
type CtxSummaryFt struct {
Content string `json:"content"`
}
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 DeleteSkillParams struct {
ID string `json:"id"`
AgentID sql.NullString `json:"agent_id"`
UserID sql.NullString `json:"user_id"`
}
type DeleteVaultEntryByScopeParams ¶ added in v0.48.0
type DeleteVaultEntryParams ¶
type DeleteVaultEntryParams struct {
UserID sql.NullString `json:"user_id"`
Name string `json:"name"`
}
type ExpireKnowledgeDraftsByTypeParams ¶
type ExpireKnowledgeDraftsByTypeParams struct {
KnowledgeType sql.NullString `json:"knowledge_type"`
Cutoff string `json:"cutoff"`
}
type ExtendRunningGroupDispatchLeaseParams ¶ added in v0.43.0
type ExtendRunningGroupDispatchLeaseParams struct {
LeaseUntil sql.NullString `json:"lease_until"`
ID string `json:"id"`
AttemptCount int64 `json:"attempt_count"`
}
type ExtendRunningGroupOutboxLeaseParams ¶ added in v0.43.0
type ExtendRunningGroupOutboxLeaseParams struct {
LeaseUntil sql.NullString `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 sql.NullString `json:"message_id"`
SummaryID sql.NullString `json:"summary_id"`
EventType string `json:"event_type"`
Role string `json:"role"`
CreatedAt string `json:"created_at"`
MsgTokenCount int64 `json:"msg_token_count"`
}
type GetContextStatsRow ¶ added in v0.46.0
type GetConversationAgentBySessionIDParams ¶ added in v0.46.0
type GetConversationAgentBySessionIDParams struct {
SessionID string `json:"session_id"`
UserID sql.NullString `json:"user_id"`
}
type GetConversationBySessionIDParams ¶ added in v0.35.3
type GetConversationBySessionIDParams struct {
SessionID string `json:"session_id"`
UserID sql.NullString `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
}
type GetConversationParams ¶ added in v0.35.3
type GetConversationParams struct {
ID string `json:"id"`
UserID sql.NullString `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
}
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 GetGroupMessageByPlatformIDParams struct {
GroupID string `json:"group_id"`
PlatformMessageID sql.NullString `json:"platform_message_id"`
}
type GetGroupStateByTripleParams ¶ added in v0.42.0
type GetIngestCursorParams ¶ added in v0.42.0
type GetMainConversationByProjectParams ¶ added in v0.35.3
type GetMainConversationByProjectParams struct {
ProjectID sql.NullString `json:"project_id"`
UserID sql.NullString `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
}
type GetMaxAttemptNoParams ¶ added in v0.49.4
type GetMemorySnapshotParams ¶
type GetMessageParams ¶ added in v0.38.0
type GetMessageScopedParams ¶ added in v0.49.0
type GetMessageScopedParams struct {
ID string `json:"id"`
UserID sql.NullString `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
}
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 string `json:"created_at"`
SessionID string `json:"session_id"`
ConversationTitle sql.NullString `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 GetSkillParams struct {
ID string `json:"id"`
AgentID interface{} `json:"agent_id"`
UserID interface{} `json:"user_id"`
}
type GetSummaryMessageSeqRangeRow ¶ added in v0.46.0
type GetSummaryParams ¶ added in v0.38.0
type GetSystemAgentSkillByNameParams ¶ added in v0.48.0
type GetSystemAgentSkillByNameParams struct {
AgentID sql.NullString `json:"agent_id"`
Name string `json:"name"`
}
type GetUserSkillByNameParams ¶
type GetUserSkillByNameParams struct {
UserID sql.NullString `json:"user_id"`
Name string `json:"name"`
}
type GetVaultEntryByScopeParams ¶ added in v0.48.0
type GetVaultEntryParams ¶
type GetVaultEntryParams struct {
UserID sql.NullString `json:"user_id"`
Name string `json:"name"`
}
type HeartbeatAttemptParams ¶ added in v0.49.4
type HeartbeatAttemptParams struct {
LeaseExpiresAt sql.NullString `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 sql.NullString `json:"session_id"`
EntityID sql.NullString `json:"entity_id"`
Scope string `json:"scope"`
Action string `json:"action"`
Source string `json:"source"`
MemoryVersionBefore sql.NullInt64 `json:"memory_version_before"`
MemoryVersionAfter sql.NullInt64 `json:"memory_version_after"`
BeforeText sql.NullString `json:"before_text"`
AfterText sql.NullString `json:"after_text"`
Metadata sql.NullString `json:"metadata"`
}
type IsIngestErrorParams ¶ added in v0.42.0
type ListActiveKnowledgeByTypeParams ¶
type ListActiveKnowledgeByTypeParams struct {
AgentID sql.NullString `json:"agent_id"`
UserID sql.NullString `json:"user_id"`
KnowledgeType interface{} `json:"knowledge_type"`
}
type ListAgentConversationLastActiveRow ¶ added in v0.46.0
type ListAgentConversationLastActiveRow struct {
AgentID sql.NullString `json:"agent_id"`
LastActive interface{} `json:"last_active"`
}
type ListArticlesParams ¶
type ListAttemptByGoalParams ¶ added in v0.49.4
type ListAttemptByGoalParams struct {
GoalID string `json:"goal_id"`
Purpose interface{} `json:"purpose"`
}
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 sql.NullString `json:"message_id"`
MessageSeq sql.NullInt64 `json:"message_seq"`
MessageRole sql.NullString `json:"message_role"`
MessageEventType sql.NullString `json:"message_event_type"`
MessageContent sql.NullString `json:"message_content"`
MessageTokenCount sql.NullInt64 `json:"message_token_count"`
MessageCreatedAt sql.NullString `json:"message_created_at"`
SummaryID sql.NullString `json:"summary_id"`
SummaryKind sql.NullString `json:"summary_kind"`
SummaryDepth sql.NullInt64 `json:"summary_depth"`
SummaryContent sql.NullString `json:"summary_content"`
SummaryTokenCount sql.NullInt64 `json:"summary_token_count"`
SummaryEarliestAt sql.NullString `json:"summary_earliest_at"`
SummaryLatestAt sql.NullString `json:"summary_latest_at"`
SummaryDescendantCount sql.NullInt64 `json:"summary_descendant_count"`
SummaryDescendantTokenCount sql.NullInt64 `json:"summary_descendant_token_count"`
SummarySourceMessageTokenCount sql.NullInt64 `json:"summary_source_message_token_count"`
SummaryCreatedAt sql.NullString `json:"summary_created_at"`
}
type ListConversationsAllParams ¶ added in v0.35.3
type ListConversationsAllParams struct {
UserID sql.NullString `json:"user_id"`
AgentID interface{} `json:"agent_id"`
}
type ListConversationsByKindParams ¶ added in v0.34.0
type ListConversationsByKindParams struct {
AgentID sql.NullString `json:"agent_id"`
UserID sql.NullString `json:"user_id"`
Kind string `json:"kind"`
}
type ListConversationsFilteredParams ¶ added in v0.46.0
type ListConversationsFilteredParams struct {
UserID sql.NullString `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
IncludeArchived interface{} `json:"include_archived"`
Kind interface{} `json:"kind"`
ProjectIDIsNull interface{} `json:"project_id_is_null"`
ProjectID interface{} `json:"project_id"`
Offset int64 `json:"offset"`
Limit int64 `json:"limit"`
}
type ListConversationsForReviewFilteredParams ¶ added in v0.46.0
type ListConversationsForReviewFilteredParams struct {
AgentID sql.NullString `json:"agent_id"`
Kind interface{} `json:"kind"`
ProjectIDIsNull interface{} `json:"project_id_is_null"`
ProjectID interface{} `json:"project_id"`
Offset int64 `json:"offset"`
Limit int64 `json:"limit"`
}
type ListConversationsParams ¶ added in v0.35.3
type ListConversationsParams struct {
UserID sql.NullString `json:"user_id"`
AgentID interface{} `json:"agent_id"`
}
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 sql.NullString `json:"waived_at"`
WaivedByUser sql.NullString `json:"waived_by_user"`
WaiverReason string `json:"waiver_reason"`
CreatedAt string `json:"created_at"`
UpstreamLifecycle string `json:"upstream_lifecycle"`
UpstreamOutput sql.NullString `json:"upstream_output"`
}
type ListExistingUserMessageContentParams ¶ added in v0.47.0
type ListExpiredRunningGroupDispatchParams ¶ added in v0.43.0
type ListExpiredRunningGroupDispatchParams struct {
Now sql.NullString `json:"now"`
LimitCount int64 `json:"limit_count"`
}
type ListExpiredRunningGroupOutboxParams ¶ added in v0.43.0
type ListExpiredRunningGroupOutboxParams struct {
Now sql.NullString `json:"now"`
LimitCount int64 `json:"limit_count"`
}
type ListFailedInboxSchedulerRunsParams ¶ added in v0.46.0
type ListFailedInboxSchedulerRunsParams struct {
UserID sql.NullString `json:"user_id"`
Since interface{} `json:"since"`
AgentID interface{} `json:"agent_id"`
LimitCount int64 `json:"limit_count"`
}
type ListFailedInboxSchedulerRunsRow ¶ added in v0.46.0
type ListFailedInboxSchedulerRunsRow struct {
RunID string `json:"run_id"`
JobID string `json:"job_id"`
AgentID sql.NullString `json:"agent_id"`
Name string `json:"name"`
Error string `json:"error"`
FinishedAt sql.NullString `json:"finished_at"`
StartedAt string `json:"started_at"`
}
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 ListGroupsByUserParams struct {
UserID sql.NullString `json:"user_id"`
OffsetCount int64 `json:"offset_count"`
LimitCount int64 `json:"limit_count"`
}
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 string `json:"created_at"`
UpdatedAt string `json:"updated_at"`
GroupName string `json:"group_name"`
CreatedByUserID sql.NullString `json:"created_by_user_id"`
LastActive string `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 sql.NullString `json:"project_id"`
Title string `json:"title"`
Intent string `json:"intent"`
Lifecycle string `json:"lifecycle"`
BlockReason string `json:"block_reason"`
UpdatedAt string `json:"updated_at"`
CreatedAt string `json:"created_at"`
}
type ListMessagesByIDsParams ¶ added in v0.41.0
type ListMessagesByLogicalPageParams ¶ added in v0.41.0
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 string `json:"created_at"`
}
type ListPendingEntriesParams ¶ added in v0.43.0
type ListPendingGroupDispatchByMessageParams ¶ added in v0.43.0
type ListPendingGroupDispatchByMessageParams struct {
GroupMessageID string `json:"group_message_id"`
Now sql.NullString `json:"now"`
}
type ListPendingGroupDispatchParams ¶ added in v0.43.0
type ListPendingGroupDispatchParams struct {
Now sql.NullString `json:"now"`
LimitCount int64 `json:"limit_count"`
}
type ListPendingGroupOutboxParams ¶ added in v0.43.0
type ListPendingGroupOutboxParams struct {
Now sql.NullString `json:"now"`
LimitCount int64 `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 interface{} `json:"agent_id"`
ProjectID interface{} `json:"project_id"`
Lifecycle interface{} `json:"lifecycle"`
Terminal interface{} `json:"terminal"`
Q interface{} `json:"q"`
IncludeArchived interface{} `json:"include_archived"`
Offset int64 `json:"offset"`
Limit int64 `json:"limit"`
}
type ListSchedJobRunsParams ¶
type ListSchedulerJobsByAgentParams ¶ added in v0.36.0
type ListSchedulerJobsByAgentParams struct {
AgentID sql.NullString `json:"agent_id"`
UserID sql.NullString `json:"user_id"`
}
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 ListSkillsByScopeParams struct {
Scope string `json:"scope"`
UserID interface{} `json:"user_id"`
AgentID interface{} `json:"agent_id"`
}
type ListSkillsForAgentContextParams ¶ added in v0.36.0
type ListSkillsForAgentContextParams struct {
AgentID sql.NullString `json:"agent_id"`
UserID sql.NullString `json:"user_id"`
}
type ListSkillsForUserParams ¶ added in v0.36.0
type ListSkillsForUserParams struct {
AgentIdsCsv sql.NullString `json:"agent_ids_csv"`
UserID sql.NullString `json:"user_id"`
}
type ListSkillsVisibleParams ¶
type ListSkillsVisibleParams struct {
AgentID sql.NullString `json:"agent_id"`
UserID sql.NullString `json:"user_id"`
}
type ListStaleAttemptsParams ¶ added in v0.49.4
type ListStaleAttemptsParams struct {
Now sql.NullString `json:"now"`
Limit int64 `json:"limit"`
}
type ListSummariesByIDsParams ¶ added in v0.41.0
type ListVaultEntriesByScopeParams ¶ added in v0.48.0
type ListVaultEntriesByScopeParams struct {
Scope string `json:"scope"`
UserID interface{} `json:"user_id"`
AgentID interface{} `json:"agent_id"`
}
type ListVaultEntriesForRuntimeParams ¶ added in v0.48.0
type ListVaultEntriesForRuntimeParams struct {
AgentID sql.NullString `json:"agent_id"`
UserID sql.NullString `json:"user_id"`
}
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 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 sql.NullString `json:"description"`
Archived int64 `json:"archived"`
CreatedAt string `json:"created_at"`
UpdatedAt string `json:"updated_at"`
}
type PromoteAttemptParams ¶ added in v0.49.4
type PromoteAttemptParams struct {
LeaseExpiresAt sql.NullString `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) AcceptRevision ¶ 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 sql.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) CreateRevision ¶ added in v0.49.4
func (q *Queries) CreateRevision(ctx context.Context, arg CreateRevisionParams) (AgentGoalRevision, error)
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 (q *Queries) GetConversationAgentBySessionID(ctx context.Context, arg GetConversationAgentBySessionIDParams) (sql.NullString, error)
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 (q *Queries) GetFreshTailMessageIDs(ctx context.Context, arg GetFreshTailMessageIDsParams) ([]sql.NullString, error)
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 (q *Queries) GetGroupMessageByIdempotencyKey(ctx context.Context, idempotencyKey sql.NullString) (CtxGroupMessage, error)
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) GetMaterializedRevision ¶ added in v0.49.4
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) GetMaxRevisionNo ¶ added in v0.49.4
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) GetOpenRevision ¶ added in v0.49.4
func (*Queries) GetPluginStateEntry ¶
func (*Queries) GetProject ¶ added in v0.34.0
func (*Queries) GetProjectByName ¶ added in v0.34.0
func (*Queries) GetProvider ¶
func (*Queries) GetRevision ¶ added in v0.49.4
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 (q *Queries) ListAcceptanceEventByAttempt(ctx context.Context, attemptID sql.NullString) ([]AgentGoalAcceptanceEvent, error)
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 (q *Queries) ListAgentConversationLastActive(ctx context.Context, userID sql.NullString) ([]ListAgentConversationLastActiveRow, error)
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) 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) 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 (q *Queries) ListConversationsForReviewByAgent(ctx context.Context, agentID sql.NullString) ([]CtxConversation, error)
func (*Queries) ListConversationsForReviewFiltered ¶ added in v0.46.0
func (q *Queries) ListConversationsForReviewFiltered(ctx context.Context, arg ListConversationsForReviewFilteredParams) ([]CtxConversation, error)
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) 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) ListRevisionByGoal ¶ added in v0.49.4
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: 0 = active (non-terminal) only, 1 = 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)
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) 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 (q *Queries) ListVaultEntriesByUser(ctx context.Context, userID sql.NullString) ([]VaultEntry, error)
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) 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) MaterializeRevision ¶ added in v0.49.4
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 sql.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) SearchArticles ¶
func (q *Queries) SearchArticles(ctx context.Context, arg SearchArticlesParams) ([]SearchArticlesRow, error)
FTS5/BM25 search over title/summary/tags/author. Matching against the hidden table-name column searches every indexed column (declared for sqlc in recally_article_fts_sqlc.sql); bm25 weights rank title hits highest, and snippet column -1 picks the best-matching column. More negative bm25 means more relevant, hence ORDER BY score ASC.
func (*Queries) SearchArticlesLike ¶ added in v0.46.0
func (q *Queries) SearchArticlesLike(ctx context.Context, arg SearchArticlesLikeParams) ([]RecallyArticle, error)
Fallback for queries with no token of 3+ runes, which trigram MATCH would silently never hit. Scans the content table directly, recency-ordered, no BM25. Pattern must be a full '%text%' built with ftsquery.EscapeLike; see SearchMessagesLike for the sqlc constraints shaping this query.
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.
func (*Queries) SearchMessagesLike ¶ added in v0.46.0
func (q *Queries) SearchMessagesLike(ctx context.Context, arg SearchMessagesLikeParams) ([]SearchMessagesLikeRow, error)
Fallback for queries with no token of 3+ runes, which trigram MATCH would silently never hit. Scans the content table directly (faster there than on the FTS table, which pays external-content read-back), recency-ordered, no BM25. Pattern must be a full '%text%' built with ftsquery.EscapeLike; sqlc cannot parse || concatenation here, so the caller wraps it, and the parens around LIKE...ESCAPE are also required by sqlc's grammar. Keep these doc comments ASCII: multibyte chars corrupt sqlc's query rewriter offsets.
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.
func (*Queries) SearchSummariesLike ¶ added in v0.46.0
func (q *Queries) SearchSummariesLike(ctx context.Context, arg SearchSummariesLikeParams) ([]SearchSummariesLikeRow, error)
Fallback for queries with no token of 3+ runes (see SearchMessagesLike).
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) SetGoalAcceptedRevision ¶ added in v0.49.4
func (q *Queries) SetGoalAcceptedRevision(ctx context.Context, arg SetGoalAcceptedRevisionParams) error
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) SetRevisionPlanningSession ¶ added in v0.49.4
func (*Queries) SubmitAttempt ¶ added in v0.49.4
func (*Queries) SupersedeOpenRevisions ¶ 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) UpdateRevisionContent ¶ added in v0.49.4
func (q *Queries) UpdateRevisionContent(ctx context.Context, arg UpdateRevisionContentParams) error
func (*Queries) UpdateRevisionStatus ¶ added in v0.49.4
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) 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) 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) 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 sql.NullString `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 int64 `json:"starred"`
FilePath string `json:"file_path"`
Metadata string `json:"metadata"`
PublishedAt sql.NullString `json:"published_at"`
SavedAt string `json:"saved_at"`
ReadAt sql.NullString `json:"read_at"`
CreatedAt string `json:"created_at"`
UpdatedAt string `json:"updated_at"`
}
type RecallyArticleFt ¶ added in v0.46.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 string `json:"top_tags"`
CreatedAt string `json:"created_at"`
UpdatedAt string `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 sql.NullString `json:"agent_id"`
Url string `json:"url"`
Kind string `json:"kind"`
Metadata string `json:"metadata"`
Title string `json:"title"`
Description string `json:"description"`
CheckInterval string `json:"check_interval"`
LastCheckedAt sql.NullString `json:"last_checked_at"`
LastEtag string `json:"last_etag"`
LastModified string `json:"last_modified"`
Enabled int64 `json:"enabled"`
CreatedAt string `json:"created_at"`
UpdatedAt string `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 sql.NullString `json:"article_id"`
Attempts int64 `json:"attempts"`
ErrorMsg string `json:"error_msg"`
DiscoveredAt string `json:"discovered_at"`
ProcessedAt sql.NullString `json:"processed_at"`
}
type RecordSchedulerJobRunParams ¶
type RecordSchedulerJobRunParams struct {
LastRunAt sql.NullString `json:"last_run_at"`
LastError string `json:"last_error"`
UpdatedAt string `json:"updated_at"`
ID string `json:"id"`
}
type RemoveGroupMemberParams ¶ added in v0.42.0
type RemoveUserAgentParams ¶
type RequeueGroupDispatchParams ¶ added in v0.43.0
type RequeueGroupDispatchParams struct {
NextAttemptAt sql.NullString `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 sql.NullString `json:"next_attempt_at"`
LastError string `json:"last_error"`
ID string `json:"id"`
AttemptCount int64 `json:"attempt_count"`
}
type ResolveSkillParams ¶
type ResolveSkillParams struct {
Name string `json:"name"`
AgentID sql.NullString `json:"agent_id"`
UserID sql.NullString `json:"user_id"`
}
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 string `json:"payload"`
SessionMode string `json:"session_mode"`
Enabled int64 `json:"enabled"`
AgentID sql.NullString `json:"agent_id"`
UserID sql.NullString `json:"user_id"`
CreatedAt string `json:"created_at"`
UpdatedAt string `json:"updated_at"`
LastRunAt sql.NullString `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 string `json:"started_at"`
FinishedAt sql.NullString `json:"finished_at"`
Error string `json:"error"`
Output string `json:"output"`
UserID sql.NullString `json:"user_id"`
}
type SearchArticlesLikeParams ¶ added in v0.46.0
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 SearchMessagesLikeParams ¶ added in v0.46.0
type SearchMessagesLikeParams struct {
UserID sql.NullString `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
Pattern string `json:"pattern"`
Limit int64 `json:"limit"`
}
type SearchMessagesLikeRow ¶ added in v0.49.0
type SearchMessagesLikeRow 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 string `json:"created_at"`
SessionID string `json:"session_id"`
ConversationTitle sql.NullString `json:"conversation_title"`
}
type SearchMessagesParams ¶
type SearchMessagesParams struct {
Match string `json:"match"`
UserID sql.NullString `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
Limit int64 `json:"limit"`
}
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 string `json:"created_at"`
SessionID string `json:"session_id"`
ConversationTitle sql.NullString `json:"conversation_title"`
Snippet string `json:"snippet"`
Score float64 `json:"score"`
}
type SearchSummariesLikeParams ¶ added in v0.46.0
type SearchSummariesLikeParams struct {
UserID sql.NullString `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
Pattern string `json:"pattern"`
Limit int64 `json:"limit"`
}
type SearchSummariesLikeRow ¶ added in v0.49.0
type SearchSummariesLikeRow 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 sql.NullString `json:"earliest_at"`
LatestAt sql.NullString `json:"latest_at"`
DescendantCount int64 `json:"descendant_count"`
DescendantTokenCount int64 `json:"descendant_token_count"`
SourceMessageTokenCount int64 `json:"source_message_token_count"`
CreatedAt string `json:"created_at"`
SessionID string `json:"session_id"`
ConversationTitle sql.NullString `json:"conversation_title"`
}
type SearchSummariesParams ¶
type SearchSummariesParams struct {
Match string `json:"match"`
UserID sql.NullString `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
Limit int64 `json:"limit"`
}
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 sql.NullString `json:"earliest_at"`
LatestAt sql.NullString `json:"latest_at"`
DescendantCount int64 `json:"descendant_count"`
DescendantTokenCount int64 `json:"descendant_token_count"`
SourceMessageTokenCount int64 `json:"source_message_token_count"`
CreatedAt string `json:"created_at"`
SessionID string `json:"session_id"`
ConversationTitle sql.NullString `json:"conversation_title"`
Snippet string `json:"snippet"`
Score float64 `json:"score"`
}
type SeedProviderParams ¶
type SetAttemptExecutorParams ¶ added in v0.49.4
type SetAttemptExecutorParams struct {
ExecutorAgentID sql.NullString `json:"executor_agent_id"`
ID string `json:"id"`
}
type SetAttemptGapsParams ¶ added in v0.49.4
type SetGoalAcceptanceStateParams ¶ added in v0.49.4
type SetGoalAcceptedRevisionParams ¶ added in v0.49.4
type SetGoalAcceptedRevisionParams struct {
AcceptedRevisionID sql.NullString `json:"accepted_revision_id"`
ID string `json:"id"`
}
type SetGoalRequiredTotalParams ¶ added in v0.49.4
type SetGroupDispatchResultMessageParams ¶ added in v0.47.0
type SetRevisionPlanningSessionParams ¶ added in v0.49.4
type SetRevisionPlanningSessionParams struct {
PlanningSessionID sql.NullString `json:"planning_session_id"`
ID string `json:"id"`
}
type Skill ¶
type Skill struct {
ID string `json:"id"`
Scope string `json:"scope"`
UserID sql.NullString `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
Name string `json:"name"`
Description string `json:"description"`
Status string `json:"status"`
DisableModelInvocation int64 `json:"disable_model_invocation"`
Metadata string `json:"metadata"`
CreatedAt string `json:"created_at"`
UpdatedAt string `json:"updated_at"`
}
type SubmitAttemptParams ¶ added in v0.49.4
type SubmitAttemptParams struct {
Evidence string `json:"evidence"`
Output string `json:"output"`
RevisionID sql.NullString `json:"revision_id"`
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 string `json:"sandbox"`
EnabledBuiltinSkills string `json:"enabled_builtin_skills"`
Scope string `json:"scope"`
Enabled int64 `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 int64 `json:"starred"`
FilePath string `json:"file_path"`
Metadata string `json:"metadata"`
PublishedAt sql.NullString `json:"published_at"`
ReadAt sql.NullString `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 int64 `json:"enabled"`
ID string `json:"id"`
}
type UpdateConversationArchivedParams ¶
type UpdateConversationArchivedParams struct {
Archived int64 `json:"archived"`
SessionID string `json:"session_id"`
UserID sql.NullString `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
}
type UpdateConversationBootstrappedParams ¶ added in v0.35.3
type UpdateConversationBootstrappedParams struct {
ID string `json:"id"`
UserID sql.NullString `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
}
type UpdateConversationInfoBySessionIDParams ¶ added in v0.46.0
type UpdateConversationInfoBySessionIDParams struct {
Title interface{} `json:"title"`
Archived int64 `json:"archived"`
Kind interface{} `json:"kind"`
ProjectID interface{} `json:"project_id"`
SessionID string `json:"session_id"`
UserID sql.NullString `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
}
type UpdateConversationKindProjectParams ¶ added in v0.34.0
type UpdateConversationKindProjectParams struct {
Kind string `json:"kind"`
ProjectID sql.NullString `json:"project_id"`
SessionID string `json:"session_id"`
UserID sql.NullString `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
}
type UpdateConversationLastActiveParams ¶ added in v0.35.3
type UpdateConversationLastActiveParams struct {
SessionID string `json:"session_id"`
UserID sql.NullString `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
}
type UpdateConversationTitleBySessionIDParams ¶
type UpdateConversationTitleBySessionIDParams struct {
Title sql.NullString `json:"title"`
SessionID string `json:"session_id"`
UserID sql.NullString `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
}
type UpdateConversationTitleParams ¶
type UpdateConversationTitleParams struct {
Title sql.NullString `json:"title"`
ID string `json:"id"`
UserID sql.NullString `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
}
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 string `json:"metadata"`
CheckInterval string `json:"check_interval"`
LastCheckedAt sql.NullString `json:"last_checked_at"`
LastEtag string `json:"last_etag"`
LastModified string `json:"last_modified"`
Enabled int64 `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 string `json:"acceptance_contract"`
ConvergencePolicy string `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 UpdateRevisionContentParams ¶ added in v0.49.4
type UpdateRevisionStatusParams ¶ added in v0.49.4
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 string `json:"payload"`
SessionMode string `json:"session_mode"`
Enabled int64 `json:"enabled"`
AgentID sql.NullString `json:"agent_id"`
UserID sql.NullString `json:"user_id"`
UpdatedAt string `json:"updated_at"`
LastRunAt sql.NullString `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 int64 `json:"disable_model_invocation"`
Metadata string `json:"metadata"`
ID string `json:"id"`
AgentID sql.NullString `json:"agent_id"`
UserID sql.NullString `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 UpsertAgentSoulParams ¶
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 string `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 UpsertPluginParams ¶
type UpsertProfileEntriesParams ¶ added in v0.42.0
type UpsertSettingParams ¶
type UpsertSkillFileParams ¶
type UpsertVaultEntryByScopeParams ¶ added in v0.48.0
type UpsertVaultEntryByScopeParams struct {
ID string `json:"id"`
Scope string `json:"scope"`
UserID sql.NullString `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
Name string `json:"name"`
Ciphertext string `json:"ciphertext"`
}
type UpsertVaultEntryParams ¶
type UpsertVaultEntryParams struct {
ID string `json:"id"`
UserID sql.NullString `json:"user_id"`
Name string `json:"name"`
Ciphertext string `json:"ciphertext"`
}
type VaultEntry ¶
type VaultEntry struct {
ID string `json:"id"`
Scope string `json:"scope"`
UserID sql.NullString `json:"user_id"`
AgentID sql.NullString `json:"agent_id"`
Name string `json:"name"`
Ciphertext string `json:"ciphertext"`
CreatedAt string `json:"created_at"`
UpdatedAt string `json:"updated_at"`
}
type VaultUser ¶ added in v0.38.0
VaultUser holds the age key fields the vault service needs from a user record.
type WaiveEdgeParams ¶ added in v0.49.4
type WaiveEdgeParams struct {
WaivedByUser sql.NullString `json:"waived_by_user"`
WaiverReason string `json:"waiver_reason"`
GoalID string `json:"goal_id"`
UpstreamID string `json:"upstream_id"`
}
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
- agent_goal_revision.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