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