sqlc

package
v0.49.4 Latest Latest
Warning

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

Go to latest
Published: Jun 20, 2026 License: AGPL-3.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AcceptGoalParams added in v0.49.4

type AcceptGoalParams struct {
	AcceptedOutput sql.NullString `json:"accepted_output"`
	ID             string         `json:"id"`
}

type AddDigestArticleParams added in v0.30.0

type AddDigestArticleParams struct {
	DigestID  string `json:"digest_id"`
	ArticleID string `json:"article_id"`
	Section   string `json:"section"`
	Position  int64  `json:"position"`
}

type AddGroupMemberParams added in v0.42.0

type AddGroupMemberParams struct {
	GroupID        string `json:"group_id"`
	AgentID        string `json:"agent_id"`
	ReplyChannelID string `json:"reply_channel_id"`
}

type AdvanceMemorySnapshotParams

type AdvanceMemorySnapshotParams struct {
	Version   int64  `json:"version"`
	SessionID string `json:"session_id"`
	UserID    string `json:"user_id"`
	AgentID   string `json:"agent_id"`
}

type Agent added in v0.38.0

type Agent struct {
	ID                   string `json:"id"`
	Name                 string `json:"name"`
	Model                string `json:"model"`
	ModelThinking        string `json:"model_thinking"`
	ModelStrong          string `json:"model_strong"`
	ModelStrongThinking  string `json:"model_strong_thinking"`
	ModelFast            string `json:"model_fast"`
	ModelFastThinking    string `json:"model_fast_thinking"`
	SystemPrompt         string `json:"system_prompt"`
	Soul                 string `json:"soul"`
	Workspace            string `json:"workspace"`
	Sandbox              string `json:"sandbox"`
	EnabledBuiltinSkills string `json:"enabled_builtin_skills"`
	Scope                string `json:"scope"`
	CreatorID            string `json:"creator_id"`
	Enabled              int64  `json:"enabled"`
	CreatedAt            string `json:"created_at"`
	UpdatedAt            string `json:"updated_at"`
}

type AgentGoal added in v0.38.0

type AgentGoal struct {
	ID                 string         `json:"id"`
	UserID             string         `json:"user_id"`
	AgentID            string         `json:"agent_id"`
	ProjectID          sql.NullString `json:"project_id"`
	ParentID           sql.NullString `json:"parent_id"`
	RootID             string         `json:"root_id"`
	Depth              int64          `json:"depth"`
	Position           int64          `json:"position"`
	SessionID          string         `json:"session_id"`
	Title              string         `json:"title"`
	Intent             string         `json:"intent"`
	Kind               string         `json:"kind"`
	Priority           string         `json:"priority"`
	Required           int64          `json:"required"`
	AcceptanceContract string         `json:"acceptance_contract"`
	ConvergencePolicy  string         `json:"convergence_policy"`
	ReviewPolicy       string         `json:"review_policy"`
	Lifecycle          string         `json:"lifecycle"`
	BlockReason        string         `json:"block_reason"`
	AcceptanceState    string         `json:"acceptance_state"`
	AcceptedOutput     sql.NullString `json:"accepted_output"`
	AcceptanceSeq      int64          `json:"acceptance_seq"`
	ActiveAttemptID    sql.NullString `json:"active_attempt_id"`
	AttemptCount       int64          `json:"attempt_count"`
	RequiredTotal      int64          `json:"required_total"`
	RequiredAccepted   int64          `json:"required_accepted"`
	RequiredFailed     int64          `json:"required_failed"`
	RequiredBlocked    int64          `json:"required_blocked"`
	AcceptedRevisionID sql.NullString `json:"accepted_revision_id"`
	Context            string         `json:"context"`
	DispatchHint       string         `json:"dispatch_hint"`
	CreatedAt          string         `json:"created_at"`
	UpdatedAt          string         `json:"updated_at"`
	AcceptedAt         sql.NullString `json:"accepted_at"`
	CancelledAt        sql.NullString `json:"cancelled_at"`
	ArchivedAt         sql.NullString `json:"archived_at"`
}

type AgentGoalAcceptanceEvent added in v0.49.4

type AgentGoalAcceptanceEvent struct {
	ID                string         `json:"id"`
	GoalID            string         `json:"goal_id"`
	AttemptID         sql.NullString `json:"attempt_id"`
	Seq               int64          `json:"seq"`
	ItemID            string         `json:"item_id"`
	ItemKind          string         `json:"item_kind"`
	Result            string         `json:"result"`
	Command           string         `json:"command"`
	ExitCode          sql.NullInt64  `json:"exit_code"`
	CacheKey          string         `json:"cache_key"`
	Authority         string         `json:"authority"`
	ReviewerUserID    sql.NullString `json:"reviewer_user_id"`
	ReviewerAttemptID sql.NullString `json:"reviewer_attempt_id"`
	Rationale         string         `json:"rationale"`
	Scope             string         `json:"scope"`
	ScopeHash         string         `json:"scope_hash"`
	Detail            string         `json:"detail"`
	CreatedAt         string         `json:"created_at"`
}

type AgentGoalAttempt added in v0.49.4

type AgentGoalAttempt struct {
	ID              string         `json:"id"`
	GoalID          string         `json:"goal_id"`
	UserID          string         `json:"user_id"`
	AgentID         sql.NullString `json:"agent_id"`
	ExecutorAgentID sql.NullString `json:"executor_agent_id"`
	SessionID       string         `json:"session_id"`
	Purpose         string         `json:"purpose"`
	AttemptNo       int64          `json:"attempt_no"`
	Status          string         `json:"status"`
	InputContext    string         `json:"input_context"`
	Evidence        string         `json:"evidence"`
	Output          string         `json:"output"`
	RevisionID      sql.NullString `json:"revision_id"`
	Gaps            string         `json:"gaps"`
	Error           string         `json:"error"`
	HeartbeatAt     sql.NullString `json:"heartbeat_at"`
	LeaseExpiresAt  sql.NullString `json:"lease_expires_at"`
	WorkerID        string         `json:"worker_id"`
	StartedAt       sql.NullString `json:"started_at"`
	FinishedAt      sql.NullString `json:"finished_at"`
	CreatedAt       string         `json:"created_at"`
	UpdatedAt       string         `json:"updated_at"`
}

type AgentGoalEdge added in v0.49.4

type AgentGoalEdge struct {
	GoalID       string         `json:"goal_id"`
	UpstreamID   string         `json:"upstream_id"`
	EdgeKind     string         `json:"edge_kind"`
	OnFailure    string         `json:"on_failure"`
	WaivedAt     sql.NullString `json:"waived_at"`
	WaivedByUser sql.NullString `json:"waived_by_user"`
	WaiverReason string         `json:"waiver_reason"`
	CreatedAt    string         `json:"created_at"`
}

type AgentGoalRevision added in v0.49.4

type AgentGoalRevision struct {
	ID                string         `json:"id"`
	GoalID            string         `json:"goal_id"`
	RevisionNo        int64          `json:"revision_no"`
	Status            string         `json:"status"`
	ReviewPolicy      string         `json:"review_policy"`
	Content           string         `json:"content"`
	SourceAttemptID   sql.NullString `json:"source_attempt_id"`
	PlanningSessionID sql.NullString `json:"planning_session_id"`
	AcceptedAt        sql.NullString `json:"accepted_at"`
	MaterializedAt    sql.NullString `json:"materialized_at"`
	CreatedAt         string         `json:"created_at"`
	UpdatedAt         string         `json:"updated_at"`
}

type AppSetting added in v0.38.0

type AppSetting struct {
	Key       string `json:"key"`
	Value     string `json:"value"`
	CreatedAt string `json:"created_at"`
	UpdatedAt string `json:"updated_at"`
}

type AppendAcceptanceEventParams added in v0.49.4

type AppendAcceptanceEventParams struct {
	ID                string         `json:"id"`
	GoalID            string         `json:"goal_id"`
	AttemptID         sql.NullString `json:"attempt_id"`
	Seq               int64          `json:"seq"`
	ItemID            string         `json:"item_id"`
	ItemKind          string         `json:"item_kind"`
	Result            string         `json:"result"`
	Command           string         `json:"command"`
	ExitCode          sql.NullInt64  `json:"exit_code"`
	CacheKey          string         `json:"cache_key"`
	Authority         string         `json:"authority"`
	ReviewerUserID    sql.NullString `json:"reviewer_user_id"`
	ReviewerAttemptID sql.NullString `json:"reviewer_attempt_id"`
	Rationale         string         `json:"rationale"`
	Scope             string         `json:"scope"`
	ScopeHash         string         `json:"scope_hash"`
	Detail            string         `json:"detail"`
}

type AppendContextItemParams

type AppendContextItemParams struct {
	ConversationID string         `json:"conversation_id"`
	Ordinal        int64          `json:"ordinal"`
	ItemType       string         `json:"item_type"`
	MessageID      sql.NullString `json:"message_id"`
	SummaryID      sql.NullString `json:"summary_id"`
	EventType      string         `json:"event_type"`
	Role           string         `json:"role"`
}

type ArchiveProjectParams added in v0.34.0

type ArchiveProjectParams struct {
	Archived int64  `json:"archived"`
	ID       string `json:"id"`
	UserID   string `json:"user_id"`
}

type AssignUserAgentParams

type AssignUserAgentParams struct {
	UserID  string `json:"user_id"`
	AgentID string `json:"agent_id"`
}

type AuthCredential added in v0.38.0

type AuthCredential struct {
	ID           string `json:"id"`
	UserID       string `json:"user_id"`
	PasswordHash string `json:"password_hash"`
	CreatedAt    string `json:"created_at"`
	UpdatedAt    string `json:"updated_at"`
}

type AuthIdentity

type AuthIdentity struct {
	ID              string `json:"id"`
	UserID          string `json:"user_id"`
	Provider        string `json:"provider"`
	ProviderSubject string `json:"provider_subject"`
	Email           string `json:"email"`
	Name            string `json:"name"`
	AvatarUrl       string `json:"avatar_url"`
	RawClaims       string `json:"raw_claims"`
	CreatedAt       string `json:"created_at"`
	UpdatedAt       string `json:"updated_at"`
}

type AuthPolicy

type AuthPolicy struct {
	ID         string `json:"id"`
	Name       string `json:"name"`
	Effect     string `json:"effect"`
	Subjects   string `json:"subjects"`
	Actions    string `json:"actions"`
	Resources  string `json:"resources"`
	Conditions string `json:"conditions"`
	Priority   int64  `json:"priority"`
	IsSystem   int64  `json:"is_system"`
	Enabled    int64  `json:"enabled"`
	CreatedAt  string `json:"created_at"`
	UpdatedAt  string `json:"updated_at"`
}

type AuthSession

type AuthSession struct {
	ID        string `json:"id"`
	UserID    string `json:"user_id"`
	TokenHash string `json:"token_hash"`
	ExpiresAt string `json:"expires_at"`
	CreatedAt string `json:"created_at"`
	UpdatedAt string `json:"updated_at"`
}

type AuthUser

type AuthUser struct {
	ID               string         `json:"id"`
	Email            string         `json:"email"`
	Name             string         `json:"name"`
	AvatarUrl        string         `json:"avatar_url"`
	Role             string         `json:"role"`
	IsActive         int64          `json:"is_active"`
	DefaultAgentID   sql.NullString `json:"default_agent_id"`
	NotifyIdentityID sql.NullString `json:"notify_identity_id"`
	AgePublicKey     string         `json:"age_public_key"`
	AgePrivateKey    string         `json:"age_private_key"`
	CreatedAt        string         `json:"created_at"`
	UpdatedAt        string         `json:"updated_at"`
}

type AuthUserAgent

type AuthUserAgent struct {
	UserID  string `json:"user_id"`
	AgentID string `json:"agent_id"`
}

type AuthUserToken

type AuthUserToken struct {
	ID            string         `json:"id"`
	UserID        string         `json:"user_id"`
	Name          string         `json:"name"`
	TokenHash     string         `json:"token_hash"`
	TokenPrefix   string         `json:"token_prefix"`
	AutoGenerated int64          `json:"auto_generated"`
	LastUsedAt    sql.NullString `json:"last_used_at"`
	ExpiresAt     sql.NullString `json:"expires_at"`
	RotatedAt     sql.NullString `json:"rotated_at"`
	RevokedAt     sql.NullString `json:"revoked_at"`
	CreatedAt     string         `json:"created_at"`
	UpdatedAt     string         `json:"updated_at"`
}

type BlockGoalParams added in v0.49.4

type BlockGoalParams struct {
	BlockReason string `json:"block_reason"`
	ID          string `json:"id"`
}

type Channel added in v0.38.0

type Channel struct {
	ID        string         `json:"id"`
	Name      string         `json:"name"`
	Type      string         `json:"type"`
	AgentID   sql.NullString `json:"agent_id"`
	Enabled   int64          `json:"enabled"`
	Config    string         `json:"config"`
	CreatedAt string         `json:"created_at"`
	UpdatedAt string         `json:"updated_at"`
}

type ChannelAgent added in v0.38.0

type ChannelAgent struct {
	ChannelID string `json:"channel_id"`
	Platform  string `json:"platform"`
	ChatID    string `json:"chat_id"`
	AgentID   string `json:"agent_id"`
	CreatedAt string `json:"created_at"`
	UpdatedAt string `json:"updated_at"`
}

type ChannelGroupMember added in v0.42.0

type ChannelGroupMember struct {
	GroupID        string `json:"group_id"`
	AgentID        string `json:"agent_id"`
	ReplyChannelID string `json:"reply_channel_id"`
	CreatedAt      string `json:"created_at"`
	UpdatedAt      string `json:"updated_at"`
}

type ChannelIdentity added in v0.38.0

type ChannelIdentity struct {
	ID         string `json:"id"`
	UserID     string `json:"user_id"`
	Platform   string `json:"platform"`
	ExternalID string `json:"external_id"`
	Name       string `json:"name"`
	CreatedAt  string `json:"created_at"`
	UpdatedAt  string `json:"updated_at"`
}

type ClaimExpiredGroupDispatchParams added in v0.43.0

type ClaimExpiredGroupDispatchParams struct {
	LeaseUntil sql.NullString `json:"lease_until"`
	ID         string         `json:"id"`
	Now        sql.NullString `json:"now"`
}

type ClaimExpiredGroupOutboxParams added in v0.43.0

type ClaimExpiredGroupOutboxParams struct {
	LeaseUntil sql.NullString `json:"lease_until"`
	ID         string         `json:"id"`
	Now        sql.NullString `json:"now"`
}

type ClaimGoalParams added in v0.49.4

type ClaimGoalParams struct {
	ActiveAttemptID sql.NullString `json:"active_attempt_id"`
	ID              string         `json:"id"`
}

type ClaimPendingGroupDispatchParams added in v0.43.0

type ClaimPendingGroupDispatchParams struct {
	LeaseUntil sql.NullString `json:"lease_until"`
	ID         string         `json:"id"`
	Now        sql.NullString `json:"now"`
}

type ClaimPendingGroupOutboxParams added in v0.43.0

type ClaimPendingGroupOutboxParams struct {
	LeaseUntil sql.NullString `json:"lease_until"`
	ID         string         `json:"id"`
	Now        sql.NullString `json:"now"`
}

type ConsumeDispatchHintParams added in v0.38.0

type ConsumeDispatchHintParams struct {
	DispatchHint string `json:"dispatch_hint"`
	ID           string `json:"id"`
}

type CountArticlesByStatusParams

type CountArticlesByStatusParams struct {
	UserID string `json:"user_id"`
	Status string `json:"status"`
}

type CountRootGoalParams added in v0.49.4

type CountRootGoalParams struct {
	UserID          string      `json:"user_id"`
	AgentID         interface{} `json:"agent_id"`
	ProjectID       interface{} `json:"project_id"`
	Lifecycle       interface{} `json:"lifecycle"`
	Terminal        interface{} `json:"terminal"`
	Q               interface{} `json:"q"`
	IncludeArchived interface{} `json:"include_archived"`
}

type CreateAgentParams

type CreateAgentParams struct {
	ID                   string `json:"id"`
	Name                 string `json:"name"`
	Model                string `json:"model"`
	ModelThinking        string `json:"model_thinking"`
	ModelStrong          string `json:"model_strong"`
	ModelStrongThinking  string `json:"model_strong_thinking"`
	ModelFast            string `json:"model_fast"`
	ModelFastThinking    string `json:"model_fast_thinking"`
	SystemPrompt         string `json:"system_prompt"`
	Soul                 string `json:"soul"`
	Workspace            string `json:"workspace"`
	Sandbox              string `json:"sandbox"`
	EnabledBuiltinSkills string `json:"enabled_builtin_skills"`
	Scope                string `json:"scope"`
	CreatorID            string `json:"creator_id"`
	Enabled              int64  `json:"enabled"`
}

type CreateArticleParams

type CreateArticleParams struct {
	ID           string         `json:"id"`
	UserID       string         `json:"user_id"`
	AgentID      sql.NullString `json:"agent_id"`
	Url          string         `json:"url"`
	CanonicalUrl string         `json:"canonical_url"`
	SourceType   string         `json:"source_type"`
	Title        string         `json:"title"`
	Author       string         `json:"author"`
	Summary      string         `json:"summary"`
	Tags         string         `json:"tags"`
	Status       string         `json:"status"`
	Starred      int64          `json:"starred"`
	FilePath     string         `json:"file_path"`
	Metadata     string         `json:"metadata"`
	PublishedAt  sql.NullString `json:"published_at"`
	SavedAt      string         `json:"saved_at"`
	ReadAt       sql.NullString `json:"read_at"`
}

type CreateAttemptParams added in v0.49.4

type CreateAttemptParams struct {
	ID              string         `json:"id"`
	GoalID          string         `json:"goal_id"`
	UserID          string         `json:"user_id"`
	AgentID         sql.NullString `json:"agent_id"`
	ExecutorAgentID sql.NullString `json:"executor_agent_id"`
	SessionID       string         `json:"session_id"`
	Purpose         string         `json:"purpose"`
	AttemptNo       int64          `json:"attempt_no"`
	Status          string         `json:"status"`
	InputContext    string         `json:"input_context"`
	LeaseExpiresAt  sql.NullString `json:"lease_expires_at"`
}

type CreateAuthPolicyParams

type CreateAuthPolicyParams struct {
	ID         string `json:"id"`
	Name       string `json:"name"`
	Effect     string `json:"effect"`
	Subjects   string `json:"subjects"`
	Actions    string `json:"actions"`
	Resources  string `json:"resources"`
	Conditions string `json:"conditions"`
	Priority   int64  `json:"priority"`
	IsSystem   int64  `json:"is_system"`
	Enabled    int64  `json:"enabled"`
}

type CreateAuthUserTokenParams

type CreateAuthUserTokenParams struct {
	ID            string         `json:"id"`
	UserID        string         `json:"user_id"`
	Name          string         `json:"name"`
	TokenHash     string         `json:"token_hash"`
	TokenPrefix   string         `json:"token_prefix"`
	AutoGenerated int64          `json:"auto_generated"`
	ExpiresAt     sql.NullString `json:"expires_at"`
}

type CreateConversationParams

type CreateConversationParams struct {
	ID         string         `json:"id"`
	SessionID  string         `json:"session_id"`
	Title      sql.NullString `json:"title"`
	Channel    string         `json:"channel"`
	Kind       string         `json:"kind"`
	ProjectID  sql.NullString `json:"project_id"`
	Archived   int64          `json:"archived"`
	LastActive string         `json:"last_active"`
	AgentID    sql.NullString `json:"agent_id"`
	UserID     sql.NullString `json:"user_id"`
}

type CreateDigestParams added in v0.30.0

type CreateDigestParams struct {
	ID                   string `json:"id"`
	UserID               string `json:"user_id"`
	Date                 string `json:"date"`
	Narrative            string `json:"narrative"`
	SavedYesterdayCount  int64  `json:"saved_yesterday_count"`
	UnreadCount          int64  `json:"unread_count"`
	ReadCount            int64  `json:"read_count"`
	ArchivedCount        int64  `json:"archived_count"`
	StarredCount         int64  `json:"starred_count"`
	WorthRevisitingCount int64  `json:"worth_revisiting_count"`
	TotalArticles        int64  `json:"total_articles"`
	TopTags              string `json:"top_tags"`
}

type CreateEdgeParams added in v0.49.4

type CreateEdgeParams struct {
	GoalID     string `json:"goal_id"`
	UpstreamID string `json:"upstream_id"`
	EdgeKind   string `json:"edge_kind"`
	OnFailure  string `json:"on_failure"`
}

type CreateFeedEntryParams added in v0.43.0

type CreateFeedEntryParams struct {
	ID           string         `json:"id"`
	FeedID       string         `json:"feed_id"`
	Guid         string         `json:"guid"`
	Url          string         `json:"url"`
	Title        string         `json:"title"`
	Status       string         `json:"status"`
	ArticleID    sql.NullString `json:"article_id"`
	Attempts     int64          `json:"attempts"`
	ErrorMsg     string         `json:"error_msg"`
	DiscoveredAt string         `json:"discovered_at"`
	ProcessedAt  sql.NullString `json:"processed_at"`
}

type CreateFeedParams added in v0.43.0

type CreateFeedParams struct {
	ID            string         `json:"id"`
	UserID        string         `json:"user_id"`
	AgentID       sql.NullString `json:"agent_id"`
	Url           string         `json:"url"`
	Kind          string         `json:"kind"`
	Metadata      string         `json:"metadata"`
	Title         string         `json:"title"`
	Description   string         `json:"description"`
	CheckInterval string         `json:"check_interval"`
	LastCheckedAt sql.NullString `json:"last_checked_at"`
	LastEtag      string         `json:"last_etag"`
	LastModified  string         `json:"last_modified"`
	Enabled       int64          `json:"enabled"`
}

type CreateGoalParams added in v0.49.4

type CreateGoalParams struct {
	ID                 string         `json:"id"`
	UserID             string         `json:"user_id"`
	AgentID            string         `json:"agent_id"`
	ProjectID          sql.NullString `json:"project_id"`
	ParentID           sql.NullString `json:"parent_id"`
	RootID             string         `json:"root_id"`
	Depth              int64          `json:"depth"`
	Position           int64          `json:"position"`
	SessionID          string         `json:"session_id"`
	Title              string         `json:"title"`
	Intent             string         `json:"intent"`
	Kind               string         `json:"kind"`
	Priority           string         `json:"priority"`
	Required           int64          `json:"required"`
	AcceptanceContract string         `json:"acceptance_contract"`
	ConvergencePolicy  string         `json:"convergence_policy"`
	ReviewPolicy       string         `json:"review_policy"`
	Lifecycle          string         `json:"lifecycle"`
	Context            string         `json:"context"`
	DispatchHint       string         `json:"dispatch_hint"`
}

type CreateGroupDispatchParams added in v0.43.0

type CreateGroupDispatchParams struct {
	ID             string         `json:"id"`
	GroupMessageID string         `json:"group_message_id"`
	GroupID        string         `json:"group_id"`
	AgentID        string         `json:"agent_id"`
	ReplyChannelID string         `json:"reply_channel_id"`
	Status         string         `json:"status"`
	AttemptCount   int64          `json:"attempt_count"`
	LeaseUntil     sql.NullString `json:"lease_until"`
	NextAttemptAt  sql.NullString `json:"next_attempt_at"`
	LastError      string         `json:"last_error"`
}

type CreateGroupMessageParams added in v0.42.0

type CreateGroupMessageParams struct {
	ID                string         `json:"id"`
	GroupID           string         `json:"group_id"`
	Seq               int64          `json:"seq"`
	SourceChannelID   sql.NullString `json:"source_channel_id"`
	ActorType         string         `json:"actor_type"`
	ActorID           string         `json:"actor_id"`
	PlatformMessageID sql.NullString `json:"platform_message_id"`
	ReplyTo           sql.NullString `json:"reply_to"`
	PlatformTimestamp sql.NullString `json:"platform_timestamp"`
	IdempotencyKey    sql.NullString `json:"idempotency_key"`
	Content           string         `json:"content"`
	Reasoning         string         `json:"reasoning"`
	AgentSessionID    string         `json:"agent_session_id"`
}

type CreateGroupOutboxParams added in v0.43.0

type CreateGroupOutboxParams struct {
	ID             string         `json:"id"`
	GroupMessageID string         `json:"group_message_id"`
	GroupID        string         `json:"group_id"`
	Envelope       string         `json:"envelope"`
	Status         string         `json:"status"`
	AttemptCount   int64          `json:"attempt_count"`
	LeaseUntil     sql.NullString `json:"lease_until"`
	NextAttemptAt  sql.NullString `json:"next_attempt_at"`
	LastError      string         `json:"last_error"`
}

type CreateGroupStateParams added in v0.42.0

type CreateGroupStateParams struct {
	ID               string         `json:"id"`
	Platform         string         `json:"platform"`
	PlatformGroupID  string         `json:"platform_group_id"`
	PlatformThreadID string         `json:"platform_thread_id"`
	GroupName        string         `json:"group_name"`
	CreatedByUserID  sql.NullString `json:"created_by_user_id"`
}

type CreateIngestErrorParams added in v0.42.0

type CreateIngestErrorParams struct {
	ID       string `json:"id"`
	GroupID  string `json:"group_id"`
	Pipeline string `json:"pipeline"`
	Seq      int64  `json:"seq"`
	Reason   string `json:"reason"`
}

type CreateMemorySnapshotParams

type CreateMemorySnapshotParams struct {
	SessionID string `json:"session_id"`
	UserID    string `json:"user_id"`
	AgentID   string `json:"agent_id"`
	Version   int64  `json:"version"`
}

type CreateMessageParams

type CreateMessageParams struct {
	ID             string `json:"id"`
	ConversationID string `json:"conversation_id"`
	Seq            int64  `json:"seq"`
	Role           string `json:"role"`
	EventType      string `json:"event_type"`
	Content        string `json:"content"`
	TokenCount     int64  `json:"token_count"`
}

type CreateMessagePartParams

type CreateMessagePartParams struct {
	ID          string         `json:"id"`
	MessageID   string         `json:"message_id"`
	PartType    string         `json:"part_type"`
	Ordinal     int64          `json:"ordinal"`
	TextContent sql.NullString `json:"text_content"`
	ToolCallID  sql.NullString `json:"tool_call_id"`
	ToolName    sql.NullString `json:"tool_name"`
	ToolInput   sql.NullString `json:"tool_input"`
	ToolOutput  sql.NullString `json:"tool_output"`
	Metadata    sql.NullString `json:"metadata"`
}

type CreateProjectParams added in v0.34.0

type CreateProjectParams struct {
	ID          string         `json:"id"`
	AgentID     string         `json:"agent_id"`
	UserID      string         `json:"user_id"`
	Name        string         `json:"name"`
	BaseDir     string         `json:"base_dir"`
	Description sql.NullString `json:"description"`
}

type CreateProviderParams

type CreateProviderParams struct {
	ID      string `json:"id"`
	Type    string `json:"type"`
	Name    string `json:"name"`
	Enabled int64  `json:"enabled"`
	Config  string `json:"config"`
}

type CreateRevisionParams added in v0.49.4

type CreateRevisionParams struct {
	ID                string         `json:"id"`
	GoalID            string         `json:"goal_id"`
	RevisionNo        int64          `json:"revision_no"`
	Status            string         `json:"status"`
	ReviewPolicy      string         `json:"review_policy"`
	Content           string         `json:"content"`
	SourceAttemptID   sql.NullString `json:"source_attempt_id"`
	PlanningSessionID sql.NullString `json:"planning_session_id"`
}

type CreateSchedJobRunParams

type CreateSchedJobRunParams struct {
	ID         string         `json:"id"`
	JobID      string         `json:"job_id"`
	SessionID  string         `json:"session_id"`
	Status     string         `json:"status"`
	StartedAt  string         `json:"started_at"`
	FinishedAt sql.NullString `json:"finished_at"`
	Error      string         `json:"error"`
	UserID     sql.NullString `json:"user_id"`
}

type CreateSchedulerJobParams

type CreateSchedulerJobParams struct {
	ID            string         `json:"id"`
	OwnerKind     string         `json:"owner_kind"`
	ExecScope     string         `json:"exec_scope"`
	PluginID      string         `json:"plugin_id"`
	JobKey        string         `json:"job_key"`
	RuntimeName   string         `json:"runtime_name"`
	Name          string         `json:"name"`
	Description   string         `json:"description"`
	ScheduleCron  string         `json:"schedule_cron"`
	ScheduleEvery string         `json:"schedule_every"`
	ScheduleAt    string         `json:"schedule_at"`
	Message       string         `json:"message"`
	Payload       string         `json:"payload"`
	SessionMode   string         `json:"session_mode"`
	Enabled       int64          `json:"enabled"`
	AgentID       sql.NullString `json:"agent_id"`
	UserID        sql.NullString `json:"user_id"`
	CreatedAt     string         `json:"created_at"`
	UpdatedAt     string         `json:"updated_at"`
	LastRunAt     sql.NullString `json:"last_run_at"`
	LastError     string         `json:"last_error"`
}

type CreateShareParams added in v0.35.0

type CreateShareParams struct {
	ID        string         `json:"id"`
	TokenHash string         `json:"token_hash"`
	UserID    string         `json:"user_id"`
	Title     string         `json:"title"`
	MediaType string         `json:"media_type"`
	Content   []byte         `json:"content"`
	ExpiresAt sql.NullString `json:"expires_at"`
}

type CreateSkillParams

type CreateSkillParams struct {
	ID                     string         `json:"id"`
	Scope                  string         `json:"scope"`
	UserID                 sql.NullString `json:"user_id"`
	AgentID                sql.NullString `json:"agent_id"`
	Name                   string         `json:"name"`
	Description            string         `json:"description"`
	Status                 string         `json:"status"`
	DisableModelInvocation int64          `json:"disable_model_invocation"`
	Metadata               string         `json:"metadata"`
}

type CreateSummaryParams

type CreateSummaryParams struct {
	ID                      string         `json:"id"`
	ConversationID          string         `json:"conversation_id"`
	Kind                    string         `json:"kind"`
	Depth                   int64          `json:"depth"`
	Content                 string         `json:"content"`
	TokenCount              int64          `json:"token_count"`
	EarliestAt              sql.NullString `json:"earliest_at"`
	LatestAt                sql.NullString `json:"latest_at"`
	DescendantCount         int64          `json:"descendant_count"`
	DescendantTokenCount    int64          `json:"descendant_token_count"`
	SourceMessageTokenCount int64          `json:"source_message_token_count"`
}

type CreateWebChannelIfNotExistsParams added in v0.43.0

type CreateWebChannelIfNotExistsParams struct {
	ID      string         `json:"id"`
	AgentID sql.NullString `json:"agent_id"`
}

type CtxAgentMemory

type CtxAgentMemory struct {
	UserID         string `json:"user_id"`
	AgentID        string `json:"agent_id"`
	Content        string `json:"content"`
	Soul           string `json:"soul"`
	Version        int64  `json:"version"`
	Constraints    string `json:"constraints"`
	ProfileEntries string `json:"profile_entries"`
	CreatedAt      string `json:"created_at"`
	UpdatedAt      string `json:"updated_at"`
}

type CtxAgentMemoryChangelog added in v0.38.0

type CtxAgentMemoryChangelog struct {
	ID                  string         `json:"id"`
	UserID              string         `json:"user_id"`
	AgentID             string         `json:"agent_id"`
	SessionID           sql.NullString `json:"session_id"`
	EntityID            sql.NullString `json:"entity_id"`
	Scope               string         `json:"scope"`
	Action              string         `json:"action"`
	Source              string         `json:"source"`
	MemoryVersionBefore sql.NullInt64  `json:"memory_version_before"`
	MemoryVersionAfter  sql.NullInt64  `json:"memory_version_after"`
	BeforeText          sql.NullString `json:"before_text"`
	AfterText           sql.NullString `json:"after_text"`
	Metadata            sql.NullString `json:"metadata"`
	CreatedAt           string         `json:"created_at"`
}

type CtxAgentMemorySnapshot added in v0.38.0

type CtxAgentMemorySnapshot struct {
	SessionID string `json:"session_id"`
	UserID    string `json:"user_id"`
	AgentID   string `json:"agent_id"`
	Version   int64  `json:"version"`
	CreatedAt string `json:"created_at"`
	UpdatedAt string `json:"updated_at"`
}

type CtxConversation

type CtxConversation struct {
	ID             string         `json:"id"`
	SessionID      string         `json:"session_id"`
	Title          sql.NullString `json:"title"`
	Channel        string         `json:"channel"`
	Kind           string         `json:"kind"`
	ProjectID      sql.NullString `json:"project_id"`
	Archived       int64          `json:"archived"`
	LastActive     string         `json:"last_active"`
	BootstrappedAt sql.NullString `json:"bootstrapped_at"`
	AgentID        sql.NullString `json:"agent_id"`
	UserID         sql.NullString `json:"user_id"`
	CreatedAt      string         `json:"created_at"`
	UpdatedAt      string         `json:"updated_at"`
}

type CtxGroupDispatch added in v0.43.0

type CtxGroupDispatch struct {
	ID              string         `json:"id"`
	GroupMessageID  string         `json:"group_message_id"`
	GroupID         string         `json:"group_id"`
	AgentID         string         `json:"agent_id"`
	ReplyChannelID  string         `json:"reply_channel_id"`
	Status          string         `json:"status"`
	AttemptCount    int64          `json:"attempt_count"`
	LeaseUntil      sql.NullString `json:"lease_until"`
	NextAttemptAt   sql.NullString `json:"next_attempt_at"`
	LastError       string         `json:"last_error"`
	ResultMessageID string         `json:"result_message_id"`
	CreatedAt       string         `json:"created_at"`
	UpdatedAt       string         `json:"updated_at"`
}

type CtxGroupIngestCursor added in v0.42.0

type CtxGroupIngestCursor struct {
	GroupID   string `json:"group_id"`
	Pipeline  string `json:"pipeline"`
	LastSeq   int64  `json:"last_seq"`
	UpdatedAt string `json:"updated_at"`
}

type CtxGroupIngestError added in v0.42.0

type CtxGroupIngestError struct {
	ID        string `json:"id"`
	GroupID   string `json:"group_id"`
	Pipeline  string `json:"pipeline"`
	Seq       int64  `json:"seq"`
	Reason    string `json:"reason"`
	CreatedAt string `json:"created_at"`
}

type CtxGroupMemory added in v0.42.0

type CtxGroupMemory struct {
	GroupID   string `json:"group_id"`
	Content   string `json:"content"`
	Version   int64  `json:"version"`
	CreatedAt string `json:"created_at"`
	UpdatedAt string `json:"updated_at"`
}

type CtxGroupMessage added in v0.42.0

type CtxGroupMessage struct {
	ID                string         `json:"id"`
	GroupID           string         `json:"group_id"`
	Seq               int64          `json:"seq"`
	SourceChannelID   sql.NullString `json:"source_channel_id"`
	ActorType         string         `json:"actor_type"`
	ActorID           string         `json:"actor_id"`
	PlatformMessageID sql.NullString `json:"platform_message_id"`
	ReplyTo           sql.NullString `json:"reply_to"`
	PlatformTimestamp sql.NullString `json:"platform_timestamp"`
	IdempotencyKey    sql.NullString `json:"idempotency_key"`
	Content           string         `json:"content"`
	Reasoning         string         `json:"reasoning"`
	AgentSessionID    string         `json:"agent_session_id"`
	CreatedAt         string         `json:"created_at"`
}

type CtxGroupOutbox added in v0.43.0

type CtxGroupOutbox struct {
	ID             string         `json:"id"`
	GroupMessageID string         `json:"group_message_id"`
	GroupID        string         `json:"group_id"`
	Envelope       string         `json:"envelope"`
	Status         string         `json:"status"`
	AttemptCount   int64          `json:"attempt_count"`
	LeaseUntil     sql.NullString `json:"lease_until"`
	NextAttemptAt  sql.NullString `json:"next_attempt_at"`
	LastError      string         `json:"last_error"`
	CreatedAt      string         `json:"created_at"`
	UpdatedAt      string         `json:"updated_at"`
}

type CtxGroupState added in v0.42.0

type CtxGroupState struct {
	ID               string         `json:"id"`
	Platform         string         `json:"platform"`
	PlatformGroupID  string         `json:"platform_group_id"`
	PlatformThreadID string         `json:"platform_thread_id"`
	NextSeq          int64          `json:"next_seq"`
	CreatedAt        string         `json:"created_at"`
	UpdatedAt        string         `json:"updated_at"`
	GroupName        string         `json:"group_name"`
	CreatedByUserID  sql.NullString `json:"created_by_user_id"`
}

type CtxItem

type CtxItem struct {
	ConversationID string         `json:"conversation_id"`
	Ordinal        int64          `json:"ordinal"`
	ItemType       string         `json:"item_type"`
	MessageID      sql.NullString `json:"message_id"`
	SummaryID      sql.NullString `json:"summary_id"`
	EventType      string         `json:"event_type"`
	Role           string         `json:"role"`
	CreatedAt      string         `json:"created_at"`
}

type CtxMessage

type CtxMessage struct {
	ID             string `json:"id"`
	ConversationID string `json:"conversation_id"`
	Seq            int64  `json:"seq"`
	Role           string `json:"role"`
	EventType      string `json:"event_type"`
	Content        string `json:"content"`
	TokenCount     int64  `json:"token_count"`
	CreatedAt      string `json:"created_at"`
}

type CtxMessageFt added in v0.46.0

type CtxMessageFt struct {
	Content string `json:"content"`
}

type CtxMessagePart

type CtxMessagePart struct {
	ID          string         `json:"id"`
	MessageID   string         `json:"message_id"`
	PartType    string         `json:"part_type"`
	Ordinal     int64          `json:"ordinal"`
	TextContent sql.NullString `json:"text_content"`
	ToolCallID  sql.NullString `json:"tool_call_id"`
	ToolName    sql.NullString `json:"tool_name"`
	ToolInput   sql.NullString `json:"tool_input"`
	ToolOutput  sql.NullString `json:"tool_output"`
	Metadata    sql.NullString `json:"metadata"`
}

type CtxSummary

type CtxSummary struct {
	ID                      string         `json:"id"`
	ConversationID          string         `json:"conversation_id"`
	Kind                    string         `json:"kind"`
	Depth                   int64          `json:"depth"`
	Content                 string         `json:"content"`
	TokenCount              int64          `json:"token_count"`
	EarliestAt              sql.NullString `json:"earliest_at"`
	LatestAt                sql.NullString `json:"latest_at"`
	DescendantCount         int64          `json:"descendant_count"`
	DescendantTokenCount    int64          `json:"descendant_token_count"`
	SourceMessageTokenCount int64          `json:"source_message_token_count"`
	CreatedAt               string         `json:"created_at"`
}

type CtxSummaryFt added in v0.46.0

type CtxSummaryFt struct {
	Content string `json:"content"`
}

type CtxSummaryMessage

type CtxSummaryMessage struct {
	SummaryID string `json:"summary_id"`
	MessageID string `json:"message_id"`
	Ordinal   int64  `json:"ordinal"`
}

type CtxSummaryParent

type CtxSummaryParent struct {
	SummaryID       string `json:"summary_id"`
	ParentSummaryID string `json:"parent_summary_id"`
	Ordinal         int64  `json:"ordinal"`
}

type DBTX

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type DeleteArticleParams added in v0.35.3

type DeleteArticleParams struct {
	ID     string `json:"id"`
	UserID string `json:"user_id"`
}

type DeleteChatAgentParams

type DeleteChatAgentParams struct {
	ChannelID string `json:"channel_id"`
	Platform  string `json:"platform"`
	ChatID    string `json:"chat_id"`
}

type DeleteContextItemsInRangeParams

type DeleteContextItemsInRangeParams struct {
	ConversationID string `json:"conversation_id"`
	Ordinal        int64  `json:"ordinal"`
	Ordinal_2      int64  `json:"ordinal_2"`
}

type DeleteDigestArticlesParams added in v0.30.0

type DeleteDigestArticlesParams struct {
	DigestID string `json:"digest_id"`
	Section  string `json:"section"`
}

type DeleteEdgeParams added in v0.49.4

type DeleteEdgeParams struct {
	GoalID     string `json:"goal_id"`
	UpstreamID string `json:"upstream_id"`
}

type DeleteFeedParams added in v0.43.0

type DeleteFeedParams struct {
	ID     string `json:"id"`
	UserID string `json:"user_id"`
}

type DeletePluginStateEntryParams

type DeletePluginStateEntryParams struct {
	PluginID  string `json:"plugin_id"`
	ScopeKind string `json:"scope_kind"`
	ScopeID   string `json:"scope_id"`
	StateKey  string `json:"state_key"`
}

type DeleteProjectParams added in v0.34.0

type DeleteProjectParams struct {
	ID     string `json:"id"`
	UserID string `json:"user_id"`
}

type DeleteShareByUserParams added in v0.35.0

type DeleteShareByUserParams struct {
	ID     string `json:"id"`
	UserID string `json:"user_id"`
}

type DeleteSkillFileParams

type DeleteSkillFileParams struct {
	SkillID string `json:"skill_id"`
	Path    string `json:"path"`
}

type DeleteSkillParams added in v0.35.3

type DeleteSkillParams struct {
	ID      string         `json:"id"`
	AgentID sql.NullString `json:"agent_id"`
	UserID  sql.NullString `json:"user_id"`
}

type DeleteUserAgentMemoryParams

type DeleteUserAgentMemoryParams struct {
	UserID  string `json:"user_id"`
	AgentID string `json:"agent_id"`
}

type DeleteVaultEntryByScopeParams added in v0.48.0

type DeleteVaultEntryByScopeParams struct {
	Scope   string      `json:"scope"`
	UserID  interface{} `json:"user_id"`
	AgentID interface{} `json:"agent_id"`
	Name    string      `json:"name"`
}

type DeleteVaultEntryParams

type DeleteVaultEntryParams struct {
	UserID sql.NullString `json:"user_id"`
	Name   string         `json:"name"`
}

type ExpireKnowledgeDraftsByTypeParams

type ExpireKnowledgeDraftsByTypeParams struct {
	KnowledgeType sql.NullString `json:"knowledge_type"`
	Cutoff        string         `json:"cutoff"`
}

type ExtendRunningGroupDispatchLeaseParams added in v0.43.0

type ExtendRunningGroupDispatchLeaseParams struct {
	LeaseUntil   sql.NullString `json:"lease_until"`
	ID           string         `json:"id"`
	AttemptCount int64          `json:"attempt_count"`
}

type ExtendRunningGroupOutboxLeaseParams added in v0.43.0

type ExtendRunningGroupOutboxLeaseParams struct {
	LeaseUntil   sql.NullString `json:"lease_until"`
	ID           string         `json:"id"`
	AttemptCount int64          `json:"attempt_count"`
}

type FinalizeAttemptParams added in v0.49.4

type FinalizeAttemptParams struct {
	ToStatus string `json:"to_status"`
	Error    string `json:"error"`
	ID       string `json:"id"`
}

type GetActiveAttemptParams added in v0.49.4

type GetActiveAttemptParams struct {
	GoalID  string `json:"goal_id"`
	Purpose string `json:"purpose"`
}

type GetArticleByCanonicalURLParams

type GetArticleByCanonicalURLParams struct {
	UserID       string `json:"user_id"`
	CanonicalUrl string `json:"canonical_url"`
}

type GetArticleParams added in v0.35.3

type GetArticleParams struct {
	ID     string `json:"id"`
	UserID string `json:"user_id"`
}

type GetChatAgentParams

type GetChatAgentParams struct {
	ChannelID string `json:"channel_id"`
	Platform  string `json:"platform"`
	ChatID    string `json:"chat_id"`
}

type GetContextMessageItemsRow

type GetContextMessageItemsRow struct {
	ConversationID string         `json:"conversation_id"`
	Ordinal        int64          `json:"ordinal"`
	ItemType       string         `json:"item_type"`
	MessageID      sql.NullString `json:"message_id"`
	SummaryID      sql.NullString `json:"summary_id"`
	EventType      string         `json:"event_type"`
	Role           string         `json:"role"`
	CreatedAt      string         `json:"created_at"`
	MsgTokenCount  int64          `json:"msg_token_count"`
}

type GetContextStatsRow added in v0.46.0

type GetContextStatsRow struct {
	MessageCount     int64 `json:"message_count"`
	SourceTokenCount int64 `json:"source_token_count"`
	ActiveTokenCount int64 `json:"active_token_count"`
	SummaryDepth     int64 `json:"summary_depth"`
}

type GetConversationAgentBySessionIDParams added in v0.46.0

type GetConversationAgentBySessionIDParams struct {
	SessionID string         `json:"session_id"`
	UserID    sql.NullString `json:"user_id"`
}

type GetConversationBySessionIDParams added in v0.35.3

type GetConversationBySessionIDParams struct {
	SessionID string         `json:"session_id"`
	UserID    sql.NullString `json:"user_id"`
	AgentID   sql.NullString `json:"agent_id"`
}

type GetConversationParams added in v0.35.3

type GetConversationParams struct {
	ID      string         `json:"id"`
	UserID  sql.NullString `json:"user_id"`
	AgentID sql.NullString `json:"agent_id"`
}

type GetConversationTimeBoundsRow added in v0.46.0

type GetConversationTimeBoundsRow struct {
	EarliestAt interface{} `json:"earliest_at"`
	LatestAt   interface{} `json:"latest_at"`
}

type GetDigestByDateParams added in v0.30.0

type GetDigestByDateParams struct {
	UserID string `json:"user_id"`
	Date   string `json:"date"`
}

type GetEdgeParams added in v0.49.4

type GetEdgeParams struct {
	GoalID     string `json:"goal_id"`
	UpstreamID string `json:"upstream_id"`
}

type GetFeedByURLParams added in v0.43.0

type GetFeedByURLParams struct {
	UserID string `json:"user_id"`
	Url    string `json:"url"`
}

type GetFeedEntryParams added in v0.43.0

type GetFeedEntryParams struct {
	ID     string `json:"id"`
	FeedID string `json:"feed_id"`
}

type GetFeedParams added in v0.43.0

type GetFeedParams struct {
	ID     string `json:"id"`
	UserID string `json:"user_id"`
}

type GetFreshTailMessageIDsParams

type GetFreshTailMessageIDsParams struct {
	ConversationID string `json:"conversation_id"`
	Limit          int64  `json:"limit"`
}

type GetGroupMemberParams added in v0.42.0

type GetGroupMemberParams struct {
	GroupID string `json:"group_id"`
	AgentID string `json:"agent_id"`
}

type GetGroupMessageByPlatformIDParams added in v0.42.0

type GetGroupMessageByPlatformIDParams struct {
	GroupID           string         `json:"group_id"`
	PlatformMessageID sql.NullString `json:"platform_message_id"`
}

type GetGroupStateByTripleParams added in v0.42.0

type GetGroupStateByTripleParams struct {
	Platform         string `json:"platform"`
	PlatformGroupID  string `json:"platform_group_id"`
	PlatformThreadID string `json:"platform_thread_id"`
}

type GetIngestCursorParams added in v0.42.0

type GetIngestCursorParams struct {
	GroupID  string `json:"group_id"`
	Pipeline string `json:"pipeline"`
}

type GetMainConversationByProjectParams added in v0.35.3

type GetMainConversationByProjectParams struct {
	ProjectID sql.NullString `json:"project_id"`
	UserID    sql.NullString `json:"user_id"`
	AgentID   sql.NullString `json:"agent_id"`
}

type GetMaxAttemptNoParams added in v0.49.4

type GetMaxAttemptNoParams struct {
	GoalID  string `json:"goal_id"`
	Purpose string `json:"purpose"`
}

type GetMemoryChangelogAtVersionParams

type GetMemoryChangelogAtVersionParams struct {
	UserID             string        `json:"user_id"`
	AgentID            string        `json:"agent_id"`
	Scope              string        `json:"scope"`
	MemoryVersionAfter sql.NullInt64 `json:"memory_version_after"`
}

type GetMemorySnapshotParams

type GetMemorySnapshotParams struct {
	SessionID string `json:"session_id"`
	UserID    string `json:"user_id"`
	AgentID   string `json:"agent_id"`
}

type GetMessageParams added in v0.38.0

type GetMessageParams struct {
	ID             string `json:"id"`
	ConversationID string `json:"conversation_id"`
}

type GetMessageScopedParams added in v0.49.0

type GetMessageScopedParams struct {
	ID      string         `json:"id"`
	UserID  sql.NullString `json:"user_id"`
	AgentID sql.NullString `json:"agent_id"`
}

type GetMessageScopedRow added in v0.49.0

type GetMessageScopedRow struct {
	ID                string         `json:"id"`
	ConversationID    string         `json:"conversation_id"`
	Seq               int64          `json:"seq"`
	Role              string         `json:"role"`
	EventType         string         `json:"event_type"`
	Content           string         `json:"content"`
	TokenCount        int64          `json:"token_count"`
	CreatedAt         string         `json:"created_at"`
	SessionID         string         `json:"session_id"`
	ConversationTitle sql.NullString `json:"conversation_title"`
}

type GetMessagesByConversationRangeParams

type GetMessagesByConversationRangeParams struct {
	ConversationID string `json:"conversation_id"`
	Seq            int64  `json:"seq"`
	Seq_2          int64  `json:"seq_2"`
}

type GetMessagesSinceParams

type GetMessagesSinceParams struct {
	ConversationID string `json:"conversation_id"`
	CreatedAt      string `json:"created_at"`
}

type GetPluginStateEntryParams

type GetPluginStateEntryParams struct {
	PluginID  string `json:"plugin_id"`
	ScopeKind string `json:"scope_kind"`
	ScopeID   string `json:"scope_id"`
	StateKey  string `json:"state_key"`
}

type GetProjectByNameParams added in v0.34.0

type GetProjectByNameParams struct {
	AgentID string `json:"agent_id"`
	UserID  string `json:"user_id"`
	Name    string `json:"name"`
}

type GetProjectParams added in v0.34.0

type GetProjectParams struct {
	ID     string `json:"id"`
	UserID string `json:"user_id"`
}

type GetSchedJobRunParams added in v0.38.0

type GetSchedJobRunParams struct {
	ID    string `json:"id"`
	JobID string `json:"job_id"`
}

type GetSkillFileParams

type GetSkillFileParams struct {
	SkillID string `json:"skill_id"`
	Path    string `json:"path"`
}

type GetSkillParams added in v0.35.3

type GetSkillParams struct {
	ID      string      `json:"id"`
	AgentID interface{} `json:"agent_id"`
	UserID  interface{} `json:"user_id"`
}

type GetSummariesByDepthParams

type GetSummariesByDepthParams struct {
	ConversationID string `json:"conversation_id"`
	Depth          int64  `json:"depth"`
}

type GetSummaryMessageSeqRangeRow added in v0.46.0

type GetSummaryMessageSeqRangeRow struct {
	MessageSeqFrom int64 `json:"message_seq_from"`
	MessageSeqTo   int64 `json:"message_seq_to"`
}

type GetSummaryParams added in v0.38.0

type GetSummaryParams struct {
	ID             string `json:"id"`
	ConversationID string `json:"conversation_id"`
}

type GetSystemAgentSkillByNameParams added in v0.48.0

type GetSystemAgentSkillByNameParams struct {
	AgentID sql.NullString `json:"agent_id"`
	Name    string         `json:"name"`
}

type GetUserAgentMemoryParams

type GetUserAgentMemoryParams struct {
	UserID  string `json:"user_id"`
	AgentID string `json:"agent_id"`
}

type GetUserSkillByNameParams

type GetUserSkillByNameParams struct {
	UserID sql.NullString `json:"user_id"`
	Name   string         `json:"name"`
}

type GetVaultEntryByScopeParams added in v0.48.0

type GetVaultEntryByScopeParams struct {
	Scope   string      `json:"scope"`
	UserID  interface{} `json:"user_id"`
	AgentID interface{} `json:"agent_id"`
	Name    string      `json:"name"`
}

type GetVaultEntryParams

type GetVaultEntryParams struct {
	UserID sql.NullString `json:"user_id"`
	Name   string         `json:"name"`
}

type HeartbeatAttemptParams added in v0.49.4

type HeartbeatAttemptParams struct {
	LeaseExpiresAt sql.NullString `json:"lease_expires_at"`
	ID             string         `json:"id"`
}

type InsertMemoryChangelogParams

type InsertMemoryChangelogParams struct {
	ID                  string         `json:"id"`
	UserID              string         `json:"user_id"`
	AgentID             string         `json:"agent_id"`
	SessionID           sql.NullString `json:"session_id"`
	EntityID            sql.NullString `json:"entity_id"`
	Scope               string         `json:"scope"`
	Action              string         `json:"action"`
	Source              string         `json:"source"`
	MemoryVersionBefore sql.NullInt64  `json:"memory_version_before"`
	MemoryVersionAfter  sql.NullInt64  `json:"memory_version_after"`
	BeforeText          sql.NullString `json:"before_text"`
	AfterText           sql.NullString `json:"after_text"`
	Metadata            sql.NullString `json:"metadata"`
}

type IsIngestErrorParams added in v0.42.0

type IsIngestErrorParams struct {
	GroupID  string `json:"group_id"`
	Pipeline string `json:"pipeline"`
	Seq      int64  `json:"seq"`
}

type LinkSummaryToMessageParams

type LinkSummaryToMessageParams struct {
	SummaryID string `json:"summary_id"`
	MessageID string `json:"message_id"`
	Ordinal   int64  `json:"ordinal"`
}

type LinkSummaryToParentParams

type LinkSummaryToParentParams struct {
	SummaryID       string `json:"summary_id"`
	ParentSummaryID string `json:"parent_summary_id"`
	Ordinal         int64  `json:"ordinal"`
}

type ListActiveKnowledgeByTypeParams

type ListActiveKnowledgeByTypeParams struct {
	AgentID       sql.NullString `json:"agent_id"`
	UserID        sql.NullString `json:"user_id"`
	KnowledgeType interface{}    `json:"knowledge_type"`
}

type ListAgentConversationLastActiveRow added in v0.46.0

type ListAgentConversationLastActiveRow struct {
	AgentID    sql.NullString `json:"agent_id"`
	LastActive interface{}    `json:"last_active"`
}

type ListArticlesParams

type ListArticlesParams struct {
	UserID     string      `json:"user_id"`
	Status     interface{} `json:"status"`
	SourceType interface{} `json:"source_type"`
	Starred    interface{} `json:"starred"`
	Offset     int64       `json:"offset"`
	Limit      int64       `json:"limit"`
}

type ListAttemptByGoalParams added in v0.49.4

type ListAttemptByGoalParams struct {
	GoalID  string      `json:"goal_id"`
	Purpose interface{} `json:"purpose"`
}

type ListContextItemsPageParams added in v0.46.0

type ListContextItemsPageParams struct {
	ConversationID string `json:"conversation_id"`
	OffsetCount    int64  `json:"offset_count"`
	LimitCount     int64  `json:"limit_count"`
}

type ListContextItemsPageRow added in v0.46.0

type ListContextItemsPageRow struct {
	Ordinal                        int64          `json:"ordinal"`
	ItemType                       string         `json:"item_type"`
	EventType                      string         `json:"event_type"`
	Role                           string         `json:"role"`
	MessageID                      sql.NullString `json:"message_id"`
	MessageSeq                     sql.NullInt64  `json:"message_seq"`
	MessageRole                    sql.NullString `json:"message_role"`
	MessageEventType               sql.NullString `json:"message_event_type"`
	MessageContent                 sql.NullString `json:"message_content"`
	MessageTokenCount              sql.NullInt64  `json:"message_token_count"`
	MessageCreatedAt               sql.NullString `json:"message_created_at"`
	SummaryID                      sql.NullString `json:"summary_id"`
	SummaryKind                    sql.NullString `json:"summary_kind"`
	SummaryDepth                   sql.NullInt64  `json:"summary_depth"`
	SummaryContent                 sql.NullString `json:"summary_content"`
	SummaryTokenCount              sql.NullInt64  `json:"summary_token_count"`
	SummaryEarliestAt              sql.NullString `json:"summary_earliest_at"`
	SummaryLatestAt                sql.NullString `json:"summary_latest_at"`
	SummaryDescendantCount         sql.NullInt64  `json:"summary_descendant_count"`
	SummaryDescendantTokenCount    sql.NullInt64  `json:"summary_descendant_token_count"`
	SummarySourceMessageTokenCount sql.NullInt64  `json:"summary_source_message_token_count"`
	SummaryCreatedAt               sql.NullString `json:"summary_created_at"`
}

type ListConversationsAllParams added in v0.35.3

type ListConversationsAllParams struct {
	UserID  sql.NullString `json:"user_id"`
	AgentID interface{}    `json:"agent_id"`
}

type ListConversationsByKindParams added in v0.34.0

type ListConversationsByKindParams struct {
	AgentID sql.NullString `json:"agent_id"`
	UserID  sql.NullString `json:"user_id"`
	Kind    string         `json:"kind"`
}

type ListConversationsFilteredParams added in v0.46.0

type ListConversationsFilteredParams struct {
	UserID          sql.NullString `json:"user_id"`
	AgentID         sql.NullString `json:"agent_id"`
	IncludeArchived interface{}    `json:"include_archived"`
	Kind            interface{}    `json:"kind"`
	ProjectIDIsNull interface{}    `json:"project_id_is_null"`
	ProjectID       interface{}    `json:"project_id"`
	Offset          int64          `json:"offset"`
	Limit           int64          `json:"limit"`
}

type ListConversationsForReviewFilteredParams added in v0.46.0

type ListConversationsForReviewFilteredParams struct {
	AgentID         sql.NullString `json:"agent_id"`
	Kind            interface{}    `json:"kind"`
	ProjectIDIsNull interface{}    `json:"project_id_is_null"`
	ProjectID       interface{}    `json:"project_id"`
	Offset          int64          `json:"offset"`
	Limit           int64          `json:"limit"`
}

type ListConversationsParams added in v0.35.3

type ListConversationsParams struct {
	UserID  sql.NullString `json:"user_id"`
	AgentID interface{}    `json:"agent_id"`
}

type ListDigestArticlesParams added in v0.30.0

type ListDigestArticlesParams struct {
	DigestID string `json:"digest_id"`
	Section  string `json:"section"`
}

type ListDigestsParams added in v0.30.0

type ListDigestsParams struct {
	UserID string `json:"user_id"`
	Limit  int64  `json:"limit"`
	Offset int64  `json:"offset"`
}

type ListEdgeWithUpstreamStateRow added in v0.49.4

type ListEdgeWithUpstreamStateRow struct {
	GoalID            string         `json:"goal_id"`
	UpstreamID        string         `json:"upstream_id"`
	EdgeKind          string         `json:"edge_kind"`
	OnFailure         string         `json:"on_failure"`
	WaivedAt          sql.NullString `json:"waived_at"`
	WaivedByUser      sql.NullString `json:"waived_by_user"`
	WaiverReason      string         `json:"waiver_reason"`
	CreatedAt         string         `json:"created_at"`
	UpstreamLifecycle string         `json:"upstream_lifecycle"`
	UpstreamOutput    sql.NullString `json:"upstream_output"`
}

type ListExistingUserMessageContentParams added in v0.47.0

type ListExistingUserMessageContentParams struct {
	ConversationID string   `json:"conversation_id"`
	Contents       []string `json:"contents"`
}

type ListExpiredRunningGroupDispatchParams added in v0.43.0

type ListExpiredRunningGroupDispatchParams struct {
	Now        sql.NullString `json:"now"`
	LimitCount int64          `json:"limit_count"`
}

type ListExpiredRunningGroupOutboxParams added in v0.43.0

type ListExpiredRunningGroupOutboxParams struct {
	Now        sql.NullString `json:"now"`
	LimitCount int64          `json:"limit_count"`
}

type ListFailedInboxSchedulerRunsParams added in v0.46.0

type ListFailedInboxSchedulerRunsParams struct {
	UserID     sql.NullString `json:"user_id"`
	Since      interface{}    `json:"since"`
	AgentID    interface{}    `json:"agent_id"`
	LimitCount int64          `json:"limit_count"`
}

type ListFailedInboxSchedulerRunsRow added in v0.46.0

type ListFailedInboxSchedulerRunsRow struct {
	RunID      string         `json:"run_id"`
	JobID      string         `json:"job_id"`
	AgentID    sql.NullString `json:"agent_id"`
	Name       string         `json:"name"`
	Error      string         `json:"error"`
	FinishedAt sql.NullString `json:"finished_at"`
	StartedAt  string         `json:"started_at"`
}

type ListFeedEntriesParams added in v0.43.0

type ListFeedEntriesParams struct {
	FeedID string      `json:"feed_id"`
	Status interface{} `json:"status"`
	Limit  int64       `json:"limit"`
}

type ListFeedsParams added in v0.43.0

type ListFeedsParams struct {
	UserID string `json:"user_id"`
	Offset int64  `json:"offset"`
	Limit  int64  `json:"limit"`
}

type ListGroupMessagesAfterSeqParams added in v0.42.0

type ListGroupMessagesAfterSeqParams struct {
	GroupID    string `json:"group_id"`
	MinSeq     int64  `json:"min_seq"`
	BatchLimit int64  `json:"batch_limit"`
}

type ListGroupMessagesBetweenSeqsParams added in v0.42.0

type ListGroupMessagesBetweenSeqsParams struct {
	GroupID   string `json:"group_id"`
	AfterSeq  int64  `json:"after_seq"`
	BeforeSeq int64  `json:"before_seq"`
}

type ListGroupMessagesPaginatedParams added in v0.43.0

type ListGroupMessagesPaginatedParams struct {
	GroupID     string `json:"group_id"`
	OffsetCount int64  `json:"offset_count"`
	LimitCount  int64  `json:"limit_count"`
}

type ListGroupsByUserParams added in v0.43.0

type ListGroupsByUserParams struct {
	UserID      sql.NullString `json:"user_id"`
	OffsetCount int64          `json:"offset_count"`
	LimitCount  int64          `json:"limit_count"`
}

type ListGroupsByUserRow added in v0.46.0

type ListGroupsByUserRow struct {
	ID               string         `json:"id"`
	Platform         string         `json:"platform"`
	PlatformGroupID  string         `json:"platform_group_id"`
	PlatformThreadID string         `json:"platform_thread_id"`
	NextSeq          int64          `json:"next_seq"`
	CreatedAt        string         `json:"created_at"`
	UpdatedAt        string         `json:"updated_at"`
	GroupName        string         `json:"group_name"`
	CreatedByUserID  sql.NullString `json:"created_by_user_id"`
	LastActive       string         `json:"last_active"`
}

type ListGroupsWithPendingIngestRow added in v0.42.0

type ListGroupsWithPendingIngestRow struct {
	GroupID   string `json:"group_id"`
	CursorSeq int64  `json:"cursor_seq"`
	HeadSeq   int64  `json:"head_seq"`
}

type ListInboxGoalsParams added in v0.49.4

type ListInboxGoalsParams struct {
	UserID     string      `json:"user_id"`
	AgentID    interface{} `json:"agent_id"`
	Since      string      `json:"since"`
	LimitCount int64       `json:"limit_count"`
}

type ListInboxGoalsRow added in v0.49.4

type ListInboxGoalsRow struct {
	ID          string         `json:"id"`
	AgentID     string         `json:"agent_id"`
	ProjectID   sql.NullString `json:"project_id"`
	Title       string         `json:"title"`
	Intent      string         `json:"intent"`
	Lifecycle   string         `json:"lifecycle"`
	BlockReason string         `json:"block_reason"`
	UpdatedAt   string         `json:"updated_at"`
	CreatedAt   string         `json:"created_at"`
}

type ListMemoryChangelogParams

type ListMemoryChangelogParams struct {
	UserID  string `json:"user_id"`
	AgentID string `json:"agent_id"`
	Scope   string `json:"scope"`
	Limit   int64  `json:"limit"`
}

type ListMessagesByIDsParams added in v0.41.0

type ListMessagesByIDsParams struct {
	ConversationID string   `json:"conversation_id"`
	MessageIds     []string `json:"message_ids"`
}

type ListMessagesByLogicalPageParams added in v0.41.0

type ListMessagesByLogicalPageParams struct {
	ConversationID string      `json:"conversation_id"`
	After          interface{} `json:"after"`
	Before         interface{} `json:"before"`
	Offset         int64       `json:"offset"`
	Limit          int64       `json:"limit"`
}

type ListMessagesByLogicalPageRow added in v0.41.0

type ListMessagesByLogicalPageRow struct {
	ID             string `json:"id"`
	ConversationID string `json:"conversation_id"`
	Seq            int64  `json:"seq"`
	Role           string `json:"role"`
	EventType      string `json:"event_type"`
	Content        string `json:"content"`
	TokenCount     int64  `json:"token_count"`
	CreatedAt      string `json:"created_at"`
}

type ListPendingEntriesParams added in v0.43.0

type ListPendingEntriesParams struct {
	FeedID string `json:"feed_id"`
	Offset int64  `json:"offset"`
	Limit  int64  `json:"limit"`
}

type ListPendingGroupDispatchByMessageParams added in v0.43.0

type ListPendingGroupDispatchByMessageParams struct {
	GroupMessageID string         `json:"group_message_id"`
	Now            sql.NullString `json:"now"`
}

type ListPendingGroupDispatchParams added in v0.43.0

type ListPendingGroupDispatchParams struct {
	Now        sql.NullString `json:"now"`
	LimitCount int64          `json:"limit_count"`
}

type ListPendingGroupOutboxParams added in v0.43.0

type ListPendingGroupOutboxParams struct {
	Now        sql.NullString `json:"now"`
	LimitCount int64          `json:"limit_count"`
}

type ListProjectsAllParams added in v0.34.0

type ListProjectsAllParams struct {
	AgentID string `json:"agent_id"`
	UserID  string `json:"user_id"`
}

type ListProjectsParams added in v0.34.0

type ListProjectsParams struct {
	AgentID string `json:"agent_id"`
	UserID  string `json:"user_id"`
}

type ListRecentGroupMessagesBeforeSeqParams added in v0.43.0

type ListRecentGroupMessagesBeforeSeqParams struct {
	GroupID   string `json:"group_id"`
	BeforeSeq int64  `json:"before_seq"`
	MaxCount  int64  `json:"max_count"`
}

type ListRecentGroupMessagesParams added in v0.42.0

type ListRecentGroupMessagesParams struct {
	GroupID  string `json:"group_id"`
	MaxCount int64  `json:"max_count"`
}

type ListRootGoalParams added in v0.49.4

type ListRootGoalParams struct {
	UserID          string      `json:"user_id"`
	AgentID         interface{} `json:"agent_id"`
	ProjectID       interface{} `json:"project_id"`
	Lifecycle       interface{} `json:"lifecycle"`
	Terminal        interface{} `json:"terminal"`
	Q               interface{} `json:"q"`
	IncludeArchived interface{} `json:"include_archived"`
	Offset          int64       `json:"offset"`
	Limit           int64       `json:"limit"`
}

type ListSchedJobRunsParams

type ListSchedJobRunsParams struct {
	JobID  string      `json:"job_id"`
	UserID interface{} `json:"user_id"`
	Offset int64       `json:"offset"`
	Limit  int64       `json:"limit"`
}

type ListSchedulerJobsByAgentParams added in v0.36.0

type ListSchedulerJobsByAgentParams struct {
	AgentID sql.NullString `json:"agent_id"`
	UserID  sql.NullString `json:"user_id"`
}

type ListSharesByUserParams added in v0.38.0

type ListSharesByUserParams struct {
	UserID string `json:"user_id"`
	Limit  int64  `json:"limit"`
	Offset int64  `json:"offset"`
}

type ListSharesByUserRow added in v0.35.0

type ListSharesByUserRow struct {
	ID        string         `json:"id"`
	TokenHash string         `json:"token_hash"`
	UserID    string         `json:"user_id"`
	Title     string         `json:"title"`
	MediaType string         `json:"media_type"`
	ExpiresAt sql.NullString `json:"expires_at"`
	CreatedAt string         `json:"created_at"`
	UpdatedAt string         `json:"updated_at"`
}

type ListSkillsByScopeParams added in v0.48.0

type ListSkillsByScopeParams struct {
	Scope   string      `json:"scope"`
	UserID  interface{} `json:"user_id"`
	AgentID interface{} `json:"agent_id"`
}

type ListSkillsForAgentContextParams added in v0.36.0

type ListSkillsForAgentContextParams struct {
	AgentID sql.NullString `json:"agent_id"`
	UserID  sql.NullString `json:"user_id"`
}

type ListSkillsForUserParams added in v0.36.0

type ListSkillsForUserParams struct {
	AgentIdsCsv sql.NullString `json:"agent_ids_csv"`
	UserID      sql.NullString `json:"user_id"`
}

type ListSkillsVisibleParams

type ListSkillsVisibleParams struct {
	AgentID sql.NullString `json:"agent_id"`
	UserID  sql.NullString `json:"user_id"`
}

type ListStaleAttemptsParams added in v0.49.4

type ListStaleAttemptsParams struct {
	Now   sql.NullString `json:"now"`
	Limit int64          `json:"limit"`
}

type ListSummariesByIDsParams added in v0.41.0

type ListSummariesByIDsParams struct {
	ConversationID string   `json:"conversation_id"`
	SummaryIds     []string `json:"summary_ids"`
}

type ListUnreadArticlesOlderThanParams

type ListUnreadArticlesOlderThanParams struct {
	UserID   string      `json:"user_id"`
	Datetime interface{} `json:"datetime"`
	Limit    int64       `json:"limit"`
}

type ListVaultEntriesByScopeParams added in v0.48.0

type ListVaultEntriesByScopeParams struct {
	Scope   string      `json:"scope"`
	UserID  interface{} `json:"user_id"`
	AgentID interface{} `json:"agent_id"`
}

type ListVaultEntriesForRuntimeParams added in v0.48.0

type ListVaultEntriesForRuntimeParams struct {
	AgentID sql.NullString `json:"agent_id"`
	UserID  sql.NullString `json:"user_id"`
}

type MarkGroupDispatchCompletedParams added in v0.43.0

type MarkGroupDispatchCompletedParams struct {
	ID           string `json:"id"`
	AttemptCount int64  `json:"attempt_count"`
}

type MarkGroupDispatchFailedParams added in v0.43.0

type MarkGroupDispatchFailedParams struct {
	LastError    string `json:"last_error"`
	ID           string `json:"id"`
	AttemptCount int64  `json:"attempt_count"`
}

type MarkGroupOutboxCompletedParams added in v0.43.0

type MarkGroupOutboxCompletedParams struct {
	ID           string `json:"id"`
	AttemptCount int64  `json:"attempt_count"`
}

type MarkGroupOutboxFailedParams added in v0.43.0

type MarkGroupOutboxFailedParams struct {
	LastError    string `json:"last_error"`
	ID           string `json:"id"`
	AttemptCount int64  `json:"attempt_count"`
}

type Plugin added in v0.38.0

type Plugin struct {
	ID        string `json:"id"`
	Kind      string `json:"kind"`
	Name      string `json:"name"`
	Enabled   int64  `json:"enabled"`
	Config    string `json:"config"`
	CreatedAt string `json:"created_at"`
	UpdatedAt string `json:"updated_at"`
}

type PluginOauthProvider added in v0.38.0

type PluginOauthProvider struct {
	ID              string `json:"id"`
	ProviderID      string `json:"provider_id"`
	ClientID        string `json:"client_id"`
	ClientSecretEnc string `json:"client_secret_enc"`
	RedirectUrl     string `json:"redirect_url"`
	CreatedAt       string `json:"created_at"`
	UpdatedAt       string `json:"updated_at"`
}

type PluginOverride added in v0.38.0

type PluginOverride struct {
	PluginID           string        `json:"plugin_id"`
	Enabled            sql.NullInt64 `json:"enabled"`
	SessionEnvVaultKey string        `json:"session_env_vault_key"`
	Config             string        `json:"config"`
	CreatedAt          string        `json:"created_at"`
	UpdatedAt          string        `json:"updated_at"`
}

type PluginState added in v0.38.0

type PluginState struct {
	PluginID  string `json:"plugin_id"`
	ScopeKind string `json:"scope_kind"`
	ScopeID   string `json:"scope_id"`
	StateKey  string `json:"state_key"`
	Value     string `json:"value"`
	CreatedAt string `json:"created_at"`
	UpdatedAt string `json:"updated_at"`
}

type Project added in v0.34.0

type Project struct {
	ID          string         `json:"id"`
	AgentID     string         `json:"agent_id"`
	UserID      string         `json:"user_id"`
	Name        string         `json:"name"`
	BaseDir     string         `json:"base_dir"`
	Description sql.NullString `json:"description"`
	Archived    int64          `json:"archived"`
	CreatedAt   string         `json:"created_at"`
	UpdatedAt   string         `json:"updated_at"`
}

type PromoteAttemptParams added in v0.49.4

type PromoteAttemptParams struct {
	LeaseExpiresAt sql.NullString `json:"lease_expires_at"`
	ID             string         `json:"id"`
}

type Provider added in v0.38.0

type Provider struct {
	ID        string `json:"id"`
	Type      string `json:"type"`
	Name      string `json:"name"`
	Enabled   int64  `json:"enabled"`
	Config    string `json:"config"`
	CreatedAt string `json:"created_at"`
	UpdatedAt string `json:"updated_at"`
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) AcceptGoal added in v0.49.4

func (q *Queries) AcceptGoal(ctx context.Context, arg AcceptGoalParams) (int64, error)

func (*Queries) AcceptRevision added in v0.49.4

func (q *Queries) AcceptRevision(ctx context.Context, id string) (int64, error)

func (*Queries) AddDigestArticle added in v0.30.0

func (q *Queries) AddDigestArticle(ctx context.Context, arg AddDigestArticleParams) error

func (*Queries) AddGroupMember added in v0.42.0

func (q *Queries) AddGroupMember(ctx context.Context, arg AddGroupMemberParams) (ChannelGroupMember, error)

func (*Queries) AdvanceMemorySnapshot

func (q *Queries) AdvanceMemorySnapshot(ctx context.Context, arg AdvanceMemorySnapshotParams) error

func (*Queries) AppendAcceptanceEvent added in v0.49.4

func (q *Queries) AppendAcceptanceEvent(ctx context.Context, arg AppendAcceptanceEventParams) (AgentGoalAcceptanceEvent, error)

Append-only ledger row: a deterministic check result or a judgment verdict. Never updated/deleted in normal operation. The natural key (goal, attempt, item, cache_key) is unique, so a re-submitted verdict or a re-run check on identical inputs is a no-op (DO NOTHING): appending is idempotent and returns sql.ErrNoRows on the duplicate, which the caller swallows.

func (*Queries) AppendContextItem

func (q *Queries) AppendContextItem(ctx context.Context, arg AppendContextItemParams) error

func (*Queries) ArchiveGoal added in v0.49.4

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

func (*Queries) ArchiveProject added in v0.34.0

func (q *Queries) ArchiveProject(ctx context.Context, arg ArchiveProjectParams) error

func (*Queries) AssignUserAgent

func (q *Queries) AssignUserAgent(ctx context.Context, arg AssignUserAgentParams) error

func (*Queries) BlockGoal added in v0.49.4

func (q *Queries) BlockGoal(ctx context.Context, arg BlockGoalParams) (int64, error)

func (*Queries) BumpGroupSeq added in v0.42.0

func (q *Queries) BumpGroupSeq(ctx context.Context, id string) (int64, error)

func (*Queries) CancelGoal added in v0.49.4

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

func (*Queries) ClaimExpiredGroupDispatch added in v0.43.0

func (q *Queries) ClaimExpiredGroupDispatch(ctx context.Context, arg ClaimExpiredGroupDispatchParams) (CtxGroupDispatch, error)

func (*Queries) ClaimExpiredGroupOutbox added in v0.43.0

func (q *Queries) ClaimExpiredGroupOutbox(ctx context.Context, arg ClaimExpiredGroupOutboxParams) (CtxGroupOutbox, error)

func (*Queries) ClaimGoal added in v0.49.4

func (q *Queries) ClaimGoal(ctx context.Context, arg ClaimGoalParams) (int64, error)

func (*Queries) ClaimPendingGroupDispatch added in v0.43.0

func (q *Queries) ClaimPendingGroupDispatch(ctx context.Context, arg ClaimPendingGroupDispatchParams) (CtxGroupDispatch, error)

func (*Queries) ClaimPendingGroupOutbox added in v0.43.0

func (q *Queries) ClaimPendingGroupOutbox(ctx context.Context, arg ClaimPendingGroupOutboxParams) (CtxGroupOutbox, error)

func (*Queries) ClearGoalActiveAttempt added in v0.49.4

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

func (*Queries) ConsumeDispatchHint added in v0.38.0

func (q *Queries) ConsumeDispatchHint(ctx context.Context, arg ConsumeDispatchHintParams) error

func (*Queries) CountArticlesByStatus

func (q *Queries) CountArticlesByStatus(ctx context.Context, arg CountArticlesByStatusParams) (int64, error)

func (*Queries) CountDigests added in v0.30.0

func (q *Queries) CountDigests(ctx context.Context, userID string) (int64, error)

func (*Queries) CountGroupDispatchByMessage added in v0.43.0

func (q *Queries) CountGroupDispatchByMessage(ctx context.Context, groupMessageID string) (int64, error)

func (*Queries) CountGroupMembers added in v0.43.0

func (q *Queries) CountGroupMembers(ctx context.Context, groupID string) (int64, error)

func (*Queries) CountInflightAttemptsByRoot added in v0.49.4

func (q *Queries) CountInflightAttemptsByRoot(ctx context.Context, rootID string) (int64, error)

func (*Queries) CountInflightAttemptsByUser added in v0.49.4

func (q *Queries) CountInflightAttemptsByUser(ctx context.Context, userID string) (int64, error)

func (*Queries) CountNonTerminalGroupDispatchByMessage added in v0.47.0

func (q *Queries) CountNonTerminalGroupDispatchByMessage(ctx context.Context, groupMessageID string) (int64, error)

func (*Queries) CountRootGoal added in v0.49.4

func (q *Queries) CountRootGoal(ctx context.Context, arg CountRootGoalParams) (int64, error)

CountRootGoal mirrors ListRootGoal's filter so a list's reported total is exact, and the active/history/archived header badges are three cheap counts that vary only their terminal/include_archived args.

func (*Queries) CountRunningSchedJobRuns

func (q *Queries) CountRunningSchedJobRuns(ctx context.Context, jobID string) (int64, error)

func (*Queries) CountStarredArticles

func (q *Queries) CountStarredArticles(ctx context.Context, userID string) (int64, error)

func (*Queries) CreateAgent

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

func (*Queries) CreateArticle

func (q *Queries) CreateArticle(ctx context.Context, arg CreateArticleParams) (RecallyArticle, error)

func (*Queries) CreateAttempt added in v0.49.4

func (q *Queries) CreateAttempt(ctx context.Context, arg CreateAttemptParams) (AgentGoalAttempt, error)

func (*Queries) CreateAuthPolicy

func (q *Queries) CreateAuthPolicy(ctx context.Context, arg CreateAuthPolicyParams) (AuthPolicy, error)

func (*Queries) CreateAuthUserToken

func (q *Queries) CreateAuthUserToken(ctx context.Context, arg CreateAuthUserTokenParams) (AuthUserToken, error)

func (*Queries) CreateConversation

func (q *Queries) CreateConversation(ctx context.Context, arg CreateConversationParams) (CtxConversation, error)

func (*Queries) CreateDigest added in v0.30.0

func (q *Queries) CreateDigest(ctx context.Context, arg CreateDigestParams) (RecallyDigest, error)

func (*Queries) CreateEdge added in v0.49.4

func (q *Queries) CreateEdge(ctx context.Context, arg CreateEdgeParams) (AgentGoalEdge, error)

func (*Queries) CreateFeed added in v0.43.0

func (q *Queries) CreateFeed(ctx context.Context, arg CreateFeedParams) (RecallyFeed, error)

func (*Queries) CreateFeedEntry added in v0.43.0

func (q *Queries) CreateFeedEntry(ctx context.Context, arg CreateFeedEntryParams) (RecallyFeedEntry, error)

func (*Queries) CreateGoal added in v0.49.4

func (q *Queries) CreateGoal(ctx context.Context, arg CreateGoalParams) (AgentGoal, error)

func (*Queries) CreateGroupDispatch added in v0.43.0

func (q *Queries) CreateGroupDispatch(ctx context.Context, arg CreateGroupDispatchParams) error

func (*Queries) CreateGroupMessage added in v0.42.0

func (q *Queries) CreateGroupMessage(ctx context.Context, arg CreateGroupMessageParams) (CtxGroupMessage, error)

func (*Queries) CreateGroupOutbox added in v0.43.0

func (q *Queries) CreateGroupOutbox(ctx context.Context, arg CreateGroupOutboxParams) (CtxGroupOutbox, error)

func (*Queries) CreateGroupState added in v0.42.0

func (q *Queries) CreateGroupState(ctx context.Context, arg CreateGroupStateParams) (CtxGroupState, error)

func (*Queries) CreateIngestError added in v0.42.0

func (q *Queries) CreateIngestError(ctx context.Context, arg CreateIngestErrorParams) error

func (*Queries) CreateMemorySnapshot

func (q *Queries) CreateMemorySnapshot(ctx context.Context, arg CreateMemorySnapshotParams) (CtxAgentMemorySnapshot, error)

func (*Queries) CreateMessage

func (q *Queries) CreateMessage(ctx context.Context, arg CreateMessageParams) (CtxMessage, error)

func (*Queries) CreateMessagePart

func (q *Queries) CreateMessagePart(ctx context.Context, arg CreateMessagePartParams) error

func (*Queries) CreateProject added in v0.34.0

func (q *Queries) CreateProject(ctx context.Context, arg CreateProjectParams) (Project, error)

func (*Queries) CreateProvider

func (q *Queries) CreateProvider(ctx context.Context, arg CreateProviderParams) (Provider, error)

func (*Queries) CreateRevision added in v0.49.4

func (q *Queries) CreateRevision(ctx context.Context, arg CreateRevisionParams) (AgentGoalRevision, error)

func (*Queries) CreateSchedJobRun

func (q *Queries) CreateSchedJobRun(ctx context.Context, arg CreateSchedJobRunParams) (SchedJobRun, error)

func (*Queries) CreateSchedulerJob

func (q *Queries) CreateSchedulerJob(ctx context.Context, arg CreateSchedulerJobParams) (SchedJob, error)

func (*Queries) CreateShare added in v0.35.0

func (q *Queries) CreateShare(ctx context.Context, arg CreateShareParams) (Share, error)

func (*Queries) CreateSkill

func (q *Queries) CreateSkill(ctx context.Context, arg CreateSkillParams) (Skill, error)

func (*Queries) CreateSummary

func (q *Queries) CreateSummary(ctx context.Context, arg CreateSummaryParams) error

func (*Queries) CreateWebChannelIfNotExists added in v0.43.0

func (q *Queries) CreateWebChannelIfNotExists(ctx context.Context, arg CreateWebChannelIfNotExistsParams) error

func (*Queries) DecrGoalRequiredBlocked added in v0.49.4

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

func (*Queries) DeleteAgent

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

func (*Queries) DeleteAllContextItems

func (q *Queries) DeleteAllContextItems(ctx context.Context, conversationID string) error

func (*Queries) DeleteAllVaultEntriesByUser

func (q *Queries) DeleteAllVaultEntriesByUser(ctx context.Context, userID sql.NullString) error

func (*Queries) DeleteArticle

func (q *Queries) DeleteArticle(ctx context.Context, arg DeleteArticleParams) error

func (*Queries) DeleteAuthOAuthProvider added in v0.27.0

func (q *Queries) DeleteAuthOAuthProvider(ctx context.Context, providerID string) error

func (*Queries) DeleteAuthPolicy

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

func (*Queries) DeleteChannel

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

func (*Queries) DeleteChatAgent

func (q *Queries) DeleteChatAgent(ctx context.Context, arg DeleteChatAgentParams) error

func (*Queries) DeleteContextItemsInRange

func (q *Queries) DeleteContextItemsInRange(ctx context.Context, arg DeleteContextItemsInRangeParams) error

func (*Queries) DeleteDigestArticles added in v0.30.0

func (q *Queries) DeleteDigestArticles(ctx context.Context, arg DeleteDigestArticlesParams) error

func (*Queries) DeleteEdge added in v0.49.4

func (q *Queries) DeleteEdge(ctx context.Context, arg DeleteEdgeParams) error

func (*Queries) DeleteFeed added in v0.43.0

func (q *Queries) DeleteFeed(ctx context.Context, arg DeleteFeedParams) error

func (*Queries) DeleteGroupMemory added in v0.42.0

func (q *Queries) DeleteGroupMemory(ctx context.Context, groupID string) error

func (*Queries) DeleteGroupState added in v0.43.0

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

func (*Queries) DeleteManifestPluginOverride added in v0.38.0

func (q *Queries) DeleteManifestPluginOverride(ctx context.Context, pluginID string) error

func (*Queries) DeleteOldEntries added in v0.43.0

func (q *Queries) DeleteOldEntries(ctx context.Context, feedID string) error

func (*Queries) DeletePlugin

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

func (*Queries) DeletePluginStateEntry

func (q *Queries) DeletePluginStateEntry(ctx context.Context, arg DeletePluginStateEntryParams) error

func (*Queries) DeleteProject added in v0.34.0

func (q *Queries) DeleteProject(ctx context.Context, arg DeleteProjectParams) error

func (*Queries) DeleteProvider

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

func (*Queries) DeleteSchedulerJob

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

func (*Queries) DeleteSetting

func (q *Queries) DeleteSetting(ctx context.Context, key string) error

func (*Queries) DeleteShareByUser added in v0.35.0

func (q *Queries) DeleteShareByUser(ctx context.Context, arg DeleteShareByUserParams) (int64, error)

func (*Queries) DeleteSkill

func (q *Queries) DeleteSkill(ctx context.Context, arg DeleteSkillParams) error

func (*Queries) DeleteSkillFile

func (q *Queries) DeleteSkillFile(ctx context.Context, arg DeleteSkillFileParams) error

func (*Queries) DeleteSystemSkill added in v0.35.3

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

func (*Queries) DeleteUserAgentMemory

func (q *Queries) DeleteUserAgentMemory(ctx context.Context, arg DeleteUserAgentMemoryParams) error

func (*Queries) DeleteVaultEntry

func (q *Queries) DeleteVaultEntry(ctx context.Context, arg DeleteVaultEntryParams) error

func (*Queries) DeleteVaultEntryByScope added in v0.48.0

func (q *Queries) DeleteVaultEntryByScope(ctx context.Context, arg DeleteVaultEntryByScopeParams) error

func (*Queries) DeprecateExpiredDrafts

func (q *Queries) DeprecateExpiredDrafts(ctx context.Context, metadata string) error

func (*Queries) ExpireKnowledgeDraftsByType

func (q *Queries) ExpireKnowledgeDraftsByType(ctx context.Context, arg ExpireKnowledgeDraftsByTypeParams) error

func (*Queries) ExtendRunningGroupDispatchLease added in v0.43.0

func (q *Queries) ExtendRunningGroupDispatchLease(ctx context.Context, arg ExtendRunningGroupDispatchLeaseParams) (int64, error)

func (*Queries) ExtendRunningGroupOutboxLease added in v0.43.0

func (q *Queries) ExtendRunningGroupOutboxLease(ctx context.Context, arg ExtendRunningGroupOutboxLeaseParams) (int64, error)

func (*Queries) FinalizeAttempt added in v0.49.4

func (q *Queries) FinalizeAttempt(ctx context.Context, arg FinalizeAttemptParams) (int64, error)

func (*Queries) GetActiveAttempt added in v0.49.4

func (q *Queries) GetActiveAttempt(ctx context.Context, arg GetActiveAttemptParams) (AgentGoalAttempt, error)

func (*Queries) GetActiveAuthUserTokenByHash

func (q *Queries) GetActiveAuthUserTokenByHash(ctx context.Context, tokenHash string) (AuthUserToken, error)

func (*Queries) GetActiveAutoAuthUserTokenByUser

func (q *Queries) GetActiveAutoAuthUserTokenByUser(ctx context.Context, userID string) (AuthUserToken, error)

expires_at is intentionally not filtered here: TokenService rotates at autoTokenRotateAfter (60 days), which is always before autoTokenTTL (90 days), so an auto token is replaced before it can expire. The Go layer handles time-based rotation rather than relying on the DB expiry column.

func (*Queries) GetAgent

func (q *Queries) GetAgent(ctx context.Context, id string) (Agent, error)

func (*Queries) GetArticle

func (q *Queries) GetArticle(ctx context.Context, arg GetArticleParams) (RecallyArticle, error)

func (*Queries) GetArticleByCanonicalURL

func (q *Queries) GetArticleByCanonicalURL(ctx context.Context, arg GetArticleByCanonicalURLParams) (RecallyArticle, error)

func (*Queries) GetArticlesSavedThisWeek

func (q *Queries) GetArticlesSavedThisWeek(ctx context.Context, userID string) ([]RecallyArticle, error)

func (*Queries) GetAttempt added in v0.49.4

func (q *Queries) GetAttempt(ctx context.Context, id string) (AgentGoalAttempt, error)

func (*Queries) GetAuthOAuthProvider added in v0.27.0

func (q *Queries) GetAuthOAuthProvider(ctx context.Context, providerID string) (PluginOauthProvider, error)

func (*Queries) GetAuthPolicy

func (q *Queries) GetAuthPolicy(ctx context.Context, id string) (AuthPolicy, error)

func (*Queries) GetAuthUserTokenByHash

func (q *Queries) GetAuthUserTokenByHash(ctx context.Context, tokenHash string) (AuthUserToken, error)

func (*Queries) GetChannel

func (q *Queries) GetChannel(ctx context.Context, id string) (Channel, error)

func (*Queries) GetChatAgent

func (q *Queries) GetChatAgent(ctx context.Context, arg GetChatAgentParams) (ChannelAgent, error)

func (*Queries) GetContextItemCount

func (q *Queries) GetContextItemCount(ctx context.Context, conversationID string) (int64, error)

func (*Queries) GetContextItems

func (q *Queries) GetContextItems(ctx context.Context, conversationID string) ([]CtxItem, error)

func (*Queries) GetContextMessageItems

func (q *Queries) GetContextMessageItems(ctx context.Context, conversationID string) ([]GetContextMessageItemsRow, error)

func (*Queries) GetContextStats added in v0.46.0

func (q *Queries) GetContextStats(ctx context.Context, conversationID string) (GetContextStatsRow, error)

func (*Queries) GetContextTokenCount

func (q *Queries) GetContextTokenCount(ctx context.Context, conversationID string) (int64, error)

func (*Queries) GetConversation

func (q *Queries) GetConversation(ctx context.Context, arg GetConversationParams) (CtxConversation, error)

func (*Queries) GetConversationAgentBySessionID added in v0.46.0

func (q *Queries) GetConversationAgentBySessionID(ctx context.Context, arg GetConversationAgentBySessionIDParams) (sql.NullString, error)

func (*Queries) GetConversationBySessionID

func (q *Queries) GetConversationBySessionID(ctx context.Context, arg GetConversationBySessionIDParams) (CtxConversation, error)

func (*Queries) GetConversationTimeBounds added in v0.46.0

func (q *Queries) GetConversationTimeBounds(ctx context.Context, conversationID string) (GetConversationTimeBoundsRow, error)

func (*Queries) GetDigestByDate added in v0.30.0

func (q *Queries) GetDigestByDate(ctx context.Context, arg GetDigestByDateParams) (RecallyDigest, error)

func (*Queries) GetEdge added in v0.49.4

func (q *Queries) GetEdge(ctx context.Context, arg GetEdgeParams) (AgentGoalEdge, error)

func (*Queries) GetFeed added in v0.43.0

func (q *Queries) GetFeed(ctx context.Context, arg GetFeedParams) (RecallyFeed, error)

func (*Queries) GetFeedByURL added in v0.43.0

func (q *Queries) GetFeedByURL(ctx context.Context, arg GetFeedByURLParams) (RecallyFeed, error)

func (*Queries) GetFeedEntry added in v0.43.0

func (q *Queries) GetFeedEntry(ctx context.Context, arg GetFeedEntryParams) (RecallyFeedEntry, error)

func (*Queries) GetFreshTailMessageIDs

func (q *Queries) GetFreshTailMessageIDs(ctx context.Context, arg GetFreshTailMessageIDsParams) ([]sql.NullString, error)

func (*Queries) GetGoal added in v0.49.4

func (q *Queries) GetGoal(ctx context.Context, id string) (AgentGoal, error)

func (*Queries) GetGroupDispatch added in v0.43.0

func (q *Queries) GetGroupDispatch(ctx context.Context, id string) (CtxGroupDispatch, error)

func (*Queries) GetGroupLastActive added in v0.46.0

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

func (*Queries) GetGroupMember added in v0.42.0

func (q *Queries) GetGroupMember(ctx context.Context, arg GetGroupMemberParams) (ChannelGroupMember, error)

func (*Queries) GetGroupMemory added in v0.42.0

func (q *Queries) GetGroupMemory(ctx context.Context, groupID string) (CtxGroupMemory, error)

func (*Queries) GetGroupMessage added in v0.43.0

func (q *Queries) GetGroupMessage(ctx context.Context, id string) (CtxGroupMessage, error)

func (*Queries) GetGroupMessageByIdempotencyKey added in v0.42.0

func (q *Queries) GetGroupMessageByIdempotencyKey(ctx context.Context, idempotencyKey sql.NullString) (CtxGroupMessage, error)

func (*Queries) GetGroupMessageByPlatformID added in v0.42.0

func (q *Queries) GetGroupMessageByPlatformID(ctx context.Context, arg GetGroupMessageByPlatformIDParams) (CtxGroupMessage, error)

func (*Queries) GetGroupOutbox added in v0.43.0

func (q *Queries) GetGroupOutbox(ctx context.Context, id string) (CtxGroupOutbox, error)

func (*Queries) GetGroupOutboxByMessage added in v0.43.0

func (q *Queries) GetGroupOutboxByMessage(ctx context.Context, groupMessageID string) (CtxGroupOutbox, error)

func (*Queries) GetGroupStateByID added in v0.43.0

func (q *Queries) GetGroupStateByID(ctx context.Context, id string) (CtxGroupState, error)

func (*Queries) GetGroupStateByTriple added in v0.42.0

func (q *Queries) GetGroupStateByTriple(ctx context.Context, arg GetGroupStateByTripleParams) (CtxGroupState, error)

func (*Queries) GetIngestCursor added in v0.42.0

func (q *Queries) GetIngestCursor(ctx context.Context, arg GetIngestCursorParams) (CtxGroupIngestCursor, error)

func (*Queries) GetMainConversationByProject added in v0.34.0

func (q *Queries) GetMainConversationByProject(ctx context.Context, arg GetMainConversationByProjectParams) (CtxConversation, error)

func (*Queries) GetManifestPluginOverride added in v0.38.0

func (q *Queries) GetManifestPluginOverride(ctx context.Context, pluginID string) (PluginOverride, error)

func (*Queries) GetMaterializedRevision added in v0.49.4

func (q *Queries) GetMaterializedRevision(ctx context.Context, goalID string) (AgentGoalRevision, error)

func (*Queries) GetMaxAcceptanceSeq added in v0.49.4

func (q *Queries) GetMaxAcceptanceSeq(ctx context.Context, goalID string) (int64, error)

Highest seq for a goal; -1 when no rows so next seq = result+1 = 0.

func (*Queries) GetMaxAttemptNo added in v0.49.4

func (q *Queries) GetMaxAttemptNo(ctx context.Context, arg GetMaxAttemptNoParams) (int64, error)

Highest attempt_no for a goal within one purpose; 0 when none exist. The next attempt_no is this + 1 (decomposition cannot derive it from attempt_count, which only tracks execution attempts).

func (*Queries) GetMaxContextOrdinal

func (q *Queries) GetMaxContextOrdinal(ctx context.Context, conversationID string) (int64, error)

func (*Queries) GetMaxRevisionNo added in v0.49.4

func (q *Queries) GetMaxRevisionNo(ctx context.Context, goalID string) (int64, error)

func (*Queries) GetMaxSeq

func (q *Queries) GetMaxSeq(ctx context.Context, conversationID string) (int64, error)

func (*Queries) GetMemoryChangelogAtVersion

func (q *Queries) GetMemoryChangelogAtVersion(ctx context.Context, arg GetMemoryChangelogAtVersionParams) (CtxAgentMemoryChangelog, error)

func (*Queries) GetMemorySnapshot

func (q *Queries) GetMemorySnapshot(ctx context.Context, arg GetMemorySnapshotParams) (CtxAgentMemorySnapshot, error)

func (*Queries) GetMessage

func (q *Queries) GetMessage(ctx context.Context, arg GetMessageParams) (CtxMessage, error)

func (*Queries) GetMessageCount

func (q *Queries) GetMessageCount(ctx context.Context, conversationID string) (int64, error)

func (*Queries) GetMessageParts

func (q *Queries) GetMessageParts(ctx context.Context, messageID string) ([]CtxMessagePart, error)

func (*Queries) GetMessagePartsByMessages

func (q *Queries) GetMessagePartsByMessages(ctx context.Context, messageIds []string) ([]CtxMessagePart, error)

func (*Queries) GetMessageScoped added in v0.49.0

func (q *Queries) GetMessageScoped(ctx context.Context, arg GetMessageScopedParams) (GetMessageScopedRow, error)

Fetch one message in full by ID, scoped to (user_id, agent_id) across every session: the read-in-full companion to cross-session SearchMessages. Joins ctx_conversation for the same isolation filter plus provenance. Keep this doc comment ASCII; multibyte chars corrupt sqlc's query rewriter offsets.

func (*Queries) GetMessagesByConversation

func (q *Queries) GetMessagesByConversation(ctx context.Context, conversationID string) ([]CtxMessage, error)

func (*Queries) GetMessagesByConversationRange

func (q *Queries) GetMessagesByConversationRange(ctx context.Context, arg GetMessagesByConversationRangeParams) ([]CtxMessage, error)

func (*Queries) GetMessagesSince

func (q *Queries) GetMessagesSince(ctx context.Context, arg GetMessagesSinceParams) ([]CtxMessage, error)

func (*Queries) GetOpenRevision added in v0.49.4

func (q *Queries) GetOpenRevision(ctx context.Context, goalID string) (AgentGoalRevision, error)

func (*Queries) GetPlugin

func (q *Queries) GetPlugin(ctx context.Context, id string) (Plugin, error)

func (*Queries) GetPluginStateEntry

func (q *Queries) GetPluginStateEntry(ctx context.Context, arg GetPluginStateEntryParams) (string, error)

func (*Queries) GetProject added in v0.34.0

func (q *Queries) GetProject(ctx context.Context, arg GetProjectParams) (Project, error)

func (*Queries) GetProjectByName added in v0.34.0

func (q *Queries) GetProjectByName(ctx context.Context, arg GetProjectByNameParams) (Project, error)

func (*Queries) GetProvider

func (q *Queries) GetProvider(ctx context.Context, id string) (Provider, error)

func (*Queries) GetRevision added in v0.49.4

func (q *Queries) GetRevision(ctx context.Context, id string) (AgentGoalRevision, error)

func (*Queries) GetSchedJobRun

func (q *Queries) GetSchedJobRun(ctx context.Context, arg GetSchedJobRunParams) (SchedJobRun, error)

func (*Queries) GetSchedulerJob

func (q *Queries) GetSchedulerJob(ctx context.Context, id string) (SchedJob, error)

func (*Queries) GetSetting

func (q *Queries) GetSetting(ctx context.Context, key string) (AppSetting, error)

func (*Queries) GetShareByTokenHash added in v0.35.0

func (q *Queries) GetShareByTokenHash(ctx context.Context, tokenHash string) (Share, error)

func (*Queries) GetSkill

func (q *Queries) GetSkill(ctx context.Context, arg GetSkillParams) (Skill, error)

func (*Queries) GetSkillByID added in v0.48.0

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

func (*Queries) GetSkillFile

func (q *Queries) GetSkillFile(ctx context.Context, arg GetSkillFileParams) (SkillFile, error)

func (*Queries) GetSummariesByConversation

func (q *Queries) GetSummariesByConversation(ctx context.Context, conversationID string) ([]CtxSummary, error)

func (*Queries) GetSummariesByDepth

func (q *Queries) GetSummariesByDepth(ctx context.Context, arg GetSummariesByDepthParams) ([]CtxSummary, error)

func (*Queries) GetSummary

func (q *Queries) GetSummary(ctx context.Context, arg GetSummaryParams) (CtxSummary, error)

func (*Queries) GetSummaryByID added in v0.38.0

func (q *Queries) GetSummaryByID(ctx context.Context, id string) (CtxSummary, error)

func (*Queries) GetSummaryChildren

func (q *Queries) GetSummaryChildren(ctx context.Context, parentSummaryID string) ([]CtxSummary, error)

func (*Queries) GetSummaryMessageSeqRange added in v0.46.0

func (q *Queries) GetSummaryMessageSeqRange(ctx context.Context, summaryID string) (GetSummaryMessageSeqRangeRow, error)

func (*Queries) GetSummaryMessages

func (q *Queries) GetSummaryMessages(ctx context.Context, summaryID string) ([]CtxMessage, error)

func (*Queries) GetSummaryParents

func (q *Queries) GetSummaryParents(ctx context.Context, summaryID string) ([]CtxSummary, error)

func (*Queries) GetSystemAgentSkillByName added in v0.48.0

func (q *Queries) GetSystemAgentSkillByName(ctx context.Context, arg GetSystemAgentSkillByNameParams) (Skill, error)

func (*Queries) GetSystemSkillByName

func (q *Queries) GetSystemSkillByName(ctx context.Context, name string) (Skill, error)

func (*Queries) GetUserAgentMemory

func (q *Queries) GetUserAgentMemory(ctx context.Context, arg GetUserAgentMemoryParams) (CtxAgentMemory, error)

func (*Queries) GetUserSkillByName

func (q *Queries) GetUserSkillByName(ctx context.Context, arg GetUserSkillByNameParams) (Skill, error)

func (*Queries) GetVaultEntry

func (q *Queries) GetVaultEntry(ctx context.Context, arg GetVaultEntryParams) (VaultEntry, error)

func (*Queries) GetVaultEntryByScope added in v0.48.0

func (q *Queries) GetVaultEntryByScope(ctx context.Context, arg GetVaultEntryByScopeParams) (VaultEntry, error)

func (*Queries) GetVaultUser added in v0.38.0

func (q *Queries) GetVaultUser(ctx context.Context, id string) (VaultUser, error)

GetVaultUser returns the age key fields for a user. Satisfies vault.UserKeyReader.

func (*Queries) HeartbeatAttempt added in v0.49.4

func (q *Queries) HeartbeatAttempt(ctx context.Context, arg HeartbeatAttemptParams) (int64, error)

func (*Queries) IncrGoalRequiredAccepted added in v0.49.4

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

func (*Queries) IncrGoalRequiredBlocked added in v0.49.4

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

func (*Queries) IncrGoalRequiredFailed added in v0.49.4

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

func (*Queries) InsertMemoryChangelog

func (q *Queries) InsertMemoryChangelog(ctx context.Context, arg InsertMemoryChangelogParams) error

func (*Queries) IsIngestError added in v0.42.0

func (q *Queries) IsIngestError(ctx context.Context, arg IsIngestErrorParams) (bool, error)

func (*Queries) LinkSummaryToMessage

func (q *Queries) LinkSummaryToMessage(ctx context.Context, arg LinkSummaryToMessageParams) error

func (*Queries) LinkSummaryToParent

func (q *Queries) LinkSummaryToParent(ctx context.Context, arg LinkSummaryToParentParams) error

func (*Queries) ListAcceptanceEventByAttempt added in v0.49.4

func (q *Queries) ListAcceptanceEventByAttempt(ctx context.Context, attemptID sql.NullString) ([]AgentGoalAcceptanceEvent, error)

func (*Queries) ListAcceptanceEventByGoal added in v0.49.4

func (q *Queries) ListAcceptanceEventByGoal(ctx context.Context, goalID string) ([]AgentGoalAcceptanceEvent, error)

The projection fold: replay every event for a goal in seq order.

func (*Queries) ListAccessibleAgents added in v0.38.0

func (q *Queries) ListAccessibleAgents(ctx context.Context, userID string) ([]Agent, error)

func (*Queries) ListActiveKnowledgeByType

func (q *Queries) ListActiveKnowledgeByType(ctx context.Context, arg ListActiveKnowledgeByTypeParams) ([]Skill, error)

func (*Queries) ListAgentConversationLastActive added in v0.46.0

func (q *Queries) ListAgentConversationLastActive(ctx context.Context, userID sql.NullString) ([]ListAgentConversationLastActiveRow, error)

func (*Queries) ListAgentUsers

func (q *Queries) ListAgentUsers(ctx context.Context, agentID string) ([]string, error)

func (*Queries) ListAgents

func (q *Queries) ListAgents(ctx context.Context) ([]Agent, error)

func (*Queries) ListAllSchedulerJobs added in v0.38.0

func (q *Queries) ListAllSchedulerJobs(ctx context.Context) ([]SchedJob, error)

func (*Queries) ListAllSkills

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

func (*Queries) ListArticles

func (q *Queries) ListArticles(ctx context.Context, arg ListArticlesParams) ([]RecallyArticle, error)

func (*Queries) ListArticlesSavedYesterday

func (q *Queries) ListArticlesSavedYesterday(ctx context.Context, userID string) ([]RecallyArticle, error)

func (*Queries) ListAttemptByGoal added in v0.49.4

func (q *Queries) ListAttemptByGoal(ctx context.Context, arg ListAttemptByGoalParams) ([]AgentGoalAttempt, error)

func (*Queries) ListAuthPolicies

func (q *Queries) ListAuthPolicies(ctx context.Context) ([]AuthPolicy, error)

func (*Queries) ListAuthUsersByIDs added in v0.41.0

func (q *Queries) ListAuthUsersByIDs(ctx context.Context, ids []string) ([]AuthUser, error)

func (*Queries) ListChannels

func (q *Queries) ListChannels(ctx context.Context) ([]Channel, error)

func (*Queries) ListChannelsByType

func (q *Queries) ListChannelsByType(ctx context.Context, type_ string) ([]Channel, error)

func (*Queries) ListChatAgents

func (q *Queries) ListChatAgents(ctx context.Context) ([]ChannelAgent, error)

func (*Queries) ListContextItemsPage added in v0.46.0

func (q *Queries) ListContextItemsPage(ctx context.Context, arg ListContextItemsPageParams) ([]ListContextItemsPageRow, error)

func (*Queries) ListConversations

func (q *Queries) ListConversations(ctx context.Context, arg ListConversationsParams) ([]CtxConversation, error)

func (*Queries) ListConversationsAll

func (q *Queries) ListConversationsAll(ctx context.Context, arg ListConversationsAllParams) ([]CtxConversation, error)

func (*Queries) ListConversationsByKind added in v0.34.0

func (q *Queries) ListConversationsByKind(ctx context.Context, arg ListConversationsByKindParams) ([]CtxConversation, error)

func (*Queries) ListConversationsFiltered added in v0.46.0

func (q *Queries) ListConversationsFiltered(ctx context.Context, arg ListConversationsFilteredParams) ([]CtxConversation, error)

func (*Queries) ListConversationsForReviewByAgent added in v0.40.0

func (q *Queries) ListConversationsForReviewByAgent(ctx context.Context, agentID sql.NullString) ([]CtxConversation, error)

func (*Queries) ListConversationsForReviewFiltered added in v0.46.0

func (q *Queries) ListConversationsForReviewFiltered(ctx context.Context, arg ListConversationsForReviewFilteredParams) ([]CtxConversation, error)

func (*Queries) ListDigestArticles added in v0.30.0

func (q *Queries) ListDigestArticles(ctx context.Context, arg ListDigestArticlesParams) ([]RecallyArticle, error)

func (*Queries) ListDigests added in v0.30.0

func (q *Queries) ListDigests(ctx context.Context, arg ListDigestsParams) ([]RecallyDigest, error)

func (*Queries) ListDispatchableLeaves added in v0.49.4

func (q *Queries) ListDispatchableLeaves(ctx context.Context, limit int64) ([]AgentGoal, error)

func (*Queries) ListEdgeByGoal added in v0.49.4

func (q *Queries) ListEdgeByGoal(ctx context.Context, goalID string) ([]AgentGoalEdge, error)

func (*Queries) ListEdgeByUpstream added in v0.49.4

func (q *Queries) ListEdgeByUpstream(ctx context.Context, upstreamID string) ([]AgentGoalEdge, error)

func (*Queries) ListEdgeWithUpstreamState added in v0.49.4

func (q *Queries) ListEdgeWithUpstreamState(ctx context.Context, goalID string) ([]ListEdgeWithUpstreamStateRow, error)

func (*Queries) ListEnabledAgents

func (q *Queries) ListEnabledAgents(ctx context.Context) ([]Agent, error)

func (*Queries) ListEnabledAuthPolicies

func (q *Queries) ListEnabledAuthPolicies(ctx context.Context) ([]AuthPolicy, error)

func (*Queries) ListEnabledPlugins

func (q *Queries) ListEnabledPlugins(ctx context.Context) ([]Plugin, error)

func (*Queries) ListEnabledProviders

func (q *Queries) ListEnabledProviders(ctx context.Context) ([]Provider, error)

func (*Queries) ListExistingUserMessageContent added in v0.47.0

func (q *Queries) ListExistingUserMessageContent(ctx context.Context, arg ListExistingUserMessageContentParams) ([]string, error)

func (*Queries) ListExpiredRunningGroupDispatch added in v0.43.0

func (q *Queries) ListExpiredRunningGroupDispatch(ctx context.Context, arg ListExpiredRunningGroupDispatchParams) ([]CtxGroupDispatch, error)

func (*Queries) ListExpiredRunningGroupOutbox added in v0.43.0

func (q *Queries) ListExpiredRunningGroupOutbox(ctx context.Context, arg ListExpiredRunningGroupOutboxParams) ([]CtxGroupOutbox, error)

func (*Queries) ListFailedInboxSchedulerRuns added in v0.46.0

func (q *Queries) ListFailedInboxSchedulerRuns(ctx context.Context, arg ListFailedInboxSchedulerRunsParams) ([]ListFailedInboxSchedulerRunsRow, error)

func (*Queries) ListFeedEntries added in v0.43.0

func (q *Queries) ListFeedEntries(ctx context.Context, arg ListFeedEntriesParams) ([]RecallyFeedEntry, error)

func (*Queries) ListFeeds added in v0.43.0

func (q *Queries) ListFeeds(ctx context.Context, arg ListFeedsParams) ([]RecallyFeed, error)

func (*Queries) ListGoalByRoot added in v0.49.4

func (q *Queries) ListGoalByRoot(ctx context.Context, rootID string) ([]AgentGoal, error)

func (*Queries) ListGoalChildren added in v0.49.4

func (q *Queries) ListGoalChildren(ctx context.Context, parentID sql.NullString) ([]AgentGoal, error)

func (*Queries) ListGoalSubtree added in v0.49.4

func (q *Queries) ListGoalSubtree(ctx context.Context, id string) ([]AgentGoal, error)

func (*Queries) ListGroupMembers added in v0.42.0

func (q *Queries) ListGroupMembers(ctx context.Context, groupID string) ([]ChannelGroupMember, error)

func (*Queries) ListGroupMessagesAfterSeq added in v0.42.0

func (q *Queries) ListGroupMessagesAfterSeq(ctx context.Context, arg ListGroupMessagesAfterSeqParams) ([]CtxGroupMessage, error)

func (*Queries) ListGroupMessagesBetweenSeqs added in v0.42.0

func (q *Queries) ListGroupMessagesBetweenSeqs(ctx context.Context, arg ListGroupMessagesBetweenSeqsParams) ([]CtxGroupMessage, error)

func (*Queries) ListGroupMessagesPaginated added in v0.43.0

func (q *Queries) ListGroupMessagesPaginated(ctx context.Context, arg ListGroupMessagesPaginatedParams) ([]CtxGroupMessage, error)

func (*Queries) ListGroupsByAgent added in v0.42.0

func (q *Queries) ListGroupsByAgent(ctx context.Context, agentID string) ([]ChannelGroupMember, error)

func (*Queries) ListGroupsByReplyChannel added in v0.42.0

func (q *Queries) ListGroupsByReplyChannel(ctx context.Context, replyChannelID string) ([]ChannelGroupMember, error)

func (*Queries) ListGroupsByUser added in v0.43.0

func (q *Queries) ListGroupsByUser(ctx context.Context, arg ListGroupsByUserParams) ([]ListGroupsByUserRow, error)

func (*Queries) ListGroupsWithPendingIngest added in v0.42.0

func (q *Queries) ListGroupsWithPendingIngest(ctx context.Context, pipeline string) ([]ListGroupsWithPendingIngestRow, error)

func (*Queries) ListInboxGoals added in v0.49.4

func (q *Queries) ListInboxGoals(ctx context.Context, arg ListInboxGoalsParams) ([]ListInboxGoalsRow, error)

Goals needing user attention, for the inbox. Open blocks surface at any age (they wait on the user); terminal failures are windowed like failed runs. The handler splits rows into inbox kinds by lifecycle/block_reason.

func (*Queries) ListManifestPluginOverrides added in v0.38.0

func (q *Queries) ListManifestPluginOverrides(ctx context.Context) ([]PluginOverride, error)

func (*Queries) ListMemoryChangelog

func (q *Queries) ListMemoryChangelog(ctx context.Context, arg ListMemoryChangelogParams) ([]CtxAgentMemoryChangelog, error)

func (*Queries) ListMessagesByIDs added in v0.41.0

func (q *Queries) ListMessagesByIDs(ctx context.Context, arg ListMessagesByIDsParams) ([]CtxMessage, error)

func (*Queries) ListMessagesByLogicalPage added in v0.41.0

func (q *Queries) ListMessagesByLogicalPage(ctx context.Context, arg ListMessagesByLogicalPageParams) ([]ListMessagesByLogicalPageRow, error)

Keep this logical-message boundary in sync with serializeDBMessages in internal/server/sessions.go: consecutive assistant rows render as one response message, so SQL pagination must count them as one too.

func (*Queries) ListPendingEntries added in v0.43.0

func (q *Queries) ListPendingEntries(ctx context.Context, arg ListPendingEntriesParams) ([]RecallyFeedEntry, error)

func (*Queries) ListPendingGroupDispatch added in v0.43.0

func (q *Queries) ListPendingGroupDispatch(ctx context.Context, arg ListPendingGroupDispatchParams) ([]CtxGroupDispatch, error)

func (*Queries) ListPendingGroupDispatchByMessage added in v0.43.0

func (q *Queries) ListPendingGroupDispatchByMessage(ctx context.Context, arg ListPendingGroupDispatchByMessageParams) ([]CtxGroupDispatch, error)

func (*Queries) ListPendingGroupOutbox added in v0.43.0

func (q *Queries) ListPendingGroupOutbox(ctx context.Context, arg ListPendingGroupOutboxParams) ([]CtxGroupOutbox, error)

func (*Queries) ListPluginOverrides added in v0.38.0

func (q *Queries) ListPluginOverrides(ctx context.Context) ([]Plugin, error)

func (*Queries) ListPlugins

func (q *Queries) ListPlugins(ctx context.Context) ([]Plugin, error)

func (*Queries) ListPluginsByKind

func (q *Queries) ListPluginsByKind(ctx context.Context, kind string) ([]Plugin, error)

func (*Queries) ListProjects added in v0.34.0

func (q *Queries) ListProjects(ctx context.Context, arg ListProjectsParams) ([]Project, error)

func (*Queries) ListProjectsAll added in v0.34.0

func (q *Queries) ListProjectsAll(ctx context.Context, arg ListProjectsAllParams) ([]Project, error)

func (*Queries) ListProviders

func (q *Queries) ListProviders(ctx context.Context) ([]Provider, error)

func (*Queries) ListRecentGroupMessages added in v0.42.0

func (q *Queries) ListRecentGroupMessages(ctx context.Context, arg ListRecentGroupMessagesParams) ([]CtxGroupMessage, error)

func (*Queries) ListRecentGroupMessagesBeforeSeq added in v0.43.0

func (q *Queries) ListRecentGroupMessagesBeforeSeq(ctx context.Context, arg ListRecentGroupMessagesBeforeSeqParams) ([]CtxGroupMessage, error)

func (*Queries) ListRevisionByGoal added in v0.49.4

func (q *Queries) ListRevisionByGoal(ctx context.Context, goalID string) ([]AgentGoalRevision, error)

func (*Queries) ListRollupCandidates added in v0.49.4

func (q *Queries) ListRollupCandidates(ctx context.Context, limit int64) ([]AgentGoal, error)

func (*Queries) ListRootGoal added in v0.49.4

func (q *Queries) ListRootGoal(ctx context.Context, arg ListRootGoalParams) ([]AgentGoal, error)

Root goals (goals: parent_id IS NULL) for a user, scoped to an agent and narrowed by lifecycle / terminal-ness / project / free-text. Every narg is optional: NULL matches all. terminal: 0 = active (non-terminal) only, 1 = history (terminal) only, NULL = both. The terminal set is the four end states.

func (*Queries) ListSchedJobRuns

func (q *Queries) ListSchedJobRuns(ctx context.Context, arg ListSchedJobRunsParams) ([]SchedJobRun, error)

func (*Queries) ListSchedulerJobs

func (q *Queries) ListSchedulerJobs(ctx context.Context) ([]SchedJob, error)

func (*Queries) ListSchedulerJobsByAgent added in v0.36.0

func (q *Queries) ListSchedulerJobsByAgent(ctx context.Context, arg ListSchedulerJobsByAgentParams) ([]SchedJob, error)

func (*Queries) ListSettings

func (q *Queries) ListSettings(ctx context.Context) ([]AppSetting, error)

func (*Queries) ListSharesByUser added in v0.35.0

func (q *Queries) ListSharesByUser(ctx context.Context, arg ListSharesByUserParams) ([]ListSharesByUserRow, error)

func (*Queries) ListSkillFiles

func (q *Queries) ListSkillFiles(ctx context.Context, skillID string) ([]SkillFile, error)

func (*Queries) ListSkillsByScope added in v0.48.0

func (q *Queries) ListSkillsByScope(ctx context.Context, arg ListSkillsByScopeParams) ([]Skill, error)

func (*Queries) ListSkillsForAdmin added in v0.36.0

func (q *Queries) ListSkillsForAdmin(ctx context.Context, userID sql.NullString) ([]Skill, error)

func (*Queries) ListSkillsForAgentContext added in v0.36.0

func (q *Queries) ListSkillsForAgentContext(ctx context.Context, arg ListSkillsForAgentContextParams) ([]Skill, error)

ListSkillsForAgentContext returns the visible skills for one (user, agent), ordered most-specific-first so a name-dedup downstream keeps the effective skill: user_agent > user > system_agent > system.

func (*Queries) ListSkillsForUser added in v0.36.0

func (q *Queries) ListSkillsForUser(ctx context.Context, arg ListSkillsForUserParams) ([]Skill, error)

func (*Queries) ListSkillsVisible

func (q *Queries) ListSkillsVisible(ctx context.Context, arg ListSkillsVisibleParams) ([]Skill, error)

ListSkillsVisible returns the effective skill set for a (user, agent) context, ordered most-specific-first so a name-dedup keeps the highest-precedence skill: user_agent > user > system_agent > system.

func (*Queries) ListStaleAttempts added in v0.49.4

func (q *Queries) ListStaleAttempts(ctx context.Context, arg ListStaleAttemptsParams) ([]AgentGoalAttempt, error)

func (*Queries) ListStalledComposites added in v0.49.4

func (q *Queries) ListStalledComposites(ctx context.Context, limit int64) ([]AgentGoal, error)

func (*Queries) ListSummariesByIDs added in v0.41.0

func (q *Queries) ListSummariesByIDs(ctx context.Context, arg ListSummariesByIDsParams) ([]CtxSummary, error)

func (*Queries) ListSummaryParentsBySummaryIDs added in v0.46.0

func (q *Queries) ListSummaryParentsBySummaryIDs(ctx context.Context, summaryIds []string) ([]CtxSummaryParent, error)

func (*Queries) ListUnreadArticlesOlderThan

func (q *Queries) ListUnreadArticlesOlderThan(ctx context.Context, arg ListUnreadArticlesOlderThanParams) ([]RecallyArticle, error)

func (*Queries) ListUserAgentMemoriesByUser

func (q *Queries) ListUserAgentMemoriesByUser(ctx context.Context, userID string) ([]CtxAgentMemory, error)

func (*Queries) ListUserAgents

func (q *Queries) ListUserAgents(ctx context.Context, userID string) ([]string, error)

func (*Queries) ListVaultEntriesByScope added in v0.48.0

func (q *Queries) ListVaultEntriesByScope(ctx context.Context, arg ListVaultEntriesByScopeParams) ([]VaultEntry, error)

func (*Queries) ListVaultEntriesByUser

func (q *Queries) ListVaultEntriesByUser(ctx context.Context, userID sql.NullString) ([]VaultEntry, error)

func (*Queries) ListVaultEntriesForRuntime added in v0.48.0

func (q *Queries) ListVaultEntriesForRuntime(ctx context.Context, arg ListVaultEntriesForRuntimeParams) ([]VaultEntry, error)

Keep this precedence in sync with internal/vault envPrecedence.

func (*Queries) MarkGroupDispatchCompleted added in v0.43.0

func (q *Queries) MarkGroupDispatchCompleted(ctx context.Context, arg MarkGroupDispatchCompletedParams) (int64, error)

func (*Queries) MarkGroupDispatchFailed added in v0.43.0

func (q *Queries) MarkGroupDispatchFailed(ctx context.Context, arg MarkGroupDispatchFailedParams) (int64, error)

func (*Queries) MarkGroupOutboxCompleted added in v0.43.0

func (q *Queries) MarkGroupOutboxCompleted(ctx context.Context, arg MarkGroupOutboxCompletedParams) (int64, error)

func (*Queries) MarkGroupOutboxFailed added in v0.43.0

func (q *Queries) MarkGroupOutboxFailed(ctx context.Context, arg MarkGroupOutboxFailedParams) (int64, error)

func (*Queries) MaterializeRevision added in v0.49.4

func (q *Queries) MaterializeRevision(ctx context.Context, id string) (int64, error)

func (*Queries) ProbeCheckCache added in v0.49.4

func (q *Queries) ProbeCheckCache(ctx context.Context, cacheKey string) (AgentGoalAcceptanceEvent, error)

Check-result cache hit: the latest passing deterministic result for a cache_key. Returns sql.ErrNoRows on a forced miss (no cached pass).

func (*Queries) PromoteAttempt added in v0.49.4

func (q *Queries) PromoteAttempt(ctx context.Context, arg PromoteAttemptParams) (int64, error)

func (*Queries) ReconcileGoalCounters added in v0.49.4

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

func (*Queries) RecordSchedulerJobRun

func (q *Queries) RecordSchedulerJobRun(ctx context.Context, arg RecordSchedulerJobRunParams) error

func (*Queries) RemoveGroupMember added in v0.42.0

func (q *Queries) RemoveGroupMember(ctx context.Context, arg RemoveGroupMemberParams) error

func (*Queries) RemoveUserAgent

func (q *Queries) RemoveUserAgent(ctx context.Context, arg RemoveUserAgentParams) error

func (*Queries) RequeueGroupDispatch added in v0.43.0

func (q *Queries) RequeueGroupDispatch(ctx context.Context, arg RequeueGroupDispatchParams) (int64, error)

func (*Queries) RequeueGroupOutbox added in v0.43.0

func (q *Queries) RequeueGroupOutbox(ctx context.Context, arg RequeueGroupOutboxParams) (int64, error)

func (*Queries) ResolveSkill

func (q *Queries) ResolveSkill(ctx context.Context, arg ResolveSkillParams) (Skill, error)

ResolveSkill returns the single effective skill for a name in a (user, agent) context. Precedence: user_agent > user > system_agent > system.

func (*Queries) RevokeAuthUserToken

func (q *Queries) RevokeAuthUserToken(ctx context.Context, id string) (int64, error)

func (*Queries) RotateAuthUserToken

func (q *Queries) RotateAuthUserToken(ctx context.Context, id string) (int64, error)

func (*Queries) SearchArticles

func (q *Queries) SearchArticles(ctx context.Context, arg SearchArticlesParams) ([]SearchArticlesRow, error)

FTS5/BM25 search over title/summary/tags/author. Matching against the hidden table-name column searches every indexed column (declared for sqlc in recally_article_fts_sqlc.sql); bm25 weights rank title hits highest, and snippet column -1 picks the best-matching column. More negative bm25 means more relevant, hence ORDER BY score ASC.

func (*Queries) SearchArticlesLike added in v0.46.0

func (q *Queries) SearchArticlesLike(ctx context.Context, arg SearchArticlesLikeParams) ([]RecallyArticle, error)

Fallback for queries with no token of 3+ runes, which trigram MATCH would silently never hit. Scans the content table directly, recency-ordered, no BM25. Pattern must be a full '%text%' built with ftsquery.EscapeLike; see SearchMessagesLike for the sqlc constraints shaping this query.

func (*Queries) SearchMessages

func (q *Queries) SearchMessages(ctx context.Context, arg SearchMessagesParams) ([]SearchMessagesRow, error)

Spans every conversation of the current (user_id, agent_id) so memory recall survives across sessions. Joins ctx_conversation to pin the scope and surface provenance (session_id, title). Global ORDER BY score + LIMIT keeps the best matches across the merged corpus, not per-conversation truncations.

func (*Queries) SearchMessagesLike added in v0.46.0

func (q *Queries) SearchMessagesLike(ctx context.Context, arg SearchMessagesLikeParams) ([]SearchMessagesLikeRow, error)

Fallback for queries with no token of 3+ runes, which trigram MATCH would silently never hit. Scans the content table directly (faster there than on the FTS table, which pays external-content read-back), recency-ordered, no BM25. Pattern must be a full '%text%' built with ftsquery.EscapeLike; sqlc cannot parse || concatenation here, so the caller wraps it, and the parens around LIKE...ESCAPE are also required by sqlc's grammar. Keep these doc comments ASCII: multibyte chars corrupt sqlc's query rewriter offsets.

func (*Queries) SearchSummaries

func (q *Queries) SearchSummaries(ctx context.Context, arg SearchSummariesParams) ([]SearchSummariesRow, error)

Spans every conversation of the current (user_id, agent_id); see SearchMessages.

func (*Queries) SearchSummariesLike added in v0.46.0

func (q *Queries) SearchSummariesLike(ctx context.Context, arg SearchSummariesLikeParams) ([]SearchSummariesLikeRow, error)

Fallback for queries with no token of 3+ runes (see SearchMessagesLike).

func (*Queries) SeedProvider

func (q *Queries) SeedProvider(ctx context.Context, arg SeedProviderParams) error

func (*Queries) SetAttemptExecutor added in v0.49.4

func (q *Queries) SetAttemptExecutor(ctx context.Context, arg SetAttemptExecutorParams) error

func (*Queries) SetAttemptGaps added in v0.49.4

func (q *Queries) SetAttemptGaps(ctx context.Context, arg SetAttemptGapsParams) error

func (*Queries) SetGoalAcceptanceState added in v0.49.4

func (q *Queries) SetGoalAcceptanceState(ctx context.Context, arg SetGoalAcceptanceStateParams) (int64, error)

func (*Queries) SetGoalAcceptedRevision added in v0.49.4

func (q *Queries) SetGoalAcceptedRevision(ctx context.Context, arg SetGoalAcceptedRevisionParams) error

func (*Queries) SetGoalRequiredTotal added in v0.49.4

func (q *Queries) SetGoalRequiredTotal(ctx context.Context, arg SetGoalRequiredTotalParams) error

func (*Queries) SetGroupDispatchResultMessage added in v0.47.0

func (q *Queries) SetGroupDispatchResultMessage(ctx context.Context, arg SetGroupDispatchResultMessageParams) (int64, error)

func (*Queries) SetRevisionPlanningSession added in v0.49.4

func (q *Queries) SetRevisionPlanningSession(ctx context.Context, arg SetRevisionPlanningSessionParams) (int64, error)

func (*Queries) SubmitAttempt added in v0.49.4

func (q *Queries) SubmitAttempt(ctx context.Context, arg SubmitAttemptParams) (int64, error)

func (*Queries) SupersedeOpenRevisions added in v0.49.4

func (q *Queries) SupersedeOpenRevisions(ctx context.Context, goalID string) error

func (*Queries) TransitionGoalLifecycle added in v0.49.4

func (q *Queries) TransitionGoalLifecycle(ctx context.Context, arg TransitionGoalLifecycleParams) (int64, error)

func (*Queries) UnarchiveGoal added in v0.49.4

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

func (*Queries) UpdateAgent

func (q *Queries) UpdateAgent(ctx context.Context, arg UpdateAgentParams) error

func (*Queries) UpdateArticle

func (q *Queries) UpdateArticle(ctx context.Context, arg UpdateArticleParams) (RecallyArticle, error)

func (*Queries) UpdateAuthPolicy

func (q *Queries) UpdateAuthPolicy(ctx context.Context, arg UpdateAuthPolicyParams) error

func (*Queries) UpdateAuthUserTokenLastUsed

func (q *Queries) UpdateAuthUserTokenLastUsed(ctx context.Context, id string) (int64, error)

func (*Queries) UpdateConversationArchived

func (q *Queries) UpdateConversationArchived(ctx context.Context, arg UpdateConversationArchivedParams) error

func (*Queries) UpdateConversationBootstrapped

func (q *Queries) UpdateConversationBootstrapped(ctx context.Context, arg UpdateConversationBootstrappedParams) error

func (*Queries) UpdateConversationInfoBySessionID added in v0.46.0

func (q *Queries) UpdateConversationInfoBySessionID(ctx context.Context, arg UpdateConversationInfoBySessionIDParams) error

func (*Queries) UpdateConversationKindProject added in v0.34.0

func (q *Queries) UpdateConversationKindProject(ctx context.Context, arg UpdateConversationKindProjectParams) error

func (*Queries) UpdateConversationLastActive

func (q *Queries) UpdateConversationLastActive(ctx context.Context, arg UpdateConversationLastActiveParams) error

func (*Queries) UpdateConversationTitle

func (q *Queries) UpdateConversationTitle(ctx context.Context, arg UpdateConversationTitleParams) error

func (*Queries) UpdateConversationTitleBySessionID

func (q *Queries) UpdateConversationTitleBySessionID(ctx context.Context, arg UpdateConversationTitleBySessionIDParams) error

func (*Queries) UpdateFeed added in v0.43.0

func (q *Queries) UpdateFeed(ctx context.Context, arg UpdateFeedParams) (RecallyFeed, error)

func (*Queries) UpdateFeedEntry added in v0.43.0

func (q *Queries) UpdateFeedEntry(ctx context.Context, arg UpdateFeedEntryParams) (RecallyFeedEntry, error)

func (*Queries) UpdateGoalIntent added in v0.49.4

func (q *Queries) UpdateGoalIntent(ctx context.Context, arg UpdateGoalIntentParams) error

func (*Queries) UpdateGroupName added in v0.43.0

func (q *Queries) UpdateGroupName(ctx context.Context, arg UpdateGroupNameParams) (CtxGroupState, error)

func (*Queries) UpdateProject added in v0.34.0

func (q *Queries) UpdateProject(ctx context.Context, arg UpdateProjectParams) (Project, error)

func (*Queries) UpdateProvider

func (q *Queries) UpdateProvider(ctx context.Context, arg UpdateProviderParams) error

func (*Queries) UpdateRevisionContent added in v0.49.4

func (q *Queries) UpdateRevisionContent(ctx context.Context, arg UpdateRevisionContentParams) error

func (*Queries) UpdateRevisionStatus added in v0.49.4

func (q *Queries) UpdateRevisionStatus(ctx context.Context, arg UpdateRevisionStatusParams) (int64, error)

func (*Queries) UpdateSchedJobRun

func (q *Queries) UpdateSchedJobRun(ctx context.Context, arg UpdateSchedJobRunParams) error

func (*Queries) UpdateSchedulerJob

func (q *Queries) UpdateSchedulerJob(ctx context.Context, arg UpdateSchedulerJobParams) error

func (*Queries) UpdateSkillMetadata

func (q *Queries) UpdateSkillMetadata(ctx context.Context, arg UpdateSkillMetadataParams) error

func (*Queries) UpdateSystemSkillMetadata added in v0.35.3

func (q *Queries) UpdateSystemSkillMetadata(ctx context.Context, arg UpdateSystemSkillMetadataParams) error

func (*Queries) UpdateUserActive added in v0.38.0

func (q *Queries) UpdateUserActive(ctx context.Context, arg UpdateUserActiveParams) error

func (*Queries) UpdateUserRole added in v0.38.0

func (q *Queries) UpdateUserRole(ctx context.Context, arg UpdateUserRoleParams) error

func (*Queries) UpsertAgentConstraints

func (q *Queries) UpsertAgentConstraints(ctx context.Context, arg UpsertAgentConstraintsParams) (CtxAgentMemory, error)

func (*Queries) UpsertAgentSoul

func (q *Queries) UpsertAgentSoul(ctx context.Context, arg UpsertAgentSoulParams) error

func (*Queries) UpsertAgentSoulVersioned

func (q *Queries) UpsertAgentSoulVersioned(ctx context.Context, arg UpsertAgentSoulVersionedParams) (CtxAgentMemory, error)

func (*Queries) UpsertAuthOAuthProvider added in v0.27.0

func (q *Queries) UpsertAuthOAuthProvider(ctx context.Context, arg UpsertAuthOAuthProviderParams) error

func (*Queries) UpsertChannel

func (q *Queries) UpsertChannel(ctx context.Context, arg UpsertChannelParams) error

func (*Queries) UpsertChatAgent

func (q *Queries) UpsertChatAgent(ctx context.Context, arg UpsertChatAgentParams) error

func (*Queries) UpsertDigest added in v0.30.0

func (q *Queries) UpsertDigest(ctx context.Context, arg UpsertDigestParams) (RecallyDigest, error)

func (*Queries) UpsertGroupMemoryVersioned added in v0.42.0

func (q *Queries) UpsertGroupMemoryVersioned(ctx context.Context, arg UpsertGroupMemoryVersionedParams) (CtxGroupMemory, error)

func (*Queries) UpsertIngestCursor added in v0.42.0

func (q *Queries) UpsertIngestCursor(ctx context.Context, arg UpsertIngestCursorParams) error

func (*Queries) UpsertManifestPluginOverride added in v0.38.0

func (q *Queries) UpsertManifestPluginOverride(ctx context.Context, arg UpsertManifestPluginOverrideParams) error

func (*Queries) UpsertPlugin

func (q *Queries) UpsertPlugin(ctx context.Context, arg UpsertPluginParams) error

func (*Queries) UpsertPluginStateEntry

func (q *Queries) UpsertPluginStateEntry(ctx context.Context, arg UpsertPluginStateEntryParams) error

func (*Queries) UpsertProfileEntries added in v0.42.0

func (q *Queries) UpsertProfileEntries(ctx context.Context, arg UpsertProfileEntriesParams) (CtxAgentMemory, error)

func (*Queries) UpsertSetting

func (q *Queries) UpsertSetting(ctx context.Context, arg UpsertSettingParams) error

func (*Queries) UpsertSkillFile

func (q *Queries) UpsertSkillFile(ctx context.Context, arg UpsertSkillFileParams) error

func (*Queries) UpsertUserAgentMemory

func (q *Queries) UpsertUserAgentMemory(ctx context.Context, arg UpsertUserAgentMemoryParams) error

func (*Queries) UpsertUserAgentMemoryVersioned

func (q *Queries) UpsertUserAgentMemoryVersioned(ctx context.Context, arg UpsertUserAgentMemoryVersionedParams) (CtxAgentMemory, error)

func (*Queries) UpsertVaultEntry

func (q *Queries) UpsertVaultEntry(ctx context.Context, arg UpsertVaultEntryParams) error

func (*Queries) UpsertVaultEntryByScope added in v0.48.0

func (q *Queries) UpsertVaultEntryByScope(ctx context.Context, arg UpsertVaultEntryByScopeParams) error

func (*Queries) WaiveEdge added in v0.49.4

func (q *Queries) WaiveEdge(ctx context.Context, arg WaiveEdgeParams) error

func (*Queries) WithTx

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

type RecallyArticle added in v0.38.0

type RecallyArticle struct {
	ID           string         `json:"id"`
	UserID       string         `json:"user_id"`
	AgentID      sql.NullString `json:"agent_id"`
	Url          string         `json:"url"`
	CanonicalUrl string         `json:"canonical_url"`
	SourceType   string         `json:"source_type"`
	Title        string         `json:"title"`
	Author       string         `json:"author"`
	Summary      string         `json:"summary"`
	Tags         string         `json:"tags"`
	Status       string         `json:"status"`
	Starred      int64          `json:"starred"`
	FilePath     string         `json:"file_path"`
	Metadata     string         `json:"metadata"`
	PublishedAt  sql.NullString `json:"published_at"`
	SavedAt      string         `json:"saved_at"`
	ReadAt       sql.NullString `json:"read_at"`
	CreatedAt    string         `json:"created_at"`
	UpdatedAt    string         `json:"updated_at"`
}

type RecallyArticleFt added in v0.46.0

type RecallyArticleFt struct {
	Title             string `json:"title"`
	Summary           string `json:"summary"`
	Tags              string `json:"tags"`
	Author            string `json:"author"`
	RecallyArticleFts string `json:"recally_article_fts"`
}

type RecallyDigest added in v0.30.0

type RecallyDigest struct {
	ID                   string `json:"id"`
	UserID               string `json:"user_id"`
	Date                 string `json:"date"`
	Narrative            string `json:"narrative"`
	SavedYesterdayCount  int64  `json:"saved_yesterday_count"`
	UnreadCount          int64  `json:"unread_count"`
	ReadCount            int64  `json:"read_count"`
	ArchivedCount        int64  `json:"archived_count"`
	StarredCount         int64  `json:"starred_count"`
	WorthRevisitingCount int64  `json:"worth_revisiting_count"`
	TotalArticles        int64  `json:"total_articles"`
	TopTags              string `json:"top_tags"`
	CreatedAt            string `json:"created_at"`
	UpdatedAt            string `json:"updated_at"`
}

type RecallyDigestArticle added in v0.30.0

type RecallyDigestArticle struct {
	DigestID  string `json:"digest_id"`
	ArticleID string `json:"article_id"`
	Section   string `json:"section"`
	Position  int64  `json:"position"`
}

type RecallyFeed added in v0.43.0

type RecallyFeed struct {
	ID            string         `json:"id"`
	UserID        string         `json:"user_id"`
	AgentID       sql.NullString `json:"agent_id"`
	Url           string         `json:"url"`
	Kind          string         `json:"kind"`
	Metadata      string         `json:"metadata"`
	Title         string         `json:"title"`
	Description   string         `json:"description"`
	CheckInterval string         `json:"check_interval"`
	LastCheckedAt sql.NullString `json:"last_checked_at"`
	LastEtag      string         `json:"last_etag"`
	LastModified  string         `json:"last_modified"`
	Enabled       int64          `json:"enabled"`
	CreatedAt     string         `json:"created_at"`
	UpdatedAt     string         `json:"updated_at"`
}

type RecallyFeedEntry added in v0.43.0

type RecallyFeedEntry struct {
	ID           string         `json:"id"`
	FeedID       string         `json:"feed_id"`
	Guid         string         `json:"guid"`
	Url          string         `json:"url"`
	Title        string         `json:"title"`
	Status       string         `json:"status"`
	ArticleID    sql.NullString `json:"article_id"`
	Attempts     int64          `json:"attempts"`
	ErrorMsg     string         `json:"error_msg"`
	DiscoveredAt string         `json:"discovered_at"`
	ProcessedAt  sql.NullString `json:"processed_at"`
}

type RecordSchedulerJobRunParams

type RecordSchedulerJobRunParams struct {
	LastRunAt sql.NullString `json:"last_run_at"`
	LastError string         `json:"last_error"`
	UpdatedAt string         `json:"updated_at"`
	ID        string         `json:"id"`
}

type RemoveGroupMemberParams added in v0.42.0

type RemoveGroupMemberParams struct {
	GroupID string `json:"group_id"`
	AgentID string `json:"agent_id"`
}

type RemoveUserAgentParams

type RemoveUserAgentParams struct {
	UserID  string `json:"user_id"`
	AgentID string `json:"agent_id"`
}

type RequeueGroupDispatchParams added in v0.43.0

type RequeueGroupDispatchParams struct {
	NextAttemptAt sql.NullString `json:"next_attempt_at"`
	LastError     string         `json:"last_error"`
	ID            string         `json:"id"`
	AttemptCount  int64          `json:"attempt_count"`
}

type RequeueGroupOutboxParams added in v0.43.0

type RequeueGroupOutboxParams struct {
	NextAttemptAt sql.NullString `json:"next_attempt_at"`
	LastError     string         `json:"last_error"`
	ID            string         `json:"id"`
	AttemptCount  int64          `json:"attempt_count"`
}

type ResolveSkillParams

type ResolveSkillParams struct {
	Name    string         `json:"name"`
	AgentID sql.NullString `json:"agent_id"`
	UserID  sql.NullString `json:"user_id"`
}

type SchedJob

type SchedJob struct {
	ID            string         `json:"id"`
	OwnerKind     string         `json:"owner_kind"`
	ExecScope     string         `json:"exec_scope"`
	PluginID      string         `json:"plugin_id"`
	JobKey        string         `json:"job_key"`
	RuntimeName   string         `json:"runtime_name"`
	Name          string         `json:"name"`
	Description   string         `json:"description"`
	ScheduleCron  string         `json:"schedule_cron"`
	ScheduleEvery string         `json:"schedule_every"`
	ScheduleAt    string         `json:"schedule_at"`
	Message       string         `json:"message"`
	Payload       string         `json:"payload"`
	SessionMode   string         `json:"session_mode"`
	Enabled       int64          `json:"enabled"`
	AgentID       sql.NullString `json:"agent_id"`
	UserID        sql.NullString `json:"user_id"`
	CreatedAt     string         `json:"created_at"`
	UpdatedAt     string         `json:"updated_at"`
	LastRunAt     sql.NullString `json:"last_run_at"`
	LastError     string         `json:"last_error"`
}

type SchedJobRun

type SchedJobRun struct {
	ID         string         `json:"id"`
	JobID      string         `json:"job_id"`
	SessionID  string         `json:"session_id"`
	Status     string         `json:"status"`
	StartedAt  string         `json:"started_at"`
	FinishedAt sql.NullString `json:"finished_at"`
	Error      string         `json:"error"`
	Output     string         `json:"output"`
	UserID     sql.NullString `json:"user_id"`
}

type SearchArticlesLikeParams added in v0.46.0

type SearchArticlesLikeParams struct {
	UserID  string `json:"user_id"`
	Pattern string `json:"pattern"`
	Limit   int64  `json:"limit"`
}

type SearchArticlesParams

type SearchArticlesParams struct {
	Match  string `json:"match"`
	UserID string `json:"user_id"`
	Limit  int64  `json:"limit"`
}

type SearchArticlesRow added in v0.46.0

type SearchArticlesRow struct {
	RecallyArticle RecallyArticle `json:"recally_article"`
	Snippet        string         `json:"snippet"`
	Score          float64        `json:"score"`
}

type SearchMessagesLikeParams added in v0.46.0

type SearchMessagesLikeParams struct {
	UserID  sql.NullString `json:"user_id"`
	AgentID sql.NullString `json:"agent_id"`
	Pattern string         `json:"pattern"`
	Limit   int64          `json:"limit"`
}

type SearchMessagesLikeRow added in v0.49.0

type SearchMessagesLikeRow struct {
	ID                string         `json:"id"`
	ConversationID    string         `json:"conversation_id"`
	Seq               int64          `json:"seq"`
	Role              string         `json:"role"`
	EventType         string         `json:"event_type"`
	Content           string         `json:"content"`
	TokenCount        int64          `json:"token_count"`
	CreatedAt         string         `json:"created_at"`
	SessionID         string         `json:"session_id"`
	ConversationTitle sql.NullString `json:"conversation_title"`
}

type SearchMessagesParams

type SearchMessagesParams struct {
	Match   string         `json:"match"`
	UserID  sql.NullString `json:"user_id"`
	AgentID sql.NullString `json:"agent_id"`
	Limit   int64          `json:"limit"`
}

type SearchMessagesRow added in v0.46.0

type SearchMessagesRow struct {
	ID                string         `json:"id"`
	ConversationID    string         `json:"conversation_id"`
	Seq               int64          `json:"seq"`
	Role              string         `json:"role"`
	EventType         string         `json:"event_type"`
	Content           string         `json:"content"`
	TokenCount        int64          `json:"token_count"`
	CreatedAt         string         `json:"created_at"`
	SessionID         string         `json:"session_id"`
	ConversationTitle sql.NullString `json:"conversation_title"`
	Snippet           string         `json:"snippet"`
	Score             float64        `json:"score"`
}

type SearchSummariesLikeParams added in v0.46.0

type SearchSummariesLikeParams struct {
	UserID  sql.NullString `json:"user_id"`
	AgentID sql.NullString `json:"agent_id"`
	Pattern string         `json:"pattern"`
	Limit   int64          `json:"limit"`
}

type SearchSummariesLikeRow added in v0.49.0

type SearchSummariesLikeRow struct {
	ID                      string         `json:"id"`
	ConversationID          string         `json:"conversation_id"`
	Kind                    string         `json:"kind"`
	Depth                   int64          `json:"depth"`
	Content                 string         `json:"content"`
	TokenCount              int64          `json:"token_count"`
	EarliestAt              sql.NullString `json:"earliest_at"`
	LatestAt                sql.NullString `json:"latest_at"`
	DescendantCount         int64          `json:"descendant_count"`
	DescendantTokenCount    int64          `json:"descendant_token_count"`
	SourceMessageTokenCount int64          `json:"source_message_token_count"`
	CreatedAt               string         `json:"created_at"`
	SessionID               string         `json:"session_id"`
	ConversationTitle       sql.NullString `json:"conversation_title"`
}

type SearchSummariesParams

type SearchSummariesParams struct {
	Match   string         `json:"match"`
	UserID  sql.NullString `json:"user_id"`
	AgentID sql.NullString `json:"agent_id"`
	Limit   int64          `json:"limit"`
}

type SearchSummariesRow added in v0.46.0

type SearchSummariesRow struct {
	ID                      string         `json:"id"`
	ConversationID          string         `json:"conversation_id"`
	Kind                    string         `json:"kind"`
	Depth                   int64          `json:"depth"`
	Content                 string         `json:"content"`
	TokenCount              int64          `json:"token_count"`
	EarliestAt              sql.NullString `json:"earliest_at"`
	LatestAt                sql.NullString `json:"latest_at"`
	DescendantCount         int64          `json:"descendant_count"`
	DescendantTokenCount    int64          `json:"descendant_token_count"`
	SourceMessageTokenCount int64          `json:"source_message_token_count"`
	CreatedAt               string         `json:"created_at"`
	SessionID               string         `json:"session_id"`
	ConversationTitle       sql.NullString `json:"conversation_title"`
	Snippet                 string         `json:"snippet"`
	Score                   float64        `json:"score"`
}

type SeedProviderParams

type SeedProviderParams struct {
	ID      string `json:"id"`
	Type    string `json:"type"`
	Name    string `json:"name"`
	Enabled int64  `json:"enabled"`
	Config  string `json:"config"`
}

type SetAttemptExecutorParams added in v0.49.4

type SetAttemptExecutorParams struct {
	ExecutorAgentID sql.NullString `json:"executor_agent_id"`
	ID              string         `json:"id"`
}

type SetAttemptGapsParams added in v0.49.4

type SetAttemptGapsParams struct {
	Gaps string `json:"gaps"`
	ID   string `json:"id"`
}

type SetGoalAcceptanceStateParams added in v0.49.4

type SetGoalAcceptanceStateParams struct {
	AcceptanceState string `json:"acceptance_state"`
	AcceptanceSeq   int64  `json:"acceptance_seq"`
	ID              string `json:"id"`
}

type SetGoalAcceptedRevisionParams added in v0.49.4

type SetGoalAcceptedRevisionParams struct {
	AcceptedRevisionID sql.NullString `json:"accepted_revision_id"`
	ID                 string         `json:"id"`
}

type SetGoalRequiredTotalParams added in v0.49.4

type SetGoalRequiredTotalParams struct {
	RequiredTotal int64  `json:"required_total"`
	ID            string `json:"id"`
}

type SetGroupDispatchResultMessageParams added in v0.47.0

type SetGroupDispatchResultMessageParams struct {
	ResultMessageID string `json:"result_message_id"`
	ID              string `json:"id"`
	AttemptCount    int64  `json:"attempt_count"`
}

type SetRevisionPlanningSessionParams added in v0.49.4

type SetRevisionPlanningSessionParams struct {
	PlanningSessionID sql.NullString `json:"planning_session_id"`
	ID                string         `json:"id"`
}

type Share added in v0.35.0

type Share struct {
	ID        string         `json:"id"`
	TokenHash string         `json:"token_hash"`
	UserID    string         `json:"user_id"`
	Title     string         `json:"title"`
	MediaType string         `json:"media_type"`
	Content   []byte         `json:"content"`
	ExpiresAt sql.NullString `json:"expires_at"`
	CreatedAt string         `json:"created_at"`
	UpdatedAt string         `json:"updated_at"`
}

type Skill

type Skill struct {
	ID                     string         `json:"id"`
	Scope                  string         `json:"scope"`
	UserID                 sql.NullString `json:"user_id"`
	AgentID                sql.NullString `json:"agent_id"`
	Name                   string         `json:"name"`
	Description            string         `json:"description"`
	Status                 string         `json:"status"`
	DisableModelInvocation int64          `json:"disable_model_invocation"`
	Metadata               string         `json:"metadata"`
	CreatedAt              string         `json:"created_at"`
	UpdatedAt              string         `json:"updated_at"`
}

type SkillFile

type SkillFile struct {
	SkillID string `json:"skill_id"`
	Path    string `json:"path"`
	Content string `json:"content"`
}

type SubmitAttemptParams added in v0.49.4

type SubmitAttemptParams struct {
	Evidence   string         `json:"evidence"`
	Output     string         `json:"output"`
	RevisionID sql.NullString `json:"revision_id"`
	ID         string         `json:"id"`
}

type TransitionGoalLifecycleParams added in v0.49.4

type TransitionGoalLifecycleParams struct {
	ToLifecycle   string `json:"to_lifecycle"`
	BlockReason   string `json:"block_reason"`
	ID            string `json:"id"`
	FromLifecycle string `json:"from_lifecycle"`
}

type UpdateAgentParams

type UpdateAgentParams struct {
	Name                 string `json:"name"`
	Model                string `json:"model"`
	ModelThinking        string `json:"model_thinking"`
	ModelStrong          string `json:"model_strong"`
	ModelStrongThinking  string `json:"model_strong_thinking"`
	ModelFast            string `json:"model_fast"`
	ModelFastThinking    string `json:"model_fast_thinking"`
	SystemPrompt         string `json:"system_prompt"`
	Soul                 string `json:"soul"`
	Workspace            string `json:"workspace"`
	Sandbox              string `json:"sandbox"`
	EnabledBuiltinSkills string `json:"enabled_builtin_skills"`
	Scope                string `json:"scope"`
	Enabled              int64  `json:"enabled"`
	ID                   string `json:"id"`
}

type UpdateArticleParams

type UpdateArticleParams struct {
	Title       string         `json:"title"`
	Author      string         `json:"author"`
	Summary     string         `json:"summary"`
	Tags        string         `json:"tags"`
	Status      string         `json:"status"`
	Starred     int64          `json:"starred"`
	FilePath    string         `json:"file_path"`
	Metadata    string         `json:"metadata"`
	PublishedAt sql.NullString `json:"published_at"`
	ReadAt      sql.NullString `json:"read_at"`
	ID          string         `json:"id"`
	UserID      string         `json:"user_id"`
}

type UpdateAuthPolicyParams

type UpdateAuthPolicyParams struct {
	Name       string `json:"name"`
	Effect     string `json:"effect"`
	Subjects   string `json:"subjects"`
	Actions    string `json:"actions"`
	Resources  string `json:"resources"`
	Conditions string `json:"conditions"`
	Priority   int64  `json:"priority"`
	Enabled    int64  `json:"enabled"`
	ID         string `json:"id"`
}

type UpdateConversationArchivedParams

type UpdateConversationArchivedParams struct {
	Archived  int64          `json:"archived"`
	SessionID string         `json:"session_id"`
	UserID    sql.NullString `json:"user_id"`
	AgentID   sql.NullString `json:"agent_id"`
}

type UpdateConversationBootstrappedParams added in v0.35.3

type UpdateConversationBootstrappedParams struct {
	ID      string         `json:"id"`
	UserID  sql.NullString `json:"user_id"`
	AgentID sql.NullString `json:"agent_id"`
}

type UpdateConversationInfoBySessionIDParams added in v0.46.0

type UpdateConversationInfoBySessionIDParams struct {
	Title     interface{}    `json:"title"`
	Archived  int64          `json:"archived"`
	Kind      interface{}    `json:"kind"`
	ProjectID interface{}    `json:"project_id"`
	SessionID string         `json:"session_id"`
	UserID    sql.NullString `json:"user_id"`
	AgentID   sql.NullString `json:"agent_id"`
}

type UpdateConversationKindProjectParams added in v0.34.0

type UpdateConversationKindProjectParams struct {
	Kind      string         `json:"kind"`
	ProjectID sql.NullString `json:"project_id"`
	SessionID string         `json:"session_id"`
	UserID    sql.NullString `json:"user_id"`
	AgentID   sql.NullString `json:"agent_id"`
}

type UpdateConversationLastActiveParams added in v0.35.3

type UpdateConversationLastActiveParams struct {
	SessionID string         `json:"session_id"`
	UserID    sql.NullString `json:"user_id"`
	AgentID   sql.NullString `json:"agent_id"`
}

type UpdateConversationTitleBySessionIDParams

type UpdateConversationTitleBySessionIDParams struct {
	Title     sql.NullString `json:"title"`
	SessionID string         `json:"session_id"`
	UserID    sql.NullString `json:"user_id"`
	AgentID   sql.NullString `json:"agent_id"`
}

type UpdateConversationTitleParams

type UpdateConversationTitleParams struct {
	Title   sql.NullString `json:"title"`
	ID      string         `json:"id"`
	UserID  sql.NullString `json:"user_id"`
	AgentID sql.NullString `json:"agent_id"`
}

type UpdateFeedEntryParams added in v0.43.0

type UpdateFeedEntryParams struct {
	Status    string         `json:"status"`
	ArticleID sql.NullString `json:"article_id"`
	ErrorMsg  string         `json:"error_msg"`
	ID        string         `json:"id"`
	FeedID    string         `json:"feed_id"`
}

type UpdateFeedParams added in v0.43.0

type UpdateFeedParams struct {
	Title         string         `json:"title"`
	Description   string         `json:"description"`
	Metadata      string         `json:"metadata"`
	CheckInterval string         `json:"check_interval"`
	LastCheckedAt sql.NullString `json:"last_checked_at"`
	LastEtag      string         `json:"last_etag"`
	LastModified  string         `json:"last_modified"`
	Enabled       int64          `json:"enabled"`
	ID            string         `json:"id"`
	UserID        string         `json:"user_id"`
}

type UpdateGoalIntentParams added in v0.49.4

type UpdateGoalIntentParams struct {
	Title              string `json:"title"`
	Intent             string `json:"intent"`
	AcceptanceContract string `json:"acceptance_contract"`
	ConvergencePolicy  string `json:"convergence_policy"`
	ReviewPolicy       string `json:"review_policy"`
	Priority           string `json:"priority"`
	ID                 string `json:"id"`
}

type UpdateGroupNameParams added in v0.43.0

type UpdateGroupNameParams struct {
	GroupName string `json:"group_name"`
	ID        string `json:"id"`
}

type UpdateProjectParams added in v0.34.0

type UpdateProjectParams struct {
	Name        string         `json:"name"`
	Description sql.NullString `json:"description"`
	BaseDir     string         `json:"base_dir"`
	ID          string         `json:"id"`
	UserID      string         `json:"user_id"`
}

type UpdateProviderParams

type UpdateProviderParams struct {
	Type    string `json:"type"`
	Name    string `json:"name"`
	Enabled int64  `json:"enabled"`
	Config  string `json:"config"`
	ID      string `json:"id"`
}

type UpdateRevisionContentParams added in v0.49.4

type UpdateRevisionContentParams struct {
	Content string `json:"content"`
	ID      string `json:"id"`
}

type UpdateRevisionStatusParams added in v0.49.4

type UpdateRevisionStatusParams struct {
	ToStatus   string `json:"to_status"`
	ID         string `json:"id"`
	FromStatus string `json:"from_status"`
}

type UpdateSchedJobRunParams

type UpdateSchedJobRunParams struct {
	Status     string         `json:"status"`
	FinishedAt sql.NullString `json:"finished_at"`
	Error      string         `json:"error"`
	Output     string         `json:"output"`
	ID         string         `json:"id"`
	JobID      string         `json:"job_id"`
}

type UpdateSchedulerJobParams

type UpdateSchedulerJobParams struct {
	OwnerKind     string         `json:"owner_kind"`
	ExecScope     string         `json:"exec_scope"`
	PluginID      string         `json:"plugin_id"`
	JobKey        string         `json:"job_key"`
	RuntimeName   string         `json:"runtime_name"`
	Name          string         `json:"name"`
	Description   string         `json:"description"`
	ScheduleCron  string         `json:"schedule_cron"`
	ScheduleEvery string         `json:"schedule_every"`
	ScheduleAt    string         `json:"schedule_at"`
	Message       string         `json:"message"`
	Payload       string         `json:"payload"`
	SessionMode   string         `json:"session_mode"`
	Enabled       int64          `json:"enabled"`
	AgentID       sql.NullString `json:"agent_id"`
	UserID        sql.NullString `json:"user_id"`
	UpdatedAt     string         `json:"updated_at"`
	LastRunAt     sql.NullString `json:"last_run_at"`
	LastError     string         `json:"last_error"`
	ID            string         `json:"id"`
}

type UpdateSkillMetadataParams

type UpdateSkillMetadataParams struct {
	Description            string         `json:"description"`
	Status                 string         `json:"status"`
	DisableModelInvocation int64          `json:"disable_model_invocation"`
	Metadata               string         `json:"metadata"`
	ID                     string         `json:"id"`
	AgentID                sql.NullString `json:"agent_id"`
	UserID                 sql.NullString `json:"user_id"`
}

type UpdateSystemSkillMetadataParams added in v0.35.3

type UpdateSystemSkillMetadataParams struct {
	Description            string `json:"description"`
	Status                 string `json:"status"`
	DisableModelInvocation int64  `json:"disable_model_invocation"`
	Metadata               string `json:"metadata"`
	ID                     string `json:"id"`
}

type UpdateUserActiveParams added in v0.38.0

type UpdateUserActiveParams struct {
	IsActive int64  `json:"is_active"`
	ID       string `json:"id"`
}

type UpdateUserRoleParams added in v0.38.0

type UpdateUserRoleParams struct {
	Role string `json:"role"`
	ID   string `json:"id"`
}

type UpsertAgentConstraintsParams

type UpsertAgentConstraintsParams struct {
	UserID      string `json:"user_id"`
	AgentID     string `json:"agent_id"`
	Constraints string `json:"constraints"`
}

type UpsertAgentSoulParams

type UpsertAgentSoulParams struct {
	UserID  string `json:"user_id"`
	AgentID string `json:"agent_id"`
	Soul    string `json:"soul"`
}

type UpsertAgentSoulVersionedParams

type UpsertAgentSoulVersionedParams struct {
	UserID  string `json:"user_id"`
	AgentID string `json:"agent_id"`
	Soul    string `json:"soul"`
}

type UpsertAuthOAuthProviderParams added in v0.27.0

type UpsertAuthOAuthProviderParams struct {
	ID              string `json:"id"`
	ProviderID      string `json:"provider_id"`
	ClientID        string `json:"client_id"`
	ClientSecretEnc string `json:"client_secret_enc"`
	RedirectUrl     string `json:"redirect_url"`
}

type UpsertChannelParams

type UpsertChannelParams struct {
	ID      string         `json:"id"`
	Name    string         `json:"name"`
	Type    string         `json:"type"`
	AgentID sql.NullString `json:"agent_id"`
	Enabled int64          `json:"enabled"`
	Config  string         `json:"config"`
}

type UpsertChatAgentParams

type UpsertChatAgentParams struct {
	ChannelID string `json:"channel_id"`
	Platform  string `json:"platform"`
	ChatID    string `json:"chat_id"`
	AgentID   string `json:"agent_id"`
}

type UpsertDigestParams added in v0.30.0

type UpsertDigestParams struct {
	ID                   string `json:"id"`
	UserID               string `json:"user_id"`
	Date                 string `json:"date"`
	Narrative            string `json:"narrative"`
	SavedYesterdayCount  int64  `json:"saved_yesterday_count"`
	UnreadCount          int64  `json:"unread_count"`
	ReadCount            int64  `json:"read_count"`
	ArchivedCount        int64  `json:"archived_count"`
	StarredCount         int64  `json:"starred_count"`
	WorthRevisitingCount int64  `json:"worth_revisiting_count"`
	TotalArticles        int64  `json:"total_articles"`
	TopTags              string `json:"top_tags"`
}

type UpsertGroupMemoryVersionedParams added in v0.42.0

type UpsertGroupMemoryVersionedParams struct {
	GroupID string `json:"group_id"`
	Content string `json:"content"`
}

type UpsertIngestCursorParams added in v0.42.0

type UpsertIngestCursorParams struct {
	GroupID  string `json:"group_id"`
	Pipeline string `json:"pipeline"`
	LastSeq  int64  `json:"last_seq"`
}

type UpsertManifestPluginOverrideParams added in v0.38.0

type UpsertManifestPluginOverrideParams struct {
	PluginID           string        `json:"plugin_id"`
	Enabled            sql.NullInt64 `json:"enabled"`
	SessionEnvVaultKey string        `json:"session_env_vault_key"`
	Config             string        `json:"config"`
}

type UpsertPluginParams

type UpsertPluginParams struct {
	ID      string `json:"id"`
	Kind    string `json:"kind"`
	Name    string `json:"name"`
	Enabled int64  `json:"enabled"`
	Config  string `json:"config"`
}

type UpsertPluginStateEntryParams

type UpsertPluginStateEntryParams struct {
	PluginID  string `json:"plugin_id"`
	ScopeKind string `json:"scope_kind"`
	ScopeID   string `json:"scope_id"`
	StateKey  string `json:"state_key"`
	Value     string `json:"value"`
}

type UpsertProfileEntriesParams added in v0.42.0

type UpsertProfileEntriesParams struct {
	UserID         string `json:"user_id"`
	AgentID        string `json:"agent_id"`
	ProfileEntries string `json:"profile_entries"`
}

type UpsertSettingParams

type UpsertSettingParams struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

type UpsertSkillFileParams

type UpsertSkillFileParams struct {
	SkillID string `json:"skill_id"`
	Path    string `json:"path"`
	Content string `json:"content"`
}

type UpsertUserAgentMemoryParams

type UpsertUserAgentMemoryParams struct {
	UserID  string `json:"user_id"`
	AgentID string `json:"agent_id"`
	Content string `json:"content"`
}

type UpsertUserAgentMemoryVersionedParams

type UpsertUserAgentMemoryVersionedParams struct {
	UserID  string `json:"user_id"`
	AgentID string `json:"agent_id"`
	Content string `json:"content"`
}

type UpsertVaultEntryByScopeParams added in v0.48.0

type UpsertVaultEntryByScopeParams struct {
	ID         string         `json:"id"`
	Scope      string         `json:"scope"`
	UserID     sql.NullString `json:"user_id"`
	AgentID    sql.NullString `json:"agent_id"`
	Name       string         `json:"name"`
	Ciphertext string         `json:"ciphertext"`
}

type UpsertVaultEntryParams

type UpsertVaultEntryParams struct {
	ID         string         `json:"id"`
	UserID     sql.NullString `json:"user_id"`
	Name       string         `json:"name"`
	Ciphertext string         `json:"ciphertext"`
}

type VaultEntry

type VaultEntry struct {
	ID         string         `json:"id"`
	Scope      string         `json:"scope"`
	UserID     sql.NullString `json:"user_id"`
	AgentID    sql.NullString `json:"agent_id"`
	Name       string         `json:"name"`
	Ciphertext string         `json:"ciphertext"`
	CreatedAt  string         `json:"created_at"`
	UpdatedAt  string         `json:"updated_at"`
}

type VaultUser added in v0.38.0

type VaultUser struct {
	AgePublicKey  string
	AgePrivateKey string
}

VaultUser holds the age key fields the vault service needs from a user record.

type WaiveEdgeParams added in v0.49.4

type WaiveEdgeParams struct {
	WaivedByUser sql.NullString `json:"waived_by_user"`
	WaiverReason string         `json:"waiver_reason"`
	GoalID       string         `json:"goal_id"`
	UpstreamID   string         `json:"upstream_id"`
}

Jump to

Keyboard shortcuts

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