Documentation
¶
Index ¶
- func ReplaceAgentSkills(ctx context.Context, tx pgx.Tx, agentID uuid.UUID, skillIDs []string) error
- type A2AContextMapping
- type AcceptTaskDeliveryParams
- type Agent
- type AgentActionApprovalRequest
- type AgentAvailabilityAlert
- type AgentAvailabilitySnapshot
- type AgentCallPolicy
- type AgentCapability
- type AgentExample
- type AgentMetricSnapshot
- type AgentOnboardingStatus
- type AgentRuntimeToken
- type AgentSkill
- type AgentSkillBenchmarkRun
- type AgentSkillMatch
- type AgentSkillMatchVerified
- type AgentSkillScore
- type AgentToken
- type AggregateAgentRunsForWindowRow
- type BatchUpdateTaskCallbackSubscriptionsForOwnerParams
- type CancelRunParams
- type ClaimRuntimePullRunParams
- type ClaimStaleRuntimePullRunParams
- type ClaimTaskQueryParams
- type ClearAgentWebhookParams
- type CompleteProxyRunParams
- type CompleteTaskQueryParams
- type ConfirmAgentApprovalParams
- type CountAdminAgentsParams
- type CountAdminTasksParams
- type CountAdminUsersParams
- type CountAgentBucketsByCreatorRow
- type CountAgentTokensByCreatorAndAgentParams
- type CountAgentsByCreatorFilteredParams
- type CountCallRecordsForUserParams
- type CountParentRunsWithDelegationsByUserParams
- type CountPublicAgentsParams
- type CountRunsByCreatorAgentParams
- type CountRunsByUserAndAgentParams
- type CreateAdminUserParams
- type CreateAgentApprovalParams
- type CreateAgentExampleParams
- type CreateAgentParams
- type CreateAgentRuntimeTokenParams
- type CreateAgentTokenParams
- type CreateBenchmarkRunParams
- type CreateDeliveryTargetParams
- type CreatePendingWorkflowRunParams
- type CreateProxyRunArtifactParams
- type CreateProxyRunParams
- type CreateRegistryFederationInviteParams
- type CreateRegistryNodeParams
- type CreateRegistryPeerParams
- type CreateRunArtifactChunkParams
- type CreateRunArtifactParams
- type CreateRunDelegationParams
- type CreateRunDeliveryParams
- type CreateRunEventParams
- type CreateRunMessageParams
- type CreateRunParams
- type CreateRunRequirementEvidenceParams
- type CreateSkillProposalParams
- type CreateTaskCallbackDeliveryParams
- type CreateTaskCallbackSubscriptionParams
- type CreateTaskQueryParams
- type CreateUserParams
- type CreateWebhookDeliveryParams
- type CreateWorkflowNodeParams
- type CreateWorkflowParams
- type CreateWorkflowRunParams
- type CreateWorkflowRunStepParams
- type DBTX
- type DeleteAgentExampleForOwnerParams
- type DeleteDeliveryTargetParams
- type DeleteRegistryPeerForOwnerParams
- type DeleteTaskCallbackSubscriptionForOwnerParams
- type DeliveryTarget
- type DisableAgentParams
- type GetActiveRegistryPeerForOwnerParams
- type GetAdminSummaryRow
- type GetAgentApprovalForCreatorParams
- type GetAgentByIDForOwnerParams
- type GetAgentBySlugForOwnerParams
- type GetAgentBySlugForOwnerRow
- type GetAgentBySlugRow
- type GetAgentSkillScoreParams
- type GetAgentVerifiedSkillStatsRow
- type GetAgentWebhookConfigRow
- type GetAgentsByIDsRow
- type GetDeliveryTargetByIDForUserParams
- type GetLatestRunEventForTypesParams
- type GetOnboardingStatusForOwnerParams
- type GetProxyRunArtifactForRequesterParams
- type GetProxyRunForNodeParams
- type GetProxyRunForRequesterParams
- type GetRegistryListingLinkForOwnerParams
- type GetRegistryListingLinkRowForOwnerParams
- type GetRegistryNodeByIDForOwnerParams
- type GetRunArtifactBySourceIDParams
- type GetRunDeliveryRow
- type GetTaskCallbackDeliveryByIDRow
- type GetUserByOAuthParams
- type GetWebhookDeliveryRow
- type IncrementAgentStatsParams
- type ListA2AContextMappingsBeforeRunByRootParams
- type ListA2AContextMappingsByRootParams
- type ListActiveTaskCallbackSubscriptionsForEventParams
- type ListAdminAgentsParams
- type ListAdminAgentsRow
- type ListAdminTasksParams
- type ListAdminTasksRow
- type ListAdminUsersParams
- type ListAdminUsersRow
- type ListAgentAvailabilityAlertsByCreatorParams
- type ListAgentAvailabilityAlertsByCreatorRow
- type ListAgentRuntimeTokensForOwnerParams
- type ListAgentStatsForCreatorRow
- type ListAgentTokensByCreatorAndAgentParams
- type ListAgentTokensByCreatorParams
- type ListAgentsByCreatorPageParams
- type ListAgentsByCreatorPageRow
- type ListAgentsDueAvailabilityCheckParams
- type ListBenchmarkBatchSummariesByAgentParams
- type ListBenchmarkBatchSummariesByAgentRow
- type ListBenchmarkRunsByBatchRow
- type ListCallRecordsForUserParams
- type ListCallRecordsForUserRow
- type ListChildRunsByParentAndUserParams
- type ListChildRunsByParentAndUserRow
- type ListDelegationLineageParams
- type ListDeliveriesByAgentParams
- type ListParentRunsWithDelegationsByUserParams
- type ListParentRunsWithDelegationsByUserRow
- type ListPendingAgentsRow
- type ListProxyRunArtifactsForRequesterParams
- type ListPublicAgentsParams
- type ListPublicAgentsRow
- type ListRegistryListingLinksByOwnerRow
- type ListRunDeliveriesByUserParams
- type ListRunEventsByRunParams
- type ListRunsByCreatorAgentWithAgentParams
- type ListRunsByCreatorAgentWithAgentRow
- type ListRunsByUserAndAgentParams
- type ListRunsByUserParams
- type ListRunsByUserWithAgentParams
- type ListRunsByUserWithAgentRow
- type ListStaleEndpointRunsParams
- type ListStaleEndpointRunsRow
- type ListStaleRuntimePullRunsParams
- type ListStaleRuntimePullRunsRow
- type ListTaskCallbackDeliveriesByRunParams
- type ListTaskCallbackDeliveriesByRunRow
- type ListTaskCallbackSubscriptionsByOwnerParams
- type ListTaskCallbackSubscriptionsByRunParams
- type ListTaskQueriesByUserParams
- type ListTopAgentsBySkillParams
- type ListTopAgentsBySkillRow
- type ListWorkflowRunsByWorkflowParams
- type ListWorkflowsByUserParams
- type MarkAgentAvailabilityAlertReadParams
- type MarkBenchmarkRunFailedParams
- type MarkBenchmarkRunSuccessParams
- type MarkDeliveryFailedFinalParams
- type MarkDeliveryFailedRetryParams
- type MarkDeliverySuccessParams
- type MarkExamplesSetParams
- type MarkRegistryPeerUsedParams
- type MarkRunDeliveryFailedFinalParams
- type MarkRunDeliveryFailedRetryParams
- type MarkRunDeliverySuccessParams
- type MarkRunFailedParams
- type MarkRunSuccessParams
- type MarkTaskCallbackDeliveryFailedFinalParams
- type MarkTaskCallbackDeliveryFailedRetryParams
- type MarkTaskCallbackDeliverySuccessParams
- type MarkTaskQueryChosenParams
- type MarkWorkflowRunFailedParams
- type MarkWorkflowRunStepFailedParams
- type MarkWorkflowRunStepSuccessParams
- type MarkWorkflowRunSuccessParams
- type ProxyRun
- type ProxyRunArtifact
- type PublishTaskQueryParams
- type Queries
- func (q *Queries) AcceptTaskDelivery(ctx context.Context, arg AcceptTaskDeliveryParams) (TaskQuery, error)
- func (q *Queries) AgentsCount(ctx context.Context) (int32, error)
- func (q *Queries) AggregateAgentRunsForWindow(ctx context.Context, interval string) ([]AggregateAgentRunsForWindowRow, error)
- func (q *Queries) BatchUpdateTaskCallbackSubscriptionsForOwner(ctx context.Context, arg BatchUpdateTaskCallbackSubscriptionsForOwnerParams) ([]TaskCallbackSubscription, error)
- func (q *Queries) CancelRun(ctx context.Context, arg CancelRunParams) (Run, error)
- func (q *Queries) CancelWorkflowRun(ctx context.Context, id uuid.UUID) (WorkflowRun, error)
- func (q *Queries) CertifyAgent(ctx context.Context, id uuid.UUID) (int64, error)
- func (q *Queries) CheckSlugAvailable(ctx context.Context, slug string) (bool, error)
- func (q *Queries) ClaimPendingProxyRun(ctx context.Context, registryNodeID uuid.UUID) (ProxyRun, error)
- func (q *Queries) ClaimPendingWorkflowRun(ctx context.Context) (WorkflowRun, error)
- func (q *Queries) ClaimRuntimePullRun(ctx context.Context, arg ClaimRuntimePullRunParams) (Run, error)
- func (q *Queries) ClaimStaleRuntimePullRun(ctx context.Context, arg ClaimStaleRuntimePullRunParams) (Run, error)
- func (q *Queries) ClaimTaskQuery(ctx context.Context, arg ClaimTaskQueryParams) (TaskQuery, error)
- func (q *Queries) ClearAgentWebhook(ctx context.Context, arg ClearAgentWebhookParams) (int64, error)
- func (q *Queries) ClearDefaultDeliveryTarget(ctx context.Context, userID uuid.UUID) error
- func (q *Queries) CompleteProxyRun(ctx context.Context, arg CompleteProxyRunParams) (ProxyRun, error)
- func (q *Queries) CompleteTaskQuery(ctx context.Context, arg CompleteTaskQueryParams) (TaskQuery, error)
- func (q *Queries) ConfirmAgentApproval(ctx context.Context, arg ConfirmAgentApprovalParams) (int64, error)
- func (q *Queries) CountActiveAgentRuntimeTokens(ctx context.Context, agentID uuid.UUID) (int32, error)
- func (q *Queries) CountActiveAgentTokensByAgent(ctx context.Context, agentID uuid.UUID) (int32, error)
- func (q *Queries) CountAdminAgents(ctx context.Context, arg CountAdminAgentsParams) (int32, error)
- func (q *Queries) CountAdminTasks(ctx context.Context, arg CountAdminTasksParams) (int32, error)
- func (q *Queries) CountAdminUsers(ctx context.Context, arg CountAdminUsersParams) (int32, error)
- func (q *Queries) CountAgentAvailabilityAlertsByCreator(ctx context.Context, creatorID uuid.UUID) (int32, error)
- func (q *Queries) CountAgentBucketsByCreator(ctx context.Context, creatorID uuid.UUID) (CountAgentBucketsByCreatorRow, error)
- func (q *Queries) CountAgentExamplesByAgentID(ctx context.Context, agentID uuid.UUID) (int32, error)
- func (q *Queries) CountAgentTokensByCreator(ctx context.Context, creatorUserID uuid.UUID) (int32, error)
- func (q *Queries) CountAgentTokensByCreatorAndAgent(ctx context.Context, arg CountAgentTokensByCreatorAndAgentParams) (int32, error)
- func (q *Queries) CountAgentsByCreator(ctx context.Context, creatorID uuid.UUID) (int32, error)
- func (q *Queries) CountAgentsByCreatorFiltered(ctx context.Context, arg CountAgentsByCreatorFilteredParams) (int32, error)
- func (q *Queries) CountCallRecordsForUser(ctx context.Context, arg CountCallRecordsForUserParams) (int32, error)
- func (q *Queries) CountClaimableRuntimePullRuns(ctx context.Context, agentID uuid.UUID) (int32, error)
- func (q *Queries) CountParentRunsWithDelegationsByUser(ctx context.Context, arg CountParentRunsWithDelegationsByUserParams) (int32, error)
- func (q *Queries) CountPendingAgentsByCreator(ctx context.Context, creatorID uuid.UUID) (int32, error)
- func (q *Queries) CountPendingProxyRunsByNode(ctx context.Context, registryNodeID uuid.UUID) (int32, error)
- func (q *Queries) CountPublicAgents(ctx context.Context, arg CountPublicAgentsParams) (int32, error)
- func (q *Queries) CountPublicAgentsByCreator(ctx context.Context, creatorID uuid.UUID) (int32, error)
- func (q *Queries) CountRegistryListingLinksByNode(ctx context.Context, registryNodeID uuid.UUID) (int32, error)
- func (q *Queries) CountRunningDelegations(ctx context.Context) (int32, error)
- func (q *Queries) CountRunsByCreatorAgent(ctx context.Context, arg CountRunsByCreatorAgentParams) (int32, error)
- func (q *Queries) CountRunsByUser(ctx context.Context, userID uuid.UUID) (int32, error)
- func (q *Queries) CountRunsByUserAndAgent(ctx context.Context, arg CountRunsByUserAndAgentParams) (int32, error)
- func (q *Queries) CountRunsByUserThisMonth(ctx context.Context, userID uuid.UUID) (int32, error)
- func (q *Queries) CountRunsForCreatorThisMonth(ctx context.Context, creatorID uuid.UUID) (int32, error)
- func (q *Queries) CountTestCasesBySkill(ctx context.Context, skillID string) (int32, error)
- func (q *Queries) CountUnreadAgentAvailabilityAlertsByCreator(ctx context.Context, creatorID uuid.UUID) (int32, error)
- func (q *Queries) CountWorkflowRunsByWorkflow(ctx context.Context, workflowID uuid.UUID) (int32, error)
- func (q *Queries) CountWorkflowsByUser(ctx context.Context, userID uuid.UUID) (int32, error)
- func (q *Queries) CreateAdminUser(ctx context.Context, arg CreateAdminUserParams) (User, error)
- func (q *Queries) CreateAgent(ctx context.Context, arg CreateAgentParams) (Agent, error)
- func (q *Queries) CreateAgentApproval(ctx context.Context, arg CreateAgentApprovalParams) (AgentActionApprovalRequest, error)
- func (q *Queries) CreateAgentExample(ctx context.Context, arg CreateAgentExampleParams) (AgentExample, error)
- func (q *Queries) CreateAgentRuntimeToken(ctx context.Context, arg CreateAgentRuntimeTokenParams) (AgentRuntimeToken, error)
- func (q *Queries) CreateAgentToken(ctx context.Context, arg CreateAgentTokenParams) (AgentToken, error)
- func (q *Queries) CreateBenchmarkRun(ctx context.Context, arg CreateBenchmarkRunParams) (AgentSkillBenchmarkRun, error)
- func (q *Queries) CreateDeliveryTarget(ctx context.Context, arg CreateDeliveryTargetParams) (DeliveryTarget, error)
- func (q *Queries) CreatePendingWorkflowRun(ctx context.Context, arg CreatePendingWorkflowRunParams) (WorkflowRun, error)
- func (q *Queries) CreateProxyRun(ctx context.Context, arg CreateProxyRunParams) (ProxyRun, error)
- func (q *Queries) CreateProxyRunArtifact(ctx context.Context, arg CreateProxyRunArtifactParams) (ProxyRunArtifact, error)
- func (q *Queries) CreateRegistryFederationInvite(ctx context.Context, arg CreateRegistryFederationInviteParams) (RegistryFederationInvite, error)
- func (q *Queries) CreateRegistryNode(ctx context.Context, arg CreateRegistryNodeParams) (RegistryNode, error)
- func (q *Queries) CreateRegistryPeer(ctx context.Context, arg CreateRegistryPeerParams) (RegistryPeer, error)
- func (q *Queries) CreateRun(ctx context.Context, arg CreateRunParams) (Run, error)
- func (q *Queries) CreateRunArtifact(ctx context.Context, arg CreateRunArtifactParams) (RunArtifact, error)
- func (q *Queries) CreateRunArtifactChunk(ctx context.Context, arg CreateRunArtifactChunkParams) (RunArtifactChunk, error)
- func (q *Queries) CreateRunDelegation(ctx context.Context, arg CreateRunDelegationParams) (RunDelegation, error)
- func (q *Queries) CreateRunDelivery(ctx context.Context, arg CreateRunDeliveryParams) (RunDelivery, error)
- func (q *Queries) CreateRunEvent(ctx context.Context, arg CreateRunEventParams) (RunEvent, error)
- func (q *Queries) CreateRunMessage(ctx context.Context, arg CreateRunMessageParams) (RunMessage, error)
- func (q *Queries) CreateRunRequirementEvidence(ctx context.Context, arg CreateRunRequirementEvidenceParams) (RunRequirementEvidence, error)
- func (q *Queries) CreateSkillProposal(ctx context.Context, arg CreateSkillProposalParams) (SkillProposal, error)
- func (q *Queries) CreateTaskCallbackDelivery(ctx context.Context, arg CreateTaskCallbackDeliveryParams) (TaskCallbackDelivery, error)
- func (q *Queries) CreateTaskCallbackSubscription(ctx context.Context, arg CreateTaskCallbackSubscriptionParams) (TaskCallbackSubscription, error)
- func (q *Queries) CreateTaskQuery(ctx context.Context, arg CreateTaskQueryParams) (TaskQuery, error)
- func (q *Queries) CreateUser(ctx context.Context, arg CreateUserParams) (User, error)
- func (q *Queries) CreateWebhookDelivery(ctx context.Context, arg CreateWebhookDeliveryParams) (WebhookDelivery, error)
- func (q *Queries) CreateWorkflow(ctx context.Context, arg CreateWorkflowParams) (Workflow, error)
- func (q *Queries) CreateWorkflowNode(ctx context.Context, arg CreateWorkflowNodeParams) (WorkflowNode, error)
- func (q *Queries) CreateWorkflowRun(ctx context.Context, arg CreateWorkflowRunParams) (WorkflowRun, error)
- func (q *Queries) CreateWorkflowRunStep(ctx context.Context, arg CreateWorkflowRunStepParams) (WorkflowRunStep, error)
- func (q *Queries) DeleteAgentExampleForOwner(ctx context.Context, arg DeleteAgentExampleForOwnerParams) (int64, error)
- func (q *Queries) DeleteDeliveryTarget(ctx context.Context, arg DeleteDeliveryTargetParams) (int64, error)
- func (q *Queries) DeleteProxyRunArtifacts(ctx context.Context, proxyRunID uuid.UUID) error
- func (q *Queries) DeleteRegistryPeerForOwner(ctx context.Context, arg DeleteRegistryPeerForOwnerParams) (int64, error)
- func (q *Queries) DeleteTaskCallbackSubscriptionForOwner(ctx context.Context, arg DeleteTaskCallbackSubscriptionForOwnerParams) (int64, error)
- func (q *Queries) DeleteWorkflowRunSteps(ctx context.Context, workflowRunID uuid.UUID) error
- func (q *Queries) DisableAgent(ctx context.Context, arg DisableAgentParams) (int64, error)
- func (q *Queries) EnsureOnboardingStatus(ctx context.Context, agentID uuid.UUID) error
- func (q *Queries) ExpireAgentApprovals(ctx context.Context) (int64, error)
- func (q *Queries) GetA2AContextMappingByRun(ctx context.Context, runID uuid.UUID) (A2AContextMapping, error)
- func (q *Queries) GetActiveRegistryPeerForOwner(ctx context.Context, arg GetActiveRegistryPeerForOwnerParams) (RegistryPeer, error)
- func (q *Queries) GetAdminSummary(ctx context.Context) (GetAdminSummaryRow, error)
- func (q *Queries) GetAgentApprovalForCreator(ctx context.Context, arg GetAgentApprovalForCreatorParams) (AgentActionApprovalRequest, error)
- func (q *Queries) GetAgentAvailabilitySnapshot(ctx context.Context, agentID uuid.UUID) (AgentAvailabilitySnapshot, error)
- func (q *Queries) GetAgentByID(ctx context.Context, id uuid.UUID) (Agent, error)
- func (q *Queries) GetAgentByIDForOwner(ctx context.Context, arg GetAgentByIDForOwnerParams) (Agent, error)
- func (q *Queries) GetAgentBySlug(ctx context.Context, slug string) (GetAgentBySlugRow, error)
- func (q *Queries) GetAgentBySlugForOwner(ctx context.Context, arg GetAgentBySlugForOwnerParams) (GetAgentBySlugForOwnerRow, error)
- func (q *Queries) GetAgentCallPolicy(ctx context.Context, agentID uuid.UUID) (string, error)
- func (q *Queries) GetAgentCapabilityByAgentID(ctx context.Context, agentID uuid.UUID) (AgentCapability, error)
- func (q *Queries) GetAgentCapabilityBySlug(ctx context.Context, slug string) (AgentCapability, error)
- func (q *Queries) GetAgentSkillScore(ctx context.Context, arg GetAgentSkillScoreParams) (AgentSkillScore, error)
- func (q *Queries) GetAgentVerifiedSkillStats(ctx context.Context, agentID uuid.UUID) (GetAgentVerifiedSkillStatsRow, error)
- func (q *Queries) GetAgentWebhookConfig(ctx context.Context, id uuid.UUID) (GetAgentWebhookConfigRow, error)
- func (q *Queries) GetAgentsByIDs(ctx context.Context, ids []uuid.UUID) ([]GetAgentsByIDsRow, error)
- func (q *Queries) GetDefaultDeliveryTarget(ctx context.Context, userID uuid.UUID) (DeliveryTarget, error)
- func (q *Queries) GetDeliveryTargetByID(ctx context.Context, id uuid.UUID) (DeliveryTarget, error)
- func (q *Queries) GetDeliveryTargetByIDForUser(ctx context.Context, arg GetDeliveryTargetByIDForUserParams) (DeliveryTarget, error)
- func (q *Queries) GetFirstExampleInputByAgentID(ctx context.Context, agentID uuid.UUID) ([]byte, error)
- func (q *Queries) GetLatestRunEventForTypes(ctx context.Context, arg GetLatestRunEventForTypesParams) (RunEvent, error)
- func (q *Queries) GetOnboardingStatusForOwner(ctx context.Context, arg GetOnboardingStatusForOwnerParams) (AgentOnboardingStatus, error)
- func (q *Queries) GetProxyRunArtifactForRequester(ctx context.Context, arg GetProxyRunArtifactForRequesterParams) (ProxyRunArtifact, error)
- func (q *Queries) GetProxyRunForNode(ctx context.Context, arg GetProxyRunForNodeParams) (ProxyRun, error)
- func (q *Queries) GetProxyRunForRequester(ctx context.Context, arg GetProxyRunForRequesterParams) (ProxyRun, error)
- func (q *Queries) GetRegistryListingLinkForOwner(ctx context.Context, arg GetRegistryListingLinkForOwnerParams) (RegistryListingLink, error)
- func (q *Queries) GetRegistryListingLinkForProxyRun(ctx context.Context, registryListingID uuid.UUID) (RegistryListingLink, error)
- func (q *Queries) GetRegistryListingLinkRowForOwner(ctx context.Context, arg GetRegistryListingLinkRowForOwnerParams) (ListRegistryListingLinksByOwnerRow, error)
- func (q *Queries) GetRegistryNodeByIDForOwner(ctx context.Context, arg GetRegistryNodeByIDForOwnerParams) (RegistryNode, error)
- func (q *Queries) GetRunArtifactBySourceID(ctx context.Context, arg GetRunArtifactBySourceIDParams) (RunArtifact, error)
- func (q *Queries) GetRunByID(ctx context.Context, id uuid.UUID) (Run, error)
- func (q *Queries) GetRunDelegationByChild(ctx context.Context, childRunID uuid.UUID) (RunDelegation, error)
- func (q *Queries) GetRunDeliveryByID(ctx context.Context, id uuid.UUID) (GetRunDeliveryRow, error)
- func (q *Queries) GetRunRequirementEvidenceByRun(ctx context.Context, runID uuid.UUID) (RunRequirementEvidence, error)
- func (q *Queries) GetRuntimePullRunState(ctx context.Context, id uuid.UUID) (RuntimePullRunState, error)
- func (q *Queries) GetSkill(ctx context.Context, id string) (Skill, error)
- func (q *Queries) GetTaskCallbackDeliveryByID(ctx context.Context, id uuid.UUID) (GetTaskCallbackDeliveryByIDRow, error)
- func (q *Queries) GetTaskQuery(ctx context.Context, id uuid.UUID) (TaskQuery, error)
- func (q *Queries) GetUserByEmail(ctx context.Context, email string) (User, error)
- func (q *Queries) GetUserByID(ctx context.Context, id uuid.UUID) (User, error)
- func (q *Queries) GetUserByOAuth(ctx context.Context, arg GetUserByOAuthParams) (User, error)
- func (q *Queries) GetWebhookDeliveryByID(ctx context.Context, id uuid.UUID) (GetWebhookDeliveryRow, error)
- func (q *Queries) GetWorkflowByID(ctx context.Context, id uuid.UUID) (Workflow, error)
- func (q *Queries) GetWorkflowRunByID(ctx context.Context, id uuid.UUID) (WorkflowRun, error)
- func (q *Queries) HasRecentRuntimePullToken(ctx context.Context, agentID uuid.UUID) (bool, error)
- func (q *Queries) IncrementAgentStats(ctx context.Context, arg IncrementAgentStatsParams) error
- func (q *Queries) IncrementTaskCallbackSubscriptionFailure(ctx context.Context, id uuid.UUID) error
- func (q *Queries) ListA2AContextMappingsBeforeRunByRoot(ctx context.Context, arg ListA2AContextMappingsBeforeRunByRootParams) ([]A2AContextMapping, error)
- func (q *Queries) ListA2AContextMappingsByRoot(ctx context.Context, arg ListA2AContextMappingsByRootParams) ([]A2AContextMapping, error)
- func (q *Queries) ListActiveAgentRuntimeTokensByPrefix(ctx context.Context, prefix string) ([]AgentRuntimeToken, error)
- func (q *Queries) ListActiveAgentTokensByPrefix(ctx context.Context, prefix string) ([]AgentToken, error)
- func (q *Queries) ListActiveRegistryFederationInvitesByPrefixForUpdate(ctx context.Context, tokenPrefix string) ([]RegistryFederationInvite, error)
- func (q *Queries) ListActiveRegistryNodesBySecretPrefix(ctx context.Context, secretPrefix string) ([]RegistryNode, error)
- func (q *Queries) ListActiveRegistryPeersForAutoRoute(ctx context.Context, ownerUserID uuid.UUID) ([]RegistryPeer, error)
- func (q *Queries) ListActiveTaskCallbackSubscriptionsForEvent(ctx context.Context, arg ListActiveTaskCallbackSubscriptionsForEventParams) ([]TaskCallbackSubscription, error)
- func (q *Queries) ListAdminAgents(ctx context.Context, arg ListAdminAgentsParams) ([]ListAdminAgentsRow, error)
- func (q *Queries) ListAdminTasks(ctx context.Context, arg ListAdminTasksParams) ([]ListAdminTasksRow, error)
- func (q *Queries) ListAdminUsers(ctx context.Context, arg ListAdminUsersParams) ([]ListAdminUsersRow, error)
- func (q *Queries) ListAgentApprovalsForCreator(ctx context.Context, creatorID uuid.UUID) ([]AgentActionApprovalRequest, error)
- func (q *Queries) ListAgentAvailabilityAlertsByCreator(ctx context.Context, arg ListAgentAvailabilityAlertsByCreatorParams) ([]ListAgentAvailabilityAlertsByCreatorRow, error)
- func (q *Queries) ListAgentExamplesByAgentID(ctx context.Context, agentID uuid.UUID) ([]AgentExample, error)
- func (q *Queries) ListAgentExamplesBySlug(ctx context.Context, slug string) ([]AgentExample, error)
- func (q *Queries) ListAgentMetricSnapshotsByAgent(ctx context.Context, agentID uuid.UUID) ([]AgentMetricSnapshot, error)
- func (q *Queries) ListAgentRuntimeTokensForOwner(ctx context.Context, arg ListAgentRuntimeTokensForOwnerParams) ([]AgentRuntimeToken, error)
- func (q *Queries) ListAgentSkillScoresByAgent(ctx context.Context, agentID uuid.UUID) ([]AgentSkillScore, error)
- func (q *Queries) ListAgentSkillScoresBySlug(ctx context.Context, slug string) ([]AgentSkillScore, error)
- func (q *Queries) ListAgentSkills(ctx context.Context, agentID uuid.UUID) ([]Skill, error)
- func (q *Queries) ListAgentStatsForCreator(ctx context.Context, creatorID uuid.UUID) ([]ListAgentStatsForCreatorRow, error)
- func (q *Queries) ListAgentTokensByCreator(ctx context.Context, arg ListAgentTokensByCreatorParams) ([]AgentToken, error)
- func (q *Queries) ListAgentTokensByCreatorAndAgent(ctx context.Context, arg ListAgentTokensByCreatorAndAgentParams) ([]AgentToken, error)
- func (q *Queries) ListAgentsByCreator(ctx context.Context, creatorID uuid.UUID) ([]Agent, error)
- func (q *Queries) ListAgentsByCreatorPage(ctx context.Context, arg ListAgentsByCreatorPageParams) ([]ListAgentsByCreatorPageRow, error)
- func (q *Queries) ListAgentsBySkills(ctx context.Context, skillIDs []string) ([]AgentSkillMatch, error)
- func (q *Queries) ListAgentsBySkillsWithVerified(ctx context.Context, skillIDs []string) ([]AgentSkillMatchVerified, error)
- func (q *Queries) ListAgentsDueAvailabilityCheck(ctx context.Context, arg ListAgentsDueAvailabilityCheckParams) ([]Agent, error)
- func (q *Queries) ListBenchmarkBatchSummariesByAgent(ctx context.Context, arg ListBenchmarkBatchSummariesByAgentParams) ([]ListBenchmarkBatchSummariesByAgentRow, error)
- func (q *Queries) ListBenchmarkRunsByBatch(ctx context.Context, batchID uuid.UUID) ([]ListBenchmarkRunsByBatchRow, error)
- func (q *Queries) ListCallRecordsForUser(ctx context.Context, arg ListCallRecordsForUserParams) ([]ListCallRecordsForUserRow, error)
- func (q *Queries) ListChildRunsByParentAndUser(ctx context.Context, arg ListChildRunsByParentAndUserParams) ([]ListChildRunsByParentAndUserRow, error)
- func (q *Queries) ListDelegationLineage(ctx context.Context, arg ListDelegationLineageParams) ([]uuid.UUID, error)
- func (q *Queries) ListDeliveriesByAgent(ctx context.Context, arg ListDeliveriesByAgentParams) ([]WebhookDelivery, error)
- func (q *Queries) ListDeliveryTargetsByUser(ctx context.Context, userID uuid.UUID) ([]DeliveryTarget, error)
- func (q *Queries) ListParentRunsWithDelegationsByUser(ctx context.Context, arg ListParentRunsWithDelegationsByUserParams) ([]ListParentRunsWithDelegationsByUserRow, error)
- func (q *Queries) ListPendingAgents(ctx context.Context) ([]ListPendingAgentsRow, error)
- func (q *Queries) ListPendingDeliveries(ctx context.Context) ([]WebhookDelivery, error)
- func (q *Queries) ListPendingRunDeliveries(ctx context.Context) ([]RunDelivery, error)
- func (q *Queries) ListPendingTaskCallbackDeliveries(ctx context.Context) ([]TaskCallbackDelivery, error)
- func (q *Queries) ListProxyRunArtifactsForRequester(ctx context.Context, arg ListProxyRunArtifactsForRequesterParams) ([]ProxyRunArtifact, error)
- func (q *Queries) ListPublicAgents(ctx context.Context, arg ListPublicAgentsParams) ([]ListPublicAgentsRow, error)
- func (q *Queries) ListPublicTaskQueries(ctx context.Context, limit int32) ([]TaskQuery, error)
- func (q *Queries) ListRegistryListingLinksByOwner(ctx context.Context, ownerUserID uuid.UUID) ([]ListRegistryListingLinksByOwnerRow, error)
- func (q *Queries) ListRegistryNodesByOwner(ctx context.Context, ownerUserID uuid.UUID) ([]RegistryNode, error)
- func (q *Queries) ListRegistryPeersByOwner(ctx context.Context, ownerUserID uuid.UUID) ([]RegistryPeer, error)
- func (q *Queries) ListRunArtifactChunksByRun(ctx context.Context, runID uuid.UUID) ([]RunArtifactChunk, error)
- func (q *Queries) ListRunArtifactsByRun(ctx context.Context, runID uuid.UUID) ([]RunArtifact, error)
- func (q *Queries) ListRunDeliveriesByRun(ctx context.Context, runID uuid.UUID) ([]RunDelivery, error)
- func (q *Queries) ListRunDeliveriesByUser(ctx context.Context, arg ListRunDeliveriesByUserParams) ([]RunDelivery, error)
- func (q *Queries) ListRunEventsByRun(ctx context.Context, arg ListRunEventsByRunParams) ([]RunEvent, error)
- func (q *Queries) ListRunMessagesByRun(ctx context.Context, runID uuid.UUID) ([]RunMessage, error)
- func (q *Queries) ListRunMessagesByRuns(ctx context.Context, runIDs []uuid.UUID) ([]RunMessage, error)
- func (q *Queries) ListRunsByCreatorAgentWithAgent(ctx context.Context, arg ListRunsByCreatorAgentWithAgentParams) ([]ListRunsByCreatorAgentWithAgentRow, error)
- func (q *Queries) ListRunsByUser(ctx context.Context, arg ListRunsByUserParams) ([]Run, error)
- func (q *Queries) ListRunsByUserAndAgent(ctx context.Context, arg ListRunsByUserAndAgentParams) ([]Run, error)
- func (q *Queries) ListRunsByUserWithAgent(ctx context.Context, arg ListRunsByUserWithAgentParams) ([]ListRunsByUserWithAgentRow, error)
- func (q *Queries) ListSkillProposalsByOwner(ctx context.Context, ownerUserID uuid.UUID) ([]SkillProposal, error)
- func (q *Queries) ListSkills(ctx context.Context) ([]Skill, error)
- func (q *Queries) ListStaleEndpointRuns(ctx context.Context, arg ListStaleEndpointRunsParams) ([]ListStaleEndpointRunsRow, error)
- func (q *Queries) ListStaleRuntimePullRuns(ctx context.Context, arg ListStaleRuntimePullRunsParams) ([]ListStaleRuntimePullRunsRow, error)
- func (q *Queries) ListTaskCallbackDeliveriesByRun(ctx context.Context, arg ListTaskCallbackDeliveriesByRunParams) ([]ListTaskCallbackDeliveriesByRunRow, error)
- func (q *Queries) ListTaskCallbackSubscriptionsByOwner(ctx context.Context, arg ListTaskCallbackSubscriptionsByOwnerParams) ([]TaskCallbackSubscription, error)
- func (q *Queries) ListTaskCallbackSubscriptionsByRun(ctx context.Context, arg ListTaskCallbackSubscriptionsByRunParams) ([]TaskCallbackSubscription, error)
- func (q *Queries) ListTaskQueriesByUser(ctx context.Context, arg ListTaskQueriesByUserParams) ([]TaskQuery, error)
- func (q *Queries) ListTestCasesBySkill(ctx context.Context, skillID string) ([]SkillTestCase, error)
- func (q *Queries) ListTopAgentsBySkill(ctx context.Context, arg ListTopAgentsBySkillParams) ([]ListTopAgentsBySkillRow, error)
- func (q *Queries) ListWorkflowNodes(ctx context.Context, workflowID uuid.UUID) ([]WorkflowNode, error)
- func (q *Queries) ListWorkflowNodesByWorkflowIDs(ctx context.Context, workflowIds []uuid.UUID) ([]WorkflowNode, error)
- func (q *Queries) ListWorkflowRunSteps(ctx context.Context, workflowRunID uuid.UUID) ([]WorkflowRunStep, error)
- func (q *Queries) ListWorkflowRunStepsByRunIDs(ctx context.Context, workflowRunIds []uuid.UUID) ([]WorkflowRunStep, error)
- func (q *Queries) ListWorkflowRunsByWorkflow(ctx context.Context, arg ListWorkflowRunsByWorkflowParams) ([]WorkflowRun, error)
- func (q *Queries) ListWorkflowsByUser(ctx context.Context, arg ListWorkflowsByUserParams) ([]Workflow, error)
- func (q *Queries) MarkAgentAvailabilityAlertRead(ctx context.Context, arg MarkAgentAvailabilityAlertReadParams) (AgentAvailabilityAlert, error)
- func (q *Queries) MarkAgentAvailabilityFailure(ctx context.Context, agentID uuid.UUID) (AgentAvailabilitySnapshot, error)
- func (q *Queries) MarkAgentAvailabilityHeartbeat(ctx context.Context, agentID uuid.UUID) (AgentAvailabilitySnapshot, error)
- func (q *Queries) MarkAgentAvailabilitySuccess(ctx context.Context, agentID uuid.UUID) (AgentAvailabilitySnapshot, error)
- func (q *Queries) MarkBenchmarkRunFailed(ctx context.Context, arg MarkBenchmarkRunFailedParams) (int64, error)
- func (q *Queries) MarkBenchmarkRunSuccess(ctx context.Context, arg MarkBenchmarkRunSuccessParams) (int64, error)
- func (q *Queries) MarkCapabilitiesSet(ctx context.Context, agentID uuid.UUID) (int64, error)
- func (q *Queries) MarkDeliveryFailedFinal(ctx context.Context, arg MarkDeliveryFailedFinalParams) error
- func (q *Queries) MarkDeliveryFailedRetry(ctx context.Context, arg MarkDeliveryFailedRetryParams) error
- func (q *Queries) MarkDeliverySuccess(ctx context.Context, arg MarkDeliverySuccessParams) error
- func (q *Queries) MarkExamplesSet(ctx context.Context, arg MarkExamplesSetParams) (int64, error)
- func (q *Queries) MarkRegistryFederationInviteConsumed(ctx context.Context, id uuid.UUID) (int64, error)
- func (q *Queries) MarkRegistryFederationInviteExpired(ctx context.Context, id uuid.UUID) error
- func (q *Queries) MarkRegistryNodeHeartbeat(ctx context.Context, id uuid.UUID) (RegistryNode, error)
- func (q *Queries) MarkRegistryPeerUsed(ctx context.Context, arg MarkRegistryPeerUsedParams) error
- func (q *Queries) MarkRunDeliveryFailedFinal(ctx context.Context, arg MarkRunDeliveryFailedFinalParams) error
- func (q *Queries) MarkRunDeliveryFailedRetry(ctx context.Context, arg MarkRunDeliveryFailedRetryParams) error
- func (q *Queries) MarkRunDeliverySuccess(ctx context.Context, arg MarkRunDeliverySuccessParams) error
- func (q *Queries) MarkRunFailed(ctx context.Context, arg MarkRunFailedParams) error
- func (q *Queries) MarkRunSuccess(ctx context.Context, arg MarkRunSuccessParams) error
- func (q *Queries) MarkTaskCallbackDeliveryFailedFinal(ctx context.Context, arg MarkTaskCallbackDeliveryFailedFinalParams) error
- func (q *Queries) MarkTaskCallbackDeliveryFailedRetry(ctx context.Context, arg MarkTaskCallbackDeliveryFailedRetryParams) error
- func (q *Queries) MarkTaskCallbackDeliverySuccess(ctx context.Context, arg MarkTaskCallbackDeliverySuccessParams) error
- func (q *Queries) MarkTaskQueryChosen(ctx context.Context, arg MarkTaskQueryChosenParams) (TaskQuery, error)
- func (q *Queries) MarkWorkflowRunFailed(ctx context.Context, arg MarkWorkflowRunFailedParams) (WorkflowRun, error)
- func (q *Queries) MarkWorkflowRunStepFailed(ctx context.Context, arg MarkWorkflowRunStepFailedParams) (WorkflowRunStep, error)
- func (q *Queries) MarkWorkflowRunStepSuccess(ctx context.Context, arg MarkWorkflowRunStepSuccessParams) (WorkflowRunStep, error)
- func (q *Queries) MarkWorkflowRunSuccess(ctx context.Context, arg MarkWorkflowRunSuccessParams) (WorkflowRun, error)
- func (q *Queries) PauseWorkflowRun(ctx context.Context, id uuid.UUID) (WorkflowRun, error)
- func (q *Queries) PublishTaskQuery(ctx context.Context, arg PublishTaskQueryParams) (TaskQuery, error)
- func (q *Queries) RedeemPendingAgentToken(ctx context.Context, arg RedeemPendingAgentTokenParams) (AgentToken, error)
- func (q *Queries) RejectAgentApproval(ctx context.Context, arg RejectAgentApprovalParams) (int64, error)
- func (q *Queries) RejectCertification(ctx context.Context, arg RejectCertificationParams) (int64, error)
- func (q *Queries) ReleaseRuntimePullRunClaim(ctx context.Context, arg ReleaseRuntimePullRunClaimParams) error
- func (q *Queries) RequestCertification(ctx context.Context, arg RequestCertificationParams) (int64, error)
- func (q *Queries) RequestTaskRevision(ctx context.Context, arg RequestTaskRevisionParams) (TaskQuery, error)
- func (q *Queries) RequeueStaleWorkflowRuns(ctx context.Context, before time.Time) (int64, error)
- func (q *Queries) ResetRunDeliveryForRetry(ctx context.Context, arg ResetRunDeliveryForRetryParams) (int64, error)
- func (q *Queries) ResetTaskCallbackSubscriptionFailures(ctx context.Context, id uuid.UUID) error
- func (q *Queries) ResumeWorkflowRun(ctx context.Context, id uuid.UUID) (WorkflowRun, error)
- func (q *Queries) RevokeAgentRuntimeTokenForOwner(ctx context.Context, arg RevokeAgentRuntimeTokenForOwnerParams) (int64, error)
- func (q *Queries) RevokeAgentTokenForCreator(ctx context.Context, arg RevokeAgentTokenForCreatorParams) (int64, error)
- func (q *Queries) RevokeRegistryNodeForOwner(ctx context.Context, arg RevokeRegistryNodeForOwnerParams) (RegistryNode, error)
- func (q *Queries) RotateRegistryNodeSecretForOwner(ctx context.Context, arg RotateRegistryNodeSecretForOwnerParams) (RegistryNode, error)
- func (q *Queries) RunsCount(ctx context.Context) (int32, error)
- func (q *Queries) SetAgentVisibilityForOwner(ctx context.Context, arg SetAgentVisibilityForOwnerParams) error
- func (q *Queries) SetAgentWebhook(ctx context.Context, arg SetAgentWebhookParams) (int64, error)
- func (q *Queries) SetDeliveryTargetDefault(ctx context.Context, arg SetDeliveryTargetDefaultParams) (int64, error)
- func (q *Queries) SumEarningsByCreatorThisMonth(ctx context.Context, creatorID uuid.UUID) (int64, error)
- func (q *Queries) SumSpentByUserThisMonth(ctx context.Context, userID uuid.UUID) (int64, error)
- func (q *Queries) SyncRegistryListingMetadataByNode(ctx context.Context, registryNodeID uuid.UUID) (int32, error)
- func (q *Queries) SyncRegistryListingMetadataForOwner(ctx context.Context, arg SyncRegistryListingMetadataForOwnerParams) (ListRegistryListingLinksByOwnerRow, error)
- func (q *Queries) TimeoutStaleProxyRuns(ctx context.Context, staleBefore time.Time) (int32, error)
- func (q *Queries) TouchAgentRuntimeToken(ctx context.Context, id uuid.UUID) error
- func (q *Queries) UpdateAdminAgentModeration(ctx context.Context, arg UpdateAdminAgentModerationParams) (Agent, error)
- func (q *Queries) UpdateAdminUserFlags(ctx context.Context, arg UpdateAdminUserFlagsParams) (User, error)
- func (q *Queries) UpdateAgentDraft(ctx context.Context, arg UpdateAgentDraftParams) (Agent, error)
- func (q *Queries) UpdateDeliveryTargetConfig(ctx context.Context, arg UpdateDeliveryTargetConfigParams) (DeliveryTarget, error)
- func (q *Queries) UpdateDryRunResult(ctx context.Context, arg UpdateDryRunResultParams) (int64, error)
- func (q *Queries) UpdateRegistryListingLinkStatusForOwner(ctx context.Context, arg UpdateRegistryListingLinkStatusForOwnerParams) (ListRegistryListingLinksByOwnerRow, error)
- func (q *Queries) UpdateRunArtifactContent(ctx context.Context, arg UpdateRunArtifactContentParams) (RunArtifact, error)
- func (q *Queries) UpdateTaskCallbackSubscriptionStatusForOwner(ctx context.Context, arg UpdateTaskCallbackSubscriptionStatusForOwnerParams) (TaskCallbackSubscription, error)
- func (q *Queries) UpdateUserBecomeCreator(ctx context.Context, id uuid.UUID) (int64, error)
- func (q *Queries) UpdateUserOAuth(ctx context.Context, arg UpdateUserOAuthParams) error
- func (q *Queries) UpsertA2AContextMapping(ctx context.Context, arg UpsertA2AContextMappingParams) (A2AContextMapping, error)
- func (q *Queries) UpsertAgentAvailabilityAlert(ctx context.Context, arg UpsertAgentAvailabilityAlertParams) (AgentAvailabilityAlert, error)
- func (q *Queries) UpsertAgentCallPolicyForOwner(ctx context.Context, arg UpsertAgentCallPolicyForOwnerParams) (AgentCallPolicy, error)
- func (q *Queries) UpsertAgentCapability(ctx context.Context, arg UpsertAgentCapabilityParams) (AgentCapability, error)
- func (q *Queries) UpsertAgentMetricSnapshot(ctx context.Context, arg UpsertAgentMetricSnapshotParams) error
- func (q *Queries) UpsertAgentSkillScore(ctx context.Context, arg UpsertAgentSkillScoreParams) (AgentSkillScore, error)
- func (q *Queries) UpsertRegistryListingLink(ctx context.Context, arg UpsertRegistryListingLinkParams) (RegistryListingLink, error)
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
- type RedeemPendingAgentTokenParams
- type RegistryFederationInvite
- type RegistryListingLink
- type RegistryNode
- type RegistryPeer
- type RejectAgentApprovalParams
- type RejectCertificationParams
- type ReleaseRuntimePullRunClaimParams
- type RequestCertificationParams
- type RequestTaskRevisionParams
- type ResetRunDeliveryForRetryParams
- type RevokeAgentRuntimeTokenForOwnerParams
- type RevokeAgentTokenForCreatorParams
- type RevokeRegistryNodeForOwnerParams
- type RotateRegistryNodeSecretForOwnerParams
- type Run
- type RunArtifact
- type RunArtifactChunk
- type RunDelegation
- type RunDelivery
- type RunEvent
- type RunMessage
- type RunRequirementEvidence
- type RuntimePullRunState
- type SetAgentVisibilityForOwnerParams
- type SetAgentWebhookParams
- type SetDeliveryTargetDefaultParams
- type Skill
- type SkillProposal
- type SkillTestCase
- type SyncRegistryListingMetadataForOwnerParams
- type TaskCallbackDelivery
- type TaskCallbackSubscription
- type TaskQuery
- type UpdateAdminAgentModerationParams
- type UpdateAdminUserFlagsParams
- type UpdateAgentDraftParams
- type UpdateDeliveryTargetConfigParams
- type UpdateDryRunResultParams
- type UpdateRegistryListingLinkStatusForOwnerParams
- type UpdateRunArtifactContentParams
- type UpdateTaskCallbackSubscriptionStatusForOwnerParams
- type UpdateUserOAuthParams
- type UpsertA2AContextMappingParams
- type UpsertAgentAvailabilityAlertParams
- type UpsertAgentCallPolicyForOwnerParams
- type UpsertAgentCapabilityParams
- type UpsertAgentMetricSnapshotParams
- type UpsertAgentSkillScoreParams
- type UpsertRegistryListingLinkParams
- type User
- type WebhookDelivery
- type Workflow
- type WorkflowNode
- type WorkflowRun
- type WorkflowRunStep
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ReplaceAgentSkills ¶
ReplaceAgentSkills 在事务内用新 skillIDs 覆盖某 Agent 的关联。
调用方负责 BeginTx + Commit/Rollback;本函数只负责在传入 tx 上执行 DELETE + 批量 INSERT。skillIDs 为空时仅清空。
调用约束:
- skillIDs 必须已被调用方校验(存在性 + 上限)
- 由于 PRIMARY KEY (agent_id, skill_id),重复元素会让 INSERT 失败; 调用方应保证去重。
Types ¶
type A2AContextMapping ¶
type A2AContextMapping struct {
ID uuid.UUID `db:"id" json:"id"`
RunID uuid.UUID `db:"run_id" json:"run_id"`
UserID uuid.UUID `db:"user_id" json:"user_id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
ProtocolContextID string `db:"protocol_context_id" json:"protocol_context_id"`
ProtocolTaskID string `db:"protocol_task_id" json:"protocol_task_id"`
RootContextID string `db:"root_context_id" json:"root_context_id"`
ParentContextID string `db:"parent_context_id" json:"parent_context_id"`
ParentTaskID string `db:"parent_task_id" json:"parent_task_id"`
ParentRunID *uuid.UUID `db:"parent_run_id" json:"parent_run_id"`
CallerAgentID *uuid.UUID `db:"caller_agent_id" json:"caller_agent_id"`
TargetAgentID *uuid.UUID `db:"target_agent_id" json:"target_agent_id"`
TraceID string `db:"trace_id" json:"trace_id"`
ReferenceTaskIDs []string `db:"reference_task_ids" json:"reference_task_ids"`
Source string `db:"source" json:"source"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
A2AContextMapping links protocol context/task ids to OpenLinker run lineage.
type Agent ¶
type Agent struct {
ID uuid.UUID `db:"id" json:"id"`
CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
Slug string `db:"slug" json:"slug"`
Name string `db:"name" json:"name"`
Description string `db:"description" json:"description"`
EndpointURL string `db:"endpoint_url" json:"endpoint_url"`
EndpointAuthHeader *string `db:"endpoint_auth_header" json:"endpoint_auth_header"`
PricePerCallCents int32 `db:"price_per_call_cents" json:"price_per_call_cents"`
Tags []string `db:"tags" json:"tags"`
LifecycleStatus string `db:"lifecycle_status" json:"lifecycle_status"`
Visibility string `db:"visibility" json:"visibility"`
CertificationStatus string `db:"certification_status" json:"certification_status"`
RejectionReason *string `db:"rejection_reason" json:"rejection_reason"`
CertifiedAt *time.Time `db:"certified_at" json:"certified_at"`
TotalCalls int32 `db:"total_calls" json:"total_calls"`
TotalRevenueCents int64 `db:"total_revenue_cents" json:"total_revenue_cents"`
WebhookURL *string `db:"webhook_url" json:"webhook_url"`
WebhookSecret *string `db:"webhook_secret" json:"-"` // 不暴露给前端
ConnectionMode string `db:"connection_mode" json:"connection_mode"`
MCPToolName *string `db:"mcp_tool_name" json:"mcp_tool_name"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
Agent 对应 agents 表(Phase 2 缺口 2 后的三维状态机模型)。
lifecycle_status active | disabled (docs/29 §三) visibility public | unlisted | private certification_status unreviewed | pending | certified | rejected 金额:price_per_call_cents 用 int32(INTEGER);累计 total_revenue_cents 用 int64(BIGINT)。 tags 用 []string(Postgres TEXT[])。 webhook_url / webhook_secret 子轮 2.1 引入,可为 NULL(未配置)。
type AgentActionApprovalRequest ¶
type AgentActionApprovalRequest struct {
ID uuid.UUID `db:"id" json:"id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
RequestedByUserID *uuid.UUID `db:"requested_by_user_id" json:"requested_by_user_id"`
RequestedByTokenID *uuid.UUID `db:"requested_by_token_id" json:"requested_by_token_id"`
Action string `db:"action" json:"action"`
PayloadJSON []byte `db:"payload_json" json:"payload_json"`
Status string `db:"status" json:"status"`
ApprovalURLSlug string `db:"approval_url_slug" json:"approval_url_slug"`
ExpiresAt time.Time `db:"expires_at" json:"expires_at"`
DecidedAt *time.Time `db:"decided_at" json:"decided_at"`
DecidedByUserID *uuid.UUID `db:"decided_by_user_id" json:"decided_by_user_id"`
DecisionNote *string `db:"decision_note" json:"decision_note"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
}
AgentActionApprovalRequest Phase 2 缺口 2:高风险动作审批记录(docs/29 §3.4)。
status: 'pending' | 'confirmed' | 'rejected' | 'expired' PayloadJSON 是 JSONB 原始字节,调用方按 action 解析。 RequestedByTokenID 允许 NULL:人类直接发起的审批不绑 Runtime Token。
type AgentAvailabilityAlert ¶
type AgentAvailabilityAlert struct {
ID uuid.UUID `db:"id" json:"id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
AlertType string `db:"alert_type" json:"alert_type"`
Severity string `db:"severity" json:"severity"`
AvailabilityStatus string `db:"availability_status" json:"availability_status"`
ConsecutiveFailures int32 `db:"consecutive_failures" json:"consecutive_failures"`
Title string `db:"title" json:"title"`
Message string `db:"message" json:"message"`
LastError *string `db:"last_error" json:"last_error"`
RepairHints []string `db:"repair_hints" json:"repair_hints"`
ReadAt *time.Time `db:"read_at" json:"read_at"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
AgentAvailabilityAlert 是创作者侧站内可用性告警。
type AgentAvailabilitySnapshot ¶
type AgentAvailabilitySnapshot struct {
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
AvailabilityStatus string `db:"availability_status" json:"availability_status"`
LastSuccessfulRunAt *time.Time `db:"last_successful_run_at" json:"last_successful_run_at"`
LastFailedRunAt *time.Time `db:"last_failed_run_at" json:"last_failed_run_at"`
LastCheckedAt *time.Time `db:"last_checked_at" json:"last_checked_at"`
ConsecutiveFailures int32 `db:"consecutive_failures" json:"consecutive_failures"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
AgentAvailabilitySnapshot 对应 agent_availability_snapshots 表。
availability_status: unknown | healthy | degraded | unreachable
type AgentCallPolicy ¶
type AgentCallPolicy struct {
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
CallableBy string `db:"callable_by" json:"callable_by"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
AgentCallPolicy 控制目标 Agent 是否接受来自其他 Agent 的平台代理调用。
type AgentCapability ¶
type AgentCapability struct {
ID uuid.UUID `db:"id" json:"id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
InputSchema []byte `db:"input_schema" json:"input_schema"`
OutputSchema []byte `db:"output_schema" json:"output_schema"`
Summary string `db:"summary" json:"summary"`
Version int32 `db:"version" json:"version"`
PublishedAt time.Time `db:"published_at" json:"published_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
AgentCapability 对应 agent_capabilities 表。
模块 A(Phase 2 §4):当前版本的能力声明(JSON Schema input/output)。 input_schema / output_schema 是 JSONB([]byte,原样透传,业务层负责解码 + 校验 draft-07)。 version 在 upsert 时自增;published_at 反映最近一次发布时间。
type AgentExample ¶
type AgentExample struct {
ID uuid.UUID `db:"id" json:"id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
Title string `db:"title" json:"title"`
InputJSON []byte `db:"input_json" json:"input_json"`
ExpectedOutputJSON []byte `db:"expected_output_json" json:"expected_output_json"`
SortOrder int32 `db:"sort_order" json:"sort_order"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
AgentExample 对应 agent_examples 表。
input_json 必填;expected_output_json 可空(dry-run 仅校验结构,benchmark 才比对)。 sort_order 决定展示与 dry-run 取首条的顺序。
type AgentMetricSnapshot ¶
type AgentMetricSnapshot struct {
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
TimeWindow string `db:"time_window" json:"time_window"`
CallCount int32 `db:"call_count" json:"call_count"`
SuccessCount int32 `db:"success_count" json:"success_count"`
FailureCount int32 `db:"failure_count" json:"failure_count"`
SuccessRateBps int32 `db:"success_rate_bps" json:"success_rate_bps"`
MedianLatencyMs *int32 `db:"median_latency_ms" json:"median_latency_ms"`
P95LatencyMs *int32 `db:"p95_latency_ms" json:"p95_latency_ms"`
SnapshottedAt time.Time `db:"snapshotted_at" json:"snapshotted_at"`
}
AgentMetricSnapshot Phase 2 缺口 2:Agent 指标快照(docs/29 §3.4)。 由 metric worker 每 5 分钟为每个 active Agent × {24h, 7d, 30d} upsert 一行。
type AgentOnboardingStatus ¶
type AgentOnboardingStatus struct {
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
EndpointSet bool `db:"endpoint_set" json:"endpoint_set"`
CapabilitiesSet bool `db:"capabilities_set" json:"capabilities_set"`
ExamplesSet bool `db:"examples_set" json:"examples_set"`
DryRunPassed bool `db:"dry_run_passed" json:"dry_run_passed"`
DryRunLastResult string `db:"dry_run_last_result" json:"dry_run_last_result"`
DryRunError *string `db:"dry_run_error" json:"dry_run_error"`
DryRunAt *time.Time `db:"dry_run_at" json:"dry_run_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
AgentOnboardingStatus 对应 agent_onboarding_status 表。
与 agents 1:1。endpoint_set 在 CreateAgent 后由 EnsureOnboardingStatus 写入 TRUE。 dry_run_last_result: 'pending' | 'pass' | 'fail'。
type AgentRuntimeToken ¶
type AgentRuntimeToken struct {
ID uuid.UUID `db:"id" json:"id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
CreatedByUserID uuid.UUID `db:"created_by_user_id" json:"created_by_user_id"`
Name string `db:"name" json:"name"`
Prefix string `db:"prefix" json:"prefix"`
TokenHash string `db:"token_hash" json:"-"`
Scopes []string `db:"scopes" json:"scopes"`
LastUsedAt *time.Time `db:"last_used_at" json:"last_used_at"`
RevokedAt *time.Time `db:"revoked_at" json:"revoked_at"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
ConnectionMode string `db:"connection_mode" json:"connection_mode"`
}
AgentRuntimeToken 是绑定单个 Agent 的自动化调用凭证。 明文 token 仅创建时返回,数据库只保存 hash 与显示用 prefix。
type AgentSkill ¶
type AgentSkill struct {
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
SkillID string `db:"skill_id" json:"skill_id"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
}
AgentSkill 对应 agent_skills 关联表。
type AgentSkillBenchmarkRun ¶
type AgentSkillBenchmarkRun struct {
ID uuid.UUID `db:"id" json:"id"`
BatchID uuid.UUID `db:"batch_id" json:"batch_id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
SkillID string `db:"skill_id" json:"skill_id"`
TestCaseID uuid.UUID `db:"test_case_id" json:"test_case_id"`
Status string `db:"status" json:"status"`
Score *int32 `db:"score" json:"score"`
RawOutput []byte `db:"raw_output" json:"raw_output"`
JudgeReasoning *string `db:"judge_reasoning" json:"judge_reasoning"`
ErrorMessage *string `db:"error_message" json:"error_message"`
StartedAt time.Time `db:"started_at" json:"started_at"`
FinishedAt *time.Time `db:"finished_at" json:"finished_at"`
}
AgentSkillBenchmarkRun 对应 agent_skill_benchmark_runs 表。
单条 case 的执行记录。status: 'pending' | 'success' | 'failed'。 score 仅 success 非空(0-100);raw_output / judge_reasoning 仅 success 写入。 同一次"跑某 skill"的多条 case 共享 batch_id。
type AgentSkillMatch ¶
type AgentSkillMatch struct {
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
MatchCount int32 `db:"match_count" json:"match_count"`
TotalCalls int32 `db:"total_calls" json:"total_calls"`
}
AgentSkillMatch 推荐结果行:命中了多少个输入 skill + 累计调用次数。
type AgentSkillMatchVerified ¶
type AgentSkillMatchVerified struct {
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
MatchCount int32 `db:"match_count" json:"match_count"`
VerifiedCount int32 `db:"verified_count" json:"verified_count"`
TotalCalls int32 `db:"total_calls" json:"total_calls"`
}
AgentSkillMatchVerified 推荐结果行(带 verified 加权)。
type AgentSkillScore ¶
type AgentSkillScore struct {
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
SkillID string `db:"skill_id" json:"skill_id"`
Status string `db:"status" json:"status"`
AverageScore *int32 `db:"average_score" json:"average_score"`
PassCount int32 `db:"pass_count" json:"pass_count"`
TotalCount int32 `db:"total_count" json:"total_count"`
LastBatchID *uuid.UUID `db:"last_batch_id" json:"last_batch_id"`
VerifiedAt *time.Time `db:"verified_at" json:"verified_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
AgentSkillScore 对应 agent_skill_scores 表(聚合)。
status: 'pending' | 'verified' | 'failed' verified = 平均分 >= 阈值(service 中配置,默认 75)。
type AgentToken ¶
type AgentToken struct {
ID uuid.UUID `db:"id" json:"id"`
AgentID *uuid.UUID `db:"agent_id" json:"agent_id"`
CreatorUserID uuid.UUID `db:"creator_user_id" json:"creator_user_id"`
Name string `db:"name" json:"name"`
Prefix string `db:"prefix" json:"prefix"`
TokenHash string `db:"token_hash" json:"-"`
Scopes []string `db:"scopes" json:"scopes"`
Status string `db:"status" json:"status"`
ExpiresAt *time.Time `db:"expires_at" json:"expires_at"`
RedeemedAt *time.Time `db:"redeemed_at" json:"redeemed_at"`
LastUsedAt *time.Time `db:"last_used_at" json:"last_used_at"`
RevokedAt *time.Time `db:"revoked_at" json:"revoked_at"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
}
AgentToken 是统一 Agent 接入凭证。pending_registration 阶段 agent_id 为空; 注册成功后同一 token 转为 active_runtime 并绑定单个 Agent。
type AggregateAgentRunsForWindowRow ¶
type AggregateAgentRunsForWindowRow struct {
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
CallCount int32 `db:"call_count" json:"call_count"`
SuccessCount int32 `db:"success_count" json:"success_count"`
FailureCount int32 `db:"failure_count" json:"failure_count"`
MedianLatencyMs *int32 `db:"median_latency_ms" json:"median_latency_ms"`
P95LatencyMs *int32 `db:"p95_latency_ms" json:"p95_latency_ms"`
}
AggregateAgentRunsForWindowRow worker 聚合返回行。
type CancelRunParams ¶
type ClaimTaskQueryParams ¶
type ClearAgentWebhookParams ¶
type ClearAgentWebhookParams struct {
ID uuid.UUID `db:"id" json:"id"`
CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
}
ClearAgentWebhookParams 入参。
type CompleteProxyRunParams ¶
type CompleteProxyRunParams struct {
ID uuid.UUID `db:"id" json:"id"`
RegistryNodeID uuid.UUID `db:"registry_node_id" json:"registry_node_id"`
Status string `db:"status" json:"status"`
Output []byte `db:"output" json:"output"`
OutputSummary *string `db:"output_summary" json:"output_summary"`
ErrorCode *string `db:"error_code" json:"error_code"`
ErrorMessage *string `db:"error_message" json:"error_message"`
Retryable bool `db:"retryable" json:"retryable"`
RetryAfterSecs int32 `db:"retry_after_secs" json:"retry_after_secs"`
}
type CompleteTaskQueryParams ¶
type CompleteTaskQueryParams struct {
ID uuid.UUID `db:"id" json:"id"`
UserID uuid.UUID `db:"user_id" json:"user_id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
CompletionRunID uuid.UUID `db:"completion_run_id" json:"completion_run_id"`
CompletionSummary string `db:"completion_summary" json:"completion_summary"`
DeliveryArtifact []byte `db:"delivery_artifact" json:"delivery_artifact"`
DeliveryVisibility string `db:"delivery_visibility" json:"delivery_visibility"`
}
type CountAdminAgentsParams ¶
type CountAdminTasksParams ¶
type CountAdminUsersParams ¶
type CountAgentBucketsByCreatorRow ¶ added in v0.1.14
type CountAgentBucketsByCreatorRow struct {
Total int32 `db:"total" json:"total"`
Online int32 `db:"online" json:"online"`
Public int32 `db:"public" json:"public"`
Unlisted int32 `db:"unlisted" json:"unlisted"`
Private int32 `db:"private" json:"private"`
Pending int32 `db:"pending" json:"pending"`
}
type CountAgentTokensByCreatorAndAgentParams ¶ added in v0.1.7
type CountAgentsByCreatorFilteredParams ¶ added in v0.1.14
type CountAgentsByCreatorFilteredParams struct {
CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
Query string `db:"query" json:"query"`
Status string `db:"status" json:"status"`
Visibility string `db:"visibility" json:"visibility"`
CertificationStatus string `db:"certification_status" json:"certification_status"`
}
type CountCallRecordsForUserParams ¶ added in v0.1.14
type CountPublicAgentsParams ¶
type CountRunsByCreatorAgentParams ¶
type CountRunsByCreatorAgentParams struct {
CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
}
CountRunsByCreatorAgentParams 入参。
type CountRunsByUserAndAgentParams ¶
type CountRunsByUserAndAgentParams struct {
UserID uuid.UUID `db:"user_id" json:"user_id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
NoStatusFilter bool `db:"no_status_filter" json:"no_status_filter"`
Statuses []string `db:"statuses" json:"statuses"`
NoSinceFilter bool `db:"no_since_filter" json:"no_since_filter"`
Since time.Time `db:"since" json:"since"`
ContextID string `db:"context_id" json:"context_id"`
}
type CreateAdminUserParams ¶
type CreateAdminUserParams struct {
Email string `db:"email" json:"email"`
PasswordHash *string `db:"password_hash" json:"password_hash"`
DisplayName string `db:"display_name" json:"display_name"`
IsAdmin bool `db:"is_admin" json:"is_admin"`
IsCreator bool `db:"is_creator" json:"is_creator"`
CreatorVerified bool `db:"creator_verified" json:"creator_verified"`
}
CreateAdminUserParams 入参(管理台创建用户)。
type CreateAgentApprovalParams ¶
type CreateAgentApprovalParams struct {
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
RequestedByUserID *uuid.UUID `db:"requested_by_user_id" json:"requested_by_user_id"`
RequestedByTokenID *uuid.UUID `db:"requested_by_token_id" json:"requested_by_token_id"`
Action string `db:"action" json:"action"`
PayloadJSON []byte `db:"payload_json" json:"payload_json"`
ApprovalURLSlug string `db:"approval_url_slug" json:"approval_url_slug"`
ExpiresAt time.Time `db:"expires_at" json:"expires_at"`
}
type CreateAgentExampleParams ¶
type CreateAgentExampleParams struct {
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
Title string `db:"title" json:"title"`
InputJSON []byte `db:"input_json" json:"input_json"`
ExpectedOutputJSON []byte `db:"expected_output_json" json:"expected_output_json"`
SortOrder int32 `db:"sort_order" json:"sort_order"`
}
type CreateAgentParams ¶
type CreateAgentParams struct {
CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
Slug string `db:"slug" json:"slug"`
Name string `db:"name" json:"name"`
Description string `db:"description" json:"description"`
EndpointURL string `db:"endpoint_url" json:"endpoint_url"`
EndpointAuthHeader *string `db:"endpoint_auth_header" json:"endpoint_auth_header"`
PricePerCallCents int32 `db:"price_per_call_cents" json:"price_per_call_cents"`
Tags []string `db:"tags" json:"tags"`
Visibility string `db:"visibility" json:"visibility"`
ConnectionMode string `db:"connection_mode" json:"connection_mode"`
MCPToolName *string `db:"mcp_tool_name" json:"mcp_tool_name"`
}
CreateAgentParams 入参。
type CreateAgentRuntimeTokenParams ¶
type CreateAgentRuntimeTokenParams struct {
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
CreatedByUserID uuid.UUID `db:"created_by_user_id" json:"created_by_user_id"`
Name string `db:"name" json:"name"`
Prefix string `db:"prefix" json:"prefix"`
TokenHash string `db:"token_hash" json:"-"`
Scopes []string `db:"scopes" json:"scopes"`
}
type CreateAgentTokenParams ¶
type CreateAgentTokenParams struct {
AgentID *uuid.UUID `db:"agent_id" json:"agent_id"`
CreatorUserID uuid.UUID `db:"creator_user_id" json:"creator_user_id"`
Name string `db:"name" json:"name"`
Prefix string `db:"prefix" json:"prefix"`
TokenHash string `db:"token_hash" json:"-"`
Scopes []string `db:"scopes" json:"scopes"`
Status string `db:"status" json:"status"`
ExpiresAt *time.Time `db:"expires_at" json:"expires_at"`
RedeemedAt *time.Time `db:"redeemed_at" json:"redeemed_at"`
}
type CreateProxyRunArtifactParams ¶
type CreateProxyRunArtifactParams struct {
ProxyRunID uuid.UUID `db:"proxy_run_id" json:"proxy_run_id"`
RegistryRunID uuid.UUID `db:"registry_run_id" json:"registry_run_id"`
SourceArtifactID string `db:"source_artifact_id" json:"source_artifact_id"`
ArtifactType string `db:"artifact_type" json:"artifact_type"`
Title string `db:"title" json:"title"`
Content []byte `db:"content" json:"content"`
MimeType *string `db:"mime_type" json:"mime_type"`
FileURI *string `db:"file_uri" json:"file_uri"`
FileName *string `db:"file_name" json:"file_name"`
FileSHA256 *string `db:"file_sha256" json:"file_sha256"`
FileSizeBytes *int64 `db:"file_size_bytes" json:"file_size_bytes"`
}
type CreateProxyRunParams ¶
type CreateProxyRunParams struct {
RegistryListingID uuid.UUID `db:"registry_listing_id" json:"registry_listing_id"`
RegistryListingLinkID uuid.UUID `db:"registry_listing_link_id" json:"registry_listing_link_id"`
RequestingUserID uuid.UUID `db:"requesting_user_id" json:"requesting_user_id"`
IdempotencyKey string `db:"idempotency_key" json:"idempotency_key"`
Input []byte `db:"input" json:"input"`
InputSummary *string `db:"input_summary" json:"input_summary"`
NodeInput []byte `db:"node_input" json:"node_input"`
}
type CreateRegistryFederationInviteParams ¶
type CreateRegistryFederationInviteParams struct {
OwnerUserID uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
Name string `db:"name" json:"name"`
APIBaseURL string `db:"api_base_url" json:"api_base_url"`
BearerToken string `db:"bearer_token" json:"-"`
TokenPrefix string `db:"token_prefix" json:"token_prefix"`
TokenHash string `db:"token_hash" json:"-"`
CredentialHint string `db:"credential_hint" json:"credential_hint"`
ExpiresInSeconds int32 `db:"expires_in_seconds" json:"expires_in_seconds"`
}
type CreateRegistryNodeParams ¶
type CreateRegistryNodeParams struct {
OwnerUserID uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
NodeName string `db:"node_name" json:"node_name"`
NodeType string `db:"node_type" json:"node_type"`
BaseURL *string `db:"base_url" json:"base_url"`
SecretPrefix string `db:"secret_prefix" json:"secret_prefix"`
SecretHash string `db:"secret_hash" json:"secret_hash"`
Scopes []string `db:"scopes" json:"scopes"`
}
type CreateRegistryPeerParams ¶
type CreateRegistryPeerParams struct {
OwnerUserID uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
Name string `db:"name" json:"name"`
APIBaseURL string `db:"api_base_url" json:"api_base_url"`
BearerToken string `db:"bearer_token" json:"-"`
CredentialHint string `db:"credential_hint" json:"credential_hint"`
Status string `db:"status" json:"status"`
}
type CreateRunArtifactChunkParams ¶
type CreateRunArtifactChunkParams struct {
RunID uuid.UUID `db:"run_id" json:"run_id"`
RunArtifactID uuid.UUID `db:"run_artifact_id" json:"run_artifact_id"`
SourceArtifactID string `db:"source_artifact_id" json:"source_artifact_id"`
EventSequence *int32 `db:"event_sequence" json:"event_sequence"`
Append bool `db:"append" json:"append"`
LastChunk bool `db:"last_chunk" json:"last_chunk"`
Parts []byte `db:"parts" json:"parts"`
Payload []byte `db:"payload" json:"payload"`
PartsSha256 *string `db:"parts_sha256" json:"parts_sha256"`
PayloadSha256 *string `db:"payload_sha256" json:"payload_sha256"`
DeclaredSha256 *string `db:"declared_sha256" json:"declared_sha256"`
ChecksumStatus string `db:"checksum_status" json:"checksum_status"`
}
type CreateRunArtifactParams ¶
type CreateRunArtifactParams struct {
RunID uuid.UUID `db:"run_id" json:"run_id"`
ArtifactType string `db:"artifact_type" json:"artifact_type"`
Title string `db:"title" json:"title"`
Content []byte `db:"content" json:"content"`
Visibility string `db:"visibility" json:"visibility"`
SourceArtifactID *string `db:"source_artifact_id" json:"source_artifact_id"`
MimeType *string `db:"mime_type" json:"mime_type"`
FileUri *string `db:"file_uri" json:"file_uri"`
FileName *string `db:"file_name" json:"file_name"`
FileSha256 *string `db:"file_sha256" json:"file_sha256"`
FileSizeBytes *int64 `db:"file_size_bytes" json:"file_size_bytes"`
}
type CreateRunDeliveryParams ¶
type CreateRunDeliveryParams struct {
RunID uuid.UUID `db:"run_id" json:"run_id"`
TargetID uuid.UUID `db:"target_id" json:"target_id"`
UserID uuid.UUID `db:"user_id" json:"user_id"`
TargetType string `db:"target_type" json:"target_type"`
TargetURL string `db:"target_url" json:"target_url"`
Payload []byte `db:"payload" json:"payload"`
}
type CreateRunEventParams ¶
type CreateRunEventParams struct {
RunID uuid.UUID `db:"run_id" json:"run_id"`
ParentRunID *uuid.UUID `db:"parent_run_id" json:"parent_run_id"`
EventType string `db:"event_type" json:"event_type"`
Payload []byte `db:"payload" json:"payload"`
}
CreateRunEventParams 入参。
ParentRunID 预留给后续 workflow / A2A child run;当前单 Agent run 一般为空。
type CreateRunMessageParams ¶
type CreateRunParams ¶
type CreateRunParams struct {
UserID uuid.UUID `db:"user_id" json:"user_id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
Input []byte `db:"input" json:"input"`
CostCents int32 `db:"cost_cents" json:"cost_cents"`
PlatformFeeCents int32 `db:"platform_fee_cents" json:"platform_fee_cents"`
CreatorRevenueCents int32 `db:"creator_revenue_cents" json:"creator_revenue_cents"`
Source string `db:"source" json:"source"`
}
CreateRunParams 入参。
Input 是 JSONB 原始字节,调用方需先 json.Marshal。 CostCents = PlatformFeeCents + CreatorRevenueCents(service 层计算)。 Source 取值 'web' / 'mcp' / 'api',由 handler 从 auth_method 派生。
type CreateRunRequirementEvidenceParams ¶
type CreateRunRequirementEvidenceParams struct {
RunID uuid.UUID `db:"run_id" json:"run_id"`
TaskID uuid.UUID `db:"task_id" json:"task_id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
UserID uuid.UUID `db:"user_id" json:"user_id"`
RequiredSkillIDs []string `db:"required_skill_ids" json:"required_skill_ids"`
RequiredMCPTools []string `db:"required_mcp_tools" json:"required_mcp_tools"`
AgentSkillIDs []string `db:"agent_skill_ids" json:"agent_skill_ids"`
MatchedSkillIDs []string `db:"matched_skill_ids" json:"matched_skill_ids"`
MissingSkillIDs []string `db:"missing_skill_ids" json:"missing_skill_ids"`
UsedMCPTools []string `db:"used_mcp_tools" json:"used_mcp_tools"`
MissingMCPTools []string `db:"missing_mcp_tools" json:"missing_mcp_tools"`
CoverageStatus string `db:"coverage_status" json:"coverage_status"`
EvidenceSource string `db:"evidence_source" json:"evidence_source"`
}
type CreateSkillProposalParams ¶
type CreateSkillProposalParams struct {
OwnerUserID uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
AgentID *uuid.UUID `db:"agent_id" json:"agent_id"`
ProposedSkillID string `db:"proposed_skill_id" json:"proposed_skill_id"`
Category string `db:"category" json:"category"`
Name string `db:"name" json:"name"`
Description string `db:"description" json:"description"`
Source string `db:"source" json:"source"`
Status string `db:"status" json:"status"`
MatchedSkillID *string `db:"matched_skill_id" json:"matched_skill_id"`
}
CreateSkillProposalParams 是 CreateSkillProposal 的参数。
type CreateTaskCallbackSubscriptionParams ¶
type CreateTaskCallbackSubscriptionParams struct {
RunID uuid.UUID `db:"run_id" json:"run_id"`
OwnerUserID uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
CallerAgentID *uuid.UUID `db:"caller_agent_id" json:"caller_agent_id"`
TargetURL string `db:"target_url" json:"target_url"`
Secret string `db:"secret" json:"secret"`
EventTypes []string `db:"event_types" json:"event_types"`
AuthScheme *string `db:"auth_scheme" json:"auth_scheme"`
AuthCredentials *string `db:"auth_credentials" json:"auth_credentials"`
Metadata []byte `db:"metadata" json:"metadata"`
}
type CreateTaskQueryParams ¶
type CreateTaskQueryParams struct {
UserID uuid.UUID `db:"user_id" json:"user_id"`
Query string `db:"query" json:"query"`
ParsedSkills []string `db:"parsed_skills" json:"parsed_skills"`
MCPTools []string `db:"mcp_tools" json:"mcp_tools"`
RecommendedAgentIDs []uuid.UUID `db:"recommended_agent_ids" json:"recommended_agent_ids"`
}
CreateTaskQueryParams 入参。
type CreateUserParams ¶
type CreateUserParams struct {
Email string `db:"email" json:"email"`
PasswordHash *string `db:"password_hash" json:"password_hash"`
OauthProvider *string `db:"oauth_provider" json:"oauth_provider"`
OauthID *string `db:"oauth_id" json:"oauth_id"`
DisplayName string `db:"display_name" json:"display_name"`
AvatarURL *string `db:"avatar_url" json:"avatar_url"`
}
CreateUserParams 入参(password_hash / oauth_* / avatar_url 可空)。
type CreateWebhookDeliveryParams ¶
type CreateWebhookDeliveryParams struct {
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
RunID uuid.UUID `db:"run_id" json:"run_id"`
URL string `db:"url" json:"url"`
Payload []byte `db:"payload" json:"payload"`
}
CreateWebhookDeliveryParams 入参。
type CreateWorkflowNodeParams ¶
type CreateWorkflowNodeParams struct {
WorkflowID uuid.UUID `db:"workflow_id" json:"workflow_id"`
NodeKey string `db:"node_key" json:"node_key"`
NodeType string `db:"node_type" json:"node_type"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
Title string `db:"title" json:"title"`
Config []byte `db:"config" json:"config"`
Position int32 `db:"position" json:"position"`
}
type CreateWorkflowParams ¶
type CreateWorkflowRunParams ¶
type CreateWorkflowRunStepParams ¶
type CreateWorkflowRunStepParams struct {
WorkflowRunID uuid.UUID `db:"workflow_run_id" json:"workflow_run_id"`
WorkflowNodeID uuid.UUID `db:"workflow_node_id" json:"workflow_node_id"`
NodeKey string `db:"node_key" json:"node_key"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
Input []byte `db:"input" json:"input"`
Sequence int32 `db:"sequence" json:"sequence"`
}
type DBTX ¶
type DBTX interface {
Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
Query(context.Context, string, ...interface{}) (pgx.Rows, error)
QueryRow(context.Context, string, ...interface{}) pgx.Row
}
DBTX 抽象 pgx 连接接口,pgxpool.Pool 与 pgx.Tx 都实现它。 这样 Queries 既可走连接池,也可走事务(WithTx)。
type DeliveryTarget ¶
type DeliveryTarget struct {
ID uuid.UUID `db:"id" json:"id"`
UserID uuid.UUID `db:"user_id" json:"user_id"`
Name string `db:"name" json:"name"`
Type string `db:"type" json:"type"`
Config []byte `db:"config" json:"config"`
Secret string `db:"secret" json:"-"`
IsDefault bool `db:"is_default" json:"is_default"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
DeliveryTarget 对应 delivery_targets 表(用户拥有的投递目标)。
type: 'webhook' | 'slack'。Config 是 JSONB({url, event_types})。 Secret 给 webhook 投递做 HMAC 签名;slack 也存一份以备未来扩展。
type DisableAgentParams ¶
type GetAdminSummaryRow ¶
type GetAdminSummaryRow struct {
TotalUsers int32 `db:"total_users" json:"total_users"`
AdminUsers int32 `db:"admin_users" json:"admin_users"`
CreatorUsers int32 `db:"creator_users" json:"creator_users"`
VerifiedCreators int32 `db:"verified_creators" json:"verified_creators"`
TotalAgents int32 `db:"total_agents" json:"total_agents"`
ActiveAgents int32 `db:"active_agents" json:"active_agents"`
DisabledAgents int32 `db:"disabled_agents" json:"disabled_agents"`
PendingAgents int32 `db:"pending_agents" json:"pending_agents"`
CertifiedAgents int32 `db:"certified_agents" json:"certified_agents"`
TotalTasks int32 `db:"total_tasks" json:"total_tasks"`
PublicTasks int32 `db:"public_tasks" json:"public_tasks"`
PrivateTasks int32 `db:"private_tasks" json:"private_tasks"`
OpenTasks int32 `db:"open_tasks" json:"open_tasks"`
ClaimedTasks int32 `db:"claimed_tasks" json:"claimed_tasks"`
CompletedTasks int32 `db:"completed_tasks" json:"completed_tasks"`
AcceptedTasks int32 `db:"accepted_tasks" json:"accepted_tasks"`
RevisionRequestedTasks int32 `db:"revision_requested_tasks" json:"revision_requested_tasks"`
}
type GetAgentBySlugRow ¶
type GetAgentWebhookConfigRow ¶
type GetAgentWebhookConfigRow struct {
ID uuid.UUID `db:"id" json:"id"`
CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
Slug string `db:"slug" json:"slug"`
WebhookURL *string `db:"webhook_url" json:"webhook_url"`
WebhookSecret *string `db:"webhook_secret" json:"-"`
}
GetAgentWebhookConfigRow 仅 webhook 触发用最小字段集。
type GetAgentsByIDsRow ¶
GetAgentsByIDsRow Agent 全字段 + creator 显示名。
type GetRunDeliveryRow ¶
type GetRunDeliveryRow struct {
RunDelivery
TargetSecret *string `db:"target_secret" json:"-"`
TargetConfig []byte `db:"target_config" json:"-"`
}
GetRunDeliveryRow JOIN 结果:投递记录 + 当前 target 的 secret / config。
投递时 target 已被删时 TargetSecret / TargetConfig 为 NULL,worker 会标 final failed。
type GetTaskCallbackDeliveryByIDRow ¶
type GetTaskCallbackDeliveryByIDRow struct {
TaskCallbackDelivery
TargetURL string `db:"target_url" json:"target_url"`
Secret string `db:"secret" json:"-"`
AuthScheme *string `db:"auth_scheme" json:"auth_scheme,omitempty"`
AuthCredentials *string `db:"auth_credentials" json:"-"`
EventType string `db:"event_type" json:"event_type"`
}
type GetUserByOAuthParams ¶
type GetUserByOAuthParams struct {
OauthProvider *string `db:"oauth_provider" json:"oauth_provider"`
OauthID *string `db:"oauth_id" json:"oauth_id"`
}
GetUserByOAuthParams 入参。
type GetWebhookDeliveryRow ¶
type GetWebhookDeliveryRow struct {
WebhookDelivery
WebhookSecret *string `db:"webhook_secret" json:"-"`
}
GetWebhookDeliveryRow JOIN 结果:投递记录 + 当前 agent 的 secret。
投递时若 agent 已 ClearWebhook(secret = NULL),worker 会判定 final fail。
type ListA2AContextMappingsBeforeRunByRootParams ¶
type ListA2AContextMappingsBeforeRunByRootParams struct {
UserID uuid.UUID `db:"user_id" json:"user_id"`
RootContextID string `db:"root_context_id" json:"root_context_id"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
RunID uuid.UUID `db:"run_id" json:"run_id"`
Limit int32 `db:"limit" json:"limit"`
}
type ListAdminAgentsParams ¶
type ListAdminAgentsParams struct {
Query string `db:"query" json:"query"`
LifecycleStatus string `db:"lifecycle_status" json:"lifecycle_status"`
Visibility string `db:"visibility" json:"visibility"`
CertificationStatus string `db:"certification_status" json:"certification_status"`
Limit int32 `db:"limit" json:"limit"`
Offset int32 `db:"offset" json:"offset"`
}
type ListAdminAgentsRow ¶
type ListAdminAgentsRow struct {
Agent
CreatorEmail string `db:"creator_email" json:"creator_email"`
CreatorName string `db:"creator_name" json:"creator_name"`
RecommendedTaskCount int32 `db:"recommended_task_count" json:"recommended_task_count"`
ChosenTaskCount int32 `db:"chosen_task_count" json:"chosen_task_count"`
ClaimedTaskCount int32 `db:"claimed_task_count" json:"claimed_task_count"`
CompletedTaskCount int32 `db:"completed_task_count" json:"completed_task_count"`
LastRunAt *time.Time `db:"last_run_at" json:"last_run_at"`
}
type ListAdminTasksParams ¶
type ListAdminTasksParams struct {
Query string `db:"query" json:"query"`
Visibility string `db:"visibility" json:"visibility"`
DeliveryStatus string `db:"delivery_status" json:"delivery_status"`
Status string `db:"status" json:"status"`
Limit int32 `db:"limit" json:"limit"`
Offset int32 `db:"offset" json:"offset"`
}
type ListAdminTasksRow ¶
type ListAdminTasksRow struct {
TaskQuery
UserEmail string `db:"user_email" json:"user_email"`
UserDisplayName string `db:"user_display_name" json:"user_display_name"`
ChosenAgentSlug *string `db:"chosen_agent_slug" json:"chosen_agent_slug"`
ChosenAgentName *string `db:"chosen_agent_name" json:"chosen_agent_name"`
ClaimedAgentSlug *string `db:"claimed_agent_slug" json:"claimed_agent_slug"`
ClaimedAgentName *string `db:"claimed_agent_name" json:"claimed_agent_name"`
ClaimedByEmail *string `db:"claimed_by_email" json:"claimed_by_email"`
ClaimedByDisplayName *string `db:"claimed_by_display_name" json:"claimed_by_display_name"`
}
type ListAdminUsersParams ¶
type ListAdminUsersRow ¶
type ListAdminUsersRow struct {
User
AgentCount int32 `db:"agent_count" json:"agent_count"`
ActiveAgentCount int32 `db:"active_agent_count" json:"active_agent_count"`
TaskCount int32 `db:"task_count" json:"task_count"`
PublicTaskCount int32 `db:"public_task_count" json:"public_task_count"`
RunCount int32 `db:"run_count" json:"run_count"`
LastTaskAt *time.Time `db:"last_task_at" json:"last_task_at"`
LastRunAt *time.Time `db:"last_run_at" json:"last_run_at"`
}
type ListAgentAvailabilityAlertsByCreatorRow ¶
type ListAgentAvailabilityAlertsByCreatorRow struct {
AgentAvailabilityAlert
AgentSlug string `db:"agent_slug" json:"agent_slug"`
AgentName string `db:"agent_name" json:"agent_name"`
}
type ListAgentStatsForCreatorRow ¶
type ListAgentStatsForCreatorRow struct {
ID uuid.UUID `db:"id" json:"id"`
Slug string `db:"slug" json:"slug"`
Name string `db:"name" json:"name"`
Status string `db:"status" json:"status"`
PricePerCallCents int32 `db:"price_per_call_cents" json:"price_per_call_cents"`
LifetimeCalls int32 `db:"lifetime_calls" json:"lifetime_calls"`
LifetimeRevenue int64 `db:"lifetime_revenue" json:"lifetime_revenue"`
CallsThisMonth int64 `db:"calls_this_month" json:"calls_this_month"`
RevenueThisMonth int64 `db:"revenue_this_month" json:"revenue_this_month"`
}
ListAgentStatsForCreatorRow 创作者 dashboard 的每个 Agent 行。
注:lifetime_calls 来自 agents.total_calls (int32); lifetime_revenue 来自 agents.total_revenue_cents (int64); monthly 子查询 COUNT(*) 在 PostgreSQL 中返回 bigint,故 calls_this_month 用 int64; SUM(int32) 同理为 bigint。
type ListAgentTokensByCreatorAndAgentParams ¶
type ListAgentTokensByCreatorAndAgentParams struct {
CreatorUserID uuid.UUID `db:"creator_user_id" json:"creator_user_id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
Limit int32 `db:"limit" json:"limit"`
Offset int32 `db:"offset" json:"offset"`
SortBy string `db:"sort_by" json:"sort_by"`
SortDir string `db:"sort_dir" json:"sort_dir"`
}
type ListAgentTokensByCreatorParams ¶ added in v0.1.7
type ListAgentsByCreatorPageParams ¶ added in v0.1.14
type ListAgentsByCreatorPageParams struct {
CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
Query string `db:"query" json:"query"`
Status string `db:"status" json:"status"`
Visibility string `db:"visibility" json:"visibility"`
CertificationStatus string `db:"certification_status" json:"certification_status"`
SortBy string `db:"sort_by" json:"sort_by"`
Limit int32 `db:"limit" json:"limit"`
Offset int32 `db:"offset" json:"offset"`
}
type ListAgentsByCreatorPageRow ¶ added in v0.1.14
type ListAgentsByCreatorPageRow struct {
Agent
AvailabilityStatus string `db:"availability_status" json:"availability_status"`
AvailabilityLastSuccessfulRunAt *time.Time `db:"availability_last_successful_run_at" json:"availability_last_successful_run_at"`
AvailabilityLastFailedRunAt *time.Time `db:"availability_last_failed_run_at" json:"availability_last_failed_run_at"`
AvailabilityLastCheckedAt *time.Time `db:"availability_last_checked_at" json:"availability_last_checked_at"`
AvailabilityConsecutiveFailures int32 `db:"availability_consecutive_failures" json:"availability_consecutive_failures"`
LastRuntimeTokenUsedAt *time.Time `db:"last_runtime_token_used_at" json:"last_runtime_token_used_at"`
CallsThisMonth int64 `db:"calls_this_month" json:"calls_this_month"`
RevenueThisMonth int64 `db:"revenue_this_month" json:"revenue_this_month"`
}
type ListBenchmarkBatchSummariesByAgentRow ¶
type ListBenchmarkBatchSummariesByAgentRow struct {
BatchID uuid.UUID `db:"batch_id" json:"batch_id"`
SkillID string `db:"skill_id" json:"skill_id"`
StartedAt time.Time `db:"started_at" json:"started_at"`
FinishedAt *time.Time `db:"finished_at" json:"finished_at"`
TotalCount int32 `db:"total_count" json:"total_count"`
SuccessCount int32 `db:"success_count" json:"success_count"`
AverageScore *int32 `db:"average_score" json:"average_score"`
}
type ListBenchmarkRunsByBatchRow ¶
type ListBenchmarkRunsByBatchRow struct {
AgentSkillBenchmarkRun
TestCaseTitle string `db:"test_case_title" json:"test_case_title"`
}
ListBenchmarkRunsByBatchRow 行类型:benchmark run + test case 标题。
type ListCallRecordsForUserParams ¶ added in v0.1.14
type ListCallRecordsForUserRow ¶ added in v0.1.14
type ListCallRecordsForUserRow struct {
ID uuid.UUID `db:"id" json:"id"`
UserID uuid.UUID `db:"user_id" json:"user_id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
Status string `db:"status" json:"status"`
CostCents int32 `db:"cost_cents" json:"cost_cents"`
CreatorRevenueCents int32 `db:"creator_revenue_cents" json:"creator_revenue_cents"`
DurationMs *int32 `db:"duration_ms" json:"duration_ms"`
StartedAt time.Time `db:"started_at" json:"started_at"`
FinishedAt *time.Time `db:"finished_at" json:"finished_at"`
Source string `db:"source" json:"source"`
AgentSlug string `db:"agent_slug" json:"agent_slug"`
AgentName string `db:"agent_name" json:"agent_name"`
Direction string `db:"direction" json:"direction"`
ParentRunID string `db:"parent_run_id" json:"parent_run_id"`
CallerAgentID string `db:"caller_agent_id" json:"caller_agent_id"`
CallerAgentSlug string `db:"caller_agent_slug" json:"caller_agent_slug"`
CallerAgentName string `db:"caller_agent_name" json:"caller_agent_name"`
ProtocolContextID string `db:"protocol_context_id" json:"protocol_context_id"`
ProtocolTaskID string `db:"protocol_task_id" json:"protocol_task_id"`
RootContextID string `db:"root_context_id" json:"root_context_id"`
ParentContextID string `db:"parent_context_id" json:"parent_context_id"`
ParentTaskID string `db:"parent_task_id" json:"parent_task_id"`
TraceID string `db:"trace_id" json:"trace_id"`
ReferenceTaskIDs []string `db:"reference_task_ids" json:"reference_task_ids"`
ContextSource string `db:"context_source" json:"context_source"`
CallID string `db:"call_id" json:"call_id"`
ChildCount int32 `db:"child_count" json:"child_count"`
}
type ListChildRunsByParentAndUserRow ¶
type ListChildRunsByParentAndUserRow struct {
ChildRunID uuid.UUID `json:"child_run_id"`
ParentRunID uuid.UUID `json:"parent_run_id"`
CallerAgentID uuid.UUID `json:"caller_agent_id"`
Reason string `json:"reason"`
Status string `json:"status"`
CostCents int32 `json:"cost_cents"`
DurationMs *int32 `json:"duration_ms"`
StartedAt time.Time `json:"started_at"`
FinishedAt *time.Time `json:"finished_at"`
Source string `json:"source"`
CallerAgentSlug string `json:"caller_agent_slug"`
CallerAgentName string `json:"caller_agent_name"`
CallerAgentTags []string `json:"caller_agent_tags"`
CallerSkillIDs []string `json:"caller_skill_ids"`
CallerSkillNames []string `json:"caller_skill_names"`
TargetAgentID uuid.UUID `json:"target_agent_id"`
TargetAgentSlug string `json:"target_agent_slug"`
TargetAgentName string `json:"target_agent_name"`
TargetAgentTags []string `json:"target_agent_tags"`
TargetSkillIDs []string `json:"target_skill_ids"`
TargetSkillNames []string `json:"target_skill_names"`
ProtocolContextID string `json:"protocol_context_id"`
ProtocolTaskID string `json:"protocol_task_id"`
RootContextID string `json:"root_context_id"`
ParentContextID string `json:"parent_context_id"`
ParentTaskID string `json:"parent_task_id"`
TraceID string `json:"trace_id"`
ReferenceTaskIDs []string `json:"reference_task_ids"`
ContextSource string `json:"context_source"`
}
type ListDeliveriesByAgentParams ¶
type ListDeliveriesByAgentParams struct {
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
Limit int32 `db:"limit" json:"limit"`
}
ListDeliveriesByAgentParams 入参。
type ListParentRunsWithDelegationsByUserRow ¶
type ListParentRunsWithDelegationsByUserRow struct {
ParentRunID uuid.UUID `json:"parent_run_id"`
CallerAgentID uuid.UUID `json:"caller_agent_id"`
CallerAgentSlug string `json:"caller_agent_slug"`
CallerAgentName string `json:"caller_agent_name"`
CallerAgentTags []string `json:"caller_agent_tags"`
CallerSkillIDs []string `json:"caller_skill_ids"`
CallerSkillNames []string `json:"caller_skill_names"`
ParentSource string `json:"parent_source"`
Status string `json:"status"`
DurationMs *int32 `json:"duration_ms"`
StartedAt time.Time `json:"started_at"`
FinishedAt *time.Time `json:"finished_at"`
ChildCount int32 `json:"child_count"`
SuccessfulChildCount int32 `json:"successful_child_count"`
RunningChildCount int32 `json:"running_child_count"`
ActiveRuntimeTokenCount int32 `json:"active_runtime_token_count"`
LastRuntimeTokenUsedAt *time.Time `json:"last_runtime_token_used_at"`
ProtocolContextID string `json:"protocol_context_id"`
ProtocolTaskID string `json:"protocol_task_id"`
RootContextID string `json:"root_context_id"`
TraceID string `json:"trace_id"`
}
type ListPendingAgentsRow ¶
type ListPendingAgentsRow struct {
Agent
CreatorEmail string `db:"creator_email" json:"creator_email"`
CreatorName string `db:"creator_name" json:"creator_name"`
}
ListPendingAgentsRow Agent + 创作者邮箱 / 名字。
type ListPublicAgentsParams ¶
type ListPublicAgentsRow ¶
type ListPublicAgentsRow struct {
Agent
CreatorName string `db:"creator_name" json:"creator_name"`
AvailabilityStatus string `db:"availability_status" json:"availability_status"`
AvailabilityLastSuccessfulRunAt *time.Time `db:"availability_last_successful_run_at" json:"availability_last_successful_run_at"`
AvailabilityLastFailedRunAt *time.Time `db:"availability_last_failed_run_at" json:"availability_last_failed_run_at"`
AvailabilityLastCheckedAt *time.Time `db:"availability_last_checked_at" json:"availability_last_checked_at"`
AvailabilityConsecutiveFailures int32 `db:"availability_consecutive_failures" json:"availability_consecutive_failures"`
LastRuntimeTokenUsedAt *time.Time `db:"last_runtime_token_used_at" json:"last_runtime_token_used_at"`
VerifiedSkillCount int32 `db:"verified_skill_count" json:"verified_skill_count"`
LatestBenchmarkID *uuid.UUID `db:"latest_benchmark_id" json:"latest_benchmark_id"`
}
type ListRegistryListingLinksByOwnerRow ¶
type ListRegistryListingLinksByOwnerRow struct {
ID uuid.UUID `db:"id" json:"id"`
RegistryListingID uuid.UUID `db:"registry_listing_id" json:"registry_listing_id"`
RegistryNodeID uuid.UUID `db:"registry_node_id" json:"registry_node_id"`
NodeName string `db:"node_name" json:"node_name"`
LocalAgentID uuid.UUID `db:"local_agent_id" json:"local_agent_id"`
AgentSlug string `db:"agent_slug" json:"agent_slug"`
AgentName string `db:"agent_name" json:"agent_name"`
RoutingMode string `db:"routing_mode" json:"routing_mode"`
PayloadPolicy string `db:"payload_policy" json:"payload_policy"`
PayloadRedactionKeys []string `db:"payload_redaction_keys" json:"payload_redaction_keys"`
SyncStatus string `db:"sync_status" json:"sync_status"`
AgentDescription string `db:"agent_description" json:"agent_description"`
AgentTags []string `db:"agent_tags" json:"agent_tags"`
AvailabilityStatus string `db:"availability_status" json:"availability_status"`
MetadataSyncedAt *time.Time `db:"metadata_synced_at" json:"metadata_synced_at"`
MetadataSyncError *string `db:"metadata_sync_error" json:"metadata_sync_error"`
LastSyncAt time.Time `db:"last_sync_at" json:"last_sync_at"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
type ListRunDeliveriesByUserParams ¶
type ListRunDeliveriesByUserParams struct {
UserID uuid.UUID `db:"user_id" json:"user_id"`
HasAgentID bool `db:"has_agent_id" json:"has_agent_id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
HasRunID bool `db:"has_run_id" json:"has_run_id"`
RunID uuid.UUID `db:"run_id" json:"run_id"`
Status string `db:"status" json:"status"`
Limit int32 `db:"limit" json:"limit"`
}
type ListRunEventsByRunParams ¶
type ListRunEventsByRunParams struct {
RunID uuid.UUID `db:"run_id" json:"run_id"`
AfterSequence int32 `db:"after_sequence" json:"after_sequence"`
Limit int32 `db:"limit" json:"limit"`
}
ListRunEventsByRunParams 入参。
type ListRunsByCreatorAgentWithAgentParams ¶
type ListRunsByCreatorAgentWithAgentParams struct {
CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
Limit int32 `db:"limit" json:"limit"`
Offset int32 `db:"offset" json:"offset"`
}
ListRunsByCreatorAgentWithAgentParams 入参。
type ListRunsByCreatorAgentWithAgentRow ¶
type ListRunsByCreatorAgentWithAgentRow struct {
Run
AgentSlug string `db:"agent_slug" json:"agent_slug"`
AgentName string `db:"agent_name" json:"agent_name"`
}
ListRunsByCreatorAgentWithAgentRow 返回行:嵌入 Run + agent 展示字段。
type ListRunsByUserAndAgentParams ¶
type ListRunsByUserAndAgentParams struct {
UserID uuid.UUID `db:"user_id" json:"user_id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
NoCursor bool `db:"no_cursor" json:"no_cursor"`
CursorStartedAt time.Time `db:"cursor_started_at" json:"cursor_started_at"`
CursorID uuid.UUID `db:"cursor_id" json:"cursor_id"`
NoStatusFilter bool `db:"no_status_filter" json:"no_status_filter"`
Statuses []string `db:"statuses" json:"statuses"`
NoSinceFilter bool `db:"no_since_filter" json:"no_since_filter"`
Since time.Time `db:"since" json:"since"`
ContextID string `db:"context_id" json:"context_id"`
Limit int32 `db:"limit" json:"limit"`
}
ListRunsByUserAndAgentParams 入参。
type ListRunsByUserParams ¶
type ListRunsByUserParams struct {
UserID uuid.UUID `db:"user_id" json:"user_id"`
Limit int32 `db:"limit" json:"limit"`
Offset int32 `db:"offset" json:"offset"`
}
ListRunsByUserParams 入参。
type ListRunsByUserWithAgentParams ¶
type ListRunsByUserWithAgentParams struct {
UserID uuid.UUID `db:"user_id" json:"user_id"`
Limit int32 `db:"limit" json:"limit"`
Offset int32 `db:"offset" json:"offset"`
}
ListRunsByUserWithAgentParams 入参。
type ListRunsByUserWithAgentRow ¶
type ListRunsByUserWithAgentRow struct {
Run
AgentSlug string `db:"agent_slug" json:"agent_slug"`
AgentName string `db:"agent_name" json:"agent_name"`
}
ListRunsByUserWithAgentRow 返回行:嵌入 Run + agent 展示字段。
type ListStaleEndpointRunsRow ¶
type ListStaleEndpointRunsRow struct {
ID uuid.UUID `db:"id" json:"id"`
UserID uuid.UUID `db:"user_id" json:"user_id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
CostCents int32 `db:"cost_cents" json:"cost_cents"`
StartedAt time.Time `db:"started_at" json:"started_at"`
ConnectionMode string `db:"connection_mode" json:"connection_mode"`
ErrorCode string `db:"error_code" json:"error_code"`
ErrorMessage string `db:"error_message" json:"error_message"`
}
type ListStaleRuntimePullRunsRow ¶
type ListStaleRuntimePullRunsRow struct {
ID uuid.UUID `db:"id" json:"id"`
UserID uuid.UUID `db:"user_id" json:"user_id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
CostCents int32 `db:"cost_cents" json:"cost_cents"`
StartedAt time.Time `db:"started_at" json:"started_at"`
ErrorCode string `db:"error_code" json:"error_code"`
ErrorMessage string `db:"error_message" json:"error_message"`
}
type ListTaskCallbackDeliveriesByRunRow ¶
type ListTaskCallbackDeliveriesByRunRow struct {
TaskCallbackDelivery
TargetURL string `db:"target_url" json:"target_url"`
EventType string `db:"event_type" json:"event_type"`
}
type ListTaskQueriesByUserParams ¶
type ListTaskQueriesByUserParams struct {
UserID uuid.UUID `db:"user_id" json:"user_id"`
Limit int32 `db:"limit" json:"limit"`
}
ListTaskQueriesByUserParams 入参。
type ListTopAgentsBySkillRow ¶
type ListTopAgentsBySkillRow struct {
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
AverageScore *int32 `db:"average_score" json:"average_score"`
VerifiedAt *time.Time `db:"verified_at" json:"verified_at"`
Slug string `db:"slug" json:"slug"`
Name string `db:"name" json:"name"`
Description string `db:"description" json:"description"`
Tags []string `db:"tags" json:"tags"`
PricePerCallCents int32 `db:"price_per_call_cents" json:"price_per_call_cents"`
TotalCalls int32 `db:"total_calls" json:"total_calls"`
}
ListTopAgentsBySkillRow 行类型:verified 评分 + agent 公开字段。
type MarkDeliveryFailedFinalParams ¶
type MarkDeliveryFailedFinalParams struct {
ID uuid.UUID `db:"id" json:"id"`
ResponseStatus *int32 `db:"response_status" json:"response_status"`
ResponseBody *string `db:"response_body" json:"response_body"`
ErrorMessage *string `db:"error_message" json:"error_message"`
}
MarkDeliveryFailedFinalParams 入参。
type MarkDeliveryFailedRetryParams ¶
type MarkDeliveryFailedRetryParams struct {
ID uuid.UUID `db:"id" json:"id"`
ResponseStatus *int32 `db:"response_status" json:"response_status"`
ResponseBody *string `db:"response_body" json:"response_body"`
ErrorMessage *string `db:"error_message" json:"error_message"`
NextRetryAt time.Time `db:"next_retry_at" json:"next_retry_at"`
}
MarkDeliveryFailedRetryParams 入参。
type MarkDeliverySuccessParams ¶
type MarkDeliverySuccessParams struct {
ID uuid.UUID `db:"id" json:"id"`
ResponseStatus *int32 `db:"response_status" json:"response_status"`
ResponseBody *string `db:"response_body" json:"response_body"`
}
MarkDeliverySuccessParams 入参。
type MarkExamplesSetParams ¶
type MarkRunDeliveryFailedRetryParams ¶
type MarkRunDeliveryFailedRetryParams struct {
ID uuid.UUID `db:"id" json:"id"`
ResponseStatus *int32 `db:"response_status" json:"response_status"`
ResponseBody *string `db:"response_body" json:"response_body"`
ErrorMessage *string `db:"error_message" json:"error_message"`
NextRetryAt time.Time `db:"next_retry_at" json:"next_retry_at"`
}
type MarkRunFailedParams ¶
type MarkRunFailedParams struct {
ID uuid.UUID `db:"id" json:"id"`
Status string `db:"status" json:"status"`
ErrorCode *string `db:"error_code" json:"error_code"`
ErrorMessage *string `db:"error_message" json:"error_message"`
DurationMs int32 `db:"duration_ms" json:"duration_ms"`
}
MarkRunFailedParams 入参。Status 取值 'failed'、'timeout' 或 'canceled'。
type MarkRunSuccessParams ¶
type MarkRunSuccessParams struct {
ID uuid.UUID `db:"id" json:"id"`
Output []byte `db:"output" json:"output"`
DurationMs int32 `db:"duration_ms" json:"duration_ms"`
}
MarkRunSuccessParams 入参。
type MarkTaskCallbackDeliveryFailedRetryParams ¶
type MarkTaskCallbackDeliveryFailedRetryParams struct {
ID uuid.UUID `db:"id" json:"id"`
ResponseStatus *int32 `db:"response_status" json:"response_status"`
ResponseBody *string `db:"response_body" json:"response_body"`
ErrorMessage *string `db:"error_message" json:"error_message"`
NextRetryAt time.Time `db:"next_retry_at" json:"next_retry_at"`
}
type MarkTaskQueryChosenParams ¶
type MarkTaskQueryChosenParams struct {
ID uuid.UUID `db:"id" json:"id"`
UserID uuid.UUID `db:"user_id" json:"user_id"`
ChosenAgentID uuid.UUID `db:"chosen_agent_id" json:"chosen_agent_id"`
}
MarkTaskQueryChosenParams 入参。
type ProxyRun ¶
type ProxyRun struct {
ID uuid.UUID `db:"id" json:"id"`
RegistryRunID uuid.UUID `db:"registry_run_id" json:"registry_run_id"`
RegistryListingLinkID uuid.UUID `db:"registry_listing_link_id" json:"registry_listing_link_id"`
RegistryListingID uuid.UUID `db:"registry_listing_id" json:"registry_listing_id"`
RegistryNodeID uuid.UUID `db:"registry_node_id" json:"registry_node_id"`
LocalAgentID uuid.UUID `db:"local_agent_id" json:"local_agent_id"`
RequestingUserID uuid.UUID `db:"requesting_user_id" json:"requesting_user_id"`
IdempotencyKey string `db:"idempotency_key" json:"idempotency_key"`
Status string `db:"status" json:"status"`
PayloadPolicy string `db:"payload_policy" json:"payload_policy"`
PayloadRedactionKeys []string `db:"payload_redaction_keys" json:"payload_redaction_keys"`
Input []byte `db:"input" json:"input"`
InputSummary *string `db:"input_summary" json:"input_summary"`
Output []byte `db:"output" json:"output"`
OutputSummary *string `db:"output_summary" json:"output_summary"`
ErrorCode *string `db:"error_code" json:"error_code"`
ErrorMessage *string `db:"error_message" json:"error_message"`
AttemptCount int32 `db:"attempt_count" json:"attempt_count"`
MaxAttempts int32 `db:"max_attempts" json:"max_attempts"`
NextRetryAt *time.Time `db:"next_retry_at" json:"next_retry_at"`
ClaimedAt *time.Time `db:"claimed_at" json:"claimed_at"`
FinishedAt *time.Time `db:"finished_at" json:"finished_at"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
ProxyRun 对应 proxy_runs 表。
它是 Registry Listing 经 Registry Node 拉取执行的代理任务状态机。
type ProxyRunArtifact ¶
type ProxyRunArtifact struct {
ID uuid.UUID `db:"id" json:"id"`
ProxyRunID uuid.UUID `db:"proxy_run_id" json:"proxy_run_id"`
RegistryRunID uuid.UUID `db:"registry_run_id" json:"registry_run_id"`
SourceArtifactID string `db:"source_artifact_id" json:"source_artifact_id"`
ArtifactType string `db:"artifact_type" json:"artifact_type"`
Title string `db:"title" json:"title"`
Content []byte `db:"content" json:"content"`
MimeType *string `db:"mime_type" json:"mime_type"`
FileURI *string `db:"file_uri" json:"file_uri"`
FileName *string `db:"file_name" json:"file_name"`
FileSHA256 *string `db:"file_sha256" json:"file_sha256"`
FileSizeBytes *int64 `db:"file_size_bytes" json:"file_size_bytes"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
}
ProxyRunArtifact stores artifact references returned by a Registry Node for a proxy run. It deliberately keeps file metadata separate from proxy_runs.output so metadata_only listings can still expose downloadable result references.
type PublishTaskQueryParams ¶
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
Queries 持有 DBTX 引用,所有 SQL 方法定义在此结构上。
func (*Queries) AcceptTaskDelivery ¶
func (*Queries) AgentsCount ¶
AgentsCount 公开 Agent 总数(市场页用)。
func (*Queries) AggregateAgentRunsForWindow ¶
func (*Queries) BatchUpdateTaskCallbackSubscriptionsForOwner ¶
func (q *Queries) BatchUpdateTaskCallbackSubscriptionsForOwner(ctx context.Context, arg BatchUpdateTaskCallbackSubscriptionsForOwnerParams) ([]TaskCallbackSubscription, error)
func (*Queries) CancelRun ¶
CancelRun marks an owner-readable running run as canceled and returns the final row.
func (*Queries) CancelWorkflowRun ¶
func (*Queries) CertifyAgent ¶
CertifyAgent 运营授予认证。 返回受影响行数:0 表示 Agent 不在 pending(不能 certify 未申请 / 已认证 / 已拒绝的)。
func (*Queries) CheckSlugAvailable ¶
func (*Queries) ClaimPendingProxyRun ¶
func (*Queries) ClaimPendingWorkflowRun ¶
func (q *Queries) ClaimPendingWorkflowRun(ctx context.Context) (WorkflowRun, error)
func (*Queries) ClaimRuntimePullRun ¶
func (q *Queries) ClaimRuntimePullRun(ctx context.Context, arg ClaimRuntimePullRunParams) (Run, error)
ClaimRuntimePullRun atomically assigns the oldest pending queued runtime run to a Runtime Token.
func (*Queries) ClaimStaleRuntimePullRun ¶
func (*Queries) ClaimTaskQuery ¶
func (*Queries) ClearAgentWebhook ¶
func (q *Queries) ClearAgentWebhook(ctx context.Context, arg ClearAgentWebhookParams) (int64, error)
ClearAgentWebhook 创作者清除 webhook 配置。 返回受影响行数:0 表示越权或 agent 不存在。
func (*Queries) ClearDefaultDeliveryTarget ¶
func (*Queries) CompleteProxyRun ¶
func (*Queries) CompleteTaskQuery ¶
func (*Queries) ConfirmAgentApproval ¶
func (*Queries) CountActiveAgentRuntimeTokens ¶
func (*Queries) CountActiveAgentTokensByAgent ¶
func (*Queries) CountAdminAgents ¶
func (*Queries) CountAdminTasks ¶
func (*Queries) CountAdminUsers ¶
func (*Queries) CountAgentAvailabilityAlertsByCreator ¶
func (*Queries) CountAgentBucketsByCreator ¶ added in v0.1.14
func (*Queries) CountAgentExamplesByAgentID ¶
func (*Queries) CountAgentTokensByCreator ¶ added in v0.1.7
func (*Queries) CountAgentTokensByCreatorAndAgent ¶ added in v0.1.7
func (*Queries) CountAgentsByCreator ¶
CountAgentsByCreator 创作者当前 Agent 数(不包含已下架 disabled)。
func (*Queries) CountAgentsByCreatorFiltered ¶ added in v0.1.14
func (*Queries) CountCallRecordsForUser ¶ added in v0.1.14
func (*Queries) CountClaimableRuntimePullRuns ¶
func (*Queries) CountParentRunsWithDelegationsByUser ¶
func (*Queries) CountPendingAgentsByCreator ¶
func (q *Queries) CountPendingAgentsByCreator(ctx context.Context, creatorID uuid.UUID) (int32, error)
CountPendingAgentsByCreator 创作者人工处理队列 Agent 数。
func (*Queries) CountPendingProxyRunsByNode ¶
func (*Queries) CountPublicAgents ¶
func (*Queries) CountPublicAgentsByCreator ¶
func (q *Queries) CountPublicAgentsByCreator(ctx context.Context, creatorID uuid.UUID) (int32, error)
CountPublicAgentsByCreator 创作者当前公开 Agent 数。
func (*Queries) CountRegistryListingLinksByNode ¶
func (*Queries) CountRunningDelegations ¶
func (*Queries) CountRunsByCreatorAgent ¶
func (q *Queries) CountRunsByCreatorAgent(ctx context.Context, arg CountRunsByCreatorAgentParams) (int32, error)
CountRunsByCreatorAgent 创作者某个 Agent 的全部被调用次数。
func (*Queries) CountRunsByUser ¶
CountRunsByUser 用户全部调用次数。
func (*Queries) CountRunsByUserAndAgent ¶
func (*Queries) CountRunsByUserThisMonth ¶
CountRunsByUserThisMonth 用户本月调用次数(按 UTC,date_trunc('month', NOW()))。
func (*Queries) CountRunsForCreatorThisMonth ¶
func (q *Queries) CountRunsForCreatorThisMonth(ctx context.Context, creatorID uuid.UUID) (int32, error)
CountRunsForCreatorThisMonth 创作者本月被成功调用次数。
func (*Queries) CountTestCasesBySkill ¶
func (*Queries) CountUnreadAgentAvailabilityAlertsByCreator ¶
func (*Queries) CountWorkflowRunsByWorkflow ¶
func (*Queries) CountWorkflowsByUser ¶
func (*Queries) CreateAdminUser ¶
CreateAdminUser 管理台创建邮箱密码用户。
func (*Queries) CreateAgent ¶
CreateAgent 创作者新建 Agent。默认 lifecycle=active, visibility=public, certification=unreviewed。
func (*Queries) CreateAgentApproval ¶
func (q *Queries) CreateAgentApproval(ctx context.Context, arg CreateAgentApprovalParams) (AgentActionApprovalRequest, error)
func (*Queries) CreateAgentExample ¶
func (q *Queries) CreateAgentExample(ctx context.Context, arg CreateAgentExampleParams) (AgentExample, error)
func (*Queries) CreateAgentRuntimeToken ¶
func (q *Queries) CreateAgentRuntimeToken(ctx context.Context, arg CreateAgentRuntimeTokenParams) (AgentRuntimeToken, error)
func (*Queries) CreateAgentToken ¶
func (q *Queries) CreateAgentToken(ctx context.Context, arg CreateAgentTokenParams) (AgentToken, error)
func (*Queries) CreateBenchmarkRun ¶
func (q *Queries) CreateBenchmarkRun(ctx context.Context, arg CreateBenchmarkRunParams) (AgentSkillBenchmarkRun, error)
func (*Queries) CreateDeliveryTarget ¶
func (q *Queries) CreateDeliveryTarget(ctx context.Context, arg CreateDeliveryTargetParams) (DeliveryTarget, error)
func (*Queries) CreatePendingWorkflowRun ¶
func (q *Queries) CreatePendingWorkflowRun(ctx context.Context, arg CreatePendingWorkflowRunParams) (WorkflowRun, error)
func (*Queries) CreateProxyRun ¶
func (*Queries) CreateProxyRunArtifact ¶
func (q *Queries) CreateProxyRunArtifact(ctx context.Context, arg CreateProxyRunArtifactParams) (ProxyRunArtifact, error)
func (*Queries) CreateRegistryFederationInvite ¶
func (q *Queries) CreateRegistryFederationInvite(ctx context.Context, arg CreateRegistryFederationInviteParams) (RegistryFederationInvite, error)
func (*Queries) CreateRegistryNode ¶
func (q *Queries) CreateRegistryNode(ctx context.Context, arg CreateRegistryNodeParams) (RegistryNode, error)
func (*Queries) CreateRegistryPeer ¶
func (q *Queries) CreateRegistryPeer(ctx context.Context, arg CreateRegistryPeerParams) (RegistryPeer, error)
func (*Queries) CreateRunArtifact ¶
func (q *Queries) CreateRunArtifact(ctx context.Context, arg CreateRunArtifactParams) (RunArtifact, error)
func (*Queries) CreateRunArtifactChunk ¶
func (q *Queries) CreateRunArtifactChunk(ctx context.Context, arg CreateRunArtifactChunkParams) (RunArtifactChunk, error)
func (*Queries) CreateRunDelegation ¶
func (q *Queries) CreateRunDelegation(ctx context.Context, arg CreateRunDelegationParams) (RunDelegation, error)
func (*Queries) CreateRunDelivery ¶
func (q *Queries) CreateRunDelivery(ctx context.Context, arg CreateRunDeliveryParams) (RunDelivery, error)
func (*Queries) CreateRunEvent ¶
CreateRunEvent 追加 run event,并在单个 run 内分配递增 sequence。
func (*Queries) CreateRunMessage ¶
func (q *Queries) CreateRunMessage(ctx context.Context, arg CreateRunMessageParams) (RunMessage, error)
func (*Queries) CreateRunRequirementEvidence ¶
func (q *Queries) CreateRunRequirementEvidence(ctx context.Context, arg CreateRunRequirementEvidenceParams) (RunRequirementEvidence, error)
func (*Queries) CreateSkillProposal ¶
func (q *Queries) CreateSkillProposal(ctx context.Context, arg CreateSkillProposalParams) (SkillProposal, error)
CreateSkillProposal 创建或更新当前用户的 Skill Proposal。
func (*Queries) CreateTaskCallbackDelivery ¶
func (q *Queries) CreateTaskCallbackDelivery(ctx context.Context, arg CreateTaskCallbackDeliveryParams) (TaskCallbackDelivery, error)
func (*Queries) CreateTaskCallbackSubscription ¶
func (q *Queries) CreateTaskCallbackSubscription(ctx context.Context, arg CreateTaskCallbackSubscriptionParams) (TaskCallbackSubscription, error)
func (*Queries) CreateTaskQuery ¶
func (q *Queries) CreateTaskQuery(ctx context.Context, arg CreateTaskQueryParams) (TaskQuery, error)
CreateTaskQuery 写入一条任务查询。
func (*Queries) CreateUser ¶
CreateUser 创建用户。
func (*Queries) CreateWebhookDelivery ¶
func (q *Queries) CreateWebhookDelivery(ctx context.Context, arg CreateWebhookDeliveryParams) (WebhookDelivery, error)
CreateWebhookDelivery 创建投递记录(初始 pending、立即可投递)。
func (*Queries) CreateWorkflow ¶
func (*Queries) CreateWorkflowNode ¶
func (q *Queries) CreateWorkflowNode(ctx context.Context, arg CreateWorkflowNodeParams) (WorkflowNode, error)
func (*Queries) CreateWorkflowRun ¶
func (q *Queries) CreateWorkflowRun(ctx context.Context, arg CreateWorkflowRunParams) (WorkflowRun, error)
func (*Queries) CreateWorkflowRunStep ¶
func (q *Queries) CreateWorkflowRunStep(ctx context.Context, arg CreateWorkflowRunStepParams) (WorkflowRunStep, error)
func (*Queries) DeleteAgentExampleForOwner ¶
func (*Queries) DeleteDeliveryTarget ¶
func (*Queries) DeleteProxyRunArtifacts ¶
func (*Queries) DeleteRegistryPeerForOwner ¶
func (*Queries) DeleteTaskCallbackSubscriptionForOwner ¶
func (*Queries) DeleteWorkflowRunSteps ¶
func (*Queries) DisableAgent ¶
DisableAgent 创作者主动下架 (lifecycle_status='disabled')。 返回受影响行数:0 表示 Agent 不属于该 creator 或不存在。
func (*Queries) EnsureOnboardingStatus ¶
func (*Queries) ExpireAgentApprovals ¶
func (*Queries) GetA2AContextMappingByRun ¶
func (*Queries) GetActiveRegistryPeerForOwner ¶
func (q *Queries) GetActiveRegistryPeerForOwner(ctx context.Context, arg GetActiveRegistryPeerForOwnerParams) (RegistryPeer, error)
func (*Queries) GetAdminSummary ¶
func (q *Queries) GetAdminSummary(ctx context.Context) (GetAdminSummaryRow, error)
func (*Queries) GetAgentApprovalForCreator ¶
func (q *Queries) GetAgentApprovalForCreator(ctx context.Context, arg GetAgentApprovalForCreatorParams) (AgentActionApprovalRequest, error)
func (*Queries) GetAgentAvailabilitySnapshot ¶
func (*Queries) GetAgentByID ¶
func (*Queries) GetAgentByIDForOwner ¶
func (*Queries) GetAgentBySlug ¶
GetAgentBySlug 详情页。unlisted 可凭直链访问;private 与 disabled 返回 pgx.ErrNoRows。
func (*Queries) GetAgentBySlugForOwner ¶
func (q *Queries) GetAgentBySlugForOwner(ctx context.Context, arg GetAgentBySlugForOwnerParams) (GetAgentBySlugForOwnerRow, error)
GetAgentBySlugForOwner 创作者自测详情。owner 可按 slug 访问自己的 private/unlisted/public active Agent。
func (*Queries) GetAgentCallPolicy ¶
func (*Queries) GetAgentCapabilityByAgentID ¶
func (*Queries) GetAgentCapabilityBySlug ¶
func (*Queries) GetAgentSkillScore ¶
func (q *Queries) GetAgentSkillScore(ctx context.Context, arg GetAgentSkillScoreParams) (AgentSkillScore, error)
func (*Queries) GetAgentVerifiedSkillStats ¶
func (*Queries) GetAgentWebhookConfig ¶
func (q *Queries) GetAgentWebhookConfig(ctx context.Context, id uuid.UUID) (GetAgentWebhookConfigRow, error)
GetAgentWebhookConfig 仅取 webhook 字段(runtime 触发投递时用)。
func (*Queries) GetAgentsByIDs ¶
GetAgentsByIDs 批量按 id 取当前公开运行的 Agent 详情(任务推荐回填用)。 返回顺序由 Postgres 决定(无序),调用方需按入参顺序自行重排。
func (*Queries) GetDefaultDeliveryTarget ¶
func (*Queries) GetDeliveryTargetByID ¶
func (*Queries) GetDeliveryTargetByIDForUser ¶
func (q *Queries) GetDeliveryTargetByIDForUser(ctx context.Context, arg GetDeliveryTargetByIDForUserParams) (DeliveryTarget, error)
func (*Queries) GetFirstExampleInputByAgentID ¶
func (*Queries) GetLatestRunEventForTypes ¶
func (*Queries) GetOnboardingStatusForOwner ¶
func (q *Queries) GetOnboardingStatusForOwner(ctx context.Context, arg GetOnboardingStatusForOwnerParams) (AgentOnboardingStatus, error)
func (*Queries) GetProxyRunArtifactForRequester ¶
func (q *Queries) GetProxyRunArtifactForRequester(ctx context.Context, arg GetProxyRunArtifactForRequesterParams) (ProxyRunArtifact, error)
func (*Queries) GetProxyRunForNode ¶
func (*Queries) GetProxyRunForRequester ¶
func (*Queries) GetRegistryListingLinkForOwner ¶
func (q *Queries) GetRegistryListingLinkForOwner(ctx context.Context, arg GetRegistryListingLinkForOwnerParams) (RegistryListingLink, error)
func (*Queries) GetRegistryListingLinkForProxyRun ¶
func (*Queries) GetRegistryListingLinkRowForOwner ¶
func (q *Queries) GetRegistryListingLinkRowForOwner(ctx context.Context, arg GetRegistryListingLinkRowForOwnerParams) (ListRegistryListingLinksByOwnerRow, error)
func (*Queries) GetRegistryNodeByIDForOwner ¶
func (q *Queries) GetRegistryNodeByIDForOwner(ctx context.Context, arg GetRegistryNodeByIDForOwnerParams) (RegistryNode, error)
func (*Queries) GetRunArtifactBySourceID ¶
func (q *Queries) GetRunArtifactBySourceID(ctx context.Context, arg GetRunArtifactBySourceIDParams) (RunArtifact, error)
func (*Queries) GetRunByID ¶
GetRunByID 按 id 查单条调用记录(详情页用,service 层做 owner 校验)。
func (*Queries) GetRunDelegationByChild ¶
func (*Queries) GetRunDeliveryByID ¶
func (*Queries) GetRunRequirementEvidenceByRun ¶
func (*Queries) GetRuntimePullRunState ¶
func (*Queries) GetTaskCallbackDeliveryByID ¶
func (*Queries) GetTaskQuery ¶
GetTaskQuery 按 id 查单条;调用方需自行校验 user_id 归属。
func (*Queries) GetUserByEmail ¶
GetUserByEmail 按 email 查活跃用户。
func (*Queries) GetUserByID ¶
GetUserByID 按 id 查活跃用户。
func (*Queries) GetUserByOAuth ¶
GetUserByOAuth 按 OAuth provider + id 查活跃用户。
func (*Queries) GetWebhookDeliveryByID ¶
func (q *Queries) GetWebhookDeliveryByID(ctx context.Context, id uuid.UUID) (GetWebhookDeliveryRow, error)
GetWebhookDeliveryByID worker 重试时按 id 取记录(含 secret)。
func (*Queries) GetWorkflowByID ¶
func (*Queries) GetWorkflowRunByID ¶
func (*Queries) HasRecentRuntimePullToken ¶
func (*Queries) IncrementAgentStats ¶
func (q *Queries) IncrementAgentStats(ctx context.Context, arg IncrementAgentStatsParams) error
func (*Queries) IncrementTaskCallbackSubscriptionFailure ¶
func (*Queries) ListA2AContextMappingsBeforeRunByRoot ¶
func (q *Queries) ListA2AContextMappingsBeforeRunByRoot(ctx context.Context, arg ListA2AContextMappingsBeforeRunByRootParams) ([]A2AContextMapping, error)
func (*Queries) ListA2AContextMappingsByRoot ¶
func (q *Queries) ListA2AContextMappingsByRoot(ctx context.Context, arg ListA2AContextMappingsByRootParams) ([]A2AContextMapping, error)
func (*Queries) ListActiveAgentRuntimeTokensByPrefix ¶
func (*Queries) ListActiveAgentTokensByPrefix ¶
func (*Queries) ListActiveRegistryFederationInvitesByPrefixForUpdate ¶
func (*Queries) ListActiveRegistryNodesBySecretPrefix ¶
func (*Queries) ListActiveRegistryPeersForAutoRoute ¶
func (*Queries) ListActiveTaskCallbackSubscriptionsForEvent ¶
func (q *Queries) ListActiveTaskCallbackSubscriptionsForEvent(ctx context.Context, arg ListActiveTaskCallbackSubscriptionsForEventParams) ([]TaskCallbackSubscription, error)
func (*Queries) ListAdminAgents ¶
func (q *Queries) ListAdminAgents(ctx context.Context, arg ListAdminAgentsParams) ([]ListAdminAgentsRow, error)
ListAdminAgents 管理台 Agent 列表。
func (*Queries) ListAdminTasks ¶
func (q *Queries) ListAdminTasks(ctx context.Context, arg ListAdminTasksParams) ([]ListAdminTasksRow, error)
func (*Queries) ListAdminUsers ¶
func (q *Queries) ListAdminUsers(ctx context.Context, arg ListAdminUsersParams) ([]ListAdminUsersRow, error)
ListAdminUsers 管理台用户列表。
func (*Queries) ListAgentApprovalsForCreator ¶
func (*Queries) ListAgentAvailabilityAlertsByCreator ¶
func (q *Queries) ListAgentAvailabilityAlertsByCreator(ctx context.Context, arg ListAgentAvailabilityAlertsByCreatorParams) ([]ListAgentAvailabilityAlertsByCreatorRow, error)
func (*Queries) ListAgentExamplesByAgentID ¶
func (*Queries) ListAgentExamplesBySlug ¶
func (*Queries) ListAgentMetricSnapshotsByAgent ¶
func (*Queries) ListAgentRuntimeTokensForOwner ¶
func (q *Queries) ListAgentRuntimeTokensForOwner(ctx context.Context, arg ListAgentRuntimeTokensForOwnerParams) ([]AgentRuntimeToken, error)
func (*Queries) ListAgentSkillScoresByAgent ¶
func (*Queries) ListAgentSkillScoresBySlug ¶
func (*Queries) ListAgentSkills ¶
ListAgentSkills 列出某 Agent 已声明的全部 skill 详情行。
func (*Queries) ListAgentStatsForCreator ¶
func (q *Queries) ListAgentStatsForCreator(ctx context.Context, creatorID uuid.UUID) ([]ListAgentStatsForCreatorRow, error)
ListAgentStatsForCreator 创作者每个 Agent 的本月调用 + 收入。
func (*Queries) ListAgentTokensByCreator ¶
func (q *Queries) ListAgentTokensByCreator(ctx context.Context, arg ListAgentTokensByCreatorParams) ([]AgentToken, error)
func (*Queries) ListAgentTokensByCreatorAndAgent ¶
func (q *Queries) ListAgentTokensByCreatorAndAgent(ctx context.Context, arg ListAgentTokensByCreatorAndAgentParams) ([]AgentToken, error)
func (*Queries) ListAgentsByCreator ¶
func (*Queries) ListAgentsByCreatorPage ¶ added in v0.1.14
func (q *Queries) ListAgentsByCreatorPage(ctx context.Context, arg ListAgentsByCreatorPageParams) ([]ListAgentsByCreatorPageRow, error)
func (*Queries) ListAgentsBySkills ¶
func (q *Queries) ListAgentsBySkills(ctx context.Context, skillIDs []string) ([]AgentSkillMatch, error)
ListAgentsBySkills 任务驱动推荐:返回每个 approved Agent 命中了多少个输入 skill。
排序:match_count desc, total_calls desc, id(稳定 tie-break)。 上层(任务模块 2.4)通常会再按 match_count >= 阈值过滤并截 top-N。
func (*Queries) ListAgentsBySkillsWithVerified ¶
func (*Queries) ListAgentsDueAvailabilityCheck ¶
func (*Queries) ListBenchmarkBatchSummariesByAgent ¶
func (q *Queries) ListBenchmarkBatchSummariesByAgent(ctx context.Context, arg ListBenchmarkBatchSummariesByAgentParams) ([]ListBenchmarkBatchSummariesByAgentRow, error)
func (*Queries) ListBenchmarkRunsByBatch ¶
func (*Queries) ListCallRecordsForUser ¶ added in v0.1.14
func (q *Queries) ListCallRecordsForUser(ctx context.Context, arg ListCallRecordsForUserParams) ([]ListCallRecordsForUserRow, error)
func (*Queries) ListChildRunsByParentAndUser ¶
func (q *Queries) ListChildRunsByParentAndUser(ctx context.Context, arg ListChildRunsByParentAndUserParams) ([]ListChildRunsByParentAndUserRow, error)
func (*Queries) ListDelegationLineage ¶
func (*Queries) ListDeliveriesByAgent ¶
func (q *Queries) ListDeliveriesByAgent(ctx context.Context, arg ListDeliveriesByAgentParams) ([]WebhookDelivery, error)
ListDeliveriesByAgent 创作者查看 agent 的投递历史。 业务层应先校验 agent.creator_id == 当前用户。
func (*Queries) ListDeliveryTargetsByUser ¶
func (*Queries) ListParentRunsWithDelegationsByUser ¶
func (q *Queries) ListParentRunsWithDelegationsByUser(ctx context.Context, arg ListParentRunsWithDelegationsByUserParams) ([]ListParentRunsWithDelegationsByUserRow, error)
func (*Queries) ListPendingAgents ¶
func (q *Queries) ListPendingAgents(ctx context.Context) ([]ListPendingAgentsRow, error)
ListPendingAgents 运营人工处理认证申请队列。
func (*Queries) ListPendingDeliveries ¶
func (q *Queries) ListPendingDeliveries(ctx context.Context) ([]WebhookDelivery, error)
ListPendingDeliveries worker 取出所有应重试的投递。
func (*Queries) ListPendingRunDeliveries ¶
func (q *Queries) ListPendingRunDeliveries(ctx context.Context) ([]RunDelivery, error)
func (*Queries) ListPendingTaskCallbackDeliveries ¶
func (q *Queries) ListPendingTaskCallbackDeliveries(ctx context.Context) ([]TaskCallbackDelivery, error)
func (*Queries) ListProxyRunArtifactsForRequester ¶
func (q *Queries) ListProxyRunArtifactsForRequester(ctx context.Context, arg ListProxyRunArtifactsForRequesterParams) ([]ProxyRunArtifact, error)
func (*Queries) ListPublicAgents ¶
func (q *Queries) ListPublicAgents(ctx context.Context, arg ListPublicAgentsParams) ([]ListPublicAgentsRow, error)
ListPublicAgents 市场列表(visibility=public + lifecycle=active;tag/keyword 过滤;分页)。
func (*Queries) ListPublicTaskQueries ¶
ListPublicTaskQueries 最近公开任务流(任务广场用)。
只返回 visibility=public 的任务;本查询不返回用户邮箱/姓名,仅用于展示 公开摘要、Skill 和匹配状态。
func (*Queries) ListRegistryListingLinksByOwner ¶
func (*Queries) ListRegistryNodesByOwner ¶
func (*Queries) ListRegistryPeersByOwner ¶
func (*Queries) ListRunArtifactChunksByRun ¶
func (*Queries) ListRunArtifactsByRun ¶
func (*Queries) ListRunDeliveriesByRun ¶
func (*Queries) ListRunDeliveriesByUser ¶
func (q *Queries) ListRunDeliveriesByUser(ctx context.Context, arg ListRunDeliveriesByUserParams) ([]RunDelivery, error)
func (*Queries) ListRunEventsByRun ¶
func (q *Queries) ListRunEventsByRun(ctx context.Context, arg ListRunEventsByRunParams) ([]RunEvent, error)
ListRunEventsByRun 按 run 内 sequence 正序读取事件。
func (*Queries) ListRunMessagesByRun ¶
func (*Queries) ListRunMessagesByRuns ¶
func (*Queries) ListRunsByCreatorAgentWithAgent ¶
func (q *Queries) ListRunsByCreatorAgentWithAgent(ctx context.Context, arg ListRunsByCreatorAgentWithAgentParams) ([]ListRunsByCreatorAgentWithAgentRow, error)
ListRunsByCreatorAgentWithAgent 创作者查看某个自己 Agent 的被调用历史。
func (*Queries) ListRunsByUser ¶
ListRunsByUser 我的调用历史(不带 join,预留给只需要 run 数据的场景)。
func (*Queries) ListRunsByUserAndAgent ¶
func (q *Queries) ListRunsByUserAndAgent(ctx context.Context, arg ListRunsByUserAndAgentParams) ([]Run, error)
ListRunsByUserAndAgent returns one user's A2A-visible tasks for one Agent.
func (*Queries) ListRunsByUserWithAgent ¶
func (q *Queries) ListRunsByUserWithAgent(ctx context.Context, arg ListRunsByUserWithAgentParams) ([]ListRunsByUserWithAgentRow, error)
ListRunsByUserWithAgent 我的调用历史(带 agent 名称展示)。
func (*Queries) ListSkillProposalsByOwner ¶
func (q *Queries) ListSkillProposalsByOwner(ctx context.Context, ownerUserID uuid.UUID) ([]SkillProposal, error)
ListSkillProposalsByOwner 列出当前用户最近 100 条 Skill Proposal。
func (*Queries) ListSkills ¶
ListSkills 列出全部内置 skill。
func (*Queries) ListStaleEndpointRuns ¶
func (q *Queries) ListStaleEndpointRuns(ctx context.Context, arg ListStaleEndpointRunsParams) ([]ListStaleEndpointRunsRow, error)
func (*Queries) ListStaleRuntimePullRuns ¶
func (q *Queries) ListStaleRuntimePullRuns(ctx context.Context, arg ListStaleRuntimePullRunsParams) ([]ListStaleRuntimePullRunsRow, error)
func (*Queries) ListTaskCallbackDeliveriesByRun ¶
func (q *Queries) ListTaskCallbackDeliveriesByRun(ctx context.Context, arg ListTaskCallbackDeliveriesByRunParams) ([]ListTaskCallbackDeliveriesByRunRow, error)
func (*Queries) ListTaskCallbackSubscriptionsByOwner ¶
func (q *Queries) ListTaskCallbackSubscriptionsByOwner(ctx context.Context, arg ListTaskCallbackSubscriptionsByOwnerParams) ([]TaskCallbackSubscription, error)
func (*Queries) ListTaskCallbackSubscriptionsByRun ¶
func (q *Queries) ListTaskCallbackSubscriptionsByRun(ctx context.Context, arg ListTaskCallbackSubscriptionsByRunParams) ([]TaskCallbackSubscription, error)
func (*Queries) ListTaskQueriesByUser ¶
func (q *Queries) ListTaskQueriesByUser(ctx context.Context, arg ListTaskQueriesByUserParams) ([]TaskQuery, error)
ListTaskQueriesByUser 用户最近 N 条任务历史(倒序)。
func (*Queries) ListTestCasesBySkill ¶
func (*Queries) ListTopAgentsBySkill ¶
func (q *Queries) ListTopAgentsBySkill(ctx context.Context, arg ListTopAgentsBySkillParams) ([]ListTopAgentsBySkillRow, error)
func (*Queries) ListWorkflowNodes ¶
func (*Queries) ListWorkflowNodesByWorkflowIDs ¶
func (*Queries) ListWorkflowRunSteps ¶
func (*Queries) ListWorkflowRunStepsByRunIDs ¶
func (*Queries) ListWorkflowRunsByWorkflow ¶
func (q *Queries) ListWorkflowRunsByWorkflow(ctx context.Context, arg ListWorkflowRunsByWorkflowParams) ([]WorkflowRun, error)
func (*Queries) ListWorkflowsByUser ¶
func (*Queries) MarkAgentAvailabilityAlertRead ¶
func (q *Queries) MarkAgentAvailabilityAlertRead(ctx context.Context, arg MarkAgentAvailabilityAlertReadParams) (AgentAvailabilityAlert, error)
func (*Queries) MarkAgentAvailabilityFailure ¶
func (*Queries) MarkAgentAvailabilityHeartbeat ¶
func (*Queries) MarkAgentAvailabilitySuccess ¶
func (*Queries) MarkBenchmarkRunFailed ¶
func (*Queries) MarkBenchmarkRunSuccess ¶
func (*Queries) MarkCapabilitiesSet ¶
func (*Queries) MarkDeliveryFailedFinal ¶
func (q *Queries) MarkDeliveryFailedFinal(ctx context.Context, arg MarkDeliveryFailedFinalParams) error
MarkDeliveryFailedFinal 失败且放弃重试:终态 failed。
func (*Queries) MarkDeliveryFailedRetry ¶
func (q *Queries) MarkDeliveryFailedRetry(ctx context.Context, arg MarkDeliveryFailedRetryParams) error
MarkDeliveryFailedRetry 失败但还有重试机会,写入下次重试时间。
func (*Queries) MarkDeliverySuccess ¶
func (q *Queries) MarkDeliverySuccess(ctx context.Context, arg MarkDeliverySuccessParams) error
MarkDeliverySuccess 投递成功:终态。
func (*Queries) MarkExamplesSet ¶
func (*Queries) MarkRegistryFederationInviteConsumed ¶
func (*Queries) MarkRegistryFederationInviteExpired ¶
func (*Queries) MarkRegistryNodeHeartbeat ¶
func (*Queries) MarkRegistryPeerUsed ¶
func (q *Queries) MarkRegistryPeerUsed(ctx context.Context, arg MarkRegistryPeerUsedParams) error
func (*Queries) MarkRunDeliveryFailedFinal ¶
func (q *Queries) MarkRunDeliveryFailedFinal(ctx context.Context, arg MarkRunDeliveryFailedFinalParams) error
func (*Queries) MarkRunDeliveryFailedRetry ¶
func (q *Queries) MarkRunDeliveryFailedRetry(ctx context.Context, arg MarkRunDeliveryFailedRetryParams) error
func (*Queries) MarkRunDeliverySuccess ¶
func (q *Queries) MarkRunDeliverySuccess(ctx context.Context, arg MarkRunDeliverySuccessParams) error
func (*Queries) MarkRunFailed ¶
func (q *Queries) MarkRunFailed(ctx context.Context, arg MarkRunFailedParams) error
MarkRunFailed 调用失败:写错误信息与耗时。
func (*Queries) MarkRunSuccess ¶
func (q *Queries) MarkRunSuccess(ctx context.Context, arg MarkRunSuccessParams) error
MarkRunSuccess 调用成功:写 output 与耗时。 status='running' 守卫保证幂等(重放无副作用)。
func (*Queries) MarkTaskCallbackDeliveryFailedFinal ¶
func (q *Queries) MarkTaskCallbackDeliveryFailedFinal(ctx context.Context, arg MarkTaskCallbackDeliveryFailedFinalParams) error
func (*Queries) MarkTaskCallbackDeliveryFailedRetry ¶
func (q *Queries) MarkTaskCallbackDeliveryFailedRetry(ctx context.Context, arg MarkTaskCallbackDeliveryFailedRetryParams) error
func (*Queries) MarkTaskCallbackDeliverySuccess ¶
func (q *Queries) MarkTaskCallbackDeliverySuccess(ctx context.Context, arg MarkTaskCallbackDeliverySuccessParams) error
func (*Queries) MarkTaskQueryChosen ¶
func (q *Queries) MarkTaskQueryChosen(ctx context.Context, arg MarkTaskQueryChosenParams) (TaskQuery, error)
MarkTaskQueryChosen 用户选定推荐里某个 agent;返回 pgx.ErrNoRows 表示不存在或越权。
func (*Queries) MarkWorkflowRunFailed ¶
func (q *Queries) MarkWorkflowRunFailed(ctx context.Context, arg MarkWorkflowRunFailedParams) (WorkflowRun, error)
func (*Queries) MarkWorkflowRunStepFailed ¶
func (q *Queries) MarkWorkflowRunStepFailed(ctx context.Context, arg MarkWorkflowRunStepFailedParams) (WorkflowRunStep, error)
func (*Queries) MarkWorkflowRunStepSuccess ¶
func (q *Queries) MarkWorkflowRunStepSuccess(ctx context.Context, arg MarkWorkflowRunStepSuccessParams) (WorkflowRunStep, error)
func (*Queries) MarkWorkflowRunSuccess ¶
func (q *Queries) MarkWorkflowRunSuccess(ctx context.Context, arg MarkWorkflowRunSuccessParams) (WorkflowRun, error)
func (*Queries) PauseWorkflowRun ¶
func (*Queries) PublishTaskQuery ¶
func (*Queries) RedeemPendingAgentToken ¶
func (q *Queries) RedeemPendingAgentToken(ctx context.Context, arg RedeemPendingAgentTokenParams) (AgentToken, error)
func (*Queries) RejectAgentApproval ¶
func (*Queries) RejectCertification ¶
func (q *Queries) RejectCertification(ctx context.Context, arg RejectCertificationParams) (int64, error)
RejectCertification 运营拒绝认证(写原因)。 返回受影响行数:0 表示 Agent 不在 pending。
func (*Queries) ReleaseRuntimePullRunClaim ¶
func (q *Queries) ReleaseRuntimePullRunClaim(ctx context.Context, arg ReleaseRuntimePullRunClaimParams) error
func (*Queries) RequestCertification ¶
func (q *Queries) RequestCertification(ctx context.Context, arg RequestCertificationParams) (int64, error)
RequestCertification 创作者发起认证申请。 返回受影响行数:0 表示 Agent 不属于该 creator / 状态已 pending 或 certified(不能重复触发)。
func (*Queries) RequestTaskRevision ¶
func (*Queries) RequeueStaleWorkflowRuns ¶
func (*Queries) ResetRunDeliveryForRetry ¶
func (*Queries) ResetTaskCallbackSubscriptionFailures ¶
func (*Queries) ResumeWorkflowRun ¶
func (*Queries) RevokeAgentRuntimeTokenForOwner ¶
func (*Queries) RevokeAgentTokenForCreator ¶
func (*Queries) RevokeRegistryNodeForOwner ¶
func (q *Queries) RevokeRegistryNodeForOwner(ctx context.Context, arg RevokeRegistryNodeForOwnerParams) (RegistryNode, error)
func (*Queries) RotateRegistryNodeSecretForOwner ¶
func (q *Queries) RotateRegistryNodeSecretForOwner(ctx context.Context, arg RotateRegistryNodeSecretForOwnerParams) (RegistryNode, error)
func (*Queries) SetAgentVisibilityForOwner ¶
func (q *Queries) SetAgentVisibilityForOwner(ctx context.Context, arg SetAgentVisibilityForOwnerParams) error
func (*Queries) SetAgentWebhook ¶
SetAgentWebhook 创作者设置 webhook(同时刷新 secret)。 返回受影响行数:0 表示越权或 agent 不存在。
func (*Queries) SetDeliveryTargetDefault ¶
func (*Queries) SumEarningsByCreatorThisMonth ¶
func (q *Queries) SumEarningsByCreatorThisMonth(ctx context.Context, creatorID uuid.UUID) (int64, error)
SumEarningsByCreatorThisMonth 创作者本月收入(cents),通过 agent.creator_id 关联。
func (*Queries) SumSpentByUserThisMonth ¶
SumSpentByUserThisMonth 用户本月成功调用总花费(cents)。
func (*Queries) SyncRegistryListingMetadataByNode ¶
func (*Queries) SyncRegistryListingMetadataForOwner ¶
func (q *Queries) SyncRegistryListingMetadataForOwner(ctx context.Context, arg SyncRegistryListingMetadataForOwnerParams) (ListRegistryListingLinksByOwnerRow, error)
func (*Queries) TimeoutStaleProxyRuns ¶
func (*Queries) TouchAgentRuntimeToken ¶
func (*Queries) UpdateAdminAgentModeration ¶
func (q *Queries) UpdateAdminAgentModeration(ctx context.Context, arg UpdateAdminAgentModerationParams) (Agent, error)
UpdateAdminAgentModeration 管理台调整 Agent 三维状态。
func (*Queries) UpdateAdminUserFlags ¶
func (q *Queries) UpdateAdminUserFlags(ctx context.Context, arg UpdateAdminUserFlagsParams) (User, error)
UpdateAdminUserFlags 管理台调整用户身份标志。
func (*Queries) UpdateAgentDraft ¶
UpdateAgentDraft 创作者编辑;命中 0 行表示 Agent 不存在 / 不属于该 creator / 已下架。
func (*Queries) UpdateDeliveryTargetConfig ¶
func (q *Queries) UpdateDeliveryTargetConfig(ctx context.Context, arg UpdateDeliveryTargetConfigParams) (DeliveryTarget, error)
func (*Queries) UpdateDryRunResult ¶
func (*Queries) UpdateRegistryListingLinkStatusForOwner ¶
func (q *Queries) UpdateRegistryListingLinkStatusForOwner(ctx context.Context, arg UpdateRegistryListingLinkStatusForOwnerParams) (ListRegistryListingLinksByOwnerRow, error)
func (*Queries) UpdateRunArtifactContent ¶
func (q *Queries) UpdateRunArtifactContent(ctx context.Context, arg UpdateRunArtifactContentParams) (RunArtifact, error)
func (*Queries) UpdateTaskCallbackSubscriptionStatusForOwner ¶
func (q *Queries) UpdateTaskCallbackSubscriptionStatusForOwner(ctx context.Context, arg UpdateTaskCallbackSubscriptionStatusForOwnerParams) (TaskCallbackSubscription, error)
func (*Queries) UpdateUserBecomeCreator ¶
UpdateUserBecomeCreator Phase 1 一键成为创作者(无审核)。 返回受影响行数:0 表示用户不存在或已被软删。
func (*Queries) UpdateUserOAuth ¶
func (q *Queries) UpdateUserOAuth(ctx context.Context, arg UpdateUserOAuthParams) error
UpdateUserOAuth 已有 email 用户绑定 OAuth(预留,Phase 1 不使用)。
func (*Queries) UpsertA2AContextMapping ¶
func (q *Queries) UpsertA2AContextMapping(ctx context.Context, arg UpsertA2AContextMappingParams) (A2AContextMapping, error)
func (*Queries) UpsertAgentAvailabilityAlert ¶
func (q *Queries) UpsertAgentAvailabilityAlert(ctx context.Context, arg UpsertAgentAvailabilityAlertParams) (AgentAvailabilityAlert, error)
func (*Queries) UpsertAgentCallPolicyForOwner ¶
func (q *Queries) UpsertAgentCallPolicyForOwner(ctx context.Context, arg UpsertAgentCallPolicyForOwnerParams) (AgentCallPolicy, error)
func (*Queries) UpsertAgentCapability ¶
func (q *Queries) UpsertAgentCapability(ctx context.Context, arg UpsertAgentCapabilityParams) (AgentCapability, error)
func (*Queries) UpsertAgentMetricSnapshot ¶
func (q *Queries) UpsertAgentMetricSnapshot(ctx context.Context, arg UpsertAgentMetricSnapshotParams) error
func (*Queries) UpsertAgentSkillScore ¶
func (q *Queries) UpsertAgentSkillScore(ctx context.Context, arg UpsertAgentSkillScoreParams) (AgentSkillScore, error)
func (*Queries) UpsertRegistryListingLink ¶
func (q *Queries) UpsertRegistryListingLink(ctx context.Context, arg UpsertRegistryListingLinkParams) (RegistryListingLink, error)
type RegistryFederationInvite ¶
type RegistryFederationInvite struct {
ID uuid.UUID `db:"id" json:"id"`
OwnerUserID uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
Name string `db:"name" json:"name"`
APIBaseURL string `db:"api_base_url" json:"api_base_url"`
BearerToken string `db:"bearer_token" json:"-"`
TokenPrefix string `db:"token_prefix" json:"token_prefix"`
TokenHash string `db:"token_hash" json:"-"`
CredentialHint string `db:"credential_hint" json:"credential_hint"`
Status string `db:"status" json:"status"`
ExpiresAt time.Time `db:"expires_at" json:"expires_at"`
ConsumedAt *time.Time `db:"consumed_at" json:"consumed_at"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
RegistryFederationInvite is a one-time token exchange record used to create a RegistryPeer without copying the remote bearer token by hand.
type RegistryListingLink ¶
type RegistryListingLink struct {
ID uuid.UUID `db:"id" json:"id"`
RegistryListingID uuid.UUID `db:"registry_listing_id" json:"registry_listing_id"`
RegistryNodeID uuid.UUID `db:"registry_node_id" json:"registry_node_id"`
LocalAgentID uuid.UUID `db:"local_agent_id" json:"local_agent_id"`
RoutingMode string `db:"routing_mode" json:"routing_mode"`
PayloadPolicy string `db:"payload_policy" json:"payload_policy"`
PayloadRedactionKeys []string `db:"payload_redaction_keys" json:"payload_redaction_keys"`
SyncStatus string `db:"sync_status" json:"sync_status"`
SyncedAgentSlug string `db:"synced_agent_slug" json:"synced_agent_slug"`
SyncedAgentName string `db:"synced_agent_name" json:"synced_agent_name"`
SyncedAgentDescription string `db:"synced_agent_description" json:"synced_agent_description"`
SyncedAgentTags []string `db:"synced_agent_tags" json:"synced_agent_tags"`
SyncedAvailabilityStatus string `db:"synced_availability_status" json:"synced_availability_status"`
MetadataSyncedAt *time.Time `db:"metadata_synced_at" json:"metadata_synced_at"`
MetadataSyncError *string `db:"metadata_sync_error" json:"metadata_sync_error"`
LastSyncAt time.Time `db:"last_sync_at" json:"last_sync_at"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
RegistryListingLink 对应 registry_listing_links 表。
它表达“用户显式把某个本地 Agent 暴露成 Registry Listing”的关系。
type RegistryNode ¶
type RegistryNode struct {
ID uuid.UUID `db:"id" json:"id"`
OwnerUserID uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
NodeName string `db:"node_name" json:"node_name"`
NodeType string `db:"node_type" json:"node_type"`
BaseURL *string `db:"base_url" json:"base_url"`
SecretPrefix string `db:"secret_prefix" json:"secret_prefix"`
SecretHash string `db:"secret_hash" json:"-"`
Scopes []string `db:"scopes" json:"scopes"`
HeartbeatStatus string `db:"heartbeat_status" json:"heartbeat_status"`
LastHeartbeatAt *time.Time `db:"last_heartbeat_at" json:"last_heartbeat_at"`
RevokedAt *time.Time `db:"revoked_at" json:"revoked_at"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
RegistryNode 对应 registry_nodes 表。
这是 Bridge / Proxy Node 的代理身份;明文 secret 只在创建时返回,数据库只保存 hash。
type RegistryPeer ¶
type RegistryPeer struct {
ID uuid.UUID `db:"id" json:"id"`
OwnerUserID uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
Name string `db:"name" json:"name"`
APIBaseURL string `db:"api_base_url" json:"api_base_url"`
BearerToken string `db:"bearer_token" json:"-"`
CredentialHint string `db:"credential_hint" json:"credential_hint"`
Status string `db:"status" json:"status"`
LastUsedAt *time.Time `db:"last_used_at" json:"last_used_at"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
RegistryPeer stores trusted remote registry credentials for federated proxy routing. BearerToken is intentionally omitted from JSON output.
type RejectAgentApprovalParams ¶
type RejectAgentApprovalParams = ConfirmAgentApprovalParams
type Run ¶
type Run struct {
ID uuid.UUID `db:"id" json:"id"`
UserID uuid.UUID `db:"user_id" json:"user_id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
Input []byte `db:"input" json:"input"`
Output []byte `db:"output" json:"output"`
Status string `db:"status" json:"status"`
ErrorCode *string `db:"error_code" json:"error_code"`
ErrorMessage *string `db:"error_message" json:"error_message"`
CostCents int32 `db:"cost_cents" json:"cost_cents"`
PlatformFeeCents int32 `db:"platform_fee_cents" json:"platform_fee_cents"`
CreatorRevenueCents int32 `db:"creator_revenue_cents" json:"creator_revenue_cents"`
DurationMs *int32 `db:"duration_ms" json:"duration_ms"`
StartedAt time.Time `db:"started_at" json:"started_at"`
FinishedAt *time.Time `db:"finished_at" json:"finished_at"`
Source string `db:"source" json:"source"`
ClaimedByRuntimeTokenID *uuid.UUID `db:"claimed_by_runtime_token_id" json:"claimed_by_runtime_token_id"`
ClaimedAt *time.Time `db:"claimed_at" json:"claimed_at"`
}
Run 对应 runs 表(每次调用一行)。
status: 'running' | 'success' | 'failed' | 'timeout' | 'canceled' 金额单位 cents(int32):cost_cents = platform_fee_cents + creator_revenue_cents input/output 是 JSONB([]byte,原样透传)
type RunArtifact ¶
type RunArtifact struct {
ID uuid.UUID `db:"id" json:"id"`
RunID uuid.UUID `db:"run_id" json:"run_id"`
ArtifactType string `db:"artifact_type" json:"artifact_type"`
Title string `db:"title" json:"title"`
Content []byte `db:"content" json:"content"`
Visibility string `db:"visibility" json:"visibility"`
SourceArtifactID *string `db:"source_artifact_id" json:"source_artifact_id"`
MimeType *string `db:"mime_type" json:"mime_type"`
FileUri *string `db:"file_uri" json:"file_uri"`
FileName *string `db:"file_name" json:"file_name"`
FileSha256 *string `db:"file_sha256" json:"file_sha256"`
FileSizeBytes *int64 `db:"file_size_bytes" json:"file_size_bytes"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
}
RunArtifact 对应 run_artifacts 表。
artifact_type: json | text | file | data visibility: private | shared | public_example
type RunArtifactChunk ¶
type RunArtifactChunk struct {
ID uuid.UUID `db:"id" json:"id"`
RunID uuid.UUID `db:"run_id" json:"run_id"`
RunArtifactID uuid.UUID `db:"run_artifact_id" json:"run_artifact_id"`
SourceArtifactID string `db:"source_artifact_id" json:"source_artifact_id"`
EventSequence *int32 `db:"event_sequence" json:"event_sequence"`
ChunkIndex int32 `db:"chunk_index" json:"chunk_index"`
Append bool `db:"append" json:"append"`
LastChunk bool `db:"last_chunk" json:"last_chunk"`
Parts []byte `db:"parts" json:"parts"`
Payload []byte `db:"payload" json:"payload"`
PartsSha256 *string `db:"parts_sha256" json:"parts_sha256"`
PayloadSha256 *string `db:"payload_sha256" json:"payload_sha256"`
DeclaredSha256 *string `db:"declared_sha256" json:"declared_sha256"`
ChecksumStatus string `db:"checksum_status" json:"checksum_status"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
}
RunArtifactChunk 对应 run_artifact_chunks 表。
type RunDelegation ¶
type RunDelegation struct {
ChildRunID uuid.UUID `db:"child_run_id" json:"child_run_id"`
ParentRunID uuid.UUID `db:"parent_run_id" json:"parent_run_id"`
CallerAgentID uuid.UUID `db:"caller_agent_id" json:"caller_agent_id"`
Reason string `db:"reason" json:"reason"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
}
RunDelegation 将被调用的 child run 关联到发起委派的 parent run。
type RunDelivery ¶
type RunDelivery struct {
ID uuid.UUID `db:"id" json:"id"`
RunID uuid.UUID `db:"run_id" json:"run_id"`
TargetID uuid.UUID `db:"target_id" json:"target_id"`
UserID uuid.UUID `db:"user_id" json:"user_id"`
TargetType string `db:"target_type" json:"target_type"`
TargetURL string `db:"target_url" json:"target_url"`
Payload []byte `db:"payload" json:"payload"`
Status string `db:"status" json:"status"`
ResponseStatus *int32 `db:"response_status" json:"response_status"`
ResponseBody *string `db:"response_body" json:"response_body"`
ErrorMessage *string `db:"error_message" json:"error_message"`
AttemptCount int32 `db:"attempt_count" json:"attempt_count"`
NextRetryAt *time.Time `db:"next_retry_at" json:"next_retry_at"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
RunDelivery 对应 run_deliveries 表(用户侧投递记录)。
status: 'pending' | 'success' | 'failed' target_type / target_url 是投递时快照,即便 target 被删也能展示历史。
type RunEvent ¶
type RunEvent struct {
ID uuid.UUID `db:"id" json:"id"`
RunID uuid.UUID `db:"run_id" json:"run_id"`
ParentRunID *uuid.UUID `db:"parent_run_id" json:"parent_run_id"`
Sequence int32 `db:"sequence" json:"sequence"`
EventType string `db:"event_type" json:"event_type"`
Payload []byte `db:"payload" json:"payload"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
}
RunEvent 对应 run_events 表。
sequence 在单个 run 内递增,用于 SSE Last-Event-ID / 断线续传。 payload 是 JSONB 原始字节,调用方按 event_type 解析。
type RunMessage ¶
type RunMessage struct {
ID uuid.UUID `db:"id" json:"id"`
RunID uuid.UUID `db:"run_id" json:"run_id"`
EventSequence *int32 `db:"event_sequence" json:"event_sequence"`
Role string `db:"role" json:"role"`
Content string `db:"content" json:"content"`
Payload []byte `db:"payload" json:"payload"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
}
RunMessage 对应 run_messages 表。
role: user | agent | tool | platform
type RunRequirementEvidence ¶
type RunRequirementEvidence struct {
RunID uuid.UUID `db:"run_id" json:"run_id"`
TaskID uuid.UUID `db:"task_id" json:"task_id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
UserID uuid.UUID `db:"user_id" json:"user_id"`
RequiredSkillIDs []string `db:"required_skill_ids" json:"required_skill_ids"`
RequiredMCPTools []string `db:"required_mcp_tools" json:"required_mcp_tools"`
AgentSkillIDs []string `db:"agent_skill_ids" json:"agent_skill_ids"`
MatchedSkillIDs []string `db:"matched_skill_ids" json:"matched_skill_ids"`
MissingSkillIDs []string `db:"missing_skill_ids" json:"missing_skill_ids"`
UsedMCPTools []string `db:"used_mcp_tools" json:"used_mcp_tools"`
MissingMCPTools []string `db:"missing_mcp_tools" json:"missing_mcp_tools"`
CoverageStatus string `db:"coverage_status" json:"coverage_status"`
EvidenceSource string `db:"evidence_source" json:"evidence_source"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
}
RunRequirementEvidence 对应 run_requirement_evidence 表。
它把任务发布时声明的 Skill/MCP 要求快照到一次实际 run,避免运行完成后 只能从临时 metadata 猜测这次调用是否覆盖任务要求。
type RuntimePullRunState ¶
type RuntimePullRunState struct {
ID uuid.UUID `db:"id" json:"id"`
UserID uuid.UUID `db:"user_id" json:"user_id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
Status string `db:"status" json:"status"`
CostCents int32 `db:"cost_cents" json:"cost_cents"`
CreatorRevenueCents int32 `db:"creator_revenue_cents" json:"creator_revenue_cents"`
StartedAt time.Time `db:"started_at" json:"started_at"`
ClaimedByRuntimeTokenID *uuid.UUID `db:"claimed_by_runtime_token_id" json:"claimed_by_runtime_token_id"`
}
type SetAgentWebhookParams ¶
type SetAgentWebhookParams struct {
ID uuid.UUID `db:"id" json:"id"`
WebhookURL *string `db:"webhook_url" json:"webhook_url"`
WebhookSecret *string `db:"webhook_secret" json:"webhook_secret"`
CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
}
SetAgentWebhookParams 入参。
type Skill ¶
type Skill struct {
ID string `db:"id" json:"id"`
Category string `db:"category" json:"category"`
Name string `db:"name" json:"name"`
Description string `db:"description" json:"description"`
SortOrder int32 `db:"sort_order" json:"sort_order"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
}
Skill 对应 skills 表(平台维护的 30 个核心 skill)。
id 形如 "content/translation" / "dev/code-review";category 是 id 前的目录名。 description 用于 LLM 解析任务描述时做语义匹配。
type SkillProposal ¶
type SkillProposal struct {
ID uuid.UUID `db:"id" json:"id"`
OwnerUserID uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
AgentID *uuid.UUID `db:"agent_id" json:"agent_id"`
ProposedSkillID string `db:"proposed_skill_id" json:"proposed_skill_id"`
Category string `db:"category" json:"category"`
Name string `db:"name" json:"name"`
Description string `db:"description" json:"description"`
Source string `db:"source" json:"source"`
Status string `db:"status" json:"status"`
MatchedSkillID *string `db:"matched_skill_id" json:"matched_skill_id"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
SkillProposal 对应 skill_proposals 表。
用户提交缺失 Skill 或导入 Agent 声明时写入,平台后续可合并到 skills。 当 proposed_skill_id 已存在时 status=merged,并通过 matched_skill_id 指向内置 Skill。
type SkillTestCase ¶
type SkillTestCase struct {
ID uuid.UUID `db:"id" json:"id"`
SkillID string `db:"skill_id" json:"skill_id"`
Title string `db:"title" json:"title"`
InputJSON []byte `db:"input_json" json:"input_json"`
JudgePrompt string `db:"judge_prompt" json:"judge_prompt"`
SortOrder int32 `db:"sort_order" json:"sort_order"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
}
SkillTestCase 对应 skill_test_cases 表。
模块 B(Phase 2 §5):Skill Benchmark 测试用例(平台维护)。 input_json 喂给 Agent endpoint;judge_prompt 是 LLM-as-judge 评分模板, service 层会用真实 endpoint 输出替换 prompt 中的 {output} 占位。
type TaskCallbackDelivery ¶
type TaskCallbackDelivery struct {
ID uuid.UUID `db:"id" json:"id"`
SubscriptionID uuid.UUID `db:"subscription_id" json:"subscription_id"`
RunEventID uuid.UUID `db:"run_event_id" json:"run_event_id"`
Payload []byte `db:"payload" json:"payload"`
Status string `db:"status" json:"status"`
ResponseStatus *int32 `db:"response_status" json:"response_status"`
ResponseBody *string `db:"response_body" json:"response_body"`
ErrorMessage *string `db:"error_message" json:"error_message"`
AttemptCount int32 `db:"attempt_count" json:"attempt_count"`
NextRetryAt *time.Time `db:"next_retry_at" json:"next_retry_at"`
DeliveredAt *time.Time `db:"delivered_at" json:"delivered_at"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
TaskCallbackDelivery 对应 task_callback_deliveries 表。
type TaskCallbackSubscription ¶
type TaskCallbackSubscription struct {
ID uuid.UUID `db:"id" json:"id"`
RunID uuid.UUID `db:"run_id" json:"run_id"`
OwnerUserID uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
CallerAgentID *uuid.UUID `db:"caller_agent_id" json:"caller_agent_id"`
TargetURL string `db:"target_url" json:"target_url"`
Secret string `db:"secret" json:"-"`
EventTypes []string `db:"event_types" json:"event_types"`
AuthScheme *string `db:"auth_scheme" json:"auth_scheme,omitempty"`
AuthCredentials *string `db:"auth_credentials" json:"-"`
Metadata []byte `db:"metadata" json:"metadata"`
Status string `db:"status" json:"status"`
ConsecutiveFailures int32 `db:"consecutive_failures" json:"consecutive_failures"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
DeletedAt *time.Time `db:"deleted_at" json:"deleted_at"`
}
TaskCallbackSubscription 对应 task_callback_subscriptions 表。
status: 'active' | 'paused' | 'failed' | 'deleted'
type TaskQuery ¶
type TaskQuery struct {
ID uuid.UUID `db:"id" json:"id"`
UserID uuid.UUID `db:"user_id" json:"user_id"`
Query string `db:"query" json:"query"`
ParsedSkills []string `db:"parsed_skills" json:"parsed_skills"`
MCPTools []string `db:"mcp_tools" json:"mcp_tools"`
RecommendedAgentIDs []uuid.UUID `db:"recommended_agent_ids" json:"recommended_agent_ids"`
ChosenAgentID *uuid.UUID `db:"chosen_agent_id" json:"chosen_agent_id"`
ChosenAt *time.Time `db:"chosen_at" json:"chosen_at"`
ClaimedAgentID *uuid.UUID `db:"claimed_agent_id" json:"claimed_agent_id"`
ClaimedByUserID *uuid.UUID `db:"claimed_by_user_id" json:"claimed_by_user_id"`
ClaimedAt *time.Time `db:"claimed_at" json:"claimed_at"`
ClaimRunID *uuid.UUID `db:"claim_run_id" json:"claim_run_id"`
CompletedAt *time.Time `db:"completed_at" json:"completed_at"`
CompletionSummary *string `db:"completion_summary" json:"completion_summary"`
CompletionRunID *uuid.UUID `db:"completion_run_id" json:"completion_run_id"`
DeliveryStatus string `db:"delivery_status" json:"delivery_status"`
DeliveryVisibility string `db:"delivery_visibility" json:"delivery_visibility"`
DeliveryArtifact []byte `db:"delivery_artifact" json:"delivery_artifact"`
AcceptedAt *time.Time `db:"accepted_at" json:"accepted_at"`
RevisionRequestedAt *time.Time `db:"revision_requested_at" json:"revision_requested_at"`
RevisionNote *string `db:"revision_note" json:"revision_note"`
Visibility string `db:"visibility" json:"visibility"`
PublicSummary *string `db:"public_summary" json:"public_summary"`
PublishedAt *time.Time `db:"published_at" json:"published_at"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
}
TaskQuery 对应 task_queries 表(任务驱动 A 形态)。
query 是用户自然语言描述;parsed_skills 是关联/解析出的 skill_id 列表;mcp_tools 是任务关联的 MCP 工具名。 recommended_agent_ids 按推荐顺序保存(top 3);chosen_agent_id 记录用户最终选择(可空)。 claimed_* / completion_* 让任务广场形成"接单 -> 运行 -> 结果回填"的最小闭环。 delivery_* / accepted_at / revision_* 记录任务交付、验收和修订状态。 visibility / public_summary / published_at 区分私有推荐草稿和显式公开任务。
type UpdateAdminAgentModerationParams ¶
type UpdateAdminAgentModerationParams struct {
ID uuid.UUID `db:"id" json:"id"`
LifecycleStatus string `db:"lifecycle_status" json:"lifecycle_status"`
Visibility string `db:"visibility" json:"visibility"`
CertificationStatus string `db:"certification_status" json:"certification_status"`
RejectionReason string `db:"rejection_reason" json:"rejection_reason"`
}
type UpdateAgentDraftParams ¶
type UpdateAgentDraftParams struct {
ID uuid.UUID `db:"id" json:"id"`
Name string `db:"name" json:"name"`
Description string `db:"description" json:"description"`
EndpointURL string `db:"endpoint_url" json:"endpoint_url"`
EndpointAuthHeader *string `db:"endpoint_auth_header" json:"endpoint_auth_header"`
PricePerCallCents int32 `db:"price_per_call_cents" json:"price_per_call_cents"`
Tags []string `db:"tags" json:"tags"`
CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
Visibility string `db:"visibility" json:"visibility"`
ConnectionMode string `db:"connection_mode" json:"connection_mode"`
MCPToolName *string `db:"mcp_tool_name" json:"mcp_tool_name"`
}
UpdateAgentDraftParams 入参。Visibility 可由创作者直接改 (public/unlisted/private)。
type UpdateRunArtifactContentParams ¶
type UpdateRunArtifactContentParams struct {
ID uuid.UUID `db:"id" json:"id"`
RunID uuid.UUID `db:"run_id" json:"run_id"`
ArtifactType string `db:"artifact_type" json:"artifact_type"`
Title string `db:"title" json:"title"`
Content []byte `db:"content" json:"content"`
Visibility string `db:"visibility" json:"visibility"`
MimeType *string `db:"mime_type" json:"mime_type"`
FileUri *string `db:"file_uri" json:"file_uri"`
FileName *string `db:"file_name" json:"file_name"`
FileSha256 *string `db:"file_sha256" json:"file_sha256"`
FileSizeBytes *int64 `db:"file_size_bytes" json:"file_size_bytes"`
}
type UpdateUserOAuthParams ¶
type UpdateUserOAuthParams struct {
ID uuid.UUID `db:"id" json:"id"`
OauthProvider *string `db:"oauth_provider" json:"oauth_provider"`
OauthID *string `db:"oauth_id" json:"oauth_id"`
AvatarURL string `db:"avatar_url" json:"avatar_url"`
}
UpdateUserOAuthParams 入参。
type UpsertA2AContextMappingParams ¶
type UpsertA2AContextMappingParams struct {
RunID uuid.UUID `db:"run_id" json:"run_id"`
UserID uuid.UUID `db:"user_id" json:"user_id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
ProtocolContextID string `db:"protocol_context_id" json:"protocol_context_id"`
ProtocolTaskID string `db:"protocol_task_id" json:"protocol_task_id"`
RootContextID string `db:"root_context_id" json:"root_context_id"`
ParentContextID string `db:"parent_context_id" json:"parent_context_id"`
ParentTaskID string `db:"parent_task_id" json:"parent_task_id"`
ParentRunID *uuid.UUID `db:"parent_run_id" json:"parent_run_id"`
CallerAgentID *uuid.UUID `db:"caller_agent_id" json:"caller_agent_id"`
TargetAgentID *uuid.UUID `db:"target_agent_id" json:"target_agent_id"`
TraceID string `db:"trace_id" json:"trace_id"`
ReferenceTaskIDs []string `db:"reference_task_ids" json:"reference_task_ids"`
Source string `db:"source" json:"source"`
}
type UpsertAgentAvailabilityAlertParams ¶
type UpsertAgentAvailabilityAlertParams struct {
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
AlertType string `db:"alert_type" json:"alert_type"`
Severity string `db:"severity" json:"severity"`
AvailabilityStatus string `db:"availability_status" json:"availability_status"`
ConsecutiveFailures int32 `db:"consecutive_failures" json:"consecutive_failures"`
Title string `db:"title" json:"title"`
Message string `db:"message" json:"message"`
LastError *string `db:"last_error" json:"last_error"`
RepairHints []string `db:"repair_hints" json:"repair_hints"`
}
type UpsertAgentCapabilityParams ¶
type UpsertAgentCapabilityParams struct {
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
InputSchema []byte `db:"input_schema" json:"input_schema"`
OutputSchema []byte `db:"output_schema" json:"output_schema"`
Summary string `db:"summary" json:"summary"`
}
type UpsertAgentMetricSnapshotParams ¶
type UpsertAgentMetricSnapshotParams struct {
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
TimeWindow string `db:"time_window" json:"time_window"`
CallCount int32 `db:"call_count" json:"call_count"`
SuccessCount int32 `db:"success_count" json:"success_count"`
FailureCount int32 `db:"failure_count" json:"failure_count"`
SuccessRateBps int32 `db:"success_rate_bps" json:"success_rate_bps"`
MedianLatencyMs *int32 `db:"median_latency_ms" json:"median_latency_ms"`
P95LatencyMs *int32 `db:"p95_latency_ms" json:"p95_latency_ms"`
}
type UpsertAgentSkillScoreParams ¶
type UpsertAgentSkillScoreParams struct {
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
SkillID string `db:"skill_id" json:"skill_id"`
Status string `db:"status" json:"status"`
AverageScore *int32 `db:"average_score" json:"average_score"`
PassCount int32 `db:"pass_count" json:"pass_count"`
TotalCount int32 `db:"total_count" json:"total_count"`
LastBatchID *uuid.UUID `db:"last_batch_id" json:"last_batch_id"`
VerifiedAt *time.Time `db:"verified_at" json:"verified_at"`
}
type UpsertRegistryListingLinkParams ¶
type UpsertRegistryListingLinkParams struct {
RegistryListingID uuid.UUID `db:"registry_listing_id" json:"registry_listing_id"`
RegistryNodeID uuid.UUID `db:"registry_node_id" json:"registry_node_id"`
LocalAgentID uuid.UUID `db:"local_agent_id" json:"local_agent_id"`
RoutingMode string `db:"routing_mode" json:"routing_mode"`
PayloadPolicy string `db:"payload_policy" json:"payload_policy"`
PayloadRedactionKeys []string `db:"payload_redaction_keys" json:"payload_redaction_keys"`
}
type User ¶
type User struct {
ID uuid.UUID `db:"id" json:"id"`
Email string `db:"email" json:"email"`
PasswordHash *string `db:"password_hash" json:"password_hash"`
OauthProvider *string `db:"oauth_provider" json:"oauth_provider"`
OauthID *string `db:"oauth_id" json:"oauth_id"`
DisplayName string `db:"display_name" json:"display_name"`
AvatarURL *string `db:"avatar_url" json:"avatar_url"`
IsCreator bool `db:"is_creator" json:"is_creator"`
CreatorVerified bool `db:"creator_verified" json:"creator_verified"`
IsAdmin bool `db:"is_admin" json:"is_admin"`
DisabledAt *time.Time `db:"disabled_at" json:"disabled_at"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
DeletedAt *time.Time `db:"deleted_at" json:"deleted_at"`
}
User 对应 users 表。 password_hash / oauth_provider / oauth_id / avatar_url / deleted_at 可空。
type WebhookDelivery ¶
type WebhookDelivery struct {
ID uuid.UUID `db:"id" json:"id"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
RunID uuid.UUID `db:"run_id" json:"run_id"`
URL string `db:"url" json:"url"`
Payload []byte `db:"payload" json:"payload"`
Status string `db:"status" json:"status"`
ResponseStatus *int32 `db:"response_status" json:"response_status"`
ResponseBody *string `db:"response_body" json:"response_body"`
ErrorMessage *string `db:"error_message" json:"error_message"`
AttemptCount int32 `db:"attempt_count" json:"attempt_count"`
NextRetryAt *time.Time `db:"next_retry_at" json:"next_retry_at"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
WebhookDelivery 对应 webhook_deliveries 表(投递日志)。
status: 'pending' | 'success' | 'failed' next_retry_at NULL 表示完成或放弃;非 NULL 时由 worker 重试
type Workflow ¶
type Workflow struct {
ID uuid.UUID `db:"id" json:"id"`
UserID uuid.UUID `db:"user_id" json:"user_id"`
Name string `db:"name" json:"name"`
Description string `db:"description" json:"description"`
Status string `db:"status" json:"status"`
Edges []byte `db:"edges" json:"edges"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
Workflow 对应 workflows 表。
type WorkflowNode ¶
type WorkflowNode struct {
ID uuid.UUID `db:"id" json:"id"`
WorkflowID uuid.UUID `db:"workflow_id" json:"workflow_id"`
NodeKey string `db:"node_key" json:"node_key"`
NodeType string `db:"node_type" json:"node_type"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
Title string `db:"title" json:"title"`
Config []byte `db:"config" json:"config"`
Position int32 `db:"position" json:"position"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
}
WorkflowNode 对应 workflow_nodes 表。
type WorkflowRun ¶
type WorkflowRun struct {
ID uuid.UUID `db:"id" json:"id"`
WorkflowID uuid.UUID `db:"workflow_id" json:"workflow_id"`
UserID uuid.UUID `db:"user_id" json:"user_id"`
Status string `db:"status" json:"status"`
Input []byte `db:"input" json:"input"`
Output []byte `db:"output" json:"output"`
ErrorMessage *string `db:"error_message" json:"error_message"`
StartedAt time.Time `db:"started_at" json:"started_at"`
FinishedAt *time.Time `db:"finished_at" json:"finished_at"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
AttemptCount int32 `db:"attempt_count" json:"attempt_count"`
MaxAttempts int32 `db:"max_attempts" json:"max_attempts"`
NextRetryAt *time.Time `db:"next_retry_at" json:"next_retry_at"`
ClaimedAt *time.Time `db:"claimed_at" json:"claimed_at"`
LastWorkerError *string `db:"last_worker_error" json:"last_worker_error"`
}
WorkflowRun 对应 workflow_runs 表。
type WorkflowRunStep ¶
type WorkflowRunStep struct {
ID uuid.UUID `db:"id" json:"id"`
WorkflowRunID uuid.UUID `db:"workflow_run_id" json:"workflow_run_id"`
WorkflowNodeID uuid.UUID `db:"workflow_node_id" json:"workflow_node_id"`
NodeKey string `db:"node_key" json:"node_key"`
AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
RunID *uuid.UUID `db:"run_id" json:"run_id"`
Status string `db:"status" json:"status"`
Input []byte `db:"input" json:"input"`
Output []byte `db:"output" json:"output"`
ErrorMessage *string `db:"error_message" json:"error_message"`
Sequence int32 `db:"sequence" json:"sequence"`
StartedAt time.Time `db:"started_at" json:"started_at"`
FinishedAt *time.Time `db:"finished_at" json:"finished_at"`
CreatedAt time.Time `db:"created_at" json:"created_at"`
UpdatedAt time.Time `db:"updated_at" json:"updated_at"`
}
WorkflowRunStep 对应 workflow_run_steps 表。
Source Files
¶
- a2a.sql.go
- agent_approvals.sql.go
- agent_availability.sql.go
- agent_metrics.sql.go
- agent_tokens.sql.go
- agents.sql.go
- agents_market.sql.go
- benchmark.sql.go
- call_records.sql.go
- capabilities.sql.go
- db.go
- delivery.sql.go
- models.go
- registry_bridge.sql.go
- registry_peers.sql.go
- run_artifacts.sql.go
- run_events.sql.go
- run_messages.sql.go
- run_requirements.sql.go
- runs.sql.go
- runs_dashboard.sql.go
- skills.sql.go
- task_callbacks.sql.go
- tasks.sql.go
- users.sql.go
- webhooks.sql.go
- workflows.sql.go