sqlc

package
v0.45.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddDigestArticleParams added in v0.30.0 

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

type AddGroupMemberParams added in v0.42.0 

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

type AdvanceMemorySnapshotParams 

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

type Agent added in v0.38.0 

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

type AgentGoal added in v0.38.0 

type AgentGoal struct {
	ID             string         `json:"id"`
	UserID         string         `json:"user_id"`
	AgentID        string         `json:"agent_id"`
	ProjectID      sql.NullString `json:"project_id"`
	Title          string         `json:"title"`
	Description    string         `json:"description"`
	Status         string         `json:"status"`
	Priority       string         `json:"priority"`
	ReviewPolicy   string         `json:"review_policy"`
	ActiveReviewID sql.NullString `json:"active_review_id"`
	Context        string         `json:"context"`
	Output         string         `json:"output"`
	CreatedAt      string         `json:"created_at"`
	UpdatedAt      string         `json:"updated_at"`
	CompletedAt    sql.NullString `json:"completed_at"`
	CancelledAt    sql.NullString `json:"cancelled_at"`
}

type AgentReview added in v0.38.0 

type AgentReview struct {
	ID                    string         `json:"id"`
	TaskID                sql.NullString `json:"task_id"`
	GoalID                sql.NullString `json:"goal_id"`
	SubmittedRunID        sql.NullString `json:"submitted_run_id"`
	ReviewerRunID         sql.NullString `json:"reviewer_run_id"`
	ReviewerType          string         `json:"reviewer_type"`
	ReviewerUserID        sql.NullString `json:"reviewer_user_id"`
	EscalatedFromReviewID sql.NullString `json:"escalated_from_review_id"`
	Status                string         `json:"status"`
	Summary               string         `json:"summary"`
	Feedback              string         `json:"feedback"`
	CreatedAt             string         `json:"created_at"`
	UpdatedAt             string         `json:"updated_at"`
	ResolvedAt            sql.NullString `json:"resolved_at"`
}

type AgentReviewItem added in v0.38.0 

type AgentReviewItem struct {
	ID          string         `json:"id"`
	ReviewID    string         `json:"review_id"`
	CriterionID sql.NullString `json:"criterion_id"`
	Passed      sql.NullInt64  `json:"passed"`
	Evidence    string         `json:"evidence"`
	CreatedAt   string         `json:"created_at"`
}

type AgentTask added in v0.30.0 

type AgentTask struct {
	ID              string         `json:"id"`
	UserID          string         `json:"user_id"`
	AgentID         string         `json:"agent_id"`
	SessionID       string         `json:"session_id"`
	GoalID          sql.NullString `json:"goal_id"`
	ProjectID       sql.NullString `json:"project_id"`
	Title           string         `json:"title"`
	Description     string         `json:"description"`
	Status          string         `json:"status"`
	Priority        string         `json:"priority"`
	ReviewPolicy    string         `json:"review_policy"`
	ActiveReviewID  sql.NullString `json:"active_review_id"`
	Required        int64          `json:"required"`
	RetryCount      int64          `json:"retry_count"`
	MaxRetries      int64          `json:"max_retries"`
	NotBefore       sql.NullString `json:"not_before"`
	DeadlineAt      sql.NullString `json:"deadline_at"`
	ActiveRunID     sql.NullString `json:"active_run_id"`
	ActiveBlockerID sql.NullString `json:"active_blocker_id"`
	Context         string         `json:"context"`
	Output          string         `json:"output"`
	CreatedAt       string         `json:"created_at"`
	UpdatedAt       string         `json:"updated_at"`
	CompletedAt     sql.NullString `json:"completed_at"`
	CancelledAt     sql.NullString `json:"cancelled_at"`
}

type AgentTaskBlocker added in v0.38.0 

type AgentTaskBlocker struct {
	ID             string         `json:"id"`
	TaskID         string         `json:"task_id"`
	Kind           string         `json:"kind"`
	Status         string         `json:"status"`
	Question       string         `json:"question"`
	Detail         string         `json:"detail"`
	Resolution     string         `json:"resolution"`
	CreatedByRunID sql.NullString `json:"created_by_run_id"`
	CreatedAt      string         `json:"created_at"`
	ResolvedAt     sql.NullString `json:"resolved_at"`
}

type AgentTaskCriterion added in v0.38.0 

type AgentTaskCriterion struct {
	ID           string `json:"id"`
	TaskID       string `json:"task_id"`
	Description  string `json:"description"`
	RequiredFlag int64  `json:"required_flag"`
	Position     int64  `json:"position"`
	CreatedAt    string `json:"created_at"`
}

type AgentTaskDep added in v0.38.0 

type AgentTaskDep struct {
	TaskID       string         `json:"task_id"`
	DepTaskID    string         `json:"dep_task_id"`
	DepKind      string         `json:"dep_kind"`
	OnFailure    string         `json:"on_failure"`
	WaivedAt     sql.NullString `json:"waived_at"`
	WaivedByUser sql.NullString `json:"waived_by_user"`
	WaiverReason string         `json:"waiver_reason"`
	CreatedAt    string         `json:"created_at"`
}

type AgentTaskDispatchHint added in v0.38.0 

type AgentTaskDispatchHint struct {
	ID              string         `json:"id"`
	TaskID          sql.NullString `json:"task_id"`
	GoalID          sql.NullString `json:"goal_id"`
	Kind            string         `json:"kind"`
	ExecutorAgentID string         `json:"executor_agent_id"`
	ConsumedAt      sql.NullString `json:"consumed_at"`
	CreatedAt       string         `json:"created_at"`
}

type AgentTaskEvent added in v0.30.0 

type AgentTaskEvent struct {
	ID         string         `json:"id"`
	TaskID     sql.NullString `json:"task_id"`
	GoalID     sql.NullString `json:"goal_id"`
	RunID      sql.NullString `json:"run_id"`
	BlockerID  sql.NullString `json:"blocker_id"`
	ReviewID   sql.NullString `json:"review_id"`
	EventType  string         `json:"event_type"`
	FromStatus sql.NullString `json:"from_status"`
	ToStatus   sql.NullString `json:"to_status"`
	ActorType  string         `json:"actor_type"`
	ActorID    sql.NullString `json:"actor_id"`
	Detail     string         `json:"detail"`
	CreatedAt  string         `json:"created_at"`
}

type AgentTaskRun added in v0.38.0 

type AgentTaskRun struct {
	ID              string         `json:"id"`
	TaskID          sql.NullString `json:"task_id"`
	GoalID          sql.NullString `json:"goal_id"`
	UserID          string         `json:"user_id"`
	AgentID         sql.NullString `json:"agent_id"`
	ExecutorAgentID sql.NullString `json:"executor_agent_id"`
	Kind            string         `json:"kind"`
	AttemptNo       int64          `json:"attempt_no"`
	Status          string         `json:"status"`
	SessionID       string         `json:"session_id"`
	Input           string         `json:"input"`
	Result          string         `json:"result"`
	Error           string         `json:"error"`
	HeartbeatAt     sql.NullString `json:"heartbeat_at"`
	LeaseExpiresAt  sql.NullString `json:"lease_expires_at"`
	WorkerID        string         `json:"worker_id"`
	StartedAt       sql.NullString `json:"started_at"`
	FinishedAt      sql.NullString `json:"finished_at"`
	CreatedAt       string         `json:"created_at"`
	UpdatedAt       string         `json:"updated_at"`
}

type AppSetting added in v0.38.0 

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

type AppendAgentTaskBlockerDetailParams added in v0.38.0 

type AppendAgentTaskBlockerDetailParams struct {
	Detail string `json:"detail"`
	ID     string `json:"id"`
}

type AppendContextItemParams 

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

type ArchiveProjectParams added in v0.34.0 

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

type AssignUserAgentParams 

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

type AuthCredential added in v0.38.0 

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

type AuthIdentity 

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

type AuthPolicy 

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

type AuthSession 

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

type AuthUser 

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

type AuthUserAgent 

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

type AuthUserToken 

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

type CancelAgentTaskBlockerParams added in v0.38.0 

type CancelAgentTaskBlockerParams struct {
	ResolvedAt sql.NullString `json:"resolved_at"`
	ID         string         `json:"id"`
}

type Channel added in v0.38.0 

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

type ChannelAgent added in v0.38.0 

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

type ChannelGroupMember added in v0.42.0 

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

type ChannelIdentity added in v0.38.0 

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

type ClaimAgentTaskParams added in v0.38.0 

type ClaimAgentTaskParams struct {
	ActiveRunID sql.NullString `json:"active_run_id"`
	UpdatedAt   string         `json:"updated_at"`
	ID          string         `json:"id"`
}

type ClaimExpiredGroupDispatchParams added in v0.43.0 

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

type ClaimExpiredGroupOutboxParams added in v0.43.0 

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

type ClaimPendingGroupDispatchParams added in v0.43.0 

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

type ClaimPendingGroupOutboxParams added in v0.43.0 

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

type ConsumeDispatchHintParams added in v0.38.0 

type ConsumeDispatchHintParams struct {
	ConsumedAt sql.NullString `json:"consumed_at"`
	ID         string         `json:"id"`
}

type CountArticlesByStatusParams 

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

type CreateAgentGoalParams added in v0.38.0 

type CreateAgentGoalParams struct {
	ID           string         `json:"id"`
	UserID       string         `json:"user_id"`
	AgentID      string         `json:"agent_id"`
	ProjectID    sql.NullString `json:"project_id"`
	Title        string         `json:"title"`
	Description  string         `json:"description"`
	Status       string         `json:"status"`
	Priority     string         `json:"priority"`
	ReviewPolicy string         `json:"review_policy"`
	Context      string         `json:"context"`
	Output       string         `json:"output"`
	CreatedAt    string         `json:"created_at"`
	UpdatedAt    string         `json:"updated_at"`
}

type CreateAgentParams 

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

type CreateAgentReviewParams added in v0.38.0 

type CreateAgentReviewParams struct {
	ID                    string         `json:"id"`
	TaskID                sql.NullString `json:"task_id"`
	GoalID                sql.NullString `json:"goal_id"`
	SubmittedRunID        sql.NullString `json:"submitted_run_id"`
	ReviewerRunID         sql.NullString `json:"reviewer_run_id"`
	ReviewerType          string         `json:"reviewer_type"`
	ReviewerUserID        sql.NullString `json:"reviewer_user_id"`
	EscalatedFromReviewID sql.NullString `json:"escalated_from_review_id"`
	Status                string         `json:"status"`
	Summary               string         `json:"summary"`
	Feedback              string         `json:"feedback"`
	CreatedAt             string         `json:"created_at"`
	UpdatedAt             string         `json:"updated_at"`
}

type CreateAgentTaskBlockerParams added in v0.38.0 

type CreateAgentTaskBlockerParams struct {
	ID             string         `json:"id"`
	TaskID         string         `json:"task_id"`
	Kind           string         `json:"kind"`
	Status         string         `json:"status"`
	Question       string         `json:"question"`
	Detail         string         `json:"detail"`
	CreatedByRunID sql.NullString `json:"created_by_run_id"`
	CreatedAt      string         `json:"created_at"`
}

type CreateAgentTaskCriterionParams added in v0.38.0 

type CreateAgentTaskCriterionParams struct {
	ID           string `json:"id"`
	TaskID       string `json:"task_id"`
	Description  string `json:"description"`
	RequiredFlag int64  `json:"required_flag"`
	Position     int64  `json:"position"`
	CreatedAt    string `json:"created_at"`
}

type CreateAgentTaskDepParams added in v0.38.0 

type CreateAgentTaskDepParams struct {
	TaskID    string `json:"task_id"`
	DepTaskID string `json:"dep_task_id"`
	DepKind   string `json:"dep_kind"`
	OnFailure string `json:"on_failure"`
	CreatedAt string `json:"created_at"`
}

type CreateAgentTaskDispatchHintParams added in v0.38.0 

type CreateAgentTaskDispatchHintParams struct {
	ID              string         `json:"id"`
	TaskID          sql.NullString `json:"task_id"`
	Kind            string         `json:"kind"`
	ExecutorAgentID string         `json:"executor_agent_id"`
	CreatedAt       string         `json:"created_at"`
}

type CreateAgentTaskParams added in v0.30.0 

type CreateAgentTaskParams struct {
	ID          string         `json:"id"`
	UserID      string         `json:"user_id"`
	AgentID     string         `json:"agent_id"`
	SessionID   string         `json:"session_id"`
	GoalID      sql.NullString `json:"goal_id"`
	ProjectID   sql.NullString `json:"project_id"`
	Title       string         `json:"title"`
	Description string         `json:"description"`
	Status      string         `json:"status"`
	Priority    string         `json:"priority"`
	Required    int64          `json:"required"`
	RetryCount  int64          `json:"retry_count"`
	MaxRetries  int64          `json:"max_retries"`
	NotBefore   sql.NullString `json:"not_before"`
	DeadlineAt  sql.NullString `json:"deadline_at"`
	Context     string         `json:"context"`
	Output      string         `json:"output"`
	CreatedAt   string         `json:"created_at"`
	UpdatedAt   string         `json:"updated_at"`
}

type CreateAgentTaskRunParams added in v0.38.0 

type CreateAgentTaskRunParams struct {
	ID              string         `json:"id"`
	TaskID          sql.NullString `json:"task_id"`
	GoalID          sql.NullString `json:"goal_id"`
	UserID          string         `json:"user_id"`
	AgentID         sql.NullString `json:"agent_id"`
	ExecutorAgentID sql.NullString `json:"executor_agent_id"`
	Kind            string         `json:"kind"`
	AttemptNo       int64          `json:"attempt_no"`
	Status          string         `json:"status"`
	SessionID       string         `json:"session_id"`
	Input           string         `json:"input"`
	LeaseExpiresAt  sql.NullString `json:"lease_expires_at"`
	WorkerID        string         `json:"worker_id"`
	StartedAt       sql.NullString `json:"started_at"`
	CreatedAt       string         `json:"created_at"`
	UpdatedAt       string         `json:"updated_at"`
}

type CreateArticleParams 

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

type CreateAuthPolicyParams 

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

type CreateAuthUserTokenParams 

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

type CreateConversationParams 

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

type CreateDigestParams added in v0.30.0 

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

type CreateFeedEntryParams added in v0.43.0 

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

type CreateFeedParams added in v0.43.0 

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

type CreateGroupDispatchParams added in v0.43.0 

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

type CreateGroupMessageParams added in v0.42.0 

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

type CreateGroupOutboxParams added in v0.43.0 

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

type CreateGroupStateParams added in v0.42.0 

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

type CreateIngestErrorParams added in v0.42.0 

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

type CreateMemorySnapshotParams 

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

type CreateMessageParams 

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

type CreateMessagePartParams 

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

type CreateProjectParams added in v0.34.0 

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

type CreateProviderParams 

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

type CreateSchedJobRunParams 

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

type CreateSchedulerJobParams 

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

type CreateShareParams added in v0.35.0 

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

type CreateSkillParams 

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

type CreateSummaryParams 

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

type CreateWebChannelIfNotExistsParams added in v0.43.0 

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

type CtxAgentMemory 

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

type CtxAgentMemoryChangelog added in v0.38.0 

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

type CtxAgentMemorySnapshot added in v0.38.0 

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

type CtxConversation 

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

type CtxGroupDispatch added in v0.43.0 

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

type CtxGroupIngestCursor added in v0.42.0 

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

type CtxGroupIngestError added in v0.42.0 

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

type CtxGroupMemory added in v0.42.0 

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

type CtxGroupMessage added in v0.42.0 

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

type CtxGroupOutbox added in v0.43.0 

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

type CtxGroupState added in v0.42.0 

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

type CtxItem 

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

type CtxMessage 

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

type CtxMessagePart 

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

type CtxSummary 

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

type CtxSummaryMessage 

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

type CtxSummaryParent 

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

type DBTX 

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

type DeleteAgentTaskDepParams added in v0.38.0 

type DeleteAgentTaskDepParams struct {
	TaskID    string `json:"task_id"`
	DepTaskID string `json:"dep_task_id"`
}

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 DeleteFeedParams added in v0.43.0 

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

type DeletePluginStateEntryParams 

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

type DeleteProjectParams added in v0.34.0 

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

type DeleteShareByUserParams added in v0.35.0 

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

type DeleteSkillFileParams 

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

type DeleteSkillParams added in v0.35.3 

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

type DeleteUserAgentMemoryParams 

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

type DeleteVaultEntryParams 

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

type ExpireKnowledgeDraftsByTypeParams 

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

type ExtendRunningGroupDispatchLeaseParams added in v0.43.0 

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

type ExtendRunningGroupOutboxLeaseParams added in v0.43.0 

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

type FinishAgentTaskRunParams added in v0.38.0 

type FinishAgentTaskRunParams struct {
	Status     string         `json:"status"`
	Result     string         `json:"result"`
	Error      string         `json:"error"`
	FinishedAt sql.NullString `json:"finished_at"`
	UpdatedAt  string         `json:"updated_at"`
	ID         string         `json:"id"`
}

type GetAgentSkillByNameParams 

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

type GetArticleByCanonicalURLParams 

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

type GetArticleParams added in v0.35.3 

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

type GetChatAgentParams 

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

type GetContextMessageItemsRow 

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

type GetConversationBySessionIDParams added in v0.35.3 

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

type GetConversationParams added in v0.35.3 

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

type GetDigestByDateParams added in v0.30.0 

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

type GetFeedByURLParams added in v0.43.0 

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

type GetFeedEntryParams added in v0.43.0 

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

type GetFeedParams added in v0.43.0 

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

type GetFreshTailMessageIDsParams 

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

type GetGroupMemberParams added in v0.42.0 

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

type GetGroupMessageByPlatformIDParams added in v0.42.0 

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

type GetGroupStateByTripleParams added in v0.42.0 

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

type GetIngestCursorParams added in v0.42.0 

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

type GetLiveDispatchHintForTaskParams added in v0.38.0 

type GetLiveDispatchHintForTaskParams struct {
	TaskID sql.NullString `json:"task_id"`
	Kind   string         `json:"kind"`
}

type GetMainConversationByProjectParams added in v0.35.3 

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

type GetMemoryChangelogAtVersionParams 

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

type GetMemorySnapshotParams 

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

type GetMessageParams added in v0.38.0 

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

type GetMessagesByConversationRangeParams 

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

type GetMessagesSinceParams 

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

type GetPluginStateEntryParams 

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

type GetProjectByNameParams added in v0.34.0 

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

type GetProjectParams added in v0.34.0 

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

type GetSchedJobRunParams added in v0.38.0 

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

type GetSkillFileParams 

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

type GetSkillParams added in v0.35.3 

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

type GetSummariesByDepthParams 

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

type GetSummaryParams added in v0.38.0 

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

type GetUserAgentMemoryParams 

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

type GetUserSkillByNameParams 

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

type GetVaultEntryParams 

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

type GoalChildCountsRow added in v0.38.0 

type GoalChildCountsRow struct {
	Total             int64           `json:"total"`
	RequiredDone      sql.NullFloat64 `json:"required_done"`
	RequiredFailed    sql.NullFloat64 `json:"required_failed"`
	RequiredCancelled sql.NullFloat64 `json:"required_cancelled"`
	RequiredBlocked   sql.NullFloat64 `json:"required_blocked"`
	RequiredPending   sql.NullFloat64 `json:"required_pending"`
}

type HeartbeatAgentTaskRunParams added in v0.38.0 

type HeartbeatAgentTaskRunParams struct {
	HeartbeatAt    sql.NullString `json:"heartbeat_at"`
	LeaseExpiresAt sql.NullString `json:"lease_expires_at"`
	UpdatedAt      string         `json:"updated_at"`
	ID             string         `json:"id"`
}

type IncrementAgentTaskRetryParams added in v0.38.0 

type IncrementAgentTaskRetryParams struct {
	UpdatedAt string `json:"updated_at"`
	ID        string `json:"id"`
}

type InsertAgentTaskEventParams added in v0.30.0 

type InsertAgentTaskEventParams struct {
	ID         string         `json:"id"`
	TaskID     sql.NullString `json:"task_id"`
	GoalID     sql.NullString `json:"goal_id"`
	RunID      sql.NullString `json:"run_id"`
	BlockerID  sql.NullString `json:"blocker_id"`
	ReviewID   sql.NullString `json:"review_id"`
	EventType  string         `json:"event_type"`
	FromStatus sql.NullString `json:"from_status"`
	ToStatus   sql.NullString `json:"to_status"`
	ActorType  string         `json:"actor_type"`
	ActorID    sql.NullString `json:"actor_id"`
	Detail     string         `json:"detail"`
	CreatedAt  string         `json:"created_at"`
}

type InsertMemoryChangelogParams 

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

type IsIngestErrorParams added in v0.42.0 

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

type LatestAgentTaskRunForGoalParams added in v0.38.0 

type LatestAgentTaskRunForGoalParams struct {
	GoalID sql.NullString `json:"goal_id"`
	Kind   string         `json:"kind"`
}

type LatestAgentTaskRunForTaskParams added in v0.38.0 

type LatestAgentTaskRunForTaskParams struct {
	TaskID sql.NullString `json:"task_id"`
	Kind   string         `json:"kind"`
}

type LinkSummaryToMessageParams 

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

type LinkSummaryToParentParams 

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

type ListActiveKnowledgeByTypeParams 

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

type ListAgentGoalsByUserAndAgentParams added in v0.41.3 

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

type ListAgentGoalsByUserParams added in v0.38.0 

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

type ListAgentGoalsParams added in v0.38.0 

type ListAgentGoalsParams struct {
	Limit  int64 `json:"limit"`
	Offset int64 `json:"offset"`
}

type ListAgentReviewsByGoalParams added in v0.38.0 

type ListAgentReviewsByGoalParams struct {
	GoalID sql.NullString `json:"goal_id"`
	Limit  int64          `json:"limit"`
	Offset int64          `json:"offset"`
}

type ListAgentReviewsByTaskParams added in v0.38.0 

type ListAgentReviewsByTaskParams struct {
	TaskID sql.NullString `json:"task_id"`
	Limit  int64          `json:"limit"`
	Offset int64          `json:"offset"`
}

type ListAgentTaskDepsWithUpstreamByTasksRow added in v0.41.0 

type ListAgentTaskDepsWithUpstreamByTasksRow struct {
	AgentTaskDep   AgentTaskDep `json:"agent_task_dep"`
	UpstreamStatus string       `json:"upstream_status"`
}

type ListAgentTaskDepsWithUpstreamPagedParams added in v0.38.0 

type ListAgentTaskDepsWithUpstreamPagedParams struct {
	TaskID string `json:"task_id"`
	Limit  int64  `json:"limit"`
	Offset int64  `json:"offset"`
}

type ListAgentTaskDepsWithUpstreamPagedRow added in v0.38.0 

type ListAgentTaskDepsWithUpstreamPagedRow struct {
	AgentTaskDep   AgentTaskDep `json:"agent_task_dep"`
	UpstreamStatus string       `json:"upstream_status"`
}

type ListAgentTaskDepsWithUpstreamRow added in v0.38.0 

type ListAgentTaskDepsWithUpstreamRow struct {
	AgentTaskDep   AgentTaskDep `json:"agent_task_dep"`
	UpstreamStatus string       `json:"upstream_status"`
}

type ListAgentTaskEventsParams added in v0.38.0 

type ListAgentTaskEventsParams struct {
	TaskID sql.NullString `json:"task_id"`
	Limit  int64          `json:"limit"`
	Offset int64          `json:"offset"`
}

type ListAgentTaskRunsByTaskParams added in v0.38.0 

type ListAgentTaskRunsByTaskParams struct {
	TaskID sql.NullString `json:"task_id"`
	Limit  int64          `json:"limit"`
	Offset int64          `json:"offset"`
}

type ListAgentTasksByUserParams added in v0.38.0 

type ListAgentTasksByUserParams struct {
	UserID    string      `json:"user_id"`
	AgentID   interface{} `json:"agent_id"`
	Status    interface{} `json:"status"`
	ProjectID interface{} `json:"project_id"`
	Offset    int64       `json:"offset"`
	Limit     int64       `json:"limit"`
}

type ListAgentTasksParams added in v0.38.0 

type ListAgentTasksParams struct {
	Limit  int64 `json:"limit"`
	Offset int64 `json:"offset"`
}

type ListArticlesParams 

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

type ListChildrenByGoalPagedParams added in v0.38.0 

type ListChildrenByGoalPagedParams struct {
	GoalID sql.NullString `json:"goal_id"`
	Limit  int64          `json:"limit"`
	Offset int64          `json:"offset"`
}

type ListConversationsAllParams added in v0.35.3 

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

type ListConversationsByKindParams added in v0.34.0 

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

type ListConversationsParams added in v0.35.3 

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

type ListDigestArticlesParams added in v0.30.0 

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

type ListDigestsParams added in v0.30.0 

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

type ListExpiredRunningGroupDispatchParams added in v0.43.0 

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

type ListExpiredRunningGroupOutboxParams added in v0.43.0 

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

type ListFeedEntriesParams added in v0.43.0 

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

type ListFeedsParams added in v0.43.0 

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

type ListGroupMessagesAfterSeqParams added in v0.42.0 

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

type ListGroupMessagesBetweenSeqsParams added in v0.42.0 

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

type ListGroupMessagesPaginatedParams added in v0.43.0 

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

type ListGroupsByUserParams added in v0.43.0 

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

type 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 ListMemoryChangelogParams 

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

type ListMessagesByIDsParams added in v0.41.0 

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

type ListMessagesByLogicalPageParams added in v0.41.0 

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

type ListMessagesByLogicalPageRow added in v0.41.0 

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

type ListPendingEntriesParams added in v0.43.0 

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

type ListPendingGroupDispatchByMessageParams added in v0.43.0 

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

type ListPendingGroupDispatchParams added in v0.43.0 

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

type ListPendingGroupOutboxParams added in v0.43.0 

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

type ListProjectsAllParams added in v0.34.0 

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

type ListProjectsParams added in v0.34.0 

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

type ListReadyCandidatesParams added in v0.38.0 

type ListReadyCandidatesParams struct {
	NotBefore sql.NullString `json:"not_before"`
	Limit     int64          `json:"limit"`
}

type ListRecentGroupMessagesBeforeSeqParams added in v0.43.0 

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

type ListRecentGroupMessagesParams added in v0.42.0 

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

type ListSchedJobRunsParams 

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

type ListSchedulerJobsByAgentParams added in v0.36.0 

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

type ListSharesByUserParams added in v0.38.0 

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

type ListSharesByUserRow added in v0.35.0 

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

type ListSkillsForAgentContextParams added in v0.36.0 

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

type ListSkillsForUserParams added in v0.36.0 

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

type ListSkillsVisibleParams 

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

type ListStaleAgentTaskRunsParams added in v0.38.0 

type ListStaleAgentTaskRunsParams struct {
	LeaseExpiresAt sql.NullString `json:"lease_expires_at"`
	Limit          int64          `json:"limit"`
}

type ListSummariesByIDsParams added in v0.41.0 

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

type ListUnreadArticlesOlderThanParams 

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

type 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 NextAttemptNoForGoalParams added in v0.38.0 

type NextAttemptNoForGoalParams struct {
	GoalID sql.NullString `json:"goal_id"`
	Kind   string         `json:"kind"`
}

type NextAttemptNoForTaskParams added in v0.38.0 

type NextAttemptNoForTaskParams struct {
	TaskID sql.NullString `json:"task_id"`
	Kind   string         `json:"kind"`
}

type Plugin added in v0.38.0 

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

type PluginOauthProvider added in v0.38.0 

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

type PluginOverride added in v0.38.0 

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

type PluginState added in v0.38.0 

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

type Project added in v0.34.0 

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

type PromoteAgentTaskRunParams added in v0.38.0 

type PromoteAgentTaskRunParams struct {
	StartedAt      sql.NullString `json:"started_at"`
	HeartbeatAt    sql.NullString `json:"heartbeat_at"`
	LeaseExpiresAt sql.NullString `json:"lease_expires_at"`
	UpdatedAt      string         `json:"updated_at"`
	ID             string         `json:"id"`
}

type Provider added in v0.38.0 

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

type Queries 

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

func New 

func New(db DBTX) *Queries

func (*Queries) 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) AppendAgentTaskBlockerDetail added in v0.38.0 

func (q *Queries) AppendAgentTaskBlockerDetail(ctx context.Context, arg AppendAgentTaskBlockerDetailParams) error

func (*Queries) AppendContextItem 

func (q *Queries) AppendContextItem(ctx context.Context, arg AppendContextItemParams) 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) BumpGroupSeq added in v0.42.0 

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

func (*Queries) CancelAgentTaskBlocker added in v0.38.0 

func (q *Queries) CancelAgentTaskBlocker(ctx context.Context, arg CancelAgentTaskBlockerParams) (int64, error)

func (*Queries) ClaimAgentTask added in v0.38.0 

func (q *Queries) ClaimAgentTask(ctx context.Context, arg ClaimAgentTaskParams) (int64, error)

Atomic claim: ready + no active run -> running. session_id is required at task creation.

func (*Queries) ClaimExpiredGroupDispatch added in v0.43.0 

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

func (*Queries) ClaimExpiredGroupOutbox added in v0.43.0 

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

func (*Queries) ClaimPendingGroupDispatch added in v0.43.0 

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

func (*Queries) ClaimPendingGroupOutbox added in v0.43.0 

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

func (*Queries) ConsumeDispatchHint added in v0.38.0 

func (q *Queries) ConsumeDispatchHint(ctx context.Context, arg ConsumeDispatchHintParams) (int64, 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) CountRunningAgentTasks added in v0.38.0 

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

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) CreateAgentGoal added in v0.38.0 

func (q *Queries) CreateAgentGoal(ctx context.Context, arg CreateAgentGoalParams) (AgentGoal, error)

Slice 3: goal queries.

func (*Queries) CreateAgentReview added in v0.38.0 

func (q *Queries) CreateAgentReview(ctx context.Context, arg CreateAgentReviewParams) (AgentReview, error)

Slice 2: review queries.

func (*Queries) CreateAgentTask added in v0.30.0 

func (q *Queries) CreateAgentTask(ctx context.Context, arg CreateAgentTaskParams) (AgentTask, error)

agent_task v2 queries Slice 1. Status writes are split: only the transition service uses the *Status* / *Active* / Claim mutators. Other code paths read via Get/List and write only non-status fields via UpdateAgentTaskMeta.

func (*Queries) CreateAgentTaskBlocker added in v0.38.0 

func (q *Queries) CreateAgentTaskBlocker(ctx context.Context, arg CreateAgentTaskBlockerParams) (AgentTaskBlocker, error)

Blocker queries.

func (*Queries) CreateAgentTaskCriterion added in v0.38.0 

func (q *Queries) CreateAgentTaskCriterion(ctx context.Context, arg CreateAgentTaskCriterionParams) (AgentTaskCriterion, error)

func (*Queries) CreateAgentTaskDep added in v0.38.0 

func (q *Queries) CreateAgentTaskDep(ctx context.Context, arg CreateAgentTaskDepParams) (AgentTaskDep, error)

DAG edge queries. Cycle prevention is enforced at the service layer.

func (*Queries) CreateAgentTaskDispatchHint added in v0.38.0 

func (q *Queries) CreateAgentTaskDispatchHint(ctx context.Context, arg CreateAgentTaskDispatchHintParams) (AgentTaskDispatchHint, error)

Dispatch hint persistence between task creation and the next claim (B1 / D13).

func (*Queries) CreateAgentTaskRun added in v0.38.0 

func (q *Queries) CreateAgentTaskRun(ctx context.Context, arg CreateAgentTaskRunParams) (AgentTaskRun, error)

Run queries one row per execution attempt.

func (*Queries) CreateArticle 

func (q *Queries) CreateArticle(ctx context.Context, arg CreateArticleParams) (RecallyArticle, 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) 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) 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) DeleteAgent 

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

func (*Queries) DeleteAgentTask added in v0.30.0 

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

func (*Queries) DeleteAgentTaskDep added in v0.38.0 

func (q *Queries) DeleteAgentTaskDep(ctx context.Context, arg DeleteAgentTaskDepParams) 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 string) 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) DeleteDispatchHint added in v0.38.0 

func (q *Queries) DeleteDispatchHint(ctx context.Context, id string) 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) DeprecateExpiredDrafts 

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

func (*Queries) ExpireKnowledgeDraftsByType 

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

func (*Queries) ExtendRunningGroupDispatchLease added in v0.43.0 

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

func (*Queries) ExtendRunningGroupOutboxLease added in v0.43.0 

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

func (*Queries) FinishAgentTaskRun added in v0.38.0 

func (q *Queries) FinishAgentTaskRun(ctx context.Context, arg FinishAgentTaskRunParams) 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) GetAgentGoal added in v0.38.0 

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

func (*Queries) GetAgentReview added in v0.38.0 

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

func (*Queries) GetAgentSkillByName 

func (q *Queries) GetAgentSkillByName(ctx context.Context, arg GetAgentSkillByNameParams) (Skill, error)

func (*Queries) GetAgentTask added in v0.30.0 

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

func (*Queries) GetAgentTaskBlocker added in v0.38.0 

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

func (*Queries) GetAgentTaskRun added in v0.38.0 

func (q *Queries) GetAgentTaskRun(ctx context.Context, id string) (AgentTaskRun, 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) 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) 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) GetConversationBySessionID 

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

func (*Queries) GetDigestByDate added in v0.30.0 

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

func (*Queries) GetFeed added in v0.43.0 

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

func (*Queries) GetFeedByURL added in v0.43.0 

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

func (*Queries) GetFeedEntry added in v0.43.0 

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

func (*Queries) GetFreshTailMessageIDs 

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

func (*Queries) GetGroupDispatch added in v0.43.0 

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

func (*Queries) GetGroupMember added in v0.42.0 

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

func (*Queries) GetGroupMemory added in v0.42.0 

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

func (*Queries) GetGroupMessage added in v0.43.0 

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

func (*Queries) GetGroupMessageByIdempotencyKey added in v0.42.0 

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

func (*Queries) GetGroupMessageByPlatformID added in v0.42.0 

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

func (*Queries) GetGroupOutbox added in v0.43.0 

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

func (*Queries) GetGroupOutboxByMessage added in v0.43.0 

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

func (*Queries) GetGroupStateByID added in v0.43.0 

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

func (*Queries) GetGroupStateByTriple added in v0.42.0 

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

func (*Queries) GetIngestCursor added in v0.42.0 

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

func (*Queries) GetLiveDispatchHintForTask added in v0.38.0 

func (q *Queries) GetLiveDispatchHintForTask(ctx context.Context, arg GetLiveDispatchHintForTaskParams) (AgentTaskDispatchHint, 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) 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) 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) GetOpenBlockerForTask added in v0.38.0 

func (q *Queries) GetOpenBlockerForTask(ctx context.Context, taskID string) (AgentTaskBlocker, error)

func (*Queries) GetOpenReviewForTask added in v0.38.0 

func (q *Queries) GetOpenReviewForTask(ctx context.Context, taskID sql.NullString) (AgentReview, error)

func (*Queries) GetPlugin 

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

func (*Queries) GetPluginStateEntry 

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

func (*Queries) GetProject added in v0.34.0 

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

func (*Queries) GetProjectByName added in v0.34.0 

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

func (*Queries) GetProvider 

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

func (*Queries) 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) 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) 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) 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) 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) GoalChildCounts added in v0.38.0 

func (q *Queries) GoalChildCounts(ctx context.Context, goalID sql.NullString) (GoalChildCountsRow, error)

Aggregate counts of children by required_flag + status for rollup logic.

func (*Queries) HeartbeatAgentTaskRun added in v0.38.0 

func (q *Queries) HeartbeatAgentTaskRun(ctx context.Context, arg HeartbeatAgentTaskRunParams) (int64, error)

func (*Queries) IncrementAgentTaskRetry added in v0.38.0 

func (q *Queries) IncrementAgentTaskRetry(ctx context.Context, arg IncrementAgentTaskRetryParams) error

func (*Queries) InsertAgentTaskEvent added in v0.30.0 

func (q *Queries) InsertAgentTaskEvent(ctx context.Context, arg InsertAgentTaskEventParams) (AgentTaskEvent, error)

Append-only audit log.

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) LatestAgentTaskRunForGoal added in v0.38.0 

func (q *Queries) LatestAgentTaskRunForGoal(ctx context.Context, arg LatestAgentTaskRunForGoalParams) (AgentTaskRun, error)

func (*Queries) LatestAgentTaskRunForTask added in v0.38.0 

func (q *Queries) LatestAgentTaskRunForTask(ctx context.Context, arg LatestAgentTaskRunForTaskParams) (AgentTaskRun, 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) 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) ListAgentGoals added in v0.38.0 

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

func (*Queries) ListAgentGoalsByUser added in v0.38.0 

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

func (*Queries) ListAgentGoalsByUserAndAgent added in v0.41.3 

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

func (*Queries) ListAgentReviewsByGoal added in v0.38.0 

func (q *Queries) ListAgentReviewsByGoal(ctx context.Context, arg ListAgentReviewsByGoalParams) ([]AgentReview, error)

func (*Queries) ListAgentReviewsByTask added in v0.38.0 

func (q *Queries) ListAgentReviewsByTask(ctx context.Context, arg ListAgentReviewsByTaskParams) ([]AgentReview, error)

func (*Queries) ListAgentTaskBlockersByTask added in v0.38.0 

func (q *Queries) ListAgentTaskBlockersByTask(ctx context.Context, taskID string) ([]AgentTaskBlocker, error)

func (*Queries) ListAgentTaskCriteria added in v0.38.0 

func (q *Queries) ListAgentTaskCriteria(ctx context.Context, taskID string) ([]AgentTaskCriterion, error)

func (*Queries) ListAgentTaskDependents added in v0.38.0 

func (q *Queries) ListAgentTaskDependents(ctx context.Context, depTaskID string) ([]AgentTaskDep, error)

func (*Queries) ListAgentTaskDeps added in v0.38.0 

func (q *Queries) ListAgentTaskDeps(ctx context.Context, taskID string) ([]AgentTaskDep, error)

func (*Queries) ListAgentTaskDepsWithUpstream added in v0.38.0 

func (q *Queries) ListAgentTaskDepsWithUpstream(ctx context.Context, taskID string) ([]ListAgentTaskDepsWithUpstreamRow, error)

Returns each dep edge joined with the upstream task's status, so readiness can be computed without N+1 queries.

func (*Queries) ListAgentTaskDepsWithUpstreamByTasks added in v0.41.0 

func (q *Queries) ListAgentTaskDepsWithUpstreamByTasks(ctx context.Context, taskIds []string) ([]ListAgentTaskDepsWithUpstreamByTasksRow, error)

func (*Queries) ListAgentTaskDepsWithUpstreamPaged added in v0.38.0 

func (q *Queries) ListAgentTaskDepsWithUpstreamPaged(ctx context.Context, arg ListAgentTaskDepsWithUpstreamPagedParams) ([]ListAgentTaskDepsWithUpstreamPagedRow, error)

func (*Queries) ListAgentTaskEvents added in v0.30.0 

func (q *Queries) ListAgentTaskEvents(ctx context.Context, arg ListAgentTaskEventsParams) ([]AgentTaskEvent, error)

func (*Queries) ListAgentTaskEventsByGoal added in v0.38.0 

func (q *Queries) ListAgentTaskEventsByGoal(ctx context.Context, goalID sql.NullString) ([]AgentTaskEvent, error)

func (*Queries) ListAgentTaskEventsByRun added in v0.38.0 

func (q *Queries) ListAgentTaskEventsByRun(ctx context.Context, runID sql.NullString) ([]AgentTaskEvent, error)

func (*Queries) ListAgentTaskRunsByTask added in v0.38.0 

func (q *Queries) ListAgentTaskRunsByTask(ctx context.Context, arg ListAgentTaskRunsByTaskParams) ([]AgentTaskRun, error)

func (*Queries) ListAgentTasks added in v0.30.0 

func (q *Queries) ListAgentTasks(ctx context.Context, arg ListAgentTasksParams) ([]AgentTask, error)

func (*Queries) ListAgentTasksByUser added in v0.30.0 

func (q *Queries) ListAgentTasksByUser(ctx context.Context, arg ListAgentTasksByUserParams) ([]AgentTask, error)

func (*Queries) ListAgentUsers 

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

func (*Queries) ListAgents 

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

func (*Queries) ListAllSchedulerJobs added in v0.38.0 

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

func (*Queries) ListAllSkills 

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

func (*Queries) ListArticles 

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

func (*Queries) ListArticlesSavedYesterday 

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

func (*Queries) ListAuthPolicies 

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

func (*Queries) ListAuthUsersByIDs added in v0.41.0 

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

func (*Queries) ListChannels 

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

func (*Queries) ListChannelsByType 

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

func (*Queries) ListChatAgents 

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

func (*Queries) ListChildrenByGoal added in v0.38.0 

func (q *Queries) ListChildrenByGoal(ctx context.Context, goalID sql.NullString) ([]AgentTask, error)

func (*Queries) ListChildrenByGoalPaged added in v0.38.0 

func (q *Queries) ListChildrenByGoalPaged(ctx context.Context, arg ListChildrenByGoalPagedParams) ([]AgentTask, 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) ListConversationsForReviewByAgent added in v0.40.0 

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

func (*Queries) ListDigestArticles added in v0.30.0 

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

func (*Queries) ListDigests added in v0.30.0 

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

func (*Queries) 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) 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) 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) ListGoalPlanningCandidates added in v0.38.0 

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

func (*Queries) ListGoalSynthesisCandidates added in v0.38.0 

func (q *Queries) ListGoalSynthesisCandidates(ctx context.Context, limit int64) ([]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) ([]CtxGroupState, error)

func (*Queries) ListGroupsWithPendingIngest added in v0.42.0 

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

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) ListOpenAgentReviewsForDispatch added in v0.38.0 

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

Reviews awaiting agent dispatch: open, reviewer_type='agent', reviewer_run_id unset.

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) ListReachableDownstream added in v0.38.0 

func (q *Queries) ListReachableDownstream(ctx context.Context, depTaskID string) ([]AgentTask, error)

Reachable downstream tasks of a given task (Slice 4 reopen cascade). Bounded by SQLite's default recursive limit; we additionally cap depth at 1000 in the CTE to prevent runaway cycles (cycles are forbidden by AddDep but the CTE is defensive).

func (*Queries) ListReadyCandidates added in v0.38.0 

func (q *Queries) ListReadyCandidates(ctx context.Context, arg ListReadyCandidatesParams) ([]AgentTask, error)

Coarse pre-filter for the dispatcher tick (HP4). Real dispatchability is decided by readiness.Compute in Go.

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) 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) ListSkillsForAdmin added in v0.36.0 

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

func (*Queries) ListSkillsForAgentContext added in v0.36.0 

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

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)

func (*Queries) ListStaleAgentTaskRuns added in v0.38.0 

func (q *Queries) ListStaleAgentTaskRuns(ctx context.Context, arg ListStaleAgentTaskRunsParams) ([]AgentTaskRun, error)

func (*Queries) ListSummariesByIDs added in v0.41.0 

func (q *Queries) ListSummariesByIDs(ctx context.Context, arg ListSummariesByIDsParams) ([]CtxSummary, 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) ListVaultEntriesByUser 

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

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) NextAttemptNoForGoal added in v0.38.0 

func (q *Queries) NextAttemptNoForGoal(ctx context.Context, arg NextAttemptNoForGoalParams) (int64, error)

func (*Queries) NextAttemptNoForTask added in v0.38.0 

func (q *Queries) NextAttemptNoForTask(ctx context.Context, arg NextAttemptNoForTaskParams) (int64, error)

func (*Queries) PromoteAgentTaskRun added in v0.38.0 

func (q *Queries) PromoteAgentTaskRun(ctx context.Context, arg PromoteAgentTaskRunParams) (int64, error)

Flip a queued run to running. Returns affected-rows so callers can detect losing a race (e.g. another tick already promoted the run).

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) ResolveAgentTaskBlocker added in v0.38.0 

func (q *Queries) ResolveAgentTaskBlocker(ctx context.Context, arg ResolveAgentTaskBlockerParams) (int64, error)

func (*Queries) ResolveSkill 

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

func (*Queries) RevokeAuthUserToken 

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

func (*Queries) RotateAuthUserToken 

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

func (*Queries) SearchArticles 

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

Phase 1 MVP: LIKE-based search. Upgrade to FTS5 in future phase.

func (*Queries) SearchMessages 

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

func (*Queries) SearchSummaries 

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

func (*Queries) SeedProvider 

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

func (*Queries) SetAgentGoalActiveReview added in v0.38.0 

func (q *Queries) SetAgentGoalActiveReview(ctx context.Context, arg SetAgentGoalActiveReviewParams) error

func (*Queries) SetAgentGoalOutput added in v0.38.0 

func (q *Queries) SetAgentGoalOutput(ctx context.Context, arg SetAgentGoalOutputParams) error

func (*Queries) SetAgentReviewDecision added in v0.38.0 

func (q *Queries) SetAgentReviewDecision(ctx context.Context, arg SetAgentReviewDecisionParams) (int64, error)

func (*Queries) SetAgentReviewReviewerRun added in v0.38.0 

func (q *Queries) SetAgentReviewReviewerRun(ctx context.Context, arg SetAgentReviewReviewerRunParams) (int64, error)

func (*Queries) SetAgentTaskActiveBlocker added in v0.38.0 

func (q *Queries) SetAgentTaskActiveBlocker(ctx context.Context, arg SetAgentTaskActiveBlockerParams) error

func (*Queries) SetAgentTaskActiveReview added in v0.38.0 

func (q *Queries) SetAgentTaskActiveReview(ctx context.Context, arg SetAgentTaskActiveReviewParams) error

func (*Queries) SetAgentTaskActiveRun added in v0.38.0 

func (q *Queries) SetAgentTaskActiveRun(ctx context.Context, arg SetAgentTaskActiveRunParams) error

func (*Queries) SetAgentTaskCancelled added in v0.38.0 

func (q *Queries) SetAgentTaskCancelled(ctx context.Context, arg SetAgentTaskCancelledParams) error

func (*Queries) SetAgentTaskOutput added in v0.38.0 

func (q *Queries) SetAgentTaskOutput(ctx context.Context, arg SetAgentTaskOutputParams) error

func (*Queries) SetAgentTaskReviewPolicy added in v0.38.0 

func (q *Queries) SetAgentTaskReviewPolicy(ctx context.Context, arg SetAgentTaskReviewPolicyParams) error

func (*Queries) TransitionAgentGoalStatus added in v0.38.0 

func (q *Queries) TransitionAgentGoalStatus(ctx context.Context, arg TransitionAgentGoalStatusParams) (int64, error)

func (*Queries) TransitionAgentTaskStatus added in v0.38.0 

func (q *Queries) TransitionAgentTaskStatus(ctx context.Context, arg TransitionAgentTaskStatusParams) (int64, error)

Transition service uses these. Conditional UPDATE returns affected rows so callers can detect lost races.

func (*Queries) UpdateAgent 

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

func (*Queries) UpdateAgentTaskMeta added in v0.38.0 

func (q *Queries) UpdateAgentTaskMeta(ctx context.Context, arg UpdateAgentTaskMetaParams) 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) 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) 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) UpsertAuthOAuthProvider added in v0.27.0 

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

func (*Queries) UpsertChannel 

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

func (*Queries) UpsertChatAgent 

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

func (*Queries) UpsertDigest added in v0.30.0 

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

func (*Queries) UpsertGroupMemoryVersioned added in v0.42.0 

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

func (*Queries) UpsertIngestCursor added in v0.42.0 

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

func (*Queries) UpsertManifestPluginOverride added in v0.38.0 

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

func (*Queries) UpsertPlugin 

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

func (*Queries) UpsertPluginStateEntry 

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

func (*Queries) UpsertProfileEntries added in v0.42.0 

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

func (*Queries) UpsertSetting 

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

func (*Queries) UpsertSkillFile 

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

func (*Queries) UpsertUserAgentMemory 

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

func (*Queries) UpsertUserAgentMemoryVersioned 

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

func (*Queries) UpsertVaultEntry 

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

func (*Queries) WaiveAgentTaskDep added in v0.38.0 

func (q *Queries) WaiveAgentTaskDep(ctx context.Context, arg WaiveAgentTaskDepParams) (int64, error)

Waiver path for hard deps whose upstream failed/cancelled with on_failure=block.

func (*Queries) WithTx 

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

type RecallyArticle added in v0.38.0 

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

type RecallyDigest added in v0.30.0 

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

type RecallyDigestArticle added in v0.30.0 

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

type RecallyFeed added in v0.43.0 

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

type RecallyFeedEntry added in v0.43.0 

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

type RecordSchedulerJobRunParams 

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

type RemoveGroupMemberParams added in v0.42.0 

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

type RemoveUserAgentParams 

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

type RequeueGroupDispatchParams added in v0.43.0 

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

type RequeueGroupOutboxParams added in v0.43.0 

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

type ResolveAgentTaskBlockerParams added in v0.38.0 

type ResolveAgentTaskBlockerParams struct {
	Resolution string         `json:"resolution"`
	ResolvedAt sql.NullString `json:"resolved_at"`
	ID         string         `json:"id"`
}

type ResolveSkillParams 

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

type SchedJob 

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

type SchedJobRun 

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

type SearchArticlesParams 

type SearchArticlesParams struct {
	UserID  string         `json:"user_id"`
	Column2 sql.NullString `json:"column_2"`
	Column3 sql.NullString `json:"column_3"`
	Column4 sql.NullString `json:"column_4"`
	Column5 sql.NullString `json:"column_5"`
	Limit   int64          `json:"limit"`
}

type SearchMessagesParams 

type SearchMessagesParams struct {
	ConversationID string `json:"conversation_id"`
	Content        string `json:"content"`
	Limit          int64  `json:"limit"`
}

type SearchSummariesParams 

type SearchSummariesParams struct {
	ConversationID string `json:"conversation_id"`
	Content        string `json:"content"`
	Limit          int64  `json:"limit"`
}

type SeedProviderParams 

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

type SetAgentGoalActiveReviewParams added in v0.38.0 

type SetAgentGoalActiveReviewParams struct {
	ActiveReviewID sql.NullString `json:"active_review_id"`
	UpdatedAt      string         `json:"updated_at"`
	ID             string         `json:"id"`
}

type SetAgentGoalOutputParams added in v0.38.0 

type SetAgentGoalOutputParams struct {
	Output      string         `json:"output"`
	CompletedAt sql.NullString `json:"completed_at"`
	UpdatedAt   string         `json:"updated_at"`
	ID          string         `json:"id"`
}

type SetAgentReviewDecisionParams added in v0.38.0 

type SetAgentReviewDecisionParams struct {
	Status     string         `json:"status"`
	Summary    string         `json:"summary"`
	Feedback   string         `json:"feedback"`
	ResolvedAt sql.NullString `json:"resolved_at"`
	UpdatedAt  string         `json:"updated_at"`
	ID         string         `json:"id"`
}

type SetAgentReviewReviewerRunParams added in v0.38.0 

type SetAgentReviewReviewerRunParams struct {
	ReviewerRunID sql.NullString `json:"reviewer_run_id"`
	UpdatedAt     string         `json:"updated_at"`
	ID            string         `json:"id"`
}

type SetAgentTaskActiveBlockerParams added in v0.38.0 

type SetAgentTaskActiveBlockerParams struct {
	ActiveBlockerID sql.NullString `json:"active_blocker_id"`
	UpdatedAt       string         `json:"updated_at"`
	ID              string         `json:"id"`
}

type SetAgentTaskActiveReviewParams added in v0.38.0 

type SetAgentTaskActiveReviewParams struct {
	ActiveReviewID sql.NullString `json:"active_review_id"`
	UpdatedAt      string         `json:"updated_at"`
	ID             string         `json:"id"`
}

type SetAgentTaskActiveRunParams added in v0.38.0 

type SetAgentTaskActiveRunParams struct {
	ActiveRunID sql.NullString `json:"active_run_id"`
	UpdatedAt   string         `json:"updated_at"`
	ID          string         `json:"id"`
}

type SetAgentTaskCancelledParams added in v0.38.0 

type SetAgentTaskCancelledParams struct {
	CancelledAt sql.NullString `json:"cancelled_at"`
	UpdatedAt   string         `json:"updated_at"`
	ID          string         `json:"id"`
}

type SetAgentTaskOutputParams added in v0.38.0 

type SetAgentTaskOutputParams struct {
	Output      string         `json:"output"`
	CompletedAt sql.NullString `json:"completed_at"`
	UpdatedAt   string         `json:"updated_at"`
	ID          string         `json:"id"`
}

type SetAgentTaskReviewPolicyParams added in v0.38.0 

type SetAgentTaskReviewPolicyParams struct {
	ReviewPolicy string `json:"review_policy"`
	UpdatedAt    string `json:"updated_at"`
	ID           string `json:"id"`
}

type Share added in v0.35.0 

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

type Skill 

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

type SkillFile 

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

type TransitionAgentGoalStatusParams added in v0.38.0 

type TransitionAgentGoalStatusParams struct {
	Status    string `json:"status"`
	UpdatedAt string `json:"updated_at"`
	ID        string `json:"id"`
	Status_2  string `json:"status_2"`
}

type TransitionAgentTaskStatusParams added in v0.38.0 

type TransitionAgentTaskStatusParams struct {
	Status    string `json:"status"`
	UpdatedAt string `json:"updated_at"`
	ID        string `json:"id"`
	Status_2  string `json:"status_2"`
}

type UpdateAgentParams 

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

type UpdateAgentTaskMetaParams added in v0.38.0 

type UpdateAgentTaskMetaParams struct {
	Title       string         `json:"title"`
	Description string         `json:"description"`
	Priority    string         `json:"priority"`
	NotBefore   sql.NullString `json:"not_before"`
	DeadlineAt  sql.NullString `json:"deadline_at"`
	Context     string         `json:"context"`
	UpdatedAt   string         `json:"updated_at"`
	ID          string         `json:"id"`
}

type UpdateArticleParams 

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

type UpdateAuthPolicyParams 

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

type UpdateConversationArchivedParams 

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

type UpdateConversationBootstrappedParams added in v0.35.3 

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

type UpdateConversationKindProjectParams added in v0.34.0 

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

type UpdateConversationLastActiveParams added in v0.35.3 

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

type UpdateConversationTitleBySessionIDParams 

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

type UpdateConversationTitleParams 

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

type UpdateFeedEntryParams added in v0.43.0 

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

type UpdateFeedParams added in v0.43.0 

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

type UpdateGroupNameParams added in v0.43.0 

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

type UpdateProjectParams added in v0.34.0 

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

type UpdateProviderParams 

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

type UpdateSchedJobRunParams 

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

type UpdateSchedulerJobParams 

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

type UpdateSkillMetadataParams 

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

type UpdateSystemSkillMetadataParams added in v0.35.3 

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

type UpdateUserActiveParams added in v0.38.0 

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

type UpdateUserRoleParams added in v0.38.0 

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

type UpsertAgentConstraintsParams 

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

type UpsertAgentSoulParams 

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

type UpsertAgentSoulVersionedParams 

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

type UpsertAuthOAuthProviderParams added in v0.27.0 

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

type UpsertChannelParams 

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

type UpsertChatAgentParams 

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

type UpsertDigestParams added in v0.30.0 

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

type UpsertGroupMemoryVersionedParams added in v0.42.0 

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

type UpsertIngestCursorParams added in v0.42.0 

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

type UpsertManifestPluginOverrideParams added in v0.38.0 

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

type UpsertPluginParams 

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

type UpsertPluginStateEntryParams 

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

type UpsertProfileEntriesParams added in v0.42.0 

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

type UpsertSettingParams 

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

type UpsertSkillFileParams 

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

type UpsertUserAgentMemoryParams 

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

type UpsertUserAgentMemoryVersionedParams 

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

type UpsertVaultEntryParams 

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

type VaultEntry 

type VaultEntry struct {
	ID         string `json:"id"`
	UserID     string `json:"user_id"`
	Name       string `json:"name"`
	Ciphertext string `json:"ciphertext"`
	CreatedAt  string `json:"created_at"`
	UpdatedAt  string `json:"updated_at"`
}

type VaultUser added in v0.38.0 

type VaultUser struct {
	AgePublicKey  string
	AgePrivateKey string
}

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

type WaiveAgentTaskDepParams added in v0.38.0 

type WaiveAgentTaskDepParams struct {
	WaivedAt     sql.NullString `json:"waived_at"`
	WaivedByUser sql.NullString `json:"waived_by_user"`
	WaiverReason string         `json:"waiver_reason"`
	TaskID       string         `json:"task_id"`
	DepTaskID    string         `json:"dep_task_id"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.