db

package
v0.1.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 6, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ReplaceAgentSkills

func ReplaceAgentSkills(ctx context.Context, tx pgx.Tx, agentID uuid.UUID, skillIDs []string) error

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 AcceptTaskDeliveryParams

type AcceptTaskDeliveryParams struct {
	ID     uuid.UUID `db:"id" json:"id"`
	UserID uuid.UUID `db:"user_id" json:"user_id"`
}

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 BatchUpdateTaskCallbackSubscriptionsForOwnerParams

type BatchUpdateTaskCallbackSubscriptionsForOwnerParams struct {
	OwnerUserID uuid.UUID   `db:"owner_user_id" json:"owner_user_id"`
	IDs         []uuid.UUID `db:"ids" json:"ids"`
	Status      string      `db:"status" json:"status"`
}

type CancelRunParams

type CancelRunParams struct {
	ID           uuid.UUID `db:"id" json:"id"`
	UserID       uuid.UUID `db:"user_id" json:"user_id"`
	ErrorMessage string    `db:"error_message" json:"error_message"`
}

type ClaimRuntimePullRunParams

type ClaimRuntimePullRunParams struct {
	AgentID        uuid.UUID `db:"agent_id" json:"agent_id"`
	RuntimeTokenID uuid.UUID `db:"runtime_token_id" json:"runtime_token_id"`
}

type ClaimStaleRuntimePullRunParams

type ClaimStaleRuntimePullRunParams struct {
	AgentID        uuid.UUID `db:"agent_id" json:"agent_id"`
	RuntimeTokenID uuid.UUID `db:"runtime_token_id" json:"runtime_token_id"`
	ClaimedBefore  time.Time `db:"claimed_before" json:"claimed_before"`
}

type ClaimTaskQueryParams

type ClaimTaskQueryParams 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"`
}

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 ConfirmAgentApprovalParams

type ConfirmAgentApprovalParams struct {
	ID           uuid.UUID `db:"id" json:"id"`
	CreatorID    uuid.UUID `db:"creator_id" json:"creator_id"`
	DecisionNote *string   `db:"decision_note" json:"decision_note"`
}

type CountAdminAgentsParams

type CountAdminAgentsParams 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"`
}

type CountAdminTasksParams

type CountAdminTasksParams 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"`
}

type CountAdminUsersParams

type CountAdminUsersParams struct {
	Query string `db:"query" json:"query"`
	Role  string `db:"role" json:"role"`
}

type CountAgentTokensByCreatorAndAgentParams added in v0.1.7

type CountAgentTokensByCreatorAndAgentParams struct {
	CreatorUserID uuid.UUID `db:"creator_user_id" json:"creator_user_id"`
	AgentID       uuid.UUID `db:"agent_id" json:"agent_id"`
}

type CountParentRunsWithDelegationsByUserParams

type CountParentRunsWithDelegationsByUserParams struct {
	UserID uuid.UUID `db:"user_id" json:"user_id"`
	Search string    `db:"search" json:"search"`
}

type CountPublicAgentsParams

type CountPublicAgentsParams struct {
	Tags         []string `db:"tags" json:"tags"`
	Keyword      string   `db:"keyword" json:"keyword"`
	CallableOnly bool     `db:"callable_only" json:"callable_only"`
}

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 CreateBenchmarkRunParams

type CreateBenchmarkRunParams struct {
	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"`
}

type CreateDeliveryTargetParams

type CreateDeliveryTargetParams struct {
	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:"secret"`
	IsDefault bool      `db:"is_default" json:"is_default"`
}

type CreatePendingWorkflowRunParams

type CreatePendingWorkflowRunParams struct {
	WorkflowID  uuid.UUID `db:"workflow_id" json:"workflow_id"`
	UserID      uuid.UUID `db:"user_id" json:"user_id"`
	Input       []byte    `db:"input" json:"input"`
	MaxAttempts int32     `db:"max_attempts" json:"max_attempts"`
}

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 CreateRunDelegationParams

type CreateRunDelegationParams 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"`
}

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 CreateRunMessageParams struct {
	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"`
}

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 CreateTaskCallbackDeliveryParams

type CreateTaskCallbackDeliveryParams struct {
	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"`
}

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 CreateWorkflowParams struct {
	UserID      uuid.UUID `db:"user_id" json:"user_id"`
	Name        string    `db:"name" json:"name"`
	Description string    `db:"description" json:"description"`
	Edges       []byte    `db:"edges" json:"edges"`
}

type CreateWorkflowRunParams

type CreateWorkflowRunParams struct {
	WorkflowID uuid.UUID `db:"workflow_id" json:"workflow_id"`
	UserID     uuid.UUID `db:"user_id" json:"user_id"`
	Input      []byte    `db:"input" json:"input"`
}

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 DeleteAgentExampleForOwnerParams

type DeleteAgentExampleForOwnerParams 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"`
}

type DeleteDeliveryTargetParams

type DeleteDeliveryTargetParams struct {
	ID     uuid.UUID `db:"id" json:"id"`
	UserID uuid.UUID `db:"user_id" json:"user_id"`
}

type DeleteRegistryPeerForOwnerParams

type DeleteRegistryPeerForOwnerParams struct {
	ID          uuid.UUID `db:"id" json:"id"`
	OwnerUserID uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
}

type DeleteTaskCallbackSubscriptionForOwnerParams

type DeleteTaskCallbackSubscriptionForOwnerParams 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"`
}

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 DisableAgentParams struct {
	ID        uuid.UUID `db:"id" json:"id"`
	CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
}

type GetActiveRegistryPeerForOwnerParams

type GetActiveRegistryPeerForOwnerParams struct {
	ID          uuid.UUID `db:"id" json:"id"`
	OwnerUserID uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
}

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 GetAgentApprovalForCreatorParams

type GetAgentApprovalForCreatorParams struct {
	ID        uuid.UUID `db:"id" json:"id"`
	CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
}

type GetAgentByIDForOwnerParams

type GetAgentByIDForOwnerParams struct {
	ID        uuid.UUID `db:"id" json:"id"`
	CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
}

type GetAgentBySlugForOwnerParams

type GetAgentBySlugForOwnerParams struct {
	Slug      string    `db:"slug" json:"slug"`
	CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
}

type GetAgentBySlugForOwnerRow

type GetAgentBySlugForOwnerRow struct {
	Agent
	CreatorName string `db:"creator_name" json:"creator_name"`
}

type GetAgentBySlugRow

type GetAgentBySlugRow struct {
	Agent
	CreatorName string `db:"creator_name" json:"creator_name"`
}

type GetAgentSkillScoreParams

type GetAgentSkillScoreParams struct {
	AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
	SkillID string    `db:"skill_id" json:"skill_id"`
}

type GetAgentVerifiedSkillStatsRow

type GetAgentVerifiedSkillStatsRow struct {
	VerifiedCount int32      `db:"verified_count" json:"verified_count"`
	LatestBatchID *uuid.UUID `db:"latest_batch_id" json:"latest_batch_id"`
}

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

type GetAgentsByIDsRow struct {
	Agent
	CreatorName string `db:"creator_name" json:"creator_name"`
}

GetAgentsByIDsRow Agent 全字段 + creator 显示名。

type GetDeliveryTargetByIDForUserParams

type GetDeliveryTargetByIDForUserParams struct {
	ID     uuid.UUID `db:"id" json:"id"`
	UserID uuid.UUID `db:"user_id" json:"user_id"`
}

type GetLatestRunEventForTypesParams

type GetLatestRunEventForTypesParams struct {
	RunID      uuid.UUID `db:"run_id" json:"run_id"`
	EventTypes []string  `db:"event_types" json:"event_types"`
}

type GetOnboardingStatusForOwnerParams

type GetOnboardingStatusForOwnerParams struct {
	AgentID   uuid.UUID `db:"agent_id" json:"agent_id"`
	CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
}

type GetProxyRunArtifactForRequesterParams

type GetProxyRunArtifactForRequesterParams struct {
	ID               uuid.UUID `db:"id" json:"id"`
	ProxyRunID       uuid.UUID `db:"proxy_run_id" json:"proxy_run_id"`
	RequestingUserID uuid.UUID `db:"requesting_user_id" json:"requesting_user_id"`
}

type GetProxyRunForNodeParams

type GetProxyRunForNodeParams struct {
	ID             uuid.UUID `db:"id" json:"id"`
	RegistryNodeID uuid.UUID `db:"registry_node_id" json:"registry_node_id"`
}

type GetProxyRunForRequesterParams

type GetProxyRunForRequesterParams struct {
	ID               uuid.UUID `db:"id" json:"id"`
	RequestingUserID uuid.UUID `db:"requesting_user_id" json:"requesting_user_id"`
}

type GetRegistryListingLinkForOwnerParams

type GetRegistryListingLinkForOwnerParams struct {
	RegistryListingID uuid.UUID `db:"registry_listing_id" json:"registry_listing_id"`
	OwnerUserID       uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
}

type GetRegistryListingLinkRowForOwnerParams

type GetRegistryListingLinkRowForOwnerParams struct {
	ID          uuid.UUID `db:"id" json:"id"`
	OwnerUserID uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
}

type GetRegistryNodeByIDForOwnerParams

type GetRegistryNodeByIDForOwnerParams struct {
	ID          uuid.UUID `db:"id" json:"id"`
	OwnerUserID uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
}

type GetRunArtifactBySourceIDParams

type GetRunArtifactBySourceIDParams struct {
	RunID            uuid.UUID `db:"run_id" json:"run_id"`
	SourceArtifactID string    `db:"source_artifact_id" json:"source_artifact_id"`
}

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 IncrementAgentStatsParams

type IncrementAgentStatsParams struct {
	ID           uuid.UUID `db:"id" json:"id"`
	RevenueCents int64     `db:"total_revenue_cents" json:"total_revenue_cents"`
}

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 ListA2AContextMappingsByRootParams

type ListA2AContextMappingsByRootParams struct {
	UserID        uuid.UUID `db:"user_id" json:"user_id"`
	RootContextID string    `db:"root_context_id" json:"root_context_id"`
	Limit         int32     `db:"limit" json:"limit"`
}

type ListActiveTaskCallbackSubscriptionsForEventParams

type ListActiveTaskCallbackSubscriptionsForEventParams struct {
	RunID     uuid.UUID `db:"run_id" json:"run_id"`
	EventType string    `db:"event_type" json:"event_type"`
}

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 ListAdminUsersParams struct {
	Query  string `db:"query" json:"query"`
	Role   string `db:"role" json:"role"`
	Limit  int32  `db:"limit" json:"limit"`
	Offset int32  `db:"offset" json:"offset"`
}

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 ListAgentAvailabilityAlertsByCreatorParams

type ListAgentAvailabilityAlertsByCreatorParams struct {
	CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
	Limit     int32     `db:"limit" json:"limit"`
}

type ListAgentAvailabilityAlertsByCreatorRow

type ListAgentAvailabilityAlertsByCreatorRow struct {
	AgentAvailabilityAlert
	AgentSlug string `db:"agent_slug" json:"agent_slug"`
	AgentName string `db:"agent_name" json:"agent_name"`
}

type ListAgentRuntimeTokensForOwnerParams

type ListAgentRuntimeTokensForOwnerParams struct {
	AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
	UserID  uuid.UUID `db:"user_id" json:"user_id"`
}

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 ListAgentTokensByCreatorParams struct {
	CreatorUserID uuid.UUID `db:"creator_user_id" json:"creator_user_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 ListAgentsDueAvailabilityCheckParams

type ListAgentsDueAvailabilityCheckParams struct {
	StaleSeconds int32 `db:"stale_seconds" json:"stale_seconds"`
	Limit        int32 `db:"limit" json:"limit"`
}

type ListBenchmarkBatchSummariesByAgentParams

type ListBenchmarkBatchSummariesByAgentParams struct {
	AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
	Limit   int32     `db:"limit" json:"limit"`
}

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 ListChildRunsByParentAndUserParams

type ListChildRunsByParentAndUserParams struct {
	ParentRunID uuid.UUID `db:"parent_run_id" json:"parent_run_id"`
	UserID      uuid.UUID `db:"user_id" json:"user_id"`
}

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 ListDelegationLineageParams

type ListDelegationLineageParams struct {
	RunID    uuid.UUID `db:"run_id" json:"run_id"`
	MaxDepth int32     `db:"max_depth" json:"max_depth"`
}

type ListDeliveriesByAgentParams

type ListDeliveriesByAgentParams struct {
	AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
	Limit   int32     `db:"limit" json:"limit"`
}

ListDeliveriesByAgentParams 入参。

type ListParentRunsWithDelegationsByUserParams

type ListParentRunsWithDelegationsByUserParams struct {
	UserID uuid.UUID `db:"user_id" json:"user_id"`
	Search string    `db:"search" json:"search"`
	Limit  int32     `db:"limit" json:"limit"`
	Offset int32     `db:"offset" json:"offset"`
}

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 ListProxyRunArtifactsForRequesterParams

type ListProxyRunArtifactsForRequesterParams struct {
	ProxyRunID       uuid.UUID `db:"proxy_run_id" json:"proxy_run_id"`
	RequestingUserID uuid.UUID `db:"requesting_user_id" json:"requesting_user_id"`
}

type ListPublicAgentsParams

type ListPublicAgentsParams struct {
	Tags         []string `db:"tags" json:"tags"`
	Keyword      string   `db:"keyword" json:"keyword"`
	Limit        int32    `db:"limit" json:"limit"`
	Offset       int32    `db:"offset" json:"offset"`
	CallableOnly bool     `db:"callable_only" json:"callable_only"`
}

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 ListStaleEndpointRunsParams

type ListStaleEndpointRunsParams struct {
	StaleBefore time.Time `db:"stale_before" json:"stale_before"`
	Limit       int32     `db:"limit" json:"limit"`
}

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 ListStaleRuntimePullRunsParams

type ListStaleRuntimePullRunsParams struct {
	DispatchStaleBefore time.Time `db:"dispatch_stale_before" json:"dispatch_stale_before"`
	ResultStaleBefore   time.Time `db:"result_stale_before" json:"result_stale_before"`
	Limit               int32     `db:"limit" json:"limit"`
}

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 ListTaskCallbackDeliveriesByRunParams

type ListTaskCallbackDeliveriesByRunParams struct {
	RunID       uuid.UUID `db:"run_id" json:"run_id"`
	OwnerUserID uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
	Limit       int32     `db:"limit" json:"limit"`
}

type ListTaskCallbackDeliveriesByRunRow

type ListTaskCallbackDeliveriesByRunRow struct {
	TaskCallbackDelivery
	TargetURL string `db:"target_url" json:"target_url"`
	EventType string `db:"event_type" json:"event_type"`
}

type ListTaskCallbackSubscriptionsByOwnerParams

type ListTaskCallbackSubscriptionsByOwnerParams struct {
	OwnerUserID uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
	Status      string    `db:"status" json:"status"`
	Limit       int32     `db:"limit" json:"limit"`
}

type ListTaskCallbackSubscriptionsByRunParams

type ListTaskCallbackSubscriptionsByRunParams struct {
	RunID       uuid.UUID `db:"run_id" json:"run_id"`
	OwnerUserID uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
}

type ListTaskQueriesByUserParams

type ListTaskQueriesByUserParams struct {
	UserID uuid.UUID `db:"user_id" json:"user_id"`
	Limit  int32     `db:"limit" json:"limit"`
}

ListTaskQueriesByUserParams 入参。

type ListTopAgentsBySkillParams

type ListTopAgentsBySkillParams struct {
	SkillID string `db:"skill_id" json:"skill_id"`
	Limit   int32  `db:"limit" json:"limit"`
}

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 ListWorkflowRunsByWorkflowParams

type ListWorkflowRunsByWorkflowParams struct {
	WorkflowID uuid.UUID `db:"workflow_id" json:"workflow_id"`
	Limit      int32     `db:"limit" json:"limit"`
}

type ListWorkflowsByUserParams

type ListWorkflowsByUserParams struct {
	UserID uuid.UUID `db:"user_id" json:"user_id"`
	Limit  int32     `db:"limit" json:"limit"`
}

type MarkAgentAvailabilityAlertReadParams

type MarkAgentAvailabilityAlertReadParams struct {
	ID        uuid.UUID `db:"id" json:"id"`
	CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
}

type MarkBenchmarkRunFailedParams

type MarkBenchmarkRunFailedParams struct {
	ID           uuid.UUID `db:"id" json:"id"`
	ErrorMessage string    `db:"error_message" json:"error_message"`
}

type MarkBenchmarkRunSuccessParams

type MarkBenchmarkRunSuccessParams struct {
	ID             uuid.UUID `db:"id" json:"id"`
	Score          int32     `db:"score" json:"score"`
	RawOutput      []byte    `db:"raw_output" json:"raw_output"`
	JudgeReasoning string    `db:"judge_reasoning" json:"judge_reasoning"`
}

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 MarkExamplesSetParams struct {
	AgentID     uuid.UUID `db:"agent_id" json:"agent_id"`
	ExamplesSet bool      `db:"examples_set" json:"examples_set"`
}

type MarkRegistryPeerUsedParams

type MarkRegistryPeerUsedParams struct {
	ID          uuid.UUID `db:"id" json:"id"`
	OwnerUserID uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
}

type MarkRunDeliveryFailedFinalParams

type MarkRunDeliveryFailedFinalParams 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"`
}

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 MarkRunDeliverySuccessParams

type MarkRunDeliverySuccessParams struct {
	ID             uuid.UUID `db:"id" json:"id"`
	ResponseStatus *int32    `db:"response_status" json:"response_status"`
	ResponseBody   *string   `db:"response_body" json:"response_body"`
}

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 MarkTaskCallbackDeliveryFailedFinalParams

type MarkTaskCallbackDeliveryFailedFinalParams 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"`
}

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 MarkTaskCallbackDeliverySuccessParams

type MarkTaskCallbackDeliverySuccessParams struct {
	ID             uuid.UUID `db:"id" json:"id"`
	ResponseStatus *int32    `db:"response_status" json:"response_status"`
	ResponseBody   *string   `db:"response_body" json:"response_body"`
}

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 MarkWorkflowRunFailedParams

type MarkWorkflowRunFailedParams struct {
	ID           uuid.UUID `db:"id" json:"id"`
	ErrorMessage *string   `db:"error_message" json:"error_message"`
}

type MarkWorkflowRunStepFailedParams

type MarkWorkflowRunStepFailedParams struct {
	ID           uuid.UUID  `db:"id" json:"id"`
	RunID        *uuid.UUID `db:"run_id" json:"run_id"`
	ErrorMessage *string    `db:"error_message" json:"error_message"`
}

type MarkWorkflowRunStepSuccessParams

type MarkWorkflowRunStepSuccessParams struct {
	ID     uuid.UUID  `db:"id" json:"id"`
	RunID  *uuid.UUID `db:"run_id" json:"run_id"`
	Output []byte     `db:"output" json:"output"`
}

type MarkWorkflowRunSuccessParams

type MarkWorkflowRunSuccessParams struct {
	ID     uuid.UUID `db:"id" json:"id"`
	Output []byte    `db:"output" json:"output"`
}

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 PublishTaskQueryParams struct {
	ID            uuid.UUID `db:"id" json:"id"`
	UserID        uuid.UUID `db:"user_id" json:"user_id"`
	PublicSummary string    `db:"public_summary" json:"public_summary"`
}

type Queries

type Queries struct {
	// contains filtered or unexported fields
}

Queries 持有 DBTX 引用,所有 SQL 方法定义在此结构上。

func New

func New(db DBTX) *Queries

New 创建一个 Queries 实例。

func (*Queries) AcceptTaskDelivery

func (q *Queries) AcceptTaskDelivery(ctx context.Context, arg AcceptTaskDeliveryParams) (TaskQuery, error)

func (*Queries) AgentsCount

func (q *Queries) AgentsCount(ctx context.Context) (int32, error)

AgentsCount 公开 Agent 总数(市场页用)。

func (*Queries) AggregateAgentRunsForWindow

func (q *Queries) AggregateAgentRunsForWindow(ctx context.Context, interval string) ([]AggregateAgentRunsForWindowRow, error)

func (*Queries) CancelRun

func (q *Queries) CancelRun(ctx context.Context, arg CancelRunParams) (Run, error)

CancelRun marks an owner-readable running run as canceled and returns the final row.

func (*Queries) CancelWorkflowRun

func (q *Queries) CancelWorkflowRun(ctx context.Context, id uuid.UUID) (WorkflowRun, error)

func (*Queries) CertifyAgent

func (q *Queries) CertifyAgent(ctx context.Context, id uuid.UUID) (int64, error)

CertifyAgent 运营授予认证。 返回受影响行数:0 表示 Agent 不在 pending(不能 certify 未申请 / 已认证 / 已拒绝的)。

func (*Queries) CheckSlugAvailable

func (q *Queries) CheckSlugAvailable(ctx context.Context, slug string) (bool, error)

func (*Queries) ClaimPendingProxyRun

func (q *Queries) ClaimPendingProxyRun(ctx context.Context, registryNodeID uuid.UUID) (ProxyRun, error)

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 (q *Queries) ClaimStaleRuntimePullRun(ctx context.Context, arg ClaimStaleRuntimePullRunParams) (Run, error)

func (*Queries) ClaimTaskQuery

func (q *Queries) ClaimTaskQuery(ctx context.Context, arg ClaimTaskQueryParams) (TaskQuery, error)

func (*Queries) ClearAgentWebhook

func (q *Queries) ClearAgentWebhook(ctx context.Context, arg ClearAgentWebhookParams) (int64, error)

ClearAgentWebhook 创作者清除 webhook 配置。 返回受影响行数:0 表示越权或 agent 不存在。

func (*Queries) ClearDefaultDeliveryTarget

func (q *Queries) ClearDefaultDeliveryTarget(ctx context.Context, userID uuid.UUID) error

func (*Queries) CompleteProxyRun

func (q *Queries) CompleteProxyRun(ctx context.Context, arg CompleteProxyRunParams) (ProxyRun, error)

func (*Queries) CompleteTaskQuery

func (q *Queries) CompleteTaskQuery(ctx context.Context, arg CompleteTaskQueryParams) (TaskQuery, error)

func (*Queries) ConfirmAgentApproval

func (q *Queries) ConfirmAgentApproval(ctx context.Context, arg ConfirmAgentApprovalParams) (int64, error)

func (*Queries) CountActiveAgentRuntimeTokens

func (q *Queries) CountActiveAgentRuntimeTokens(ctx context.Context, agentID uuid.UUID) (int32, error)

func (*Queries) CountActiveAgentTokensByAgent

func (q *Queries) CountActiveAgentTokensByAgent(ctx context.Context, agentID uuid.UUID) (int32, error)

func (*Queries) CountAdminAgents

func (q *Queries) CountAdminAgents(ctx context.Context, arg CountAdminAgentsParams) (int32, error)

func (*Queries) CountAdminTasks

func (q *Queries) CountAdminTasks(ctx context.Context, arg CountAdminTasksParams) (int32, error)

func (*Queries) CountAdminUsers

func (q *Queries) CountAdminUsers(ctx context.Context, arg CountAdminUsersParams) (int32, error)

func (*Queries) CountAgentAvailabilityAlertsByCreator

func (q *Queries) CountAgentAvailabilityAlertsByCreator(ctx context.Context, creatorID uuid.UUID) (int32, error)

func (*Queries) CountAgentExamplesByAgentID

func (q *Queries) CountAgentExamplesByAgentID(ctx context.Context, agentID uuid.UUID) (int32, error)

func (*Queries) CountAgentTokensByCreator added in v0.1.7

func (q *Queries) CountAgentTokensByCreator(ctx context.Context, creatorUserID uuid.UUID) (int32, error)

func (*Queries) CountAgentTokensByCreatorAndAgent added in v0.1.7

func (q *Queries) CountAgentTokensByCreatorAndAgent(ctx context.Context, arg CountAgentTokensByCreatorAndAgentParams) (int32, error)

func (*Queries) CountAgentsByCreator

func (q *Queries) CountAgentsByCreator(ctx context.Context, creatorID uuid.UUID) (int32, error)

CountAgentsByCreator 创作者当前 Agent 数(不包含已下架 disabled)。

func (*Queries) CountClaimableRuntimePullRuns

func (q *Queries) CountClaimableRuntimePullRuns(ctx context.Context, agentID uuid.UUID) (int32, error)

func (*Queries) CountParentRunsWithDelegationsByUser

func (q *Queries) CountParentRunsWithDelegationsByUser(ctx context.Context, arg CountParentRunsWithDelegationsByUserParams) (int32, error)

func (*Queries) CountPendingAgentsByCreator

func (q *Queries) CountPendingAgentsByCreator(ctx context.Context, creatorID uuid.UUID) (int32, error)

CountPendingAgentsByCreator 创作者人工处理队列 Agent 数。

func (*Queries) CountPendingProxyRunsByNode

func (q *Queries) CountPendingProxyRunsByNode(ctx context.Context, registryNodeID uuid.UUID) (int32, error)

func (*Queries) CountPublicAgents

func (q *Queries) CountPublicAgents(ctx context.Context, arg CountPublicAgentsParams) (int32, error)

func (*Queries) CountPublicAgentsByCreator

func (q *Queries) CountPublicAgentsByCreator(ctx context.Context, creatorID uuid.UUID) (int32, error)

CountPublicAgentsByCreator 创作者当前公开 Agent 数。

func (*Queries) CountRegistryListingLinksByNode

func (q *Queries) CountRegistryListingLinksByNode(ctx context.Context, registryNodeID uuid.UUID) (int32, error)

func (*Queries) CountRunningDelegations

func (q *Queries) CountRunningDelegations(ctx context.Context) (int32, error)

func (*Queries) CountRunsByCreatorAgent

func (q *Queries) CountRunsByCreatorAgent(ctx context.Context, arg CountRunsByCreatorAgentParams) (int32, error)

CountRunsByCreatorAgent 创作者某个 Agent 的全部被调用次数。

func (*Queries) CountRunsByUser

func (q *Queries) CountRunsByUser(ctx context.Context, userID uuid.UUID) (int32, error)

CountRunsByUser 用户全部调用次数。

func (*Queries) CountRunsByUserAndAgent

func (q *Queries) CountRunsByUserAndAgent(ctx context.Context, arg CountRunsByUserAndAgentParams) (int32, error)

func (*Queries) CountRunsByUserThisMonth

func (q *Queries) CountRunsByUserThisMonth(ctx context.Context, userID uuid.UUID) (int32, error)

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 (q *Queries) CountTestCasesBySkill(ctx context.Context, skillID string) (int32, error)

func (*Queries) CountUnreadAgentAvailabilityAlertsByCreator

func (q *Queries) CountUnreadAgentAvailabilityAlertsByCreator(ctx context.Context, creatorID uuid.UUID) (int32, error)

func (*Queries) CountWorkflowRunsByWorkflow

func (q *Queries) CountWorkflowRunsByWorkflow(ctx context.Context, workflowID uuid.UUID) (int32, error)

func (*Queries) CountWorkflowsByUser

func (q *Queries) CountWorkflowsByUser(ctx context.Context, userID uuid.UUID) (int32, error)

func (*Queries) CreateAdminUser

func (q *Queries) CreateAdminUser(ctx context.Context, arg CreateAdminUserParams) (User, error)

CreateAdminUser 管理台创建邮箱密码用户。

func (*Queries) CreateAgent

func (q *Queries) CreateAgent(ctx context.Context, arg CreateAgentParams) (Agent, error)

CreateAgent 创作者新建 Agent。默认 lifecycle=active, visibility=public, certification=unreviewed。

func (*Queries) CreateAgentApproval

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 (q *Queries) CreateProxyRun(ctx context.Context, arg CreateProxyRunParams) (ProxyRun, error)

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) CreateRun

func (q *Queries) CreateRun(ctx context.Context, arg CreateRunParams) (Run, error)

CreateRun 在事务内创建调用记录,初始 status='running'。

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

func (q *Queries) CreateRunEvent(ctx context.Context, arg CreateRunEventParams) (RunEvent, error)

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

func (q *Queries) CreateUser(ctx context.Context, arg CreateUserParams) (User, error)

CreateUser 创建用户。

func (*Queries) CreateWebhookDelivery

func (q *Queries) CreateWebhookDelivery(ctx context.Context, arg CreateWebhookDeliveryParams) (WebhookDelivery, error)

CreateWebhookDelivery 创建投递记录(初始 pending、立即可投递)。

func (*Queries) CreateWorkflow

func (q *Queries) CreateWorkflow(ctx context.Context, arg CreateWorkflowParams) (Workflow, error)

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 (q *Queries) DeleteAgentExampleForOwner(ctx context.Context, arg DeleteAgentExampleForOwnerParams) (int64, error)

func (*Queries) DeleteDeliveryTarget

func (q *Queries) DeleteDeliveryTarget(ctx context.Context, arg DeleteDeliveryTargetParams) (int64, error)

func (*Queries) DeleteProxyRunArtifacts

func (q *Queries) DeleteProxyRunArtifacts(ctx context.Context, proxyRunID uuid.UUID) error

func (*Queries) DeleteRegistryPeerForOwner

func (q *Queries) DeleteRegistryPeerForOwner(ctx context.Context, arg DeleteRegistryPeerForOwnerParams) (int64, error)

func (*Queries) DeleteTaskCallbackSubscriptionForOwner

func (q *Queries) DeleteTaskCallbackSubscriptionForOwner(ctx context.Context, arg DeleteTaskCallbackSubscriptionForOwnerParams) (int64, error)

func (*Queries) DeleteWorkflowRunSteps

func (q *Queries) DeleteWorkflowRunSteps(ctx context.Context, workflowRunID uuid.UUID) error

func (*Queries) DisableAgent

func (q *Queries) DisableAgent(ctx context.Context, arg DisableAgentParams) (int64, error)

DisableAgent 创作者主动下架 (lifecycle_status='disabled')。 返回受影响行数:0 表示 Agent 不属于该 creator 或不存在。

func (*Queries) EnsureOnboardingStatus

func (q *Queries) EnsureOnboardingStatus(ctx context.Context, agentID uuid.UUID) error

func (*Queries) ExpireAgentApprovals

func (q *Queries) ExpireAgentApprovals(ctx context.Context) (int64, error)

func (*Queries) GetA2AContextMappingByRun

func (q *Queries) GetA2AContextMappingByRun(ctx context.Context, runID uuid.UUID) (A2AContextMapping, error)

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 (q *Queries) GetAgentAvailabilitySnapshot(ctx context.Context, agentID uuid.UUID) (AgentAvailabilitySnapshot, error)

func (*Queries) GetAgentByID

func (q *Queries) GetAgentByID(ctx context.Context, id uuid.UUID) (Agent, error)

func (*Queries) GetAgentByIDForOwner

func (q *Queries) GetAgentByIDForOwner(ctx context.Context, arg GetAgentByIDForOwnerParams) (Agent, error)

func (*Queries) GetAgentBySlug

func (q *Queries) GetAgentBySlug(ctx context.Context, slug string) (GetAgentBySlugRow, error)

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 (q *Queries) GetAgentCallPolicy(ctx context.Context, agentID uuid.UUID) (string, error)

func (*Queries) GetAgentCapabilityByAgentID

func (q *Queries) GetAgentCapabilityByAgentID(ctx context.Context, agentID uuid.UUID) (AgentCapability, error)

func (*Queries) GetAgentCapabilityBySlug

func (q *Queries) GetAgentCapabilityBySlug(ctx context.Context, slug string) (AgentCapability, error)

func (*Queries) GetAgentSkillScore

func (q *Queries) GetAgentSkillScore(ctx context.Context, arg GetAgentSkillScoreParams) (AgentSkillScore, error)

func (*Queries) GetAgentVerifiedSkillStats

func (q *Queries) GetAgentVerifiedSkillStats(ctx context.Context, agentID uuid.UUID) (GetAgentVerifiedSkillStatsRow, error)

func (*Queries) GetAgentWebhookConfig

func (q *Queries) GetAgentWebhookConfig(ctx context.Context, id uuid.UUID) (GetAgentWebhookConfigRow, error)

GetAgentWebhookConfig 仅取 webhook 字段(runtime 触发投递时用)。

func (*Queries) GetAgentsByIDs

func (q *Queries) GetAgentsByIDs(ctx context.Context, ids []uuid.UUID) ([]GetAgentsByIDsRow, error)

GetAgentsByIDs 批量按 id 取当前公开运行的 Agent 详情(任务推荐回填用)。 返回顺序由 Postgres 决定(无序),调用方需按入参顺序自行重排。

func (*Queries) GetDefaultDeliveryTarget

func (q *Queries) GetDefaultDeliveryTarget(ctx context.Context, userID uuid.UUID) (DeliveryTarget, error)

func (*Queries) GetDeliveryTargetByID

func (q *Queries) GetDeliveryTargetByID(ctx context.Context, id uuid.UUID) (DeliveryTarget, error)

func (*Queries) GetDeliveryTargetByIDForUser

func (q *Queries) GetDeliveryTargetByIDForUser(ctx context.Context, arg GetDeliveryTargetByIDForUserParams) (DeliveryTarget, error)

func (*Queries) GetFirstExampleInputByAgentID

func (q *Queries) GetFirstExampleInputByAgentID(ctx context.Context, agentID uuid.UUID) ([]byte, error)

func (*Queries) GetLatestRunEventForTypes

func (q *Queries) GetLatestRunEventForTypes(ctx context.Context, arg GetLatestRunEventForTypesParams) (RunEvent, error)

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 (q *Queries) GetProxyRunForNode(ctx context.Context, arg GetProxyRunForNodeParams) (ProxyRun, error)

func (*Queries) GetProxyRunForRequester

func (q *Queries) GetProxyRunForRequester(ctx context.Context, arg GetProxyRunForRequesterParams) (ProxyRun, error)

func (*Queries) GetRegistryListingLinkForOwner

func (q *Queries) GetRegistryListingLinkForOwner(ctx context.Context, arg GetRegistryListingLinkForOwnerParams) (RegistryListingLink, error)

func (*Queries) GetRegistryListingLinkForProxyRun

func (q *Queries) GetRegistryListingLinkForProxyRun(ctx context.Context, registryListingID uuid.UUID) (RegistryListingLink, 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

func (q *Queries) GetRunByID(ctx context.Context, id uuid.UUID) (Run, error)

GetRunByID 按 id 查单条调用记录(详情页用,service 层做 owner 校验)。

func (*Queries) GetRunDelegationByChild

func (q *Queries) GetRunDelegationByChild(ctx context.Context, childRunID uuid.UUID) (RunDelegation, error)

func (*Queries) GetRunDeliveryByID

func (q *Queries) GetRunDeliveryByID(ctx context.Context, id uuid.UUID) (GetRunDeliveryRow, error)

func (*Queries) GetRunRequirementEvidenceByRun

func (q *Queries) GetRunRequirementEvidenceByRun(ctx context.Context, runID uuid.UUID) (RunRequirementEvidence, error)

func (*Queries) GetRuntimePullRunState

func (q *Queries) GetRuntimePullRunState(ctx context.Context, id uuid.UUID) (RuntimePullRunState, error)

func (*Queries) GetSkill

func (q *Queries) GetSkill(ctx context.Context, id string) (Skill, error)

GetSkill 按 id 取单条 skill;用于校验 Agent 声明的 skill 是否存在。

func (*Queries) GetTaskCallbackDeliveryByID

func (q *Queries) GetTaskCallbackDeliveryByID(ctx context.Context, id uuid.UUID) (GetTaskCallbackDeliveryByIDRow, error)

func (*Queries) GetTaskQuery

func (q *Queries) GetTaskQuery(ctx context.Context, id uuid.UUID) (TaskQuery, error)

GetTaskQuery 按 id 查单条;调用方需自行校验 user_id 归属。

func (*Queries) GetUserByEmail

func (q *Queries) GetUserByEmail(ctx context.Context, email string) (User, error)

GetUserByEmail 按 email 查活跃用户。

func (*Queries) GetUserByID

func (q *Queries) GetUserByID(ctx context.Context, id uuid.UUID) (User, error)

GetUserByID 按 id 查活跃用户。

func (*Queries) GetUserByOAuth

func (q *Queries) GetUserByOAuth(ctx context.Context, arg GetUserByOAuthParams) (User, error)

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 (q *Queries) GetWorkflowByID(ctx context.Context, id uuid.UUID) (Workflow, error)

func (*Queries) GetWorkflowRunByID

func (q *Queries) GetWorkflowRunByID(ctx context.Context, id uuid.UUID) (WorkflowRun, error)

func (*Queries) HasRecentRuntimePullToken

func (q *Queries) HasRecentRuntimePullToken(ctx context.Context, agentID uuid.UUID) (bool, error)

func (*Queries) IncrementAgentStats

func (q *Queries) IncrementAgentStats(ctx context.Context, arg IncrementAgentStatsParams) error

func (*Queries) IncrementTaskCallbackSubscriptionFailure

func (q *Queries) IncrementTaskCallbackSubscriptionFailure(ctx context.Context, id uuid.UUID) error

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 (q *Queries) ListActiveAgentRuntimeTokensByPrefix(ctx context.Context, prefix string) ([]AgentRuntimeToken, error)

func (*Queries) ListActiveAgentTokensByPrefix

func (q *Queries) ListActiveAgentTokensByPrefix(ctx context.Context, prefix string) ([]AgentToken, error)

func (*Queries) ListActiveRegistryFederationInvitesByPrefixForUpdate

func (q *Queries) ListActiveRegistryFederationInvitesByPrefixForUpdate(ctx context.Context, tokenPrefix string) ([]RegistryFederationInvite, error)

func (*Queries) ListActiveRegistryNodesBySecretPrefix

func (q *Queries) ListActiveRegistryNodesBySecretPrefix(ctx context.Context, secretPrefix string) ([]RegistryNode, error)

func (*Queries) ListActiveRegistryPeersForAutoRoute

func (q *Queries) ListActiveRegistryPeersForAutoRoute(ctx context.Context, ownerUserID uuid.UUID) ([]RegistryPeer, 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 (q *Queries) ListAgentApprovalsForCreator(ctx context.Context, creatorID uuid.UUID) ([]AgentActionApprovalRequest, error)

func (*Queries) ListAgentExamplesByAgentID

func (q *Queries) ListAgentExamplesByAgentID(ctx context.Context, agentID uuid.UUID) ([]AgentExample, error)

func (*Queries) ListAgentExamplesBySlug

func (q *Queries) ListAgentExamplesBySlug(ctx context.Context, slug string) ([]AgentExample, error)

func (*Queries) ListAgentMetricSnapshotsByAgent

func (q *Queries) ListAgentMetricSnapshotsByAgent(ctx context.Context, agentID uuid.UUID) ([]AgentMetricSnapshot, error)

func (*Queries) ListAgentRuntimeTokensForOwner

func (q *Queries) ListAgentRuntimeTokensForOwner(ctx context.Context, arg ListAgentRuntimeTokensForOwnerParams) ([]AgentRuntimeToken, error)

func (*Queries) ListAgentSkillScoresByAgent

func (q *Queries) ListAgentSkillScoresByAgent(ctx context.Context, agentID uuid.UUID) ([]AgentSkillScore, error)

func (*Queries) ListAgentSkillScoresBySlug

func (q *Queries) ListAgentSkillScoresBySlug(ctx context.Context, slug string) ([]AgentSkillScore, error)

func (*Queries) ListAgentSkills

func (q *Queries) ListAgentSkills(ctx context.Context, agentID uuid.UUID) ([]Skill, error)

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 (q *Queries) ListAgentsByCreator(ctx context.Context, creatorID uuid.UUID) ([]Agent, 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 (q *Queries) ListAgentsBySkillsWithVerified(ctx context.Context, skillIDs []string) ([]AgentSkillMatchVerified, error)

func (*Queries) ListAgentsDueAvailabilityCheck

func (q *Queries) ListAgentsDueAvailabilityCheck(ctx context.Context, arg ListAgentsDueAvailabilityCheckParams) ([]Agent, error)

func (*Queries) ListBenchmarkRunsByBatch

func (q *Queries) ListBenchmarkRunsByBatch(ctx context.Context, batchID uuid.UUID) ([]ListBenchmarkRunsByBatchRow, error)

func (*Queries) ListDelegationLineage

func (q *Queries) ListDelegationLineage(ctx context.Context, arg ListDelegationLineageParams) ([]uuid.UUID, error)

func (*Queries) ListDeliveriesByAgent

func (q *Queries) ListDeliveriesByAgent(ctx context.Context, arg ListDeliveriesByAgentParams) ([]WebhookDelivery, error)

ListDeliveriesByAgent 创作者查看 agent 的投递历史。 业务层应先校验 agent.creator_id == 当前用户。

func (*Queries) ListDeliveryTargetsByUser

func (q *Queries) ListDeliveryTargetsByUser(ctx context.Context, userID uuid.UUID) ([]DeliveryTarget, 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

func (q *Queries) ListPublicTaskQueries(ctx context.Context, limit int32) ([]TaskQuery, error)

ListPublicTaskQueries 最近公开任务流(任务广场用)。

只返回 visibility=public 的任务;本查询不返回用户邮箱/姓名,仅用于展示 公开摘要、Skill 和匹配状态。

func (*Queries) ListRegistryListingLinksByOwner

func (q *Queries) ListRegistryListingLinksByOwner(ctx context.Context, ownerUserID uuid.UUID) ([]ListRegistryListingLinksByOwnerRow, error)

func (*Queries) ListRegistryNodesByOwner

func (q *Queries) ListRegistryNodesByOwner(ctx context.Context, ownerUserID uuid.UUID) ([]RegistryNode, error)

func (*Queries) ListRegistryPeersByOwner

func (q *Queries) ListRegistryPeersByOwner(ctx context.Context, ownerUserID uuid.UUID) ([]RegistryPeer, error)

func (*Queries) ListRunArtifactChunksByRun

func (q *Queries) ListRunArtifactChunksByRun(ctx context.Context, runID uuid.UUID) ([]RunArtifactChunk, error)

func (*Queries) ListRunArtifactsByRun

func (q *Queries) ListRunArtifactsByRun(ctx context.Context, runID uuid.UUID) ([]RunArtifact, error)

func (*Queries) ListRunDeliveriesByRun

func (q *Queries) ListRunDeliveriesByRun(ctx context.Context, runID uuid.UUID) ([]RunDelivery, error)

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 (q *Queries) ListRunMessagesByRun(ctx context.Context, runID uuid.UUID) ([]RunMessage, error)

func (*Queries) ListRunMessagesByRuns

func (q *Queries) ListRunMessagesByRuns(ctx context.Context, runIDs []uuid.UUID) ([]RunMessage, error)

func (*Queries) ListRunsByCreatorAgentWithAgent

ListRunsByCreatorAgentWithAgent 创作者查看某个自己 Agent 的被调用历史。

func (*Queries) ListRunsByUser

func (q *Queries) ListRunsByUser(ctx context.Context, arg ListRunsByUserParams) ([]Run, error)

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

func (q *Queries) ListSkills(ctx context.Context) ([]Skill, error)

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) 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 (q *Queries) ListTestCasesBySkill(ctx context.Context, skillID string) ([]SkillTestCase, error)

func (*Queries) ListTopAgentsBySkill

func (q *Queries) ListTopAgentsBySkill(ctx context.Context, arg ListTopAgentsBySkillParams) ([]ListTopAgentsBySkillRow, error)

func (*Queries) ListWorkflowNodes

func (q *Queries) ListWorkflowNodes(ctx context.Context, workflowID uuid.UUID) ([]WorkflowNode, error)

func (*Queries) ListWorkflowNodesByWorkflowIDs

func (q *Queries) ListWorkflowNodesByWorkflowIDs(ctx context.Context, workflowIds []uuid.UUID) ([]WorkflowNode, error)

func (*Queries) ListWorkflowRunSteps

func (q *Queries) ListWorkflowRunSteps(ctx context.Context, workflowRunID uuid.UUID) ([]WorkflowRunStep, error)

func (*Queries) ListWorkflowRunStepsByRunIDs

func (q *Queries) ListWorkflowRunStepsByRunIDs(ctx context.Context, workflowRunIds []uuid.UUID) ([]WorkflowRunStep, error)

func (*Queries) ListWorkflowRunsByWorkflow

func (q *Queries) ListWorkflowRunsByWorkflow(ctx context.Context, arg ListWorkflowRunsByWorkflowParams) ([]WorkflowRun, error)

func (*Queries) ListWorkflowsByUser

func (q *Queries) ListWorkflowsByUser(ctx context.Context, arg ListWorkflowsByUserParams) ([]Workflow, error)

func (*Queries) MarkAgentAvailabilityAlertRead

func (q *Queries) MarkAgentAvailabilityAlertRead(ctx context.Context, arg MarkAgentAvailabilityAlertReadParams) (AgentAvailabilityAlert, error)

func (*Queries) MarkAgentAvailabilityFailure

func (q *Queries) MarkAgentAvailabilityFailure(ctx context.Context, agentID uuid.UUID) (AgentAvailabilitySnapshot, error)

func (*Queries) MarkAgentAvailabilityHeartbeat

func (q *Queries) MarkAgentAvailabilityHeartbeat(ctx context.Context, agentID uuid.UUID) (AgentAvailabilitySnapshot, error)

func (*Queries) MarkAgentAvailabilitySuccess

func (q *Queries) MarkAgentAvailabilitySuccess(ctx context.Context, agentID uuid.UUID) (AgentAvailabilitySnapshot, error)

func (*Queries) MarkBenchmarkRunFailed

func (q *Queries) MarkBenchmarkRunFailed(ctx context.Context, arg MarkBenchmarkRunFailedParams) (int64, error)

func (*Queries) MarkBenchmarkRunSuccess

func (q *Queries) MarkBenchmarkRunSuccess(ctx context.Context, arg MarkBenchmarkRunSuccessParams) (int64, error)

func (*Queries) MarkCapabilitiesSet

func (q *Queries) MarkCapabilitiesSet(ctx context.Context, agentID uuid.UUID) (int64, error)

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 (q *Queries) MarkExamplesSet(ctx context.Context, arg MarkExamplesSetParams) (int64, error)

func (*Queries) MarkRegistryFederationInviteConsumed

func (q *Queries) MarkRegistryFederationInviteConsumed(ctx context.Context, id uuid.UUID) (int64, error)

func (*Queries) MarkRegistryFederationInviteExpired

func (q *Queries) MarkRegistryFederationInviteExpired(ctx context.Context, id uuid.UUID) error

func (*Queries) MarkRegistryNodeHeartbeat

func (q *Queries) MarkRegistryNodeHeartbeat(ctx context.Context, id uuid.UUID) (RegistryNode, error)

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 (q *Queries) PauseWorkflowRun(ctx context.Context, id uuid.UUID) (WorkflowRun, error)

func (*Queries) PublishTaskQuery

func (q *Queries) PublishTaskQuery(ctx context.Context, arg PublishTaskQueryParams) (TaskQuery, error)

func (*Queries) RedeemPendingAgentToken

func (q *Queries) RedeemPendingAgentToken(ctx context.Context, arg RedeemPendingAgentTokenParams) (AgentToken, error)

func (*Queries) RejectAgentApproval

func (q *Queries) RejectAgentApproval(ctx context.Context, arg RejectAgentApprovalParams) (int64, error)

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 (q *Queries) RequestTaskRevision(ctx context.Context, arg RequestTaskRevisionParams) (TaskQuery, error)

func (*Queries) RequeueStaleWorkflowRuns

func (q *Queries) RequeueStaleWorkflowRuns(ctx context.Context, before time.Time) (int64, error)

func (*Queries) ResetRunDeliveryForRetry

func (q *Queries) ResetRunDeliveryForRetry(ctx context.Context, arg ResetRunDeliveryForRetryParams) (int64, error)

func (*Queries) ResetTaskCallbackSubscriptionFailures

func (q *Queries) ResetTaskCallbackSubscriptionFailures(ctx context.Context, id uuid.UUID) error

func (*Queries) ResumeWorkflowRun

func (q *Queries) ResumeWorkflowRun(ctx context.Context, id uuid.UUID) (WorkflowRun, error)

func (*Queries) RevokeAgentRuntimeTokenForOwner

func (q *Queries) RevokeAgentRuntimeTokenForOwner(ctx context.Context, arg RevokeAgentRuntimeTokenForOwnerParams) (int64, error)

func (*Queries) RevokeAgentTokenForCreator

func (q *Queries) RevokeAgentTokenForCreator(ctx context.Context, arg RevokeAgentTokenForCreatorParams) (int64, error)

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) RunsCount

func (q *Queries) RunsCount(ctx context.Context) (int32, error)

RunsCount 全局调用次数(占位用,避免空文件)。

func (*Queries) SetAgentVisibilityForOwner

func (q *Queries) SetAgentVisibilityForOwner(ctx context.Context, arg SetAgentVisibilityForOwnerParams) error

func (*Queries) SetAgentWebhook

func (q *Queries) SetAgentWebhook(ctx context.Context, arg SetAgentWebhookParams) (int64, error)

SetAgentWebhook 创作者设置 webhook(同时刷新 secret)。 返回受影响行数:0 表示越权或 agent 不存在。

func (*Queries) SetDeliveryTargetDefault

func (q *Queries) SetDeliveryTargetDefault(ctx context.Context, arg SetDeliveryTargetDefaultParams) (int64, error)

func (*Queries) SumEarningsByCreatorThisMonth

func (q *Queries) SumEarningsByCreatorThisMonth(ctx context.Context, creatorID uuid.UUID) (int64, error)

SumEarningsByCreatorThisMonth 创作者本月收入(cents),通过 agent.creator_id 关联。

func (*Queries) SumSpentByUserThisMonth

func (q *Queries) SumSpentByUserThisMonth(ctx context.Context, userID uuid.UUID) (int64, error)

SumSpentByUserThisMonth 用户本月成功调用总花费(cents)。

func (*Queries) SyncRegistryListingMetadataByNode

func (q *Queries) SyncRegistryListingMetadataByNode(ctx context.Context, registryNodeID uuid.UUID) (int32, error)

func (*Queries) TimeoutStaleProxyRuns

func (q *Queries) TimeoutStaleProxyRuns(ctx context.Context, staleBefore time.Time) (int32, error)

func (*Queries) TouchAgentRuntimeToken

func (q *Queries) TouchAgentRuntimeToken(ctx context.Context, id uuid.UUID) error

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

func (q *Queries) UpdateAgentDraft(ctx context.Context, arg UpdateAgentDraftParams) (Agent, error)

UpdateAgentDraft 创作者编辑;命中 0 行表示 Agent 不存在 / 不属于该 creator / 已下架。

func (*Queries) UpdateDeliveryTargetConfig

func (q *Queries) UpdateDeliveryTargetConfig(ctx context.Context, arg UpdateDeliveryTargetConfigParams) (DeliveryTarget, error)

func (*Queries) UpdateDryRunResult

func (q *Queries) UpdateDryRunResult(ctx context.Context, arg UpdateDryRunResultParams) (int64, error)

func (*Queries) UpdateRunArtifactContent

func (q *Queries) UpdateRunArtifactContent(ctx context.Context, arg UpdateRunArtifactContentParams) (RunArtifact, error)

func (*Queries) UpdateUserBecomeCreator

func (q *Queries) UpdateUserBecomeCreator(ctx context.Context, id uuid.UUID) (int64, error)

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 (q *Queries) UpsertRegistryListingLink(ctx context.Context, arg UpsertRegistryListingLinkParams) (RegistryListingLink, error)

func (*Queries) WithTx

func (q *Queries) WithTx(tx pgx.Tx) *Queries

WithTx 返回绑定到给定事务的新 Queries 实例。

type RedeemPendingAgentTokenParams

type RedeemPendingAgentTokenParams struct {
	ID            uuid.UUID `db:"id" json:"id"`
	AgentID       uuid.UUID `db:"agent_id" json:"agent_id"`
	Scopes        []string  `db:"scopes" json:"scopes"`
	CreatorUserID uuid.UUID `db:"creator_user_id" json:"creator_user_id"`
	TokenHash     string    `db:"token_hash" json:"-"`
}

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 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 RejectCertificationParams

type RejectCertificationParams struct {
	ID              uuid.UUID `db:"id" json:"id"`
	RejectionReason string    `db:"rejection_reason" json:"rejection_reason"`
}

type ReleaseRuntimePullRunClaimParams

type ReleaseRuntimePullRunClaimParams struct {
	ID             uuid.UUID `db:"id" json:"id"`
	RuntimeTokenID uuid.UUID `db:"runtime_token_id" json:"runtime_token_id"`
}

type RequestCertificationParams

type RequestCertificationParams struct {
	ID        uuid.UUID `db:"id" json:"id"`
	CreatorID uuid.UUID `db:"creator_id" json:"creator_id"`
}

type RequestTaskRevisionParams

type RequestTaskRevisionParams struct {
	ID           uuid.UUID `db:"id" json:"id"`
	UserID       uuid.UUID `db:"user_id" json:"user_id"`
	RevisionNote string    `db:"revision_note" json:"revision_note"`
}

type ResetRunDeliveryForRetryParams

type ResetRunDeliveryForRetryParams struct {
	ID     uuid.UUID `db:"id" json:"id"`
	UserID uuid.UUID `db:"user_id" json:"user_id"`
}

type RevokeAgentRuntimeTokenForOwnerParams

type RevokeAgentRuntimeTokenForOwnerParams struct {
	ID     uuid.UUID `db:"id" json:"id"`
	UserID uuid.UUID `db:"user_id" json:"user_id"`
}

type RevokeAgentTokenForCreatorParams

type RevokeAgentTokenForCreatorParams struct {
	ID            uuid.UUID `db:"id" json:"id"`
	CreatorUserID uuid.UUID `db:"creator_user_id" json:"creator_user_id"`
}

type RevokeRegistryNodeForOwnerParams

type RevokeRegistryNodeForOwnerParams struct {
	ID          uuid.UUID `db:"id" json:"id"`
	OwnerUserID uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
}

type RotateRegistryNodeSecretForOwnerParams

type RotateRegistryNodeSecretForOwnerParams struct {
	ID           uuid.UUID `db:"id" json:"id"`
	OwnerUserID  uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
	SecretPrefix string    `db:"secret_prefix" json:"secret_prefix"`
	SecretHash   string    `db:"secret_hash" json:"secret_hash"`
}

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 SetAgentVisibilityForOwnerParams

type SetAgentVisibilityForOwnerParams struct {
	ID         uuid.UUID `db:"id" json:"id"`
	CreatorID  uuid.UUID `db:"creator_id" json:"creator_id"`
	Visibility string    `db:"visibility" json:"visibility"`
}

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 SetDeliveryTargetDefaultParams

type SetDeliveryTargetDefaultParams struct {
	ID     uuid.UUID `db:"id" json:"id"`
	UserID uuid.UUID `db:"user_id" json:"user_id"`
}

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 SyncRegistryListingMetadataForOwnerParams

type SyncRegistryListingMetadataForOwnerParams struct {
	RegistryListingID uuid.UUID `db:"registry_listing_id" json:"registry_listing_id"`
	OwnerUserID       uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
}

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 UpdateAdminUserFlagsParams

type UpdateAdminUserFlagsParams struct {
	ID              uuid.UUID `db:"id" json:"id"`
	IsAdmin         bool      `db:"is_admin" json:"is_admin"`
	IsCreator       bool      `db:"is_creator" json:"is_creator"`
	CreatorVerified bool      `db:"creator_verified" json:"creator_verified"`
	Disabled        bool      `db:"disabled" json:"disabled"`
}

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 UpdateDeliveryTargetConfigParams

type UpdateDeliveryTargetConfigParams struct {
	ID     uuid.UUID `db:"id" json:"id"`
	UserID uuid.UUID `db:"user_id" json:"user_id"`
	Config []byte    `db:"config" json:"config"`
}

type UpdateDryRunResultParams

type UpdateDryRunResultParams struct {
	AgentID uuid.UUID `db:"agent_id" json:"agent_id"`
	Result  string    `db:"result" json:"result"`
	Error   *string   `db:"error" json:"error"`
}

type UpdateRegistryListingLinkStatusForOwnerParams

type UpdateRegistryListingLinkStatusForOwnerParams struct {
	RegistryListingID uuid.UUID `db:"registry_listing_id" json:"registry_listing_id"`
	OwnerUserID       uuid.UUID `db:"owner_user_id" json:"owner_user_id"`
	SyncStatus        string    `db:"sync_status" json:"sync_status"`
}

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 UpdateTaskCallbackSubscriptionStatusForOwnerParams

type UpdateTaskCallbackSubscriptionStatusForOwnerParams 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"`
	Status      string    `db:"status" json:"status"`
}

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 UpsertAgentCallPolicyForOwnerParams

type UpsertAgentCallPolicyForOwnerParams struct {
	AgentID    uuid.UUID `db:"agent_id" json:"agent_id"`
	UserID     uuid.UUID `db:"user_id" json:"user_id"`
	CallableBy string    `db:"callable_by" json:"callable_by"`
}

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 表。

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL