sqlc

package
v0.50.7 Latest Latest
Warning

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

Go to latest
Published: Jul 15, 2026 License: AGPL-3.0 Imports: 7 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 pgtype.Text `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              json.RawMessage `json:"sandbox"`
	EnabledBuiltinSkills json.RawMessage `json:"enabled_builtin_skills"`
	Scope                string          `json:"scope"`
	CreatorID            string          `json:"creator_id"`
	Enabled              bool            `json:"enabled"`
	CreatedAt            time.Time       `json:"created_at"`
	UpdatedAt            time.Time       `json:"updated_at"`
}

type AgentGoal added in v0.38.0

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

type AgentGoalAcceptanceEvent added in v0.49.4

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

type AgentGoalAttempt added in v0.49.4

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

type AgentGoalEdge added in v0.49.4

type AgentGoalEdge struct {
	GoalID       string             `json:"goal_id"`
	UpstreamID   string             `json:"upstream_id"`
	EdgeKind     string             `json:"edge_kind"`
	OnFailure    string             `json:"on_failure"`
	WaivedAt     pgtype.Timestamptz `json:"waived_at"`
	WaivedByUser pgtype.Text        `json:"waived_by_user"`
	WaiverReason string             `json:"waiver_reason"`
	CreatedAt    time.Time          `json:"created_at"`
}

type AppSetting added in v0.38.0

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

type AppendAcceptanceEventParams added in v0.49.4

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

type AppendContextItemParams

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

type ArchiveProjectParams added in v0.34.0

type ArchiveProjectParams struct {
	Archived bool   `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    time.Time `json:"created_at"`
	UpdatedAt    time.Time `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       json.RawMessage `json:"raw_claims"`
	CreatedAt       time.Time       `json:"created_at"`
	UpdatedAt       time.Time       `json:"updated_at"`
}

type AuthPolicy

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

type AuthSession

type AuthSession struct {
	ID        string    `json:"id"`
	UserID    string    `json:"user_id"`
	TokenHash string    `json:"token_hash"`
	ExpiresAt time.Time `json:"expires_at"`
	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `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         bool        `json:"is_active"`
	DefaultAgentID   pgtype.Text `json:"default_agent_id"`
	NotifyIdentityID pgtype.Text `json:"notify_identity_id"`
	AgePublicKey     string      `json:"age_public_key"`
	AgePrivateKey    string      `json:"age_private_key"`
	CreatedAt        time.Time   `json:"created_at"`
	UpdatedAt        time.Time   `json:"updated_at"`
}

type AuthUserAgent

type 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 bool               `json:"auto_generated"`
	LastUsedAt    pgtype.Timestamptz `json:"last_used_at"`
	ExpiresAt     pgtype.Timestamptz `json:"expires_at"`
	RotatedAt     pgtype.Timestamptz `json:"rotated_at"`
	RevokedAt     pgtype.Timestamptz `json:"revoked_at"`
	CreatedAt     time.Time          `json:"created_at"`
	UpdatedAt     time.Time          `json:"updated_at"`
}

type BlockGoalParams added in v0.49.4

type 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   pgtype.Text `json:"agent_id"`
	Enabled   bool        `json:"enabled"`
	Config    string      `json:"config"`
	CreatedAt time.Time   `json:"created_at"`
	UpdatedAt time.Time   `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 time.Time `json:"created_at"`
	UpdatedAt time.Time `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      time.Time `json:"created_at"`
	UpdatedAt      time.Time `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  time.Time `json:"created_at"`
	UpdatedAt  time.Time `json:"updated_at"`
}

type ClaimExpiredGroupDispatchParams added in v0.43.0

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

type ClaimExpiredGroupOutboxParams added in v0.43.0

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

type ClaimGoalParams added in v0.49.4

type ClaimGoalParams struct {
	ActiveAttemptID pgtype.Text `json:"active_attempt_id"`
	ID              string      `json:"id"`
}

type ClaimPendingGroupDispatchParams added in v0.43.0

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

type ClaimPendingGroupOutboxParams added in v0.43.0

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

type ConsumeDispatchHintParams added in v0.38.0

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

type 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         pgtype.Text `json:"agent_id"`
	ProjectID       pgtype.Text `json:"project_id"`
	Lifecycle       pgtype.Text `json:"lifecycle"`
	Terminal        pgtype.Bool `json:"terminal"`
	Q               pgtype.Text `json:"q"`
	IncludeArchived bool        `json:"include_archived"`
}

type CreateAgentParams

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

type CreateArticleParams

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

type CreateAttemptParams added in v0.49.4

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

type CreateAuthPolicyParams

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

type 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 bool               `json:"auto_generated"`
	ExpiresAt     pgtype.Timestamptz `json:"expires_at"`
}

type CreateConversationParams

type CreateConversationParams struct {
	ID         string      `json:"id"`
	SessionID  string      `json:"session_id"`
	Title      pgtype.Text `json:"title"`
	Channel    string      `json:"channel"`
	Kind       string      `json:"kind"`
	ProjectID  pgtype.Text `json:"project_id"`
	Archived   bool        `json:"archived"`
	LastActive time.Time   `json:"last_active"`
	AgentID    pgtype.Text `json:"agent_id"`
	UserID     pgtype.Text `json:"user_id"`
}

type CreateDigestParams added in v0.30.0

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

type CreateEdgeParams added in v0.49.4

type 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    pgtype.Text        `json:"article_id"`
	Attempts     int64              `json:"attempts"`
	ErrorMsg     string             `json:"error_msg"`
	DiscoveredAt time.Time          `json:"discovered_at"`
	ProcessedAt  pgtype.Timestamptz `json:"processed_at"`
}

type CreateFeedParams added in v0.43.0

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

type CreateGoalParams added in v0.49.4

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

type CreateGroupDispatchParams added in v0.43.0

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

type CreateGroupMessageParams added in v0.42.0

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

type CreateGroupOutboxParams added in v0.43.0

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

type CreateGroupStateParams added in v0.42.0

type 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  pgtype.Text `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 pgtype.Text `json:"text_content"`
	ToolCallID  pgtype.Text `json:"tool_call_id"`
	ToolName    pgtype.Text `json:"tool_name"`
	ToolInput   pgtype.Text `json:"tool_input"`
	ToolOutput  pgtype.Text `json:"tool_output"`
	Metadata    pgtype.Text `json:"metadata"`
}

type CreateProjectParams added in v0.34.0

type 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 pgtype.Text `json:"description"`
}

type CreateProviderParams

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

type CreateSchedJobRunParams

type CreateSchedJobRunParams struct {
	ID         string             `json:"id"`
	JobID      string             `json:"job_id"`
	SessionID  string             `json:"session_id"`
	Status     string             `json:"status"`
	StartedAt  time.Time          `json:"started_at"`
	FinishedAt pgtype.Timestamptz `json:"finished_at"`
	Error      string             `json:"error"`
	UserID     pgtype.Text        `json:"user_id"`
}

type CreateSchedulerJobParams

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

type CreateShareParams added in v0.35.0

type CreateShareParams struct {
	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 pgtype.Timestamptz `json:"expires_at"`
}

type CreateSkillParams

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

type CreateSummaryParams

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

type CreateWebChannelIfNotExistsParams added in v0.43.0

type CreateWebChannelIfNotExistsParams struct {
	ID      string      `json:"id"`
	AgentID pgtype.Text `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    json.RawMessage `json:"constraints"`
	ProfileEntries json.RawMessage `json:"profile_entries"`
	CreatedAt      time.Time       `json:"created_at"`
	UpdatedAt      time.Time       `json:"updated_at"`
}

type CtxAgentMemoryChangelog added in v0.38.0

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

type CtxAgentMemorySnapshot added in v0.38.0

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

type CtxConversation

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

type CtxGroupDispatch added in v0.43.0

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

type CtxGroupIngestCursor added in v0.42.0

type CtxGroupIngestCursor struct {
	GroupID   string    `json:"group_id"`
	Pipeline  string    `json:"pipeline"`
	LastSeq   int64     `json:"last_seq"`
	UpdatedAt time.Time `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 time.Time `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 time.Time `json:"created_at"`
	UpdatedAt time.Time `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   pgtype.Text        `json:"source_channel_id"`
	ActorType         string             `json:"actor_type"`
	ActorID           string             `json:"actor_id"`
	PlatformMessageID pgtype.Text        `json:"platform_message_id"`
	ReplyTo           pgtype.Text        `json:"reply_to"`
	PlatformTimestamp pgtype.Timestamptz `json:"platform_timestamp"`
	IdempotencyKey    pgtype.Text        `json:"idempotency_key"`
	Content           string             `json:"content"`
	Reasoning         string             `json:"reasoning"`
	AgentSessionID    string             `json:"agent_session_id"`
	CreatedAt         time.Time          `json:"created_at"`
}

type CtxGroupOutbox added in v0.43.0

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

type CtxGroupState added in v0.42.0

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

type CtxItem

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

type CtxMessage

type 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      time.Time `json:"created_at"`
}

type CtxMessageEmbedding added in v0.50.0

type CtxMessageEmbedding struct {
	MessageID   string             `json:"message_id"`
	Model       string             `json:"model"`
	ContentHash []byte             `json:"content_hash"`
	Embedding   pgvector_go.Vector `json:"embedding"`
	CreatedAt   time.Time          `json:"created_at"`
	UpdatedAt   time.Time          `json:"updated_at"`
}

type CtxMessagePart

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

type CtxSummary

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

type CtxSummaryEmbedding added in v0.50.0

type CtxSummaryEmbedding struct {
	SummaryID   string             `json:"summary_id"`
	Model       string             `json:"model"`
	ContentHash []byte             `json:"content_hash"`
	Embedding   pgvector_go.Vector `json:"embedding"`
	CreatedAt   time.Time          `json:"created_at"`
	UpdatedAt   time.Time          `json:"updated_at"`
}

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 {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.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 pgtype.Text `json:"agent_id"`
	UserID  pgtype.Text `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  pgtype.Text `json:"user_id"`
	AgentID pgtype.Text `json:"agent_id"`
	Name    string      `json:"name"`
}

type DeleteVaultEntryParams

type DeleteVaultEntryParams struct {
	UserID pgtype.Text `json:"user_id"`
	Name   string      `json:"name"`
}

type ExpireKnowledgeDraftsByTypeParams

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

type ExtendRunningGroupDispatchLeaseParams added in v0.43.0

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

type ExtendRunningGroupOutboxLeaseParams added in v0.43.0

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

type FinalizeAttemptParams added in v0.49.4

type 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      pgtype.Text `json:"message_id"`
	SummaryID      pgtype.Text `json:"summary_id"`
	EventType      string      `json:"event_type"`
	Role           string      `json:"role"`
	CreatedAt      time.Time   `json:"created_at"`
	MsgTokenCount  int64       `json:"msg_token_count"`
}

type GetContextStatsRow added in v0.46.0

type 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    pgtype.Text `json:"user_id"`
}

type GetConversationBySessionIDParams added in v0.35.3

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

type GetConversationParams added in v0.35.3

type GetConversationParams struct {
	ID      string      `json:"id"`
	UserID  pgtype.Text `json:"user_id"`
	AgentID pgtype.Text `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          int32  `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 pgtype.Text `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 pgtype.Text `json:"project_id"`
	UserID    pgtype.Text `json:"user_id"`
	AgentID   pgtype.Text `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 pgtype.Int8 `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  pgtype.Text `json:"user_id"`
	AgentID pgtype.Text `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         time.Time   `json:"created_at"`
	SessionID         string      `json:"session_id"`
	ConversationTitle pgtype.Text `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      time.Time `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 pgtype.Text `json:"agent_id"`
	UserID  pgtype.Text `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 pgtype.Text `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 pgtype.Text `json:"user_id"`
	Name   string      `json:"name"`
}

type GetVaultEntryByScopeParams added in v0.48.0

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

type GetVaultEntryParams

type GetVaultEntryParams struct {
	UserID pgtype.Text `json:"user_id"`
	Name   string      `json:"name"`
}

type HeartbeatAttemptParams added in v0.49.4

type HeartbeatAttemptParams struct {
	LeaseExpiresAt pgtype.Timestamptz `json:"lease_expires_at"`
	ID             string             `json:"id"`
}

type InsertMemoryChangelogParams

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

type IsIngestErrorParams added in v0.42.0

type 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       pgtype.Text `json:"agent_id"`
	UserID        pgtype.Text `json:"user_id"`
	KnowledgeType string      `json:"knowledge_type"`
}

type ListAgentConversationLastActiveRow added in v0.46.0

type ListAgentConversationLastActiveRow struct {
	AgentID    pgtype.Text `json:"agent_id"`
	LastActive interface{} `json:"last_active"`
}

type ListArticlesNeedingEmbeddingParams added in v0.50.3

type ListArticlesNeedingEmbeddingParams struct {
	Model string `json:"model"`
	Limit int32  `json:"limit"`
}

type ListArticlesNeedingEmbeddingRow added in v0.50.3

type ListArticlesNeedingEmbeddingRow struct {
	ID            string      `json:"id"`
	Content       string      `json:"content"`
	EmbeddedModel pgtype.Text `json:"embedded_model"`
	EmbeddedHash  []byte      `json:"embedded_hash"`
}

type ListArticlesParams

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

type ListAttemptByGoalParams added in v0.49.4

type ListAttemptByGoalParams struct {
	GoalID  string      `json:"goal_id"`
	Purpose pgtype.Text `json:"purpose"`
}

type ListContextItemsPageParams added in v0.46.0

type ListContextItemsPageParams struct {
	ConversationID string      `json:"conversation_id"`
	OffsetCount    int32       `json:"offset_count"`
	LimitCount     interface{} `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                      pgtype.Text        `json:"message_id"`
	MessageSeq                     pgtype.Int8        `json:"message_seq"`
	MessageRole                    pgtype.Text        `json:"message_role"`
	MessageEventType               pgtype.Text        `json:"message_event_type"`
	MessageContent                 pgtype.Text        `json:"message_content"`
	MessageTokenCount              pgtype.Int8        `json:"message_token_count"`
	MessageCreatedAt               pgtype.Timestamptz `json:"message_created_at"`
	SummaryID                      pgtype.Text        `json:"summary_id"`
	SummaryKind                    pgtype.Text        `json:"summary_kind"`
	SummaryDepth                   pgtype.Int8        `json:"summary_depth"`
	SummaryContent                 pgtype.Text        `json:"summary_content"`
	SummaryTokenCount              pgtype.Int8        `json:"summary_token_count"`
	SummaryEarliestAt              pgtype.Timestamptz `json:"summary_earliest_at"`
	SummaryLatestAt                pgtype.Timestamptz `json:"summary_latest_at"`
	SummaryDescendantCount         pgtype.Int8        `json:"summary_descendant_count"`
	SummaryDescendantTokenCount    pgtype.Int8        `json:"summary_descendant_token_count"`
	SummarySourceMessageTokenCount pgtype.Int8        `json:"summary_source_message_token_count"`
	SummaryCreatedAt               pgtype.Timestamptz `json:"summary_created_at"`
}

type ListConversationsAllParams added in v0.35.3

type ListConversationsAllParams struct {
	UserID  pgtype.Text `json:"user_id"`
	AgentID pgtype.Text `json:"agent_id"`
}

type ListConversationsByKindParams added in v0.34.0

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

type ListConversationsFilteredParams added in v0.46.0

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

type ListConversationsForReviewFilteredParams added in v0.46.0

type ListConversationsForReviewFilteredParams struct {
	AgentID         pgtype.Text `json:"agent_id"`
	Kind            pgtype.Text `json:"kind"`
	ProjectIDIsNull interface{} `json:"project_id_is_null"`
	ProjectID       pgtype.Text `json:"project_id"`
	Offset          int32       `json:"offset"`
	Limit           interface{} `json:"limit"`
}

type ListConversationsParams added in v0.35.3

type ListConversationsParams struct {
	UserID  pgtype.Text `json:"user_id"`
	AgentID pgtype.Text `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  int32  `json:"limit"`
	Offset int32  `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          pgtype.Timestamptz `json:"waived_at"`
	WaivedByUser      pgtype.Text        `json:"waived_by_user"`
	WaiverReason      string             `json:"waiver_reason"`
	CreatedAt         time.Time          `json:"created_at"`
	UpstreamLifecycle string             `json:"upstream_lifecycle"`
	UpstreamOutput    pgtype.Text        `json:"upstream_output"`
}

type ListExistingUserMessageContentParams added in v0.47.0

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

type ListExpiredRunningGroupDispatchParams added in v0.43.0

type ListExpiredRunningGroupDispatchParams struct {
	Now        pgtype.Timestamptz `json:"now"`
	LimitCount int32              `json:"limit_count"`
}

type ListExpiredRunningGroupOutboxParams added in v0.43.0

type ListExpiredRunningGroupOutboxParams struct {
	Now        pgtype.Timestamptz `json:"now"`
	LimitCount int32              `json:"limit_count"`
}

type ListFailedInboxSchedulerRunsParams added in v0.46.0

type ListFailedInboxSchedulerRunsParams struct {
	UserID     pgtype.Text        `json:"user_id"`
	Since      pgtype.Timestamptz `json:"since"`
	AgentID    pgtype.Text        `json:"agent_id"`
	LimitCount int32              `json:"limit_count"`
}

type ListFailedInboxSchedulerRunsRow added in v0.46.0

type ListFailedInboxSchedulerRunsRow struct {
	RunID      string             `json:"run_id"`
	JobID      string             `json:"job_id"`
	AgentID    pgtype.Text        `json:"agent_id"`
	Name       string             `json:"name"`
	Error      string             `json:"error"`
	FinishedAt pgtype.Timestamptz `json:"finished_at"`
	StartedAt  time.Time          `json:"started_at"`
}

type ListFeedEntriesParams added in v0.43.0

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

type ListFeedsParams added in v0.43.0

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

type ListGroupMessagesAfterSeqParams added in v0.42.0

type ListGroupMessagesAfterSeqParams struct {
	GroupID    string `json:"group_id"`
	MinSeq     int64  `json:"min_seq"`
	BatchLimit int32  `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 int32  `json:"offset_count"`
	LimitCount  int32  `json:"limit_count"`
}

type ListGroupsByUserParams added in v0.43.0

type ListGroupsByUserParams struct {
	UserID      pgtype.Text `json:"user_id"`
	OffsetCount int32       `json:"offset_count"`
	LimitCount  int32       `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        time.Time   `json:"created_at"`
	UpdatedAt        time.Time   `json:"updated_at"`
	GroupName        string      `json:"group_name"`
	CreatedByUserID  pgtype.Text `json:"created_by_user_id"`
	LastActive       time.Time   `json:"last_active"`
}

type ListGroupsWithPendingIngestRow added in v0.42.0

type 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    pgtype.Text `json:"agent_id"`
	Since      time.Time   `json:"since"`
	LimitCount int32       `json:"limit_count"`
}

type ListInboxGoalsRow added in v0.49.4

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

type ListMemoryChangelogParams

type ListMemoryChangelogParams struct {
	UserID  string `json:"user_id"`
	AgentID string `json:"agent_id"`
	Scope   string `json:"scope"`
	Limit   int32  `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          pgtype.Timestamptz `json:"after"`
	Before         pgtype.Timestamptz `json:"before"`
	Offset         int32              `json:"offset"`
	Limit          int32              `json:"limit"`
}

type ListMessagesByLogicalPageRow added in v0.41.0

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

type ListMessagesNeedingEmbeddingParams added in v0.50.3

type ListMessagesNeedingEmbeddingParams struct {
	Model string `json:"model"`
	Limit int32  `json:"limit"`
}

type ListMessagesNeedingEmbeddingRow added in v0.50.3

type ListMessagesNeedingEmbeddingRow struct {
	ID            string      `json:"id"`
	Content       string      `json:"content"`
	EmbeddedModel pgtype.Text `json:"embedded_model"`
	EmbeddedHash  []byte      `json:"embedded_hash"`
}

type ListPendingEntriesParams added in v0.43.0

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

type ListPendingGroupDispatchByMessageParams added in v0.43.0

type ListPendingGroupDispatchByMessageParams struct {
	GroupMessageID string             `json:"group_message_id"`
	Now            pgtype.Timestamptz `json:"now"`
}

type ListPendingGroupDispatchParams added in v0.43.0

type ListPendingGroupDispatchParams struct {
	Now        pgtype.Timestamptz `json:"now"`
	LimitCount int32              `json:"limit_count"`
}

type ListPendingGroupOutboxParams added in v0.43.0

type ListPendingGroupOutboxParams struct {
	Now        pgtype.Timestamptz `json:"now"`
	LimitCount int32              `json:"limit_count"`
}

type ListProjectsAllParams added in v0.34.0

type 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  int32  `json:"max_count"`
}

type ListRecentGroupMessagesParams added in v0.42.0

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

type ListRootGoalParams added in v0.49.4

type ListRootGoalParams struct {
	UserID          string      `json:"user_id"`
	AgentID         pgtype.Text `json:"agent_id"`
	ProjectID       pgtype.Text `json:"project_id"`
	Lifecycle       pgtype.Text `json:"lifecycle"`
	Terminal        pgtype.Bool `json:"terminal"`
	Q               pgtype.Text `json:"q"`
	IncludeArchived bool        `json:"include_archived"`
	Offset          int32       `json:"offset"`
	Limit           int32       `json:"limit"`
}

type ListSchedJobRunsParams

type ListSchedJobRunsParams struct {
	JobID  string      `json:"job_id"`
	UserID pgtype.Text `json:"user_id"`
	Offset int32       `json:"offset"`
	Limit  int32       `json:"limit"`
}

type ListSchedulerJobsByAgentParams added in v0.36.0

type ListSchedulerJobsByAgentParams struct {
	AgentID pgtype.Text `json:"agent_id"`
	UserID  pgtype.Text `json:"user_id"`
}

type ListSharesByUserParams added in v0.38.0

type ListSharesByUserParams struct {
	UserID string `json:"user_id"`
	Limit  int32  `json:"limit"`
	Offset int32  `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 pgtype.Timestamptz `json:"expires_at"`
	CreatedAt time.Time          `json:"created_at"`
	UpdatedAt time.Time          `json:"updated_at"`
}

type ListSkillsByScopeParams added in v0.48.0

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

type ListSkillsForAgentContextParams added in v0.36.0

type ListSkillsForAgentContextParams struct {
	AgentID pgtype.Text `json:"agent_id"`
	UserID  pgtype.Text `json:"user_id"`
}

type ListSkillsForUserParams added in v0.36.0

type ListSkillsForUserParams struct {
	AgentIdsCsv pgtype.Text `json:"agent_ids_csv"`
	UserID      pgtype.Text `json:"user_id"`
}

type ListSkillsVisibleParams

type ListSkillsVisibleParams struct {
	AgentID pgtype.Text `json:"agent_id"`
	UserID  pgtype.Text `json:"user_id"`
}

type ListStaleAttemptsParams added in v0.49.4

type ListStaleAttemptsParams struct {
	Now   pgtype.Timestamptz `json:"now"`
	Limit int32              `json:"limit"`
}

type ListSummariesByIDsParams added in v0.41.0

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

type ListSummariesNeedingEmbeddingParams added in v0.50.3

type ListSummariesNeedingEmbeddingParams struct {
	Model string `json:"model"`
	Limit int32  `json:"limit"`
}

type ListSummariesNeedingEmbeddingRow added in v0.50.3

type ListSummariesNeedingEmbeddingRow struct {
	ID            string      `json:"id"`
	Content       string      `json:"content"`
	EmbeddedModel pgtype.Text `json:"embedded_model"`
	EmbeddedHash  []byte      `json:"embedded_hash"`
}

type ListUnreadArticlesOlderThanParams

type ListUnreadArticlesOlderThanParams struct {
	UserID string    `json:"user_id"`
	Cutoff time.Time `json:"cutoff"`
	Limit  int32     `json:"limit"`
}

type ListVaultEntriesByScopeParams added in v0.48.0

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

type ListVaultEntriesForRuntimeParams added in v0.48.0

type ListVaultEntriesForRuntimeParams struct {
	AgentID pgtype.Text `json:"agent_id"`
	UserID  pgtype.Text `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   bool            `json:"enabled"`
	Config    json.RawMessage `json:"config"`
	CreatedAt time.Time       `json:"created_at"`
	UpdatedAt time.Time       `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       time.Time `json:"created_at"`
	UpdatedAt       time.Time `json:"updated_at"`
}

type PluginOverride added in v0.38.0

type PluginOverride struct {
	PluginID           string      `json:"plugin_id"`
	Enabled            pgtype.Bool `json:"enabled"`
	SessionEnvVaultKey string      `json:"session_env_vault_key"`
	Config             string      `json:"config"`
	CreatedAt          time.Time   `json:"created_at"`
	UpdatedAt          time.Time   `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     json.RawMessage `json:"value"`
	CreatedAt time.Time       `json:"created_at"`
	UpdatedAt time.Time       `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 pgtype.Text `json:"description"`
	Archived    bool        `json:"archived"`
	CreatedAt   time.Time   `json:"created_at"`
	UpdatedAt   time.Time   `json:"updated_at"`
}

type PromoteAttemptParams added in v0.49.4

type PromoteAttemptParams struct {
	LeaseExpiresAt pgtype.Timestamptz `json:"lease_expires_at"`
	ID             string             `json:"id"`
}

type Provider added in v0.38.0

type Provider struct {
	ID        string          `json:"id"`
	Type      string          `json:"type"`
	Name      string          `json:"name"`
	Enabled   bool            `json:"enabled"`
	Config    json.RawMessage `json:"config"`
	CreatedAt time.Time       `json:"created_at"`
	UpdatedAt time.Time       `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) AddDigestArticle added in v0.30.0

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

func (*Queries) AddGroupMember added in v0.42.0

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

func (*Queries) AdvanceMemorySnapshot

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

func (*Queries) AppendAcceptanceEvent added in v0.49.4

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

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

func (*Queries) AppendContextItem

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

func (*Queries) ArchiveGoal added in v0.49.4

func (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) 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 pgtype.Text) 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, cutoff 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) (pgtype.Text, 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) ([]pgtype.Text, 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) (time.Time, 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 pgtype.Text) (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) 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) 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) GetPlugin

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

func (*Queries) GetPluginStateEntry

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

func (*Queries) GetProject added in v0.34.0

func (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) 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 pgtype.Text) ([]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 pgtype.Text) ([]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) ListArticlesNeedingEmbedding added in v0.50.3

func (q *Queries) ListArticlesNeedingEmbedding(ctx context.Context, arg ListArticlesNeedingEmbeddingParams) ([]ListArticlesNeedingEmbeddingRow, error)

Backfill candidates for articles. Unlike messages, articles are mutable, so a row whose embedding predates the article's last update (e.updated_at < a.updated_at) is a candidate too; the writer then compares content_hash to skip non-content edits (e.g. marking read). content is title + summary, the fields worth embedding. Keep ASCII.

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) ListBlockedDepComposites added in v0.50.0

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

Composites parked blocked(dep) by the rollup because a required child was blocked. The rollup scans (ListRollupCandidates/ListStalledComposites) only see active composites, so a parent driven here never re-enters rollup on its own. The dispatcher re-evaluates each: once its blocking children clear, it is woken back to active so the rollup resumes (see RecoverBlockedComposite).

func (*Queries) ListChannels

func (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 pgtype.Text) ([]CtxConversation, error)

func (*Queries) ListConversationsForReviewFiltered added in v0.46.0

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

func (*Queries) ListDecomposableComposites added in v0.50.0

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

Composites awaiting autonomous decomposition: freshly created (draft) and not planned yet. Both review policies are auto-driven: the planner always produces the plan; review_policy='human' only adds an approval gate after the plan is proposed (the goal parks blocked(needs_plan_approval)), it does not stop the planner from running. The dispatcher mints + enqueues a decomposition attempt for each, moving it draft->active so it is not re-picked.

func (*Queries) ListDigestArticles added in v0.30.0

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

func (*Queries) ListDigests added in v0.30.0

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

func (*Queries) ListDispatchableLeaves added in v0.49.4

func (q *Queries) ListDispatchableLeaves(ctx context.Context, limit int32) ([]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 pgtype.Text) ([]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) ListMessagesNeedingEmbedding added in v0.50.3

func (q *Queries) ListMessagesNeedingEmbedding(ctx context.Context, arg ListMessagesNeedingEmbeddingParams) ([]ListMessagesNeedingEmbeddingRow, error)

Backfill candidates: messages with no embedding, or one produced by a different model (a model switch invalidates the old vector space). Messages are immutable, so a row whose model already matches is never stale and is not returned. embedded_model/embedded_hash carry existing provenance so the writer can skip rows already current. Keep ASCII.

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) ListRollupCandidates added in v0.49.4

func (q *Queries) ListRollupCandidates(ctx context.Context, limit int32) ([]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: false = active (non-terminal) only, true = history (terminal) only, NULL = both. The terminal set is the four end states.

func (*Queries) ListSchedJobRuns

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

func (*Queries) ListSchedulerJobs

func (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 pgtype.Text) ([]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)

Lease-expired attempts whose lease is a liveness signal. An attempt heartbeated by a River worker (every execution attempt, and an autonomous decomposition attempt) carries a forward-moving lease, so an expired lease means a genuine orphan. Interactive decomposition attempts (planned in a session, never enqueued/heartbeated) carry a NULL lease and are skipped by the IS NOT NULL guard, so the reaper never bounces an active composite back to draft mid-planning.

func (*Queries) ListStalledComposites added in v0.49.4

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

func (*Queries) ListSummariesByIDs added in v0.41.0

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

func (*Queries) ListSummariesNeedingEmbedding added in v0.50.3

func (q *Queries) ListSummariesNeedingEmbedding(ctx context.Context, arg ListSummariesNeedingEmbeddingParams) ([]ListSummariesNeedingEmbeddingRow, error)

Backfill candidates for summaries; see ListMessagesNeedingEmbedding. Summary content is immutable, so missing or model-mismatch are the only cases. ASCII.

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 pgtype.Text) ([]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) LockConversationForWrite added in v0.50.0

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

Transaction-scoped advisory lock serializing per-conversation context writes: the message seq + context-item ordinal allocation in Append, and the compaction writeback that rewrites context items. Those are GetMax->++->insert under Read Committed, which PostgreSQL runs in parallel across writers (and nodes); the in-process striped mutex only serializes within one process. Held until the enclosing tx ends. The 'ctxconv:' prefix keeps unrelated entities out of this conversation's slot in the shared 64-bit lock space.

func (*Queries) LockGoalForWrite added in v0.50.0

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

Transaction-scoped advisory lock serializing read-modify-write sequence allocation for one goal. The acceptance ledger seq and attempt_no are each GetMax->+1->insert under Read Committed, which PostgreSQL runs in parallel across writers (and nodes): without this, two writers read the same max and compute the same next value, silently duplicating the acceptance seq (no unique backstop) or colliding on the attempt_no unique index. Held until the enclosing tx ends. The 'goal:' prefix keeps unrelated entities out of this goal's slot in the shared 64-bit lock space (matching AdvisoryXactLock / LockSchedJobForRun).

func (*Queries) LockSchedJobForRun added in v0.50.0

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

Transaction-scoped advisory lock keyed on a hash of the job ID. Held until the enclosing transaction ends, it serializes concurrent tryStartJobRun calls for the same job so the running-run check and insert below are atomic under Read Committed without a schema-level unique constraint. hashtextextended maps the text id straight to the 64-bit key pg_advisory_xact_lock expects (matching AdvisoryXactLock); a hash collision only serializes two unrelated jobs occasionally, which is harmless.

func (*Queries) MarkGoalPlanned added in v0.50.0

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

The materialize fence (CAS): stamp planned_at exactly once. A second concurrent materialize gets 0 rows and must treat it as an idempotent no-op, so children are never double-created. Replaces the old materialized revision unique index.

func (*Queries) MarkGroupDispatchCompleted added in v0.43.0

func (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) ProbeCheckCache added in v0.49.4

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

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

func (*Queries) PromoteAttempt added in v0.49.4

func (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) SearchArticleEmbeddings added in v0.50.3

func (q *Queries) SearchArticleEmbeddings(ctx context.Context, arg SearchArticleEmbeddingsParams) ([]SearchArticleEmbeddingsRow, error)

Vector KNN over article embeddings, scoped to user_id (articles carry user_id directly, no conversation join). WHERE model pins the vector space; ORDER BY the <=> operator drives the HNSW cosine index. score is cosine similarity (1 - distance), higher is better. saved_at, id break ties. Keep ASCII.

func (*Queries) SearchArticles

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

Multi-field BM25 search over title/summary/tags/author via pg_search. Each field is matched with paradedb.match, which tokenizes the raw user text with the jieba tokenizer (dictionary + statistical CJK word segmentation, CJK matches natively with no fallback tier) and never errors on punctuation. Per-field relevance is weighted natively with paradedb.boost (title 3x, tags 2x, summary/author 1x): boost scales each field's BM25 contribution to the row score, so a title hit outranks a tags hit outranks a body/author hit, with no CASE multiplier on the whole row. snippet highlights the title. match is raw user text. saved_at, id break score ties deterministically so identical queries return a stable order.

func (*Queries) SearchMessageEmbeddings added in v0.50.3

func (q *Queries) SearchMessageEmbeddings(ctx context.Context, arg SearchMessageEmbeddingsParams) ([]SearchMessageEmbeddingsRow, error)

Vector KNN over message embeddings, scoped to (user_id, agent_id) across every session like SearchMessages. WHERE model pins the query to a single vector space so a vector produced by a different model never matches; ORDER BY the <=> operator lets the HNSW cosine index drive the scan. score is cosine similarity (1 - distance), higher is better, matching the BM25 lane's score orientation for fusion. created_at, id break ties deterministically.

func (*Queries) SearchMessages

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

Spans every conversation of the current (user_id, agent_id) so memory recall survives across sessions. Joins ctx_conversation to pin the scope and surface provenance (session_id, title). Global ORDER BY score + LIMIT keeps the best matches across the merged corpus, not per-conversation truncations. Lexical ranking is pg_search BM25; paradedb.match tokenizes the raw user text with the jieba tokenizer (dictionary + statistical CJK word segmentation, so CJK matches natively with no fallback tier) and never errors on punctuation or query-syntax characters. The match arg is the raw user text. Multi-term queries are OR'd and ranked by BM25, which sinks weak partial matches below strong full matches. created_at, id break score ties deterministically: cross-source RRF uses each row's rank, so a stable order keeps the same query from reshuffling the merge.

func (*Queries) SearchSummaries

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

Spans every conversation of the current (user_id, agent_id); see SearchMessages. Lexical ranking is pg_search BM25; paradedb.match tokenizes the raw user text with the jieba tokenizer (dictionary + statistical CJK word segmentation, CJK matches natively) and never errors on punctuation. The match arg is the raw user text. Stable score tie-break (see SearchMessages): content time, then id, so the per-source rank that cross-source RRF consumes is deterministic.

func (*Queries) SearchSummaryEmbeddings added in v0.50.3

func (q *Queries) SearchSummaryEmbeddings(ctx context.Context, arg SearchSummaryEmbeddingsParams) ([]SearchSummaryEmbeddingsRow, error)

Vector KNN over summary embeddings; mirror of SearchMessageEmbeddings (same space + scope guards, cosine similarity score). Tie-break by content time then id. Keep ASCII.

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) SetGoalPlan added in v0.50.0

func (q *Queries) SetGoalPlan(ctx context.Context, arg SetGoalPlanParams) error

Write a composite's decomposition plan (children + edges). Set by a decomposition attempt before materialize; for review_policy='human' the plan sits here while the goal is blocked(needs_plan_approval) until a human acts.

func (*Queries) SetGoalRequiredTotal added in v0.49.4

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

func (*Queries) SetGroupDispatchResultMessage added in v0.47.0

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

func (*Queries) SubmitAttempt added in v0.49.4

func (q *Queries) SubmitAttempt(ctx context.Context, arg SubmitAttemptParams) (int64, 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) 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) UpsertArticleEmbedding added in v0.50.3

func (q *Queries) UpsertArticleEmbedding(ctx context.Context, arg UpsertArticleEmbeddingParams) error

Semantic-search vector for one article; see UpsertMessageEmbedding. Keep ASCII.

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) UpsertMessageEmbedding added in v0.50.3

func (q *Queries) UpsertMessageEmbedding(ctx context.Context, arg UpsertMessageEmbeddingParams) error

Write or replace the semantic-search vector for one message. model is the vector-space key every KNN query must filter on; content_hash is the hash of the embedded text so a later pass can spot rows whose source content changed. Keep this comment ASCII (sqlc rewriter offsets).

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) UpsertSummaryEmbedding added in v0.50.3

func (q *Queries) UpsertSummaryEmbedding(ctx context.Context, arg UpsertSummaryEmbeddingParams) error

Semantic-search vector for one summary; see UpsertMessageEmbedding. Keep ASCII.

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 pgx.Tx) *Queries

type RecallyArticle added in v0.38.0

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

type RecallyArticleEmbedding added in v0.50.0

type RecallyArticleEmbedding struct {
	ArticleID   string             `json:"article_id"`
	Model       string             `json:"model"`
	ContentHash []byte             `json:"content_hash"`
	Embedding   pgvector_go.Vector `json:"embedding"`
	CreatedAt   time.Time          `json:"created_at"`
	UpdatedAt   time.Time          `json:"updated_at"`
}

type RecallyDigest added in v0.30.0

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

type RecallyDigestArticle added in v0.30.0

type 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       pgtype.Text        `json:"agent_id"`
	Url           string             `json:"url"`
	Kind          string             `json:"kind"`
	Metadata      json.RawMessage    `json:"metadata"`
	Title         string             `json:"title"`
	Description   string             `json:"description"`
	CheckInterval string             `json:"check_interval"`
	LastCheckedAt pgtype.Timestamptz `json:"last_checked_at"`
	LastEtag      string             `json:"last_etag"`
	LastModified  string             `json:"last_modified"`
	Enabled       bool               `json:"enabled"`
	CreatedAt     time.Time          `json:"created_at"`
	UpdatedAt     time.Time          `json:"updated_at"`
}

type RecallyFeedEntry added in v0.43.0

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

type RecordSchedulerJobRunParams

type RecordSchedulerJobRunParams struct {
	LastRunAt pgtype.Timestamptz `json:"last_run_at"`
	LastError string             `json:"last_error"`
	UpdatedAt time.Time          `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 pgtype.Timestamptz `json:"next_attempt_at"`
	LastError     string             `json:"last_error"`
	ID            string             `json:"id"`
	AttemptCount  int64              `json:"attempt_count"`
}

type RequeueGroupOutboxParams added in v0.43.0

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

type ResolveSkillParams

type ResolveSkillParams struct {
	Name    string      `json:"name"`
	AgentID pgtype.Text `json:"agent_id"`
	UserID  pgtype.Text `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       json.RawMessage    `json:"payload"`
	SessionMode   string             `json:"session_mode"`
	Enabled       bool               `json:"enabled"`
	AgentID       pgtype.Text        `json:"agent_id"`
	UserID        pgtype.Text        `json:"user_id"`
	CreatedAt     time.Time          `json:"created_at"`
	UpdatedAt     time.Time          `json:"updated_at"`
	LastRunAt     pgtype.Timestamptz `json:"last_run_at"`
	LastError     string             `json:"last_error"`
}

type SchedJobRun

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

type SearchArticleEmbeddingsParams added in v0.50.3

type SearchArticleEmbeddingsParams struct {
	Query  pgvector_go.Vector `json:"query"`
	Model  string             `json:"model"`
	UserID string             `json:"user_id"`
	Limit  int32              `json:"limit"`
}

type SearchArticleEmbeddingsRow added in v0.50.3

type SearchArticleEmbeddingsRow struct {
	RecallyArticle RecallyArticle `json:"recally_article"`
	Score          float64        `json:"score"`
}

type SearchArticlesParams

type SearchArticlesParams struct {
	Match  string `json:"match"`
	UserID string `json:"user_id"`
	Limit  int32  `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 SearchMessageEmbeddingsParams added in v0.50.3

type SearchMessageEmbeddingsParams struct {
	Query   pgvector_go.Vector `json:"query"`
	Model   string             `json:"model"`
	UserID  pgtype.Text        `json:"user_id"`
	AgentID pgtype.Text        `json:"agent_id"`
	Limit   int32              `json:"limit"`
}

type SearchMessageEmbeddingsRow added in v0.50.3

type SearchMessageEmbeddingsRow struct {
	ID                string      `json:"id"`
	ConversationID    string      `json:"conversation_id"`
	Seq               int64       `json:"seq"`
	Role              string      `json:"role"`
	EventType         string      `json:"event_type"`
	Content           string      `json:"content"`
	TokenCount        int64       `json:"token_count"`
	CreatedAt         time.Time   `json:"created_at"`
	SessionID         string      `json:"session_id"`
	ConversationTitle pgtype.Text `json:"conversation_title"`
	Score             float64     `json:"score"`
}

type SearchMessagesParams

type SearchMessagesParams struct {
	Match   string      `json:"match"`
	UserID  pgtype.Text `json:"user_id"`
	AgentID pgtype.Text `json:"agent_id"`
	Limit   int32       `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         time.Time   `json:"created_at"`
	SessionID         string      `json:"session_id"`
	ConversationTitle pgtype.Text `json:"conversation_title"`
	Snippet           string      `json:"snippet"`
	Score             float64     `json:"score"`
}

type SearchSummariesParams

type SearchSummariesParams struct {
	Match   string      `json:"match"`
	UserID  pgtype.Text `json:"user_id"`
	AgentID pgtype.Text `json:"agent_id"`
	Limit   int32       `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              pgtype.Timestamptz `json:"earliest_at"`
	LatestAt                pgtype.Timestamptz `json:"latest_at"`
	DescendantCount         int64              `json:"descendant_count"`
	DescendantTokenCount    int64              `json:"descendant_token_count"`
	SourceMessageTokenCount int64              `json:"source_message_token_count"`
	CreatedAt               time.Time          `json:"created_at"`
	SessionID               string             `json:"session_id"`
	ConversationTitle       pgtype.Text        `json:"conversation_title"`
	Snippet                 string             `json:"snippet"`
	Score                   float64            `json:"score"`
}

type SearchSummaryEmbeddingsParams added in v0.50.3

type SearchSummaryEmbeddingsParams struct {
	Query   pgvector_go.Vector `json:"query"`
	Model   string             `json:"model"`
	UserID  pgtype.Text        `json:"user_id"`
	AgentID pgtype.Text        `json:"agent_id"`
	Limit   int32              `json:"limit"`
}

type SearchSummaryEmbeddingsRow added in v0.50.3

type SearchSummaryEmbeddingsRow struct {
	ID                      string             `json:"id"`
	ConversationID          string             `json:"conversation_id"`
	Kind                    string             `json:"kind"`
	Depth                   int64              `json:"depth"`
	Content                 string             `json:"content"`
	TokenCount              int64              `json:"token_count"`
	EarliestAt              pgtype.Timestamptz `json:"earliest_at"`
	LatestAt                pgtype.Timestamptz `json:"latest_at"`
	DescendantCount         int64              `json:"descendant_count"`
	DescendantTokenCount    int64              `json:"descendant_token_count"`
	SourceMessageTokenCount int64              `json:"source_message_token_count"`
	CreatedAt               time.Time          `json:"created_at"`
	SessionID               string             `json:"session_id"`
	ConversationTitle       pgtype.Text        `json:"conversation_title"`
	Score                   float64            `json:"score"`
}

type SeedProviderParams

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

type SetAttemptExecutorParams added in v0.49.4

type SetAttemptExecutorParams struct {
	ExecutorAgentID pgtype.Text `json:"executor_agent_id"`
	ID              string      `json:"id"`
}

type SetAttemptGapsParams added in v0.49.4

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

type SetGoalAcceptanceStateParams added in v0.49.4

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

type SetGoalPlanParams added in v0.50.0

type SetGoalPlanParams struct {
	Plan json.RawMessage `json:"plan"`
	ID   string          `json:"id"`
}

type SetGoalRequiredTotalParams added in v0.49.4

type 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 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 pgtype.Timestamptz `json:"expires_at"`
	CreatedAt time.Time          `json:"created_at"`
	UpdatedAt time.Time          `json:"updated_at"`
}

type Skill

type Skill struct {
	ID                     string          `json:"id"`
	Scope                  string          `json:"scope"`
	UserID                 pgtype.Text     `json:"user_id"`
	AgentID                pgtype.Text     `json:"agent_id"`
	Name                   string          `json:"name"`
	Description            string          `json:"description"`
	Status                 string          `json:"status"`
	DisableModelInvocation bool            `json:"disable_model_invocation"`
	Metadata               json.RawMessage `json:"metadata"`
	CreatedAt              time.Time       `json:"created_at"`
	UpdatedAt              time.Time       `json:"updated_at"`
}

type 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 json.RawMessage `json:"evidence"`
	Output   json.RawMessage `json:"output"`
	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              json.RawMessage `json:"sandbox"`
	EnabledBuiltinSkills json.RawMessage `json:"enabled_builtin_skills"`
	Scope                string          `json:"scope"`
	Enabled              bool            `json:"enabled"`
	ID                   string          `json:"id"`
}

type UpdateArticleParams

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

type UpdateAuthPolicyParams

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

type UpdateConversationArchivedParams

type UpdateConversationArchivedParams struct {
	Archived  bool        `json:"archived"`
	SessionID string      `json:"session_id"`
	UserID    pgtype.Text `json:"user_id"`
	AgentID   pgtype.Text `json:"agent_id"`
}

type UpdateConversationBootstrappedParams added in v0.35.3

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

type UpdateConversationInfoBySessionIDParams added in v0.46.0

type UpdateConversationInfoBySessionIDParams struct {
	Title     pgtype.Text `json:"title"`
	Archived  bool        `json:"archived"`
	Kind      pgtype.Text `json:"kind"`
	ProjectID pgtype.Text `json:"project_id"`
	SessionID string      `json:"session_id"`
	UserID    pgtype.Text `json:"user_id"`
	AgentID   pgtype.Text `json:"agent_id"`
}

type UpdateConversationKindProjectParams added in v0.34.0

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

type UpdateConversationLastActiveParams added in v0.35.3

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

type UpdateConversationTitleBySessionIDParams

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

type UpdateConversationTitleParams

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

type UpdateFeedEntryParams added in v0.43.0

type UpdateFeedEntryParams struct {
	Status    string      `json:"status"`
	ArticleID pgtype.Text `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      json.RawMessage    `json:"metadata"`
	CheckInterval string             `json:"check_interval"`
	LastCheckedAt pgtype.Timestamptz `json:"last_checked_at"`
	LastEtag      string             `json:"last_etag"`
	LastModified  string             `json:"last_modified"`
	Enabled       bool               `json:"enabled"`
	ID            string             `json:"id"`
	UserID        string             `json:"user_id"`
}

type UpdateGoalIntentParams added in v0.49.4

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

type UpdateGroupNameParams added in v0.43.0

type 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 pgtype.Text `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 bool            `json:"enabled"`
	Config  json.RawMessage `json:"config"`
	ID      string          `json:"id"`
}

type UpdateSchedJobRunParams

type UpdateSchedJobRunParams struct {
	Status     string             `json:"status"`
	FinishedAt pgtype.Timestamptz `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       json.RawMessage    `json:"payload"`
	SessionMode   string             `json:"session_mode"`
	Enabled       bool               `json:"enabled"`
	AgentID       pgtype.Text        `json:"agent_id"`
	UserID        pgtype.Text        `json:"user_id"`
	UpdatedAt     time.Time          `json:"updated_at"`
	LastRunAt     pgtype.Timestamptz `json:"last_run_at"`
	LastError     string             `json:"last_error"`
	ID            string             `json:"id"`
}

type UpdateSkillMetadataParams

type UpdateSkillMetadataParams struct {
	Description            string          `json:"description"`
	Status                 string          `json:"status"`
	DisableModelInvocation bool            `json:"disable_model_invocation"`
	Metadata               json.RawMessage `json:"metadata"`
	ID                     string          `json:"id"`
	AgentID                pgtype.Text     `json:"agent_id"`
	UserID                 pgtype.Text     `json:"user_id"`
}

type UpdateSystemSkillMetadataParams added in v0.35.3

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

type UpdateUserActiveParams added in v0.38.0

type UpdateUserActiveParams struct {
	IsActive bool   `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 json.RawMessage `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 UpsertArticleEmbeddingParams added in v0.50.3

type UpsertArticleEmbeddingParams struct {
	ArticleID   string             `json:"article_id"`
	Model       string             `json:"model"`
	ContentHash []byte             `json:"content_hash"`
	Embedding   pgvector_go.Vector `json:"embedding"`
}

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 pgtype.Text `json:"agent_id"`
	Enabled bool        `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              json.RawMessage `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            pgtype.Bool `json:"enabled"`
	SessionEnvVaultKey string      `json:"session_env_vault_key"`
	Config             string      `json:"config"`
}

type UpsertMessageEmbeddingParams added in v0.50.3

type UpsertMessageEmbeddingParams struct {
	MessageID   string             `json:"message_id"`
	Model       string             `json:"model"`
	ContentHash []byte             `json:"content_hash"`
	Embedding   pgvector_go.Vector `json:"embedding"`
}

type UpsertPluginParams

type UpsertPluginParams struct {
	ID      string          `json:"id"`
	Kind    string          `json:"kind"`
	Name    string          `json:"name"`
	Enabled bool            `json:"enabled"`
	Config  json.RawMessage `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     json.RawMessage `json:"value"`
}

type UpsertProfileEntriesParams added in v0.42.0

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

type UpsertSettingParams

type 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 UpsertSummaryEmbeddingParams added in v0.50.3

type UpsertSummaryEmbeddingParams struct {
	SummaryID   string             `json:"summary_id"`
	Model       string             `json:"model"`
	ContentHash []byte             `json:"content_hash"`
	Embedding   pgvector_go.Vector `json:"embedding"`
}

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     pgtype.Text `json:"user_id"`
	AgentID    pgtype.Text `json:"agent_id"`
	Name       string      `json:"name"`
	Ciphertext string      `json:"ciphertext"`
}

type UpsertVaultEntryParams

type UpsertVaultEntryParams struct {
	ID         string      `json:"id"`
	UserID     pgtype.Text `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     pgtype.Text `json:"user_id"`
	AgentID    pgtype.Text `json:"agent_id"`
	Name       string      `json:"name"`
	Ciphertext string      `json:"ciphertext"`
	CreatedAt  time.Time   `json:"created_at"`
	UpdatedAt  time.Time   `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 pgtype.Text `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