repositorypostgres

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Aug 6, 2026 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AbandonAgentSessionParams 

type AbandonAgentSessionParams struct {
	Error     sql.NullString `json:"error"`
	EndedAt   sql.NullTime   `json:"ended_at"`
	UpdatedAt time.Time      `json:"updated_at"`
	ID        string         `json:"id"`
}

type AbandonUserPromptParams 

type AbandonUserPromptParams struct {
	Error     sql.NullString `json:"error"`
	EndedAt   sql.NullTime   `json:"ended_at"`
	UpdatedAt time.Time      `json:"updated_at"`
	ID        string         `json:"id"`
}

type AddTokenTeamParams 

type AddTokenTeamParams struct {
	TokenID   string    `json:"token_id"`
	TeamID    string    `json:"team_id"`
	CreatedAt time.Time `json:"created_at"`
}

type AddUserTeamMembershipParams 

type AddUserTeamMembershipParams struct {
	UserID    string    `json:"user_id"`
	TeamID    string    `json:"team_id"`
	Source    string    `json:"source"`
	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`
}

type AgentSession 

type AgentSession struct {
	ID                string           `json:"id"`
	TeamID            sql.NullString   `json:"team_id"`
	Status            string           `json:"status"`
	ResumeMode        string           `json:"resume_mode"`
	PinnedRunnerID    sql.NullString   `json:"pinned_runner_id"`
	PinnedRunnerName  sql.NullString   `json:"pinned_runner_name"`
	CheckpointID      sql.NullString   `json:"checkpoint_id"`
	WorkspacePath     sql.NullString   `json:"workspace_path"`
	ContainerName     sql.NullString   `json:"container_name"`
	HarnessSessionID  sql.NullString   `json:"harness_session_id"`
	GitUrl            sql.NullString   `json:"git_url"`
	GitRef            sql.NullString   `json:"git_ref"`
	AgentImage        sql.NullString   `json:"agent_image"`
	Agent             sql.NullString   `json:"agent"`
	ProviderID        sql.NullString   `json:"provider_id"`
	ModelID           sql.NullString   `json:"model_id"`
	VariantID         sql.NullString   `json:"variant_id"`
	CreatedAt         time.Time        `json:"created_at"`
	UpdatedAt         time.Time        `json:"updated_at"`
	PausedAt          sql.NullTime     `json:"paused_at"`
	ExpiresAt         sql.NullTime     `json:"expires_at"`
	PauseReason       sql.NullString   `json:"pause_reason"`
	Error             sql.NullString   `json:"error"`
	SearchText        sql.NullString   `json:"search_text"`
	TaskID            string           `json:"task_id"`
	Sequence          int32            `json:"sequence"`
	Harness           sql.NullString   `json:"harness"`
	Skills            json.RawMessage  `json:"skills"`
	McpEndpoints      *json.RawMessage `json:"mcp_endpoints"`
	Env               json.RawMessage  `json:"env"`
	CommitAuthorName  sql.NullString   `json:"commit_author_name"`
	CommitAuthorEmail sql.NullString   `json:"commit_author_email"`
	GitIdentityID     sql.NullString   `json:"git_identity_id"`
	Summary           sql.NullString   `json:"summary"`
	StartedAt         sql.NullTime     `json:"started_at"`
	EndedAt           sql.NullTime     `json:"ended_at"`
	IsolationRequired bool             `json:"isolation_required"`
}

type AgentSessionCheckpoint 

type AgentSessionCheckpoint struct {
	ID             string         `json:"id"`
	AgentSessionID string         `json:"agent_session_id"`
	UserPromptID   sql.NullString `json:"user_prompt_id"`
	RunnerID       string         `json:"runner_id"`
	CheckpointPath string         `json:"checkpoint_path"`
	WorkspacePath  string         `json:"workspace_path"`
	ContainerName  sql.NullString `json:"container_name"`
	RunscVersion   sql.NullString `json:"runsc_version"`
	AgentImage     sql.NullString `json:"agent_image"`
	SizeBytes      int64          `json:"size_bytes"`
	Status         string         `json:"status"`
	Error          sql.NullString `json:"error"`
	CreatedAt      time.Time      `json:"created_at"`
	UpdatedAt      time.Time      `json:"updated_at"`
	ExpiresAt      sql.NullTime   `json:"expires_at"`
}

type ApiToken 

type ApiToken struct {
	ID        string       `json:"id"`
	Name      string       `json:"name"`
	TokenHash string       `json:"token_hash"`
	UserID    string       `json:"user_id"`
	CreatedAt time.Time    `json:"created_at"`
	UpdatedAt time.Time    `json:"updated_at"`
	ExpiresAt sql.NullTime `json:"expires_at"`
}

type ApiTokenTeam 

type ApiTokenTeam struct {
	TokenID   string    `json:"token_id"`
	TeamID    string    `json:"team_id"`
	CreatedAt time.Time `json:"created_at"`
}

type AuditLog 

type AuditLog struct {
	ID               string           `json:"id"`
	EventType        string           `json:"event_type"`
	CreatedAt        time.Time        `json:"created_at"`
	SourceType       sql.NullString   `json:"source_type"`
	SourceID         sql.NullString   `json:"source_id"`
	TargetType       sql.NullString   `json:"target_type"`
	TargetID         sql.NullString   `json:"target_id"`
	Repo             sql.NullString   `json:"repo"`
	GithubEvent      sql.NullString   `json:"github_event"`
	GithubAction     sql.NullString   `json:"github_action"`
	GithubDeliveryID sql.NullString   `json:"github_delivery_id"`
	ParentEventID    sql.NullString   `json:"parent_event_id"`
	Detail           sql.NullString   `json:"detail"`
	SearchText       sql.NullString   `json:"search_text"`
	Payload          *json.RawMessage `json:"payload"`
	TokenID          sql.NullString   `json:"token_id"`
	TokenName        sql.NullString   `json:"token_name"`
}

type CancelExecutionAttemptsByTaskParams 

type CancelExecutionAttemptsByTaskParams struct {
	Error     sql.NullString `json:"error"`
	EndedAt   sql.NullTime   `json:"ended_at"`
	UpdatedAt time.Time      `json:"updated_at"`
	TaskID    string         `json:"task_id"`
}

type CancelPendingExecutionAttemptsParams 

type CancelPendingExecutionAttemptsParams struct {
	Error     sql.NullString `json:"error"`
	EndedAt   sql.NullTime   `json:"ended_at"`
	UpdatedAt time.Time      `json:"updated_at"`
}

type CancelTaskParams 

type CancelTaskParams struct {
	Error          sql.NullString `json:"error"`
	FailureMessage sql.NullString `json:"failure_message"`
	EndedAt        sql.NullTime   `json:"ended_at"`
	UpdatedAt      time.Time      `json:"updated_at"`
	ID             string         `json:"id"`
}

type ClearPendingTasksParams 

type ClearPendingTasksParams struct {
	Error          sql.NullString `json:"error"`
	FailureMessage sql.NullString `json:"failure_message"`
	EndedAt        sql.NullTime   `json:"ended_at"`
	UpdatedAt      time.Time      `json:"updated_at"`
}

type CreateTeamParams 

type CreateTeamParams struct {
	ID            string         `json:"id"`
	Name          string         `json:"name"`
	OktaGroupID   sql.NullString `json:"okta_group_id"`
	OktaGroupName sql.NullString `json:"okta_group_name"`
	CreatedAt     time.Time      `json:"created_at"`
	UpdatedAt     time.Time      `json:"updated_at"`
}

type CreateTokenParams 

type CreateTokenParams struct {
	ID        string       `json:"id"`
	Name      string       `json:"name"`
	TokenHash string       `json:"token_hash"`
	UserID    string       `json:"user_id"`
	ExpiresAt sql.NullTime `json:"expires_at"`
	CreatedAt time.Time    `json:"created_at"`
	UpdatedAt time.Time    `json:"updated_at"`
}

type CreateTriggerParams 

type CreateTriggerParams struct {
	ID            string          `json:"id"`
	TeamID        sql.NullString  `json:"team_id"`
	Name          string          `json:"name"`
	TriggerType   string          `json:"trigger_type"`
	TriggerConfig json.RawMessage `json:"trigger_config"`
	CronExpr      string          `json:"cron_expr"`
	Prompt        string          `json:"prompt"`
	GitUrl        sql.NullString  `json:"git_url"`
	GitRef        sql.NullString  `json:"git_ref"`
	AgentImage    sql.NullString  `json:"agent_image"`
	Agent         sql.NullString  `json:"agent"`
	ProviderID    sql.NullString  `json:"provider_id"`
	ModelID       sql.NullString  `json:"model_id"`
	VariantID     sql.NullString  `json:"variant_id"`
	Harness       sql.NullString  `json:"harness"`
	Skills        json.RawMessage `json:"skills"`
	TimeoutSec    int32           `json:"timeout_sec"`
	SourceID      sql.NullString  `json:"source_id"`
	CreatedAt     time.Time       `json:"created_at"`
	UpdatedAt     time.Time       `json:"updated_at"`
}

type CreateUserParams 

type CreateUserParams struct {
	ID        string    `json:"id"`
	Name      string    `json:"name"`
	TeamID    string    `json:"team_id"`
	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`
}

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 DeactivateDefinitionsBySourceParams 

type DeactivateDefinitionsBySourceParams struct {
	UpdatedAt time.Time `json:"updated_at"`
	SourceID  string    `json:"source_id"`
}

type Definition 

type Definition struct {
	ID             string           `json:"id"`
	SourceID       string           `json:"source_id"`
	DefinitionType string           `json:"definition_type"`
	Name           string           `json:"name"`
	Scope          string           `json:"scope"`
	TeamID         sql.NullString   `json:"team_id"`
	Repo           sql.NullString   `json:"repo"`
	Path           string           `json:"path"`
	SourceCommit   string           `json:"source_commit"`
	ContentHash    string           `json:"content_hash"`
	Content        string           `json:"content"`
	Metadata       *json.RawMessage `json:"metadata"`
	Active         bool             `json:"active"`
	CreatedAt      time.Time        `json:"created_at"`
	UpdatedAt      time.Time        `json:"updated_at"`
}

type DefinitionChangeProposal 

type DefinitionChangeProposal struct {
	ID         string          `json:"id"`
	SourceID   string          `json:"source_id"`
	TaskID     sql.NullString  `json:"task_id"`
	Repo       string          `json:"repo"`
	Branch     string          `json:"branch"`
	BaseBranch string          `json:"base_branch"`
	PrNumber   int32           `json:"pr_number"`
	PrUrl      string          `json:"pr_url"`
	Title      string          `json:"title"`
	Body       string          `json:"body"`
	Files      json.RawMessage `json:"files"`
	Status     string          `json:"status"`
	CreatedAt  time.Time       `json:"created_at"`
	UpdatedAt  time.Time       `json:"updated_at"`
}

type DefinitionSource 

type DefinitionSource struct {
	ID         string         `json:"id"`
	Name       string         `json:"name"`
	Scope      string         `json:"scope"`
	TeamID     sql.NullString `json:"team_id"`
	Repo       sql.NullString `json:"repo"`
	RepoUrl    string         `json:"repo_url"`
	Branch     string         `json:"branch"`
	Path       string         `json:"path"`
	Enabled    bool           `json:"enabled"`
	CreatedAt  time.Time      `json:"created_at"`
	UpdatedAt  time.Time      `json:"updated_at"`
	LastSyncAt sql.NullTime   `json:"last_sync_at"`
}

type DefinitionSyncRun 

type DefinitionSyncRun struct {
	ID               string         `json:"id"`
	SourceID         string         `json:"source_id"`
	Status           string         `json:"status"`
	SourceCommit     sql.NullString `json:"source_commit"`
	DefinitionsCount int32          `json:"definitions_count"`
	Error            sql.NullString `json:"error"`
	StartedAt        time.Time      `json:"started_at"`
	EndedAt          time.Time      `json:"ended_at"`
	CreatedAt        time.Time      `json:"created_at"`
}

type DeleteEventCallbackParams 

type DeleteEventCallbackParams struct {
	Name   string         `json:"name"`
	TeamID sql.NullString `json:"team_id"`
}

type DeleteTokensByTeamParams 

type DeleteTokensByTeamParams struct {
	TeamID   string `json:"team_id"`
	TeamID_2 string `json:"team_id_2"`
}

type EventCallback 

type EventCallback struct {
	ID           string          `json:"id"`
	TeamID       sql.NullString  `json:"team_id"`
	Name         string          `json:"name"`
	EventType    string          `json:"event_type"`
	ActionType   string          `json:"action_type"`
	ActionConfig json.RawMessage `json:"action_config"`
	Enabled      bool            `json:"enabled"`
	CreatedAt    time.Time       `json:"created_at"`
	UpdatedAt    time.Time       `json:"updated_at"`
}

type ExecutionAttempt 

type ExecutionAttempt struct {
	ID                    string         `json:"id"`
	UserPromptID          string         `json:"user_prompt_id"`
	Sequence              int32          `json:"sequence"`
	Status                string         `json:"status"`
	RunnerID              sql.NullString `json:"runner_id"`
	RequiredRunnerID      sql.NullString `json:"required_runner_id"`
	ClaimedAt             sql.NullTime   `json:"claimed_at"`
	LeaseExpiresAt        sql.NullTime   `json:"lease_expires_at"`
	StartedAt             sql.NullTime   `json:"started_at"`
	EndedAt               sql.NullTime   `json:"ended_at"`
	WorkspacePath         sql.NullString `json:"workspace_path"`
	ContainerName         sql.NullString `json:"container_name"`
	HarnessExecutionID    sql.NullString `json:"harness_execution_id"`
	Summary               sql.NullString `json:"summary"`
	Error                 sql.NullString `json:"error"`
	ErrorCategory         sql.NullString `json:"error_category"`
	SessionExport         sql.NullString `json:"session_export"`
	TotalInputTokens      int64          `json:"total_input_tokens"`
	TotalOutputTokens     int64          `json:"total_output_tokens"`
	TotalCacheReadTokens  int64          `json:"total_cache_read_tokens"`
	TotalCacheWriteTokens int64          `json:"total_cache_write_tokens"`
	TotalReasoningTokens  int64          `json:"total_reasoning_tokens"`
	CostCents             int64          `json:"cost_cents"`
	CreatedAt             time.Time      `json:"created_at"`
	UpdatedAt             time.Time      `json:"updated_at"`
	TimeoutSec            int32          `json:"timeout_sec"`
	LastEventAt           sql.NullTime   `json:"last_event_at"`
	RunnerImageDigest     sql.NullString `json:"runner_image_digest"`
	ClaimID               string         `json:"claim_id"`
}

type ExpirePausedSessionsParams 

type ExpirePausedSessionsParams struct {
	EndedAt   sql.NullTime `json:"ended_at"`
	UpdatedAt time.Time    `json:"updated_at"`
	ExpiresAt sql.NullTime `json:"expires_at"`
}

type ExtendActiveExecutionAttemptTimeoutParams 

type ExtendActiveExecutionAttemptTimeoutParams struct {
	ExtensionSec int32     `json:"extension_sec"`
	UpdatedAt    time.Time `json:"updated_at"`
	TaskID       string    `json:"task_id"`
}

type FailAllExpiredExecutionAttemptsParams 

type FailAllExpiredExecutionAttemptsParams struct {
	EndedAt        sql.NullTime `json:"ended_at"`
	UpdatedAt      time.Time    `json:"updated_at"`
	LeaseExpiresAt sql.NullTime `json:"lease_expires_at"`
}

type FailExpiredExecutionAttemptsParams 

type FailExpiredExecutionAttemptsParams struct {
	EndedAt        sql.NullTime `json:"ended_at"`
	UpdatedAt      time.Time    `json:"updated_at"`
	LeaseExpiresAt sql.NullTime `json:"lease_expires_at"`
}

type FailExpiredLeasesParams 

type FailExpiredLeasesParams struct {
	EndedAt        sql.NullTime `json:"ended_at"`
	UpdatedAt      time.Time    `json:"updated_at"`
	LeaseExpiresAt sql.NullTime `json:"lease_expires_at"`
}

type FailPendingExecutionAttemptsForMissingRunnerParams 

type FailPendingExecutionAttemptsForMissingRunnerParams struct {
	EndedAt      sql.NullTime `json:"ended_at"`
	UpdatedAt    time.Time    `json:"updated_at"`
	StaleSeconds interface{}  `json:"stale_seconds"`
}

type FailPendingIsolationAttemptsWithoutCapableRunnerParams 

type FailPendingIsolationAttemptsWithoutCapableRunnerParams struct {
	EndedAt      sql.NullTime `json:"ended_at"`
	UpdatedAt    time.Time    `json:"updated_at"`
	StaleSeconds interface{}  `json:"stale_seconds"`
}

type FailPendingIsolationTasksParams 

type FailPendingIsolationTasksParams struct {
	EndedAt   sql.NullTime `json:"ended_at"`
	UpdatedAt time.Time    `json:"updated_at"`
}

type FailPendingResumeTasksForMissingRunnerParams 

type FailPendingResumeTasksForMissingRunnerParams struct {
	EndedAt   sql.NullTime `json:"ended_at"`
	UpdatedAt time.Time    `json:"updated_at"`
}

type FailPendingUserPromptsForUnavailableRunnerParams 

type FailPendingUserPromptsForUnavailableRunnerParams struct {
	EndedAt   sql.NullTime `json:"ended_at"`
	UpdatedAt time.Time    `json:"updated_at"`
}

type GetClaimableExecutionAttemptForUpdateParams 

type GetClaimableExecutionAttemptForUpdateParams struct {
	RunnerID         sql.NullString `json:"runner_id"`
	IsolationEnabled interface{}    `json:"isolation_enabled"`
}

type GetClaimableExecutionAttemptForUpdateRow 

type GetClaimableExecutionAttemptForUpdateRow struct {
	ExecutionAttemptID string `json:"execution_attempt_id"`
	Sequence           int32  `json:"sequence"`
	TaskID             string `json:"task_id"`
	UserPromptID       string `json:"user_prompt_id"`
	LockedTaskID       string `json:"locked_task_id"`
}

type GetDefinitionBySourceTypeNameParams 

type GetDefinitionBySourceTypeNameParams struct {
	SourceID       string      `json:"source_id"`
	DefinitionType string      `json:"definition_type"`
	Name           string      `json:"name"`
	ScopeFilter    interface{} `json:"scope_filter"`
}

type GetDefinitionChangeProposalByPRParams 

type GetDefinitionChangeProposalByPRParams struct {
	Repo     string `json:"repo"`
	PrNumber int32  `json:"pr_number"`
}

type GetEventCallbackByNameParams 

type GetEventCallbackByNameParams struct {
	Name   string         `json:"name"`
	TeamID sql.NullString `json:"team_id"`
}

type GetExecutionAttemptContextRow 

type GetExecutionAttemptContextRow struct {
	ExecutionAttemptID string `json:"execution_attempt_id"`
	UserPromptID       string `json:"user_prompt_id"`
	AgentSessionID     string `json:"agent_session_id"`
	TaskID             string `json:"task_id"`
}

type GetExecutionAttemptUsageByTaskRow 

type GetExecutionAttemptUsageByTaskRow struct {
	TotalInputTokens      int64 `json:"total_input_tokens"`
	TotalOutputTokens     int64 `json:"total_output_tokens"`
	TotalCacheReadTokens  int64 `json:"total_cache_read_tokens"`
	TotalCacheWriteTokens int64 `json:"total_cache_write_tokens"`
	TotalReasoningTokens  int64 `json:"total_reasoning_tokens"`
	CostCents             int64 `json:"cost_cents"`
}

type GetGitHubExecutionContextRow 

type GetGitHubExecutionContextRow struct {
	ExecutionAttemptID   string         `json:"execution_attempt_id"`
	UserPromptID         string         `json:"user_prompt_id"`
	AgentSessionID       string         `json:"agent_session_id"`
	TaskID               string         `json:"task_id"`
	RunnerID             sql.NullString `json:"runner_id"`
	ExecutionStatus      string         `json:"execution_status"`
	LeaseExpiresAt       sql.NullTime   `json:"lease_expires_at"`
	TaskStatus           string         `json:"task_status"`
	GithubRepo           sql.NullString `json:"github_repo"`
	GithubInstallationID sql.NullInt64  `json:"github_installation_id"`
	ClaimID              string         `json:"claim_id"`
}

type GetPausedSessionByArtifactParams 

type GetPausedSessionByArtifactParams struct {
	Repo         string        `json:"repo"`
	Number       sql.NullInt32 `json:"number"`
	ArtifactType string        `json:"artifact_type"`
}

type GetTokenByHashRow 

type GetTokenByHashRow struct {
	ID        string       `json:"id"`
	Name      string       `json:"name"`
	TokenHash string       `json:"token_hash"`
	UserID    string       `json:"user_id"`
	ExpiresAt sql.NullTime `json:"expires_at"`
	CreatedAt time.Time    `json:"created_at"`
	UpdatedAt time.Time    `json:"updated_at"`
	UserName  string       `json:"user_name"`
	TeamID    string       `json:"team_id"`
	TeamName  string       `json:"team_name"`
}

type GitIdentity 

type GitIdentity struct {
	ID             string    `json:"id"`
	TeamID         string    `json:"team_id"`
	Name           string    `json:"name"`
	GitAuthorName  string    `json:"git_author_name"`
	GitAuthorEmail string    `json:"git_author_email"`
	CredentialType string    `json:"credential_type"`
	IsDefault      bool      `json:"is_default"`
	CreatedAt      time.Time `json:"created_at"`
	UpdatedAt      time.Time `json:"updated_at"`
}

type InsertAgentSessionCheckpointParams 

type InsertAgentSessionCheckpointParams struct {
	ID             string         `json:"id"`
	AgentSessionID string         `json:"agent_session_id"`
	UserPromptID   sql.NullString `json:"user_prompt_id"`
	RunnerID       string         `json:"runner_id"`
	CheckpointPath string         `json:"checkpoint_path"`
	WorkspacePath  string         `json:"workspace_path"`
	ContainerName  sql.NullString `json:"container_name"`
	RunscVersion   sql.NullString `json:"runsc_version"`
	AgentImage     sql.NullString `json:"agent_image"`
	SizeBytes      int64          `json:"size_bytes"`
	Status         string         `json:"status"`
	Error          sql.NullString `json:"error"`
	CreatedAt      time.Time      `json:"created_at"`
	UpdatedAt      time.Time      `json:"updated_at"`
	ExpiresAt      sql.NullTime   `json:"expires_at"`
}

type InsertAgentSessionParams 

type InsertAgentSessionParams struct {
	ID                string           `json:"id"`
	TaskID            string           `json:"task_id"`
	Sequence          int32            `json:"sequence"`
	TeamID            sql.NullString   `json:"team_id"`
	Status            string           `json:"status"`
	ResumeMode        string           `json:"resume_mode"`
	IsolationRequired bool             `json:"isolation_required"`
	PauseReason       sql.NullString   `json:"pause_reason"`
	ExpiresAt         sql.NullTime     `json:"expires_at"`
	GitUrl            sql.NullString   `json:"git_url"`
	GitRef            sql.NullString   `json:"git_ref"`
	AgentImage        sql.NullString   `json:"agent_image"`
	Agent             sql.NullString   `json:"agent"`
	ProviderID        sql.NullString   `json:"provider_id"`
	ModelID           sql.NullString   `json:"model_id"`
	VariantID         sql.NullString   `json:"variant_id"`
	Harness           sql.NullString   `json:"harness"`
	Skills            json.RawMessage  `json:"skills"`
	McpEndpoints      *json.RawMessage `json:"mcp_endpoints"`
	Env               json.RawMessage  `json:"env"`
	CommitAuthorName  sql.NullString   `json:"commit_author_name"`
	CommitAuthorEmail sql.NullString   `json:"commit_author_email"`
	GitIdentityID     sql.NullString   `json:"git_identity_id"`
	SearchText        sql.NullString   `json:"search_text"`
	CreatedAt         time.Time        `json:"created_at"`
	UpdatedAt         time.Time        `json:"updated_at"`
	StartedAt         sql.NullTime     `json:"started_at"`
}

type InsertAuditLogParams 

type InsertAuditLogParams struct {
	ID               string           `json:"id"`
	EventType        string           `json:"event_type"`
	CreatedAt        time.Time        `json:"created_at"`
	SourceType       sql.NullString   `json:"source_type"`
	SourceID         sql.NullString   `json:"source_id"`
	TargetType       sql.NullString   `json:"target_type"`
	TargetID         sql.NullString   `json:"target_id"`
	Repo             sql.NullString   `json:"repo"`
	GithubEvent      sql.NullString   `json:"github_event"`
	GithubAction     sql.NullString   `json:"github_action"`
	GithubDeliveryID sql.NullString   `json:"github_delivery_id"`
	ParentEventID    sql.NullString   `json:"parent_event_id"`
	Detail           sql.NullString   `json:"detail"`
	SearchText       sql.NullString   `json:"search_text"`
	Payload          *json.RawMessage `json:"payload"`
	TokenID          sql.NullString   `json:"token_id"`
	TokenName        sql.NullString   `json:"token_name"`
}

type InsertDefinitionChangeProposalParams 

type InsertDefinitionChangeProposalParams struct {
	ID         string          `json:"id"`
	SourceID   string          `json:"source_id"`
	TaskID     sql.NullString  `json:"task_id"`
	Repo       string          `json:"repo"`
	Branch     string          `json:"branch"`
	BaseBranch string          `json:"base_branch"`
	PrNumber   int32           `json:"pr_number"`
	PrUrl      string          `json:"pr_url"`
	Title      string          `json:"title"`
	Body       string          `json:"body"`
	Files      json.RawMessage `json:"files"`
	Status     string          `json:"status"`
	CreatedAt  time.Time       `json:"created_at"`
	UpdatedAt  time.Time       `json:"updated_at"`
}

type InsertDefinitionSyncRunParams 

type InsertDefinitionSyncRunParams struct {
	ID               string         `json:"id"`
	SourceID         string         `json:"source_id"`
	Status           string         `json:"status"`
	SourceCommit     sql.NullString `json:"source_commit"`
	DefinitionsCount int32          `json:"definitions_count"`
	Error            sql.NullString `json:"error"`
	StartedAt        time.Time      `json:"started_at"`
	EndedAt          time.Time      `json:"ended_at"`
	CreatedAt        time.Time      `json:"created_at"`
}

type InsertEventCallbackParams 

type InsertEventCallbackParams struct {
	ID           string          `json:"id"`
	TeamID       sql.NullString  `json:"team_id"`
	Name         string          `json:"name"`
	EventType    string          `json:"event_type"`
	ActionType   string          `json:"action_type"`
	ActionConfig json.RawMessage `json:"action_config"`
	Enabled      bool            `json:"enabled"`
	CreatedAt    time.Time       `json:"created_at"`
	UpdatedAt    time.Time       `json:"updated_at"`
}

type InsertExecutionAttemptParams 

type InsertExecutionAttemptParams struct {
	ID               string         `json:"id"`
	UserPromptID     string         `json:"user_prompt_id"`
	Sequence         int32          `json:"sequence"`
	RunnerID         sql.NullString `json:"runner_id"`
	RequiredRunnerID sql.NullString `json:"required_runner_id"`
	ClaimedAt        sql.NullTime   `json:"claimed_at"`
	LeaseExpiresAt   sql.NullTime   `json:"lease_expires_at"`
	TimeoutSec       int32          `json:"timeout_sec"`
	LastEventAt      sql.NullTime   `json:"last_event_at"`
	StartedAt        sql.NullTime   `json:"started_at"`
	CreatedAt        time.Time      `json:"created_at"`
	UpdatedAt        time.Time      `json:"updated_at"`
}

type InsertModelCatalogParams 

type InsertModelCatalogParams struct {
	ID        string         `json:"id"`
	Name      string         `json:"name"`
	Active    bool           `json:"active"`
	Source    sql.NullString `json:"source"`
	Checksum  string         `json:"checksum"`
	Yaml      string         `json:"yaml"`
	CreatedAt time.Time      `json:"created_at"`
	UpdatedAt time.Time      `json:"updated_at"`
}

type InsertPendingExecutionAttemptParams 

type InsertPendingExecutionAttemptParams struct {
	ID               string         `json:"id"`
	UserPromptID     string         `json:"user_prompt_id"`
	Sequence         int32          `json:"sequence"`
	RequiredRunnerID sql.NullString `json:"required_runner_id"`
	TimeoutSec       int32          `json:"timeout_sec"`
	CreatedAt        time.Time      `json:"created_at"`
	UpdatedAt        time.Time      `json:"updated_at"`
}

type InsertTaskArtifactParams 

type InsertTaskArtifactParams struct {
	ID                 string         `json:"id"`
	TaskID             string         `json:"task_id"`
	AgentSessionID     sql.NullString `json:"agent_session_id"`
	UserPromptID       sql.NullString `json:"user_prompt_id"`
	ExecutionAttemptID string         `json:"execution_attempt_id"`
	ArtifactType       string         `json:"artifact_type"`
	Repo               string         `json:"repo"`
	Number             sql.NullInt32  `json:"number"`
	Url                sql.NullString `json:"url"`
	Ref                sql.NullString `json:"ref"`
	Sha                sql.NullString `json:"sha"`
	CreatedAt          time.Time      `json:"created_at"`
	DiscoveredAt       time.Time      `json:"discovered_at"`
	DiscoverySource    string         `json:"discovery_source"`
	SearchText         sql.NullString `json:"search_text"`
}

type InsertTaskEventParams 

type InsertTaskEventParams struct {
	ID                 string          `json:"id"`
	TaskID             string          `json:"task_id"`
	AgentSessionID     sql.NullString  `json:"agent_session_id"`
	UserPromptID       sql.NullString  `json:"user_prompt_id"`
	ExecutionAttemptID sql.NullString  `json:"execution_attempt_id"`
	Subject            string          `json:"subject"`
	Status             string          `json:"status"`
	EventType          string          `json:"event_type"`
	Payload            json.RawMessage `json:"payload"`
	CreatedAt          time.Time       `json:"created_at"`
}

type InsertTaskParams 

type InsertTaskParams struct {
	ID                   string         `json:"id"`
	TeamID               sql.NullString `json:"team_id"`
	Prompt               string         `json:"prompt"`
	GitUrl               sql.NullString `json:"git_url"`
	GitRef               sql.NullString `json:"git_ref"`
	GithubRepo           sql.NullString `json:"github_repo"`
	GithubInstallationID sql.NullInt64  `json:"github_installation_id"`
	TriggerName          sql.NullString `json:"trigger_name"`
	TriggerType          sql.NullString `json:"trigger_type"`
	SubmissionSource     string         `json:"submission_source"`
	SelfTestRunID        sql.NullString `json:"self_test_run_id"`
	SelfTestProfile      sql.NullString `json:"self_test_profile"`
	SelfTestCheck        sql.NullString `json:"self_test_check"`
	SelfTestNonce        sql.NullString `json:"self_test_nonce"`
	SearchText           sql.NullString `json:"search_text"`
	CreatedAt            time.Time      `json:"created_at"`
	UpdatedAt            time.Time      `json:"updated_at"`
}

type InsertTriggerRunParams 

type InsertTriggerRunParams struct {
	ID          string         `json:"id"`
	TriggerID   string         `json:"trigger_id"`
	TeamID      sql.NullString `json:"team_id"`
	TaskID      string         `json:"task_id"`
	Status      string         `json:"status"`
	TriggeredAt time.Time      `json:"triggered_at"`
	CreatedAt   time.Time      `json:"created_at"`
}

type InsertUserPromptParams 

type InsertUserPromptParams struct {
	ID                 string         `json:"id"`
	AgentSessionID     string         `json:"agent_session_id"`
	TaskID             string         `json:"task_id"`
	Sequence           int32          `json:"sequence"`
	Status             string         `json:"status"`
	Prompt             string         `json:"prompt"`
	SourceUserPromptID sql.NullString `json:"source_user_prompt_id"`
	CreatedAt          time.Time      `json:"created_at"`
	UpdatedAt          time.Time      `json:"updated_at"`
}

type IsRunnerAliveParams 

type IsRunnerAliveParams struct {
	RunnerID     string      `json:"runner_id"`
	StaleSeconds interface{} `json:"stale_seconds"`
}

type ListAgentSessionsByTeamsParams 

type ListAgentSessionsByTeamsParams struct {
	TeamIds      []string    `json:"team_ids"`
	StatusFilter interface{} `json:"status_filter"`
	PageOffset   int32       `json:"page_offset"`
	PageLimit    int32       `json:"page_limit"`
}

type ListAgentSessionsParams 

type ListAgentSessionsParams struct {
	TeamFilter   interface{} `json:"team_filter"`
	StatusFilter interface{} `json:"status_filter"`
	PageOffset   int32       `json:"page_offset"`
	PageLimit    int32       `json:"page_limit"`
}

type ListAuditLogParams 

type ListAuditLogParams struct {
	EventTypeFilter  string         `json:"event_type_filter"`
	SourceTypeFilter sql.NullString `json:"source_type_filter"`
	SourceIDFilter   sql.NullString `json:"source_id_filter"`
	TargetTypeFilter sql.NullString `json:"target_type_filter"`
	TargetIDFilter   sql.NullString `json:"target_id_filter"`
	RepoFilter       sql.NullString `json:"repo_filter"`
	CreatedAfter     sql.NullTime   `json:"created_after"`
	PageOffset       int32          `json:"page_offset"`
	PageLimit        int32          `json:"page_limit"`
}

type ListAuditLogRow 

type ListAuditLogRow struct {
	ID               string           `json:"id"`
	EventType        string           `json:"event_type"`
	CreatedAt        time.Time        `json:"created_at"`
	SourceType       sql.NullString   `json:"source_type"`
	SourceID         sql.NullString   `json:"source_id"`
	TargetType       sql.NullString   `json:"target_type"`
	TargetID         sql.NullString   `json:"target_id"`
	Repo             sql.NullString   `json:"repo"`
	GithubEvent      sql.NullString   `json:"github_event"`
	GithubAction     sql.NullString   `json:"github_action"`
	GithubDeliveryID sql.NullString   `json:"github_delivery_id"`
	ParentEventID    sql.NullString   `json:"parent_event_id"`
	Detail           sql.NullString   `json:"detail"`
	Payload          *json.RawMessage `json:"payload"`
	TokenID          sql.NullString   `json:"token_id"`
	TokenName        sql.NullString   `json:"token_name"`
}

type ListDefinitionChangeProposalsParams 

type ListDefinitionChangeProposalsParams struct {
	SourceIDFilter interface{} `json:"source_id_filter"`
	StatusFilter   interface{} `json:"status_filter"`
	PageLimit      int32       `json:"page_limit"`
}

type ListDefinitionSyncRunsParams 

type ListDefinitionSyncRunsParams struct {
	SourceIDFilter interface{} `json:"source_id_filter"`
	PageLimit      int32       `json:"page_limit"`
}

type ListDefinitionsParams 

type ListDefinitionsParams struct {
	DefinitionTypeFilter interface{} `json:"definition_type_filter"`
	SourceIDFilter       interface{} `json:"source_id_filter"`
	NameFilter           interface{} `json:"name_filter"`
}

type ListEnabledEventCallbacksForEventParams 

type ListEnabledEventCallbacksForEventParams struct {
	TeamID    sql.NullString `json:"team_id"`
	EventType string         `json:"event_type"`
}

type ListEventCallbacksByTeamsParams 

type ListEventCallbacksByTeamsParams struct {
	EnabledOnly     interface{} `json:"enabled_only"`
	EventTypeFilter interface{} `json:"event_type_filter"`
	TeamIds         []string    `json:"team_ids"`
	PageOffset      int32       `json:"page_offset"`
	PageLimit       int32       `json:"page_limit"`
}

type ListEventCallbacksParams 

type ListEventCallbacksParams struct {
	EnabledOnly     interface{}    `json:"enabled_only"`
	EventTypeFilter interface{}    `json:"event_type_filter"`
	IncludeGlobal   interface{}    `json:"include_global"`
	TeamID          sql.NullString `json:"team_id"`
	PageOffset      int32          `json:"page_offset"`
	PageLimit       int32          `json:"page_limit"`
}

type ListExecutionAttemptsForHeartbeatParams 

type ListExecutionAttemptsForHeartbeatParams struct {
	ExecutionIds []string       `json:"execution_ids"`
	RunnerID     sql.NullString `json:"runner_id"`
}

type ListExecutionAttemptsForHeartbeatRow 

type ListExecutionAttemptsForHeartbeatRow struct {
	ExecutionAttemptID string         `json:"execution_attempt_id"`
	ClaimID            string         `json:"claim_id"`
	Status             string         `json:"status"`
	Error              sql.NullString `json:"error"`
	TaskID             string         `json:"task_id"`
	AgentSessionID     string         `json:"agent_session_id"`
	UserPromptID       string         `json:"user_prompt_id"`
}

type ListLiveRunnersRow 

type ListLiveRunnersRow struct {
	ID             string          `json:"id"`
	Status         string          `json:"status"`
	ImageRef       sql.NullString  `json:"image_ref"`
	ImageDigest    sql.NullString  `json:"image_digest"`
	Version        sql.NullString  `json:"version"`
	MaxConcurrent  int32           `json:"max_concurrent"`
	RunningTasks   int32           `json:"running_tasks"`
	AvailableSlots int32           `json:"available_slots"`
	TotalStarted   int64           `json:"total_started"`
	TotalCompleted int64           `json:"total_completed"`
	TotalErrors    int64           `json:"total_errors"`
	StartedAt      sql.NullTime    `json:"started_at"`
	FirstSeenAt    time.Time       `json:"first_seen_at"`
	LastSeenAt     time.Time       `json:"last_seen_at"`
	UpdatedAt      time.Time       `json:"updated_at"`
	Metadata       json.RawMessage `json:"metadata"`
}

type ListReclaimableExecutionAttemptsForUpdateRow 

type ListReclaimableExecutionAttemptsForUpdateRow struct {
	ExecutionAttemptID string         `json:"execution_attempt_id"`
	TaskID             string         `json:"task_id"`
	UserPromptID       string         `json:"user_prompt_id"`
	LockedTaskID       string         `json:"locked_task_id"`
	TeamID             sql.NullString `json:"team_id"`
	RunnerID           sql.NullString `json:"runner_id"`
	Attempt            int32          `json:"attempt"`
	MaxAttempts        int32          `json:"max_attempts"`
	TimeoutSec         int32          `json:"timeout_sec"`
	LeaseExpiresAt     sql.NullTime   `json:"lease_expires_at"`
}

type ListTaskArtifactsParams 

type ListTaskArtifactsParams struct {
	TaskID             string         `json:"task_id"`
	AgentSessionID     sql.NullString `json:"agent_session_id"`
	UserPromptID       sql.NullString `json:"user_prompt_id"`
	ExecutionAttemptID string         `json:"execution_attempt_id"`
	ArtifactType       string         `json:"artifact_type"`
	Repo               string         `json:"repo"`
	PageOffset         int32          `json:"page_offset"`
	PageLimit          int32          `json:"page_limit"`
}

type ListTaskArtifactsRow 

type ListTaskArtifactsRow struct {
	ID                 string         `json:"id"`
	TaskID             string         `json:"task_id"`
	AgentSessionID     sql.NullString `json:"agent_session_id"`
	UserPromptID       sql.NullString `json:"user_prompt_id"`
	ExecutionAttemptID string         `json:"execution_attempt_id"`
	ArtifactType       string         `json:"artifact_type"`
	Repo               string         `json:"repo"`
	Number             sql.NullInt32  `json:"number"`
	Url                sql.NullString `json:"url"`
	Ref                sql.NullString `json:"ref"`
	Sha                sql.NullString `json:"sha"`
	CreatedAt          time.Time      `json:"created_at"`
	DiscoveredAt       time.Time      `json:"discovered_at"`
	DiscoverySource    string         `json:"discovery_source"`
}

type ListTaskEventsParams 

type ListTaskEventsParams struct {
	TaskID string `json:"task_id"`
	Limit  int32  `json:"limit"`
	Offset int32  `json:"offset"`
}

type ListTaskEventsSinceParams 

type ListTaskEventsSinceParams struct {
	TaskID    string    `json:"task_id"`
	CreatedAt time.Time `json:"created_at"`
}

type ListTasksByStatusAndTeamParams 

type ListTasksByStatusAndTeamParams struct {
	TeamID            sql.NullString `json:"team_id"`
	StatusFilter      interface{}    `json:"status_filter"`
	TriggerNameFilter interface{}    `json:"trigger_name_filter"`
	AgentFilter       interface{}    `json:"agent_filter"`
	PageOffset        int32          `json:"page_offset"`
	PageLimit         int32          `json:"page_limit"`
}

type ListTasksByStatusAndTeamsParams 

type ListTasksByStatusAndTeamsParams struct {
	TeamIds           []string    `json:"team_ids"`
	StatusFilter      interface{} `json:"status_filter"`
	TriggerNameFilter interface{} `json:"trigger_name_filter"`
	AgentFilter       interface{} `json:"agent_filter"`
	PageOffset        int32       `json:"page_offset"`
	PageLimit         int32       `json:"page_limit"`
}

type ListTasksByStatusParams 

type ListTasksByStatusParams struct {
	StatusFilter      interface{} `json:"status_filter"`
	TriggerNameFilter interface{} `json:"trigger_name_filter"`
	AgentFilter       interface{} `json:"agent_filter"`
	PageOffset        int32       `json:"page_offset"`
	PageLimit         int32       `json:"page_limit"`
}

type ListTokensRow 

type ListTokensRow struct {
	ID        string       `json:"id"`
	Name      string       `json:"name"`
	TokenHash string       `json:"token_hash"`
	UserID    string       `json:"user_id"`
	ExpiresAt sql.NullTime `json:"expires_at"`
	CreatedAt time.Time    `json:"created_at"`
	UpdatedAt time.Time    `json:"updated_at"`
	UserName  string       `json:"user_name"`
	TeamID    string       `json:"team_id"`
	TeamName  string       `json:"team_name"`
	TeamNames string       `json:"team_names"`
}

type ListTriggerRunsByTeamParams 

type ListTriggerRunsByTeamParams struct {
	TeamID     sql.NullString `json:"team_id"`
	PageOffset int32          `json:"page_offset"`
	PageLimit  int32          `json:"page_limit"`
}

type ListTriggerRunsByTeamRow 

type ListTriggerRunsByTeamRow struct {
	ID          string    `json:"id"`
	TriggerID   string    `json:"trigger_id"`
	TriggerName string    `json:"trigger_name"`
	TaskID      string    `json:"task_id"`
	Status      string    `json:"status"`
	TriggeredAt time.Time `json:"triggered_at"`
	CreatedAt   time.Time `json:"created_at"`
}

type ListTriggerRunsByTeamsParams 

type ListTriggerRunsByTeamsParams struct {
	TeamIds    []string `json:"team_ids"`
	PageOffset int32    `json:"page_offset"`
	PageLimit  int32    `json:"page_limit"`
}

type ListTriggerRunsByTeamsRow 

type ListTriggerRunsByTeamsRow struct {
	ID          string    `json:"id"`
	TriggerID   string    `json:"trigger_id"`
	TriggerName string    `json:"trigger_name"`
	TaskID      string    `json:"task_id"`
	Status      string    `json:"status"`
	TriggeredAt time.Time `json:"triggered_at"`
	CreatedAt   time.Time `json:"created_at"`
}

type ListTriggerRunsByTriggerParams 

type ListTriggerRunsByTriggerParams struct {
	TriggerID string `json:"trigger_id"`
	Limit     int32  `json:"limit"`
	Offset    int32  `json:"offset"`
}

type ListTriggerRunsByTriggerRow 

type ListTriggerRunsByTriggerRow struct {
	ID          string    `json:"id"`
	TriggerID   string    `json:"trigger_id"`
	TriggerName string    `json:"trigger_name"`
	TaskID      string    `json:"task_id"`
	Status      string    `json:"status"`
	TriggeredAt time.Time `json:"triggered_at"`
	CreatedAt   time.Time `json:"created_at"`
}

type ListUsersByTeamRow 

type ListUsersByTeamRow struct {
	ID        string    `json:"id"`
	Name      string    `json:"name"`
	TeamID    string    `json:"team_id"`
	TeamName  string    `json:"team_name"`
	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`
}

type ListUsersRow 

type ListUsersRow struct {
	ID        string    `json:"id"`
	Name      string    `json:"name"`
	TeamID    string    `json:"team_id"`
	TeamName  string    `json:"team_name"`
	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`
}

type MarkAgentSessionResumingParams 

type MarkAgentSessionResumingParams struct {
	Status    string    `json:"status"`
	UpdatedAt time.Time `json:"updated_at"`
	ID        string    `json:"id"`
}

type MarkAgentSessionTerminalByTaskParams 

type MarkAgentSessionTerminalByTaskParams struct {
	Status           string         `json:"status"`
	Summary          sql.NullString `json:"summary"`
	Error            sql.NullString `json:"error"`
	EndedAt          sql.NullTime   `json:"ended_at"`
	UpdatedAt        time.Time      `json:"updated_at"`
	TaskID           string         `json:"task_id"`
	HarnessSessionID interface{}    `json:"harness_session_id"`
}

type MarkDefinitionSourceSyncedParams 

type MarkDefinitionSourceSyncedParams struct {
	LastSyncAt sql.NullTime `json:"last_sync_at"`
	UpdatedAt  time.Time    `json:"updated_at"`
	ID         string       `json:"id"`
}

type MarkExecutionAttemptClaimedParams 

type MarkExecutionAttemptClaimedParams struct {
	RunnerID       sql.NullString `json:"runner_id"`
	ClaimID        string         `json:"claim_id"`
	ClaimedAt      sql.NullTime   `json:"claimed_at"`
	LeaseExpiresAt sql.NullTime   `json:"lease_expires_at"`
	StartedAt      sql.NullTime   `json:"started_at"`
	LastEventAt    sql.NullTime   `json:"last_event_at"`
	UpdatedAt      time.Time      `json:"updated_at"`
	ID             string         `json:"id"`
}

type MarkExecutionAttemptLostParams 

type MarkExecutionAttemptLostParams struct {
	Error     sql.NullString `json:"error"`
	EndedAt   sql.NullTime   `json:"ended_at"`
	UpdatedAt time.Time      `json:"updated_at"`
	ID        string         `json:"id"`
}

type MarkResumingSessionsFailedForUnavailableRunnerParams 

type MarkResumingSessionsFailedForUnavailableRunnerParams struct {
	EndedAt   sql.NullTime `json:"ended_at"`
	UpdatedAt time.Time    `json:"updated_at"`
}

type MarkTaskRunningParams 

type MarkTaskRunningParams struct {
	UpdatedAt time.Time `json:"updated_at"`
	ID        string    `json:"id"`
}

type MarkUserPromptRunningByTaskParams 

type MarkUserPromptRunningByTaskParams struct {
	StartedAt sql.NullTime `json:"started_at"`
	UpdatedAt time.Time    `json:"updated_at"`
	TaskID    string       `json:"task_id"`
}

type MarkUserPromptTerminalByTaskParams 

type MarkUserPromptTerminalByTaskParams struct {
	Status        string         `json:"status"`
	Summary       sql.NullString `json:"summary"`
	Error         sql.NullString `json:"error"`
	SessionExport sql.NullString `json:"session_export"`
	StartedAt     sql.NullTime   `json:"started_at"`
	EndedAt       sql.NullTime   `json:"ended_at"`
	UpdatedAt     time.Time      `json:"updated_at"`
	TaskID        string         `json:"task_id"`
}

type ModelCatalog 

type ModelCatalog struct {
	ID        string         `json:"id"`
	Name      string         `json:"name"`
	Active    bool           `json:"active"`
	Source    sql.NullString `json:"source"`
	Checksum  string         `json:"checksum"`
	Yaml      string         `json:"yaml"`
	CreatedAt time.Time      `json:"created_at"`
	UpdatedAt time.Time      `json:"updated_at"`
}

type PauseAgentSessionByTaskIDParams 

type PauseAgentSessionByTaskIDParams struct {
	Status           string       `json:"status"`
	PausedAt         sql.NullTime `json:"paused_at"`
	UpdatedAt        time.Time    `json:"updated_at"`
	TaskID           string       `json:"task_id"`
	PinnedRunnerID   interface{}  `json:"pinned_runner_id"`
	CheckpointID     interface{}  `json:"checkpoint_id"`
	WorkspacePath    interface{}  `json:"workspace_path"`
	ContainerName    interface{}  `json:"container_name"`
	HarnessSessionID interface{}  `json:"harness_session_id"`
}

type PinTaskGitHubInstallationParams 

type PinTaskGitHubInstallationParams struct {
	GithubInstallationID sql.NullInt64 `json:"github_installation_id"`
	UpdatedAt            time.Time     `json:"updated_at"`
	ID                   string        `json:"id"`
}

type Queries 

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

func New 

func New(db DBTX) *Queries

func (*Queries) AbandonAgentSession 

func (q *Queries) AbandonAgentSession(ctx context.Context, arg AbandonAgentSessionParams) (int64, error)

func (*Queries) AbandonUserPrompt 

func (q *Queries) AbandonUserPrompt(ctx context.Context, arg AbandonUserPromptParams) (int64, error)

func (*Queries) AddTokenTeam 

func (q *Queries) AddTokenTeam(ctx context.Context, arg AddTokenTeamParams) error

func (*Queries) AddUserTeamMembership 

func (q *Queries) AddUserTeamMembership(ctx context.Context, arg AddUserTeamMembershipParams) error

func (*Queries) CancelExecutionAttemptsByTask 

func (q *Queries) CancelExecutionAttemptsByTask(ctx context.Context, arg CancelExecutionAttemptsByTaskParams) (int64, error)

func (*Queries) CancelPendingExecutionAttempts 

func (q *Queries) CancelPendingExecutionAttempts(ctx context.Context, arg CancelPendingExecutionAttemptsParams) (int64, error)

func (*Queries) CancelTask 

func (q *Queries) CancelTask(ctx context.Context, arg CancelTaskParams) (int64, error)

func (*Queries) ClearExpiredExecutionAttemptExports 

func (q *Queries) ClearExpiredExecutionAttemptExports(ctx context.Context, ttlSeconds interface{}) (int64, error)

func (*Queries) ClearExpiredSessionCheckpoints 

func (q *Queries) ClearExpiredSessionCheckpoints(ctx context.Context, ttlSeconds interface{}) (int64, error)

func (*Queries) ClearExpiredUserPromptExports 

func (q *Queries) ClearExpiredUserPromptExports(ctx context.Context, ttlSeconds interface{}) (int64, error)

func (*Queries) ClearPendingTasks 

func (q *Queries) ClearPendingTasks(ctx context.Context, arg ClearPendingTasksParams) (int64, error)

func (*Queries) CountExecutionAttemptsByTask 

func (q *Queries) CountExecutionAttemptsByTask(ctx context.Context, taskID string) (int64, error)

func (*Queries) CreateTeam 

func (q *Queries) CreateTeam(ctx context.Context, arg CreateTeamParams) error

func (*Queries) CreateToken 

func (q *Queries) CreateToken(ctx context.Context, arg CreateTokenParams) error

func (*Queries) CreateTrigger 

func (q *Queries) CreateTrigger(ctx context.Context, arg CreateTriggerParams) error

func (*Queries) CreateUser 

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

func (*Queries) DeactivateDefinitionsBySource 

func (q *Queries) DeactivateDefinitionsBySource(ctx context.Context, arg DeactivateDefinitionsBySourceParams) error

func (*Queries) DeactivateModelCatalogs 

func (q *Queries) DeactivateModelCatalogs(ctx context.Context, updatedAt time.Time) error

func (*Queries) DeleteEventCallback 

func (q *Queries) DeleteEventCallback(ctx context.Context, arg DeleteEventCallbackParams) (int64, error)

func (*Queries) DeleteTeam 

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

func (*Queries) DeleteToken 

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

func (*Queries) DeleteTokenTeamsByTeam 

func (q *Queries) DeleteTokenTeamsByTeam(ctx context.Context, teamID string) error

func (*Queries) DeleteTokensByTeam 

func (q *Queries) DeleteTokensByTeam(ctx context.Context, arg DeleteTokensByTeamParams) error

func (*Queries) DeleteTrigger 

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

func (*Queries) DeleteTriggersBySource 

func (q *Queries) DeleteTriggersBySource(ctx context.Context, sourceID sql.NullString) error

func (*Queries) DeleteUserTeamMembershipsByTeam 

func (q *Queries) DeleteUserTeamMembershipsByTeam(ctx context.Context, teamID string) error

func (*Queries) DeleteUsersByTeam 

func (q *Queries) DeleteUsersByTeam(ctx context.Context, teamID string) error

func (*Queries) ExpirePausedSessions 

func (q *Queries) ExpirePausedSessions(ctx context.Context, arg ExpirePausedSessionsParams) (int64, error)

func (*Queries) ExtendActiveExecutionAttemptTimeout 

func (q *Queries) ExtendActiveExecutionAttemptTimeout(ctx context.Context, arg ExtendActiveExecutionAttemptTimeoutParams) (int64, error)

func (*Queries) FailAllExpiredExecutionAttempts 

func (q *Queries) FailAllExpiredExecutionAttempts(ctx context.Context, arg FailAllExpiredExecutionAttemptsParams) (int64, error)

func (*Queries) FailExpiredExecutionAttempts 

func (q *Queries) FailExpiredExecutionAttempts(ctx context.Context, arg FailExpiredExecutionAttemptsParams) (int64, error)

func (*Queries) FailExpiredLeases 

func (q *Queries) FailExpiredLeases(ctx context.Context, arg FailExpiredLeasesParams) (int64, error)

func (*Queries) FailPendingExecutionAttemptsForMissingRunner 

func (q *Queries) FailPendingExecutionAttemptsForMissingRunner(ctx context.Context, arg FailPendingExecutionAttemptsForMissingRunnerParams) (int64, error)

func (*Queries) FailPendingIsolationAttemptsWithoutCapableRunner 

func (q *Queries) FailPendingIsolationAttemptsWithoutCapableRunner(ctx context.Context, arg FailPendingIsolationAttemptsWithoutCapableRunnerParams) (int64, error)

Fails pending attempts whose session requires enforced isolation when no live runner advertises isolation_enabled. The task must never run unsandboxed; without a capable runner it fails fast with error_category isolation_unavailable instead of waiting forever. See issue #291.

func (*Queries) FailPendingIsolationTasks 

func (q *Queries) FailPendingIsolationTasks(ctx context.Context, arg FailPendingIsolationTasksParams) (int64, error)

Marks pending tasks whose execution attempts failed with isolation_unavailable as terminal errors. Companion to FailPendingIsolationAttemptsWithoutCapableRunner (issue #291).

func (*Queries) FailPendingResumeTasksForMissingRunner 

func (q *Queries) FailPendingResumeTasksForMissingRunner(ctx context.Context, arg FailPendingResumeTasksForMissingRunnerParams) (int64, error)

func (*Queries) FailPendingUserPromptsForUnavailableRunner 

func (q *Queries) FailPendingUserPromptsForUnavailableRunner(ctx context.Context, arg FailPendingUserPromptsForUnavailableRunnerParams) (int64, error)

func (*Queries) GetActiveModelCatalog 

func (q *Queries) GetActiveModelCatalog(ctx context.Context) (ModelCatalog, error)

func (*Queries) GetAgentSessionByID 

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

func (*Queries) GetAgentSessionByTaskID 

func (q *Queries) GetAgentSessionByTaskID(ctx context.Context, taskID string) (AgentSession, error)

func (*Queries) GetClaimableExecutionAttemptForUpdate 

func (q *Queries) GetClaimableExecutionAttemptForUpdate(ctx context.Context, arg GetClaimableExecutionAttemptForUpdateParams) (GetClaimableExecutionAttemptForUpdateRow, error)

func (*Queries) GetDefinitionBySourceTypeName 

func (q *Queries) GetDefinitionBySourceTypeName(ctx context.Context, arg GetDefinitionBySourceTypeNameParams) (Definition, error)

func (*Queries) GetDefinitionChangeProposal 

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

func (*Queries) GetDefinitionChangeProposalByPR 

func (q *Queries) GetDefinitionChangeProposalByPR(ctx context.Context, arg GetDefinitionChangeProposalByPRParams) (DefinitionChangeProposal, error)

func (*Queries) GetDefinitionSource 

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

func (*Queries) GetDefinitionSourceByName 

func (q *Queries) GetDefinitionSourceByName(ctx context.Context, name string) (DefinitionSource, error)

func (*Queries) GetEventCallbackByID 

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

func (*Queries) GetEventCallbackByName 

func (q *Queries) GetEventCallbackByName(ctx context.Context, arg GetEventCallbackByNameParams) (EventCallback, error)

func (*Queries) GetExecutionAttemptByID 

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

func (*Queries) GetExecutionAttemptContext 

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

func (*Queries) GetExecutionAttemptUsageByTask 

func (q *Queries) GetExecutionAttemptUsageByTask(ctx context.Context, taskID string) (GetExecutionAttemptUsageByTaskRow, error)

func (*Queries) GetGitHubExecutionContext 

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

func (*Queries) GetLatestAgentSessionCheckpoint 

func (q *Queries) GetLatestAgentSessionCheckpoint(ctx context.Context, agentSessionID string) (AgentSessionCheckpoint, error)

func (*Queries) GetLatestAgentSessionCheckpointByTaskID 

func (q *Queries) GetLatestAgentSessionCheckpointByTaskID(ctx context.Context, taskID string) (AgentSessionCheckpoint, error)

func (*Queries) GetLatestTaskEvent 

func (q *Queries) GetLatestTaskEvent(ctx context.Context, taskID string) (TaskEvent, error)

func (*Queries) GetModelCatalogByName 

func (q *Queries) GetModelCatalogByName(ctx context.Context, name string) (ModelCatalog, error)

func (*Queries) GetNextAgentSessionSequence 

func (q *Queries) GetNextAgentSessionSequence(ctx context.Context, taskID string) (int32, error)

func (*Queries) GetNextExecutionAttemptSequence 

func (q *Queries) GetNextExecutionAttemptSequence(ctx context.Context, userPromptID string) (int32, error)

func (*Queries) GetNextUserPromptSequence 

func (q *Queries) GetNextUserPromptSequence(ctx context.Context, agentSessionID string) (int32, error)

func (*Queries) GetPausedSessionByArtifact 

func (q *Queries) GetPausedSessionByArtifact(ctx context.Context, arg GetPausedSessionByArtifactParams) (AgentSession, error)

func (*Queries) GetRunnerHeartbeatMetadata 

func (q *Queries) GetRunnerHeartbeatMetadata(ctx context.Context, id string) (json.RawMessage, error)

func (*Queries) GetRunnerIsolationEnabled 

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

func (*Queries) GetTaskByID 

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

func (*Queries) GetTeamByID 

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

func (*Queries) GetTeamByName 

func (q *Queries) GetTeamByName(ctx context.Context, name string) (Team, error)

func (*Queries) GetTokenByHash 

func (q *Queries) GetTokenByHash(ctx context.Context, tokenHash string) (GetTokenByHashRow, error)

func (*Queries) GetTriggerByID 

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

func (*Queries) GetTriggerByName 

func (q *Queries) GetTriggerByName(ctx context.Context, name string) (Trigger, error)

func (*Queries) GetUserByID 

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

func (*Queries) GetUserPromptByID 

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

func (*Queries) GetUserPromptByTaskID 

func (q *Queries) GetUserPromptByTaskID(ctx context.Context, taskID string) (UserPrompt, error)

func (*Queries) InsertAgentSession 

func (q *Queries) InsertAgentSession(ctx context.Context, arg InsertAgentSessionParams) error

func (*Queries) InsertAgentSessionCheckpoint 

func (q *Queries) InsertAgentSessionCheckpoint(ctx context.Context, arg InsertAgentSessionCheckpointParams) error

func (*Queries) InsertAuditLog 

func (q *Queries) InsertAuditLog(ctx context.Context, arg InsertAuditLogParams) error

func (*Queries) InsertDefinitionChangeProposal 

func (q *Queries) InsertDefinitionChangeProposal(ctx context.Context, arg InsertDefinitionChangeProposalParams) error

func (*Queries) InsertDefinitionSyncRun 

func (q *Queries) InsertDefinitionSyncRun(ctx context.Context, arg InsertDefinitionSyncRunParams) error

func (*Queries) InsertEventCallback 

func (q *Queries) InsertEventCallback(ctx context.Context, arg InsertEventCallbackParams) error

func (*Queries) InsertExecutionAttempt 

func (q *Queries) InsertExecutionAttempt(ctx context.Context, arg InsertExecutionAttemptParams) error

func (*Queries) InsertModelCatalog 

func (q *Queries) InsertModelCatalog(ctx context.Context, arg InsertModelCatalogParams) error

func (*Queries) InsertPendingExecutionAttempt 

func (q *Queries) InsertPendingExecutionAttempt(ctx context.Context, arg InsertPendingExecutionAttemptParams) error

func (*Queries) InsertTask 

func (q *Queries) InsertTask(ctx context.Context, arg InsertTaskParams) error

func (*Queries) InsertTaskArtifact 

func (q *Queries) InsertTaskArtifact(ctx context.Context, arg InsertTaskArtifactParams) error

func (*Queries) InsertTaskEvent 

func (q *Queries) InsertTaskEvent(ctx context.Context, arg InsertTaskEventParams) error

func (*Queries) InsertTriggerRun 

func (q *Queries) InsertTriggerRun(ctx context.Context, arg InsertTriggerRunParams) error

func (*Queries) InsertUserPrompt 

func (q *Queries) InsertUserPrompt(ctx context.Context, arg InsertUserPromptParams) error

func (*Queries) IsRunnerAlive 

func (q *Queries) IsRunnerAlive(ctx context.Context, arg IsRunnerAliveParams) (bool, error)

func (*Queries) ListAgentSessions 

func (q *Queries) ListAgentSessions(ctx context.Context, arg ListAgentSessionsParams) ([]AgentSession, error)

func (*Queries) ListAgentSessionsByTeams 

func (q *Queries) ListAgentSessionsByTeams(ctx context.Context, arg ListAgentSessionsByTeamsParams) ([]AgentSession, error)

func (*Queries) ListAuditLog 

func (q *Queries) ListAuditLog(ctx context.Context, arg ListAuditLogParams) ([]ListAuditLogRow, error)

func (*Queries) ListDefinitionChangeProposals 

func (q *Queries) ListDefinitionChangeProposals(ctx context.Context, arg ListDefinitionChangeProposalsParams) ([]DefinitionChangeProposal, error)

func (*Queries) ListDefinitionSources 

func (q *Queries) ListDefinitionSources(ctx context.Context) ([]DefinitionSource, error)

func (*Queries) ListDefinitionSyncRuns 

func (q *Queries) ListDefinitionSyncRuns(ctx context.Context, arg ListDefinitionSyncRunsParams) ([]DefinitionSyncRun, error)

func (*Queries) ListDefinitions 

func (q *Queries) ListDefinitions(ctx context.Context, arg ListDefinitionsParams) ([]Definition, error)

func (*Queries) ListEnabledEventCallbacksForEvent 

func (q *Queries) ListEnabledEventCallbacksForEvent(ctx context.Context, arg ListEnabledEventCallbacksForEventParams) ([]EventCallback, error)

func (*Queries) ListEnabledIssueTriggersByRepo 

func (q *Queries) ListEnabledIssueTriggersByRepo(ctx context.Context, repo json.RawMessage) ([]Trigger, error)

func (*Queries) ListEnabledPRReviewTriggersByRepo 

func (q *Queries) ListEnabledPRReviewTriggersByRepo(ctx context.Context, repo json.RawMessage) ([]Trigger, error)

func (*Queries) ListEnabledTriggers 

func (q *Queries) ListEnabledTriggers(ctx context.Context) ([]Trigger, error)

func (*Queries) ListEnabledTriggersByTeam 

func (q *Queries) ListEnabledTriggersByTeam(ctx context.Context, teamID sql.NullString) ([]Trigger, error)

func (*Queries) ListEnabledTriggersByTeams 

func (q *Queries) ListEnabledTriggersByTeams(ctx context.Context, teamIds []string) ([]Trigger, error)

func (*Queries) ListEnabledTriggersByType 

func (q *Queries) ListEnabledTriggersByType(ctx context.Context, triggerType string) ([]Trigger, error)

func (*Queries) ListEventCallbacks 

func (q *Queries) ListEventCallbacks(ctx context.Context, arg ListEventCallbacksParams) ([]EventCallback, error)

func (*Queries) ListEventCallbacksByTeams 

func (q *Queries) ListEventCallbacksByTeams(ctx context.Context, arg ListEventCallbacksByTeamsParams) ([]EventCallback, error)

func (*Queries) ListExecutionAttemptsByPrompt 

func (q *Queries) ListExecutionAttemptsByPrompt(ctx context.Context, userPromptID string) ([]ExecutionAttempt, error)

func (*Queries) ListExecutionAttemptsForHeartbeat 

func (q *Queries) ListExecutionAttemptsForHeartbeat(ctx context.Context, arg ListExecutionAttemptsForHeartbeatParams) ([]ListExecutionAttemptsForHeartbeatRow, error)

func (*Queries) ListLiveRunners 

func (q *Queries) ListLiveRunners(ctx context.Context, lastSeenAt time.Time) ([]ListLiveRunnersRow, error)

func (*Queries) ListModelCatalogs 

func (q *Queries) ListModelCatalogs(ctx context.Context) ([]ModelCatalog, error)

func (*Queries) ListReclaimableExecutionAttemptsForUpdate 

func (q *Queries) ListReclaimableExecutionAttemptsForUpdate(ctx context.Context, leaseExpiresAt sql.NullTime) ([]ListReclaimableExecutionAttemptsForUpdateRow, error)

func (*Queries) ListTaskArtifacts 

func (q *Queries) ListTaskArtifacts(ctx context.Context, arg ListTaskArtifactsParams) ([]ListTaskArtifactsRow, error)

func (*Queries) ListTaskEvents 

func (q *Queries) ListTaskEvents(ctx context.Context, arg ListTaskEventsParams) ([]TaskEvent, error)

func (*Queries) ListTaskEventsSince 

func (q *Queries) ListTaskEventsSince(ctx context.Context, arg ListTaskEventsSinceParams) ([]TaskEvent, error)

func (*Queries) ListTasksBySelfTestRun 

func (q *Queries) ListTasksBySelfTestRun(ctx context.Context, selfTestRunID sql.NullString) ([]Task, error)

func (*Queries) ListTasksByStatus 

func (q *Queries) ListTasksByStatus(ctx context.Context, arg ListTasksByStatusParams) ([]Task, error)

func (*Queries) ListTasksByStatusAndTeam 

func (q *Queries) ListTasksByStatusAndTeam(ctx context.Context, arg ListTasksByStatusAndTeamParams) ([]Task, error)

func (*Queries) ListTasksByStatusAndTeams 

func (q *Queries) ListTasksByStatusAndTeams(ctx context.Context, arg ListTasksByStatusAndTeamsParams) ([]Task, error)

func (*Queries) ListTeams 

func (q *Queries) ListTeams(ctx context.Context) ([]Team, error)

func (*Queries) ListTokens 

func (q *Queries) ListTokens(ctx context.Context) ([]ListTokensRow, error)

func (*Queries) ListTriggerRunsByTeam 

func (q *Queries) ListTriggerRunsByTeam(ctx context.Context, arg ListTriggerRunsByTeamParams) ([]ListTriggerRunsByTeamRow, error)

func (*Queries) ListTriggerRunsByTeams 

func (q *Queries) ListTriggerRunsByTeams(ctx context.Context, arg ListTriggerRunsByTeamsParams) ([]ListTriggerRunsByTeamsRow, error)

func (*Queries) ListTriggerRunsByTrigger 

func (q *Queries) ListTriggerRunsByTrigger(ctx context.Context, arg ListTriggerRunsByTriggerParams) ([]ListTriggerRunsByTriggerRow, error)

func (*Queries) ListTriggers 

func (q *Queries) ListTriggers(ctx context.Context) ([]Trigger, error)

func (*Queries) ListTriggersByTeam 

func (q *Queries) ListTriggersByTeam(ctx context.Context, teamID sql.NullString) ([]Trigger, error)

func (*Queries) ListTriggersByTeams 

func (q *Queries) ListTriggersByTeams(ctx context.Context, teamIds []string) ([]Trigger, error)

func (*Queries) ListUserPromptsBySession 

func (q *Queries) ListUserPromptsBySession(ctx context.Context, agentSessionID string) ([]UserPrompt, error)

func (*Queries) ListUsers 

func (q *Queries) ListUsers(ctx context.Context) ([]ListUsersRow, error)

func (*Queries) ListUsersByTeam 

func (q *Queries) ListUsersByTeam(ctx context.Context, teamID string) ([]ListUsersByTeamRow, error)

func (*Queries) MarkAgentSessionResuming 

func (q *Queries) MarkAgentSessionResuming(ctx context.Context, arg MarkAgentSessionResumingParams) (int64, error)

func (*Queries) MarkAgentSessionTerminalByTask 

func (q *Queries) MarkAgentSessionTerminalByTask(ctx context.Context, arg MarkAgentSessionTerminalByTaskParams) (int64, error)

func (*Queries) MarkDefinitionSourceSynced 

func (q *Queries) MarkDefinitionSourceSynced(ctx context.Context, arg MarkDefinitionSourceSyncedParams) error

func (*Queries) MarkExecutionAttemptClaimed 

func (q *Queries) MarkExecutionAttemptClaimed(ctx context.Context, arg MarkExecutionAttemptClaimedParams) (int64, error)

func (*Queries) MarkExecutionAttemptLost 

func (q *Queries) MarkExecutionAttemptLost(ctx context.Context, arg MarkExecutionAttemptLostParams) (int64, error)

func (*Queries) MarkResumingSessionsFailedForUnavailableRunner 

func (q *Queries) MarkResumingSessionsFailedForUnavailableRunner(ctx context.Context, arg MarkResumingSessionsFailedForUnavailableRunnerParams) (int64, error)

func (*Queries) MarkTaskRunning 

func (q *Queries) MarkTaskRunning(ctx context.Context, arg MarkTaskRunningParams) (int64, error)

func (*Queries) MarkUserPromptRunningByTask 

func (q *Queries) MarkUserPromptRunningByTask(ctx context.Context, arg MarkUserPromptRunningByTaskParams) (int64, error)

func (*Queries) MarkUserPromptTerminalByTask 

func (q *Queries) MarkUserPromptTerminalByTask(ctx context.Context, arg MarkUserPromptTerminalByTaskParams) (int64, error)

func (*Queries) PauseAgentSessionByTaskID 

func (q *Queries) PauseAgentSessionByTaskID(ctx context.Context, arg PauseAgentSessionByTaskIDParams) (int64, error)

func (*Queries) PinTaskGitHubInstallation 

func (q *Queries) PinTaskGitHubInstallation(ctx context.Context, arg PinTaskGitHubInstallationParams) (int64, error)

func (*Queries) ReapStaleSessionsForTerminalRuns 

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

func (*Queries) ReapStaleUserPrompts 

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

func (*Queries) RenewExecutionAttemptLease 

func (q *Queries) RenewExecutionAttemptLease(ctx context.Context, arg RenewExecutionAttemptLeaseParams) (int64, error)

func (*Queries) RequeueTaskAfterExecutionAttemptLost 

func (q *Queries) RequeueTaskAfterExecutionAttemptLost(ctx context.Context, arg RequeueTaskAfterExecutionAttemptLostParams) (int64, error)

func (*Queries) RequeueTaskForPrompt 

func (q *Queries) RequeueTaskForPrompt(ctx context.Context, arg RequeueTaskForPromptParams) (int64, error)

func (*Queries) RevertOrphanedRunningUserPrompts 

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

func (*Queries) SearchAgentSessions 

func (q *Queries) SearchAgentSessions(ctx context.Context, arg SearchAgentSessionsParams) ([]AgentSession, error)

func (*Queries) SearchAgentSessionsByTeams 

func (q *Queries) SearchAgentSessionsByTeams(ctx context.Context, arg SearchAgentSessionsByTeamsParams) ([]AgentSession, error)

func (*Queries) SearchAuditLog 

func (q *Queries) SearchAuditLog(ctx context.Context, arg SearchAuditLogParams) ([]SearchAuditLogRow, error)

func (*Queries) SearchTaskArtifacts 

func (q *Queries) SearchTaskArtifacts(ctx context.Context, arg SearchTaskArtifactsParams) ([]SearchTaskArtifactsRow, error)

func (*Queries) SearchTasks 

func (q *Queries) SearchTasks(ctx context.Context, arg SearchTasksParams) ([]Task, error)

func (*Queries) SearchTasksByTeams 

func (q *Queries) SearchTasksByTeams(ctx context.Context, arg SearchTasksByTeamsParams) ([]Task, error)

func (*Queries) SetTriggerLastRun 

func (q *Queries) SetTriggerLastRun(ctx context.Context, arg SetTriggerLastRunParams) error

func (*Queries) SetTriggerNextRun 

func (q *Queries) SetTriggerNextRun(ctx context.Context, arg SetTriggerNextRunParams) error

func (*Queries) UpdateAgentSessionFromRunnerEvent 

func (q *Queries) UpdateAgentSessionFromRunnerEvent(ctx context.Context, arg UpdateAgentSessionFromRunnerEventParams) (int64, error)

func (*Queries) UpdateDefinitionChangeProposalStatus 

func (q *Queries) UpdateDefinitionChangeProposalStatus(ctx context.Context, arg UpdateDefinitionChangeProposalStatusParams) error

func (*Queries) UpdateEventCallback 

func (q *Queries) UpdateEventCallback(ctx context.Context, arg UpdateEventCallbackParams) (int64, error)

func (*Queries) UpdateExecutionAttemptFromRunnerEvent 

func (q *Queries) UpdateExecutionAttemptFromRunnerEvent(ctx context.Context, arg UpdateExecutionAttemptFromRunnerEventParams) (int64, error)

func (*Queries) UpdateTaskAggregateFromRunnerEvent 

func (q *Queries) UpdateTaskAggregateFromRunnerEvent(ctx context.Context, arg UpdateTaskAggregateFromRunnerEventParams) (int64, error)

func (*Queries) UpdateTaskSearchText 

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

func (*Queries) UpdateTrigger 

func (q *Queries) UpdateTrigger(ctx context.Context, arg UpdateTriggerParams) error

func (*Queries) UpdateTriggerRunStatusByTask 

func (q *Queries) UpdateTriggerRunStatusByTask(ctx context.Context, arg UpdateTriggerRunStatusByTaskParams) error

func (*Queries) UpsertDefinition 

func (q *Queries) UpsertDefinition(ctx context.Context, arg UpsertDefinitionParams) error

func (*Queries) UpsertDefinitionSource 

func (q *Queries) UpsertDefinitionSource(ctx context.Context, arg UpsertDefinitionSourceParams) error

func (*Queries) UpsertRunnerHeartbeat 

func (q *Queries) UpsertRunnerHeartbeat(ctx context.Context, arg UpsertRunnerHeartbeatParams) error

func (*Queries) UpsertTrigger 

func (q *Queries) UpsertTrigger(ctx context.Context, arg UpsertTriggerParams) error

func (*Queries) ValidateRunnerExecutionClaim 

func (q *Queries) ValidateRunnerExecutionClaim(ctx context.Context, arg ValidateRunnerExecutionClaimParams) (ValidateRunnerExecutionClaimRow, error)

func (*Queries) WithTx 

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

type RenewExecutionAttemptLeaseParams 

type RenewExecutionAttemptLeaseParams struct {
	LeaseExpiresAt sql.NullTime   `json:"lease_expires_at"`
	LastEventAt    sql.NullTime   `json:"last_event_at"`
	UpdatedAt      time.Time      `json:"updated_at"`
	ID             string         `json:"id"`
	RunnerID       sql.NullString `json:"runner_id"`
	ClaimID        string         `json:"claim_id"`
}

type RequeueTaskAfterExecutionAttemptLostParams 

type RequeueTaskAfterExecutionAttemptLostParams struct {
	UpdatedAt time.Time `json:"updated_at"`
	TaskID    string    `json:"task_id"`
}

type RequeueTaskForPromptParams 

type RequeueTaskForPromptParams struct {
	UpdatedAt time.Time `json:"updated_at"`
	ID        string    `json:"id"`
}

type Runner 

type Runner struct {
	ID               string          `json:"id"`
	Status           string          `json:"status"`
	ImageRef         sql.NullString  `json:"image_ref"`
	ImageDigest      sql.NullString  `json:"image_digest"`
	Version          sql.NullString  `json:"version"`
	MaxConcurrent    int32           `json:"max_concurrent"`
	RunningTasks     int32           `json:"running_tasks"`
	AvailableSlots   int32           `json:"available_slots"`
	TotalStarted     int64           `json:"total_started"`
	TotalCompleted   int64           `json:"total_completed"`
	TotalErrors      int64           `json:"total_errors"`
	StartedAt        sql.NullTime    `json:"started_at"`
	FirstSeenAt      time.Time       `json:"first_seen_at"`
	LastSeenAt       time.Time       `json:"last_seen_at"`
	UpdatedAt        time.Time       `json:"updated_at"`
	Metadata         json.RawMessage `json:"metadata"`
	IsolationEnabled bool            `json:"isolation_enabled"`
}

type SearchAgentSessionsByTeamsParams 

type SearchAgentSessionsByTeamsParams struct {
	TeamIds      []string       `json:"team_ids"`
	StatusFilter interface{}    `json:"status_filter"`
	Search       sql.NullString `json:"search"`
	PageOffset   int32          `json:"page_offset"`
	PageLimit    int32          `json:"page_limit"`
}

type SearchAgentSessionsParams 

type SearchAgentSessionsParams struct {
	TeamFilter   interface{}    `json:"team_filter"`
	StatusFilter interface{}    `json:"status_filter"`
	Search       sql.NullString `json:"search"`
	PageOffset   int32          `json:"page_offset"`
	PageLimit    int32          `json:"page_limit"`
}

type SearchAuditLogParams 

type SearchAuditLogParams struct {
	EventTypeFilter  string         `json:"event_type_filter"`
	SourceTypeFilter sql.NullString `json:"source_type_filter"`
	SourceIDFilter   sql.NullString `json:"source_id_filter"`
	TargetTypeFilter sql.NullString `json:"target_type_filter"`
	TargetIDFilter   sql.NullString `json:"target_id_filter"`
	RepoFilter       sql.NullString `json:"repo_filter"`
	CreatedAfter     sql.NullTime   `json:"created_after"`
	Search           sql.NullString `json:"search"`
	PageOffset       int32          `json:"page_offset"`
	PageLimit        int32          `json:"page_limit"`
}

type SearchAuditLogRow 

type SearchAuditLogRow struct {
	ID               string           `json:"id"`
	EventType        string           `json:"event_type"`
	CreatedAt        time.Time        `json:"created_at"`
	SourceType       sql.NullString   `json:"source_type"`
	SourceID         sql.NullString   `json:"source_id"`
	TargetType       sql.NullString   `json:"target_type"`
	TargetID         sql.NullString   `json:"target_id"`
	Repo             sql.NullString   `json:"repo"`
	GithubEvent      sql.NullString   `json:"github_event"`
	GithubAction     sql.NullString   `json:"github_action"`
	GithubDeliveryID sql.NullString   `json:"github_delivery_id"`
	ParentEventID    sql.NullString   `json:"parent_event_id"`
	Detail           sql.NullString   `json:"detail"`
	Payload          *json.RawMessage `json:"payload"`
	TokenID          sql.NullString   `json:"token_id"`
	TokenName        sql.NullString   `json:"token_name"`
}

type SearchTaskArtifactsParams 

type SearchTaskArtifactsParams struct {
	TaskID             string         `json:"task_id"`
	AgentSessionID     sql.NullString `json:"agent_session_id"`
	UserPromptID       sql.NullString `json:"user_prompt_id"`
	ExecutionAttemptID string         `json:"execution_attempt_id"`
	ArtifactType       string         `json:"artifact_type"`
	Repo               string         `json:"repo"`
	Search             sql.NullString `json:"search"`
	PageOffset         int32          `json:"page_offset"`
	PageLimit          int32          `json:"page_limit"`
}

type SearchTaskArtifactsRow 

type SearchTaskArtifactsRow struct {
	ID                 string         `json:"id"`
	TaskID             string         `json:"task_id"`
	AgentSessionID     sql.NullString `json:"agent_session_id"`
	UserPromptID       sql.NullString `json:"user_prompt_id"`
	ExecutionAttemptID string         `json:"execution_attempt_id"`
	ArtifactType       string         `json:"artifact_type"`
	Repo               string         `json:"repo"`
	Number             sql.NullInt32  `json:"number"`
	Url                sql.NullString `json:"url"`
	Ref                sql.NullString `json:"ref"`
	Sha                sql.NullString `json:"sha"`
	CreatedAt          time.Time      `json:"created_at"`
	DiscoveredAt       time.Time      `json:"discovered_at"`
	DiscoverySource    string         `json:"discovery_source"`
}

type SearchTasksByTeamsParams 

type SearchTasksByTeamsParams struct {
	TeamIds           []string       `json:"team_ids"`
	StatusFilter      interface{}    `json:"status_filter"`
	TriggerNameFilter interface{}    `json:"trigger_name_filter"`
	AgentFilter       interface{}    `json:"agent_filter"`
	Search            sql.NullString `json:"search"`
	PageOffset        int32          `json:"page_offset"`
	PageLimit         int32          `json:"page_limit"`
}

type SearchTasksParams 

type SearchTasksParams struct {
	TeamFilter        interface{}    `json:"team_filter"`
	StatusFilter      interface{}    `json:"status_filter"`
	TriggerNameFilter interface{}    `json:"trigger_name_filter"`
	AgentFilter       interface{}    `json:"agent_filter"`
	Search            sql.NullString `json:"search"`
	PageOffset        int32          `json:"page_offset"`
	PageLimit         int32          `json:"page_limit"`
}

type SetTriggerLastRunParams 

type SetTriggerLastRunParams struct {
	LastRunAt sql.NullTime `json:"last_run_at"`
	UpdatedAt time.Time    `json:"updated_at"`
	ID        string       `json:"id"`
}

type SetTriggerNextRunParams 

type SetTriggerNextRunParams struct {
	NextRunAt sql.NullTime `json:"next_run_at"`
	UpdatedAt time.Time    `json:"updated_at"`
	ID        string       `json:"id"`
}

type Task 

type Task struct {
	ID                   string         `json:"id"`
	TeamID               sql.NullString `json:"team_id"`
	Status               string         `json:"status"`
	Prompt               string         `json:"prompt"`
	GitUrl               sql.NullString `json:"git_url"`
	GitRef               sql.NullString `json:"git_ref"`
	TriggerName          sql.NullString `json:"trigger_name"`
	TriggerType          sql.NullString `json:"trigger_type"`
	SubmissionSource     string         `json:"submission_source"`
	MaxAttempts          int32          `json:"max_attempts"`
	Summary              sql.NullString `json:"summary"`
	Error                sql.NullString `json:"error"`
	ErrorCategory        sql.NullString `json:"error_category"`
	CreatedAt            time.Time      `json:"created_at"`
	UpdatedAt            time.Time      `json:"updated_at"`
	EndedAt              sql.NullTime   `json:"ended_at"`
	SearchText           sql.NullString `json:"search_text"`
	FailureCategory      sql.NullString `json:"failure_category"`
	FailureMessage       sql.NullString `json:"failure_message"`
	GithubRepo           sql.NullString `json:"github_repo"`
	GithubInstallationID sql.NullInt64  `json:"github_installation_id"`
	SelfTestRunID        sql.NullString `json:"self_test_run_id"`
	SelfTestProfile      sql.NullString `json:"self_test_profile"`
	SelfTestCheck        sql.NullString `json:"self_test_check"`
	SelfTestNonce        sql.NullString `json:"self_test_nonce"`
}

type TaskArtifact 

type TaskArtifact struct {
	ID                 string         `json:"id"`
	TaskID             string         `json:"task_id"`
	AgentSessionID     sql.NullString `json:"agent_session_id"`
	UserPromptID       sql.NullString `json:"user_prompt_id"`
	ArtifactType       string         `json:"artifact_type"`
	Repo               string         `json:"repo"`
	Number             sql.NullInt32  `json:"number"`
	Url                sql.NullString `json:"url"`
	Ref                sql.NullString `json:"ref"`
	Sha                sql.NullString `json:"sha"`
	CreatedAt          time.Time      `json:"created_at"`
	DiscoveredAt       time.Time      `json:"discovered_at"`
	DiscoverySource    string         `json:"discovery_source"`
	SearchText         sql.NullString `json:"search_text"`
	ExecutionAttemptID string         `json:"execution_attempt_id"`
}

type TaskEvent 

type TaskEvent struct {
	ID                 string          `json:"id"`
	TaskID             string          `json:"task_id"`
	Subject            string          `json:"subject"`
	Status             string          `json:"status"`
	EventType          string          `json:"event_type"`
	Payload            json.RawMessage `json:"payload"`
	CreatedAt          time.Time       `json:"created_at"`
	AgentSessionID     sql.NullString  `json:"agent_session_id"`
	UserPromptID       sql.NullString  `json:"user_prompt_id"`
	ExecutionAttemptID sql.NullString  `json:"execution_attempt_id"`
}

type Team 

type Team struct {
	ID            string         `json:"id"`
	Name          string         `json:"name"`
	OktaGroupID   sql.NullString `json:"okta_group_id"`
	OktaGroupName sql.NullString `json:"okta_group_name"`
	CreatedAt     time.Time      `json:"created_at"`
	UpdatedAt     time.Time      `json:"updated_at"`
}

type Trigger 

type Trigger struct {
	ID            string          `json:"id"`
	TeamID        sql.NullString  `json:"team_id"`
	Name          string          `json:"name"`
	TriggerType   string          `json:"trigger_type"`
	TriggerConfig json.RawMessage `json:"trigger_config"`
	CronExpr      string          `json:"cron_expr"`
	Prompt        string          `json:"prompt"`
	GitUrl        sql.NullString  `json:"git_url"`
	GitRef        sql.NullString  `json:"git_ref"`
	AgentImage    sql.NullString  `json:"agent_image"`
	Agent         sql.NullString  `json:"agent"`
	ProviderID    sql.NullString  `json:"provider_id"`
	ModelID       sql.NullString  `json:"model_id"`
	VariantID     sql.NullString  `json:"variant_id"`
	Harness       sql.NullString  `json:"harness"`
	Skills        json.RawMessage `json:"skills"`
	TimeoutSec    int32           `json:"timeout_sec"`
	Enabled       bool            `json:"enabled"`
	SourceID      sql.NullString  `json:"source_id"`
	CreatedAt     time.Time       `json:"created_at"`
	UpdatedAt     time.Time       `json:"updated_at"`
	LastRunAt     sql.NullTime    `json:"last_run_at"`
	NextRunAt     sql.NullTime    `json:"next_run_at"`
}

type TriggerRun 

type TriggerRun struct {
	ID          string         `json:"id"`
	TriggerID   string         `json:"trigger_id"`
	TeamID      sql.NullString `json:"team_id"`
	TaskID      string         `json:"task_id"`
	Status      string         `json:"status"`
	TriggeredAt time.Time      `json:"triggered_at"`
	CreatedAt   time.Time      `json:"created_at"`
}

type UpdateAgentSessionFromRunnerEventParams 

type UpdateAgentSessionFromRunnerEventParams struct {
	ProviderID       string    `json:"provider_id"`
	ModelID          string    `json:"model_id"`
	VariantID        string    `json:"variant_id"`
	HarnessSessionID string    `json:"harness_session_id"`
	UpdatedAt        time.Time `json:"updated_at"`
	TaskID           string    `json:"task_id"`
}

type UpdateDefinitionChangeProposalStatusParams 

type UpdateDefinitionChangeProposalStatusParams struct {
	Status    string    `json:"status"`
	UpdatedAt time.Time `json:"updated_at"`
	ID        string    `json:"id"`
}

type UpdateEventCallbackParams 

type UpdateEventCallbackParams struct {
	EventType    string          `json:"event_type"`
	ActionType   string          `json:"action_type"`
	ActionConfig json.RawMessage `json:"action_config"`
	Enabled      bool            `json:"enabled"`
	UpdatedAt    time.Time       `json:"updated_at"`
	Name         string          `json:"name"`
	TeamID       sql.NullString  `json:"team_id"`
}

type UpdateExecutionAttemptFromRunnerEventParams 

type UpdateExecutionAttemptFromRunnerEventParams struct {
	Status                string         `json:"status"`
	Summary               sql.NullString `json:"summary"`
	Error                 sql.NullString `json:"error"`
	ErrorCategory         string         `json:"error_category"`
	SessionExport         sql.NullString `json:"session_export"`
	LeaseExpiresAt        sql.NullTime   `json:"lease_expires_at"`
	StartedAt             sql.NullTime   `json:"started_at"`
	EndedAt               sql.NullTime   `json:"ended_at"`
	WorkspacePath         string         `json:"workspace_path"`
	HarnessExecutionID    string         `json:"harness_execution_id"`
	RunnerImageDigest     string         `json:"runner_image_digest"`
	TotalInputTokens      int64          `json:"total_input_tokens"`
	TotalOutputTokens     int64          `json:"total_output_tokens"`
	TotalCacheReadTokens  int64          `json:"total_cache_read_tokens"`
	TotalCacheWriteTokens int64          `json:"total_cache_write_tokens"`
	TotalReasoningTokens  int64          `json:"total_reasoning_tokens"`
	CostCents             int64          `json:"cost_cents"`
	LastEventAt           sql.NullTime   `json:"last_event_at"`
	UpdatedAt             time.Time      `json:"updated_at"`
	ID                    string         `json:"id"`
	RunnerID              sql.NullString `json:"runner_id"`
	ClaimID               string         `json:"claim_id"`
}

type UpdateTaskAggregateFromRunnerEventParams 

type UpdateTaskAggregateFromRunnerEventParams struct {
	Status          string         `json:"status"`
	Summary         sql.NullString `json:"summary"`
	Error           sql.NullString `json:"error"`
	ErrorCategory   interface{}    `json:"error_category"`
	FailureCategory interface{}    `json:"failure_category"`
	FailureMessage  sql.NullString `json:"failure_message"`
	EndedAt         sql.NullTime   `json:"ended_at"`
	UpdatedAt       time.Time      `json:"updated_at"`
	ID              string         `json:"id"`
}

type UpdateTriggerParams 

type UpdateTriggerParams struct {
	TriggerType   string          `json:"trigger_type"`
	TriggerConfig json.RawMessage `json:"trigger_config"`
	CronExpr      string          `json:"cron_expr"`
	Prompt        string          `json:"prompt"`
	GitUrl        sql.NullString  `json:"git_url"`
	GitRef        sql.NullString  `json:"git_ref"`
	AgentImage    sql.NullString  `json:"agent_image"`
	Agent         sql.NullString  `json:"agent"`
	ProviderID    sql.NullString  `json:"provider_id"`
	ModelID       sql.NullString  `json:"model_id"`
	VariantID     sql.NullString  `json:"variant_id"`
	Harness       sql.NullString  `json:"harness"`
	Skills        json.RawMessage `json:"skills"`
	TimeoutSec    int32           `json:"timeout_sec"`
	Enabled       bool            `json:"enabled"`
	UpdatedAt     time.Time       `json:"updated_at"`
	NewName       string          `json:"new_name"`
	OldName       string          `json:"old_name"`
}

type UpdateTriggerRunStatusByTaskParams 

type UpdateTriggerRunStatusByTaskParams struct {
	Status string `json:"status"`
	TaskID string `json:"task_id"`
}

type UpsertDefinitionParams 

type UpsertDefinitionParams struct {
	ID             string           `json:"id"`
	SourceID       string           `json:"source_id"`
	DefinitionType string           `json:"definition_type"`
	Name           string           `json:"name"`
	Scope          string           `json:"scope"`
	TeamID         sql.NullString   `json:"team_id"`
	Repo           sql.NullString   `json:"repo"`
	Path           string           `json:"path"`
	SourceCommit   string           `json:"source_commit"`
	ContentHash    string           `json:"content_hash"`
	Content        string           `json:"content"`
	Metadata       *json.RawMessage `json:"metadata"`
	Active         bool             `json:"active"`
	CreatedAt      time.Time        `json:"created_at"`
	UpdatedAt      time.Time        `json:"updated_at"`
}

type UpsertDefinitionSourceParams 

type UpsertDefinitionSourceParams struct {
	ID         string         `json:"id"`
	Name       string         `json:"name"`
	Scope      string         `json:"scope"`
	TeamID     sql.NullString `json:"team_id"`
	Repo       sql.NullString `json:"repo"`
	RepoUrl    string         `json:"repo_url"`
	Branch     string         `json:"branch"`
	Path       string         `json:"path"`
	Enabled    bool           `json:"enabled"`
	CreatedAt  time.Time      `json:"created_at"`
	UpdatedAt  time.Time      `json:"updated_at"`
	LastSyncAt sql.NullTime   `json:"last_sync_at"`
}

type UpsertRunnerHeartbeatParams 

type UpsertRunnerHeartbeatParams struct {
	ID               string          `json:"id"`
	Status           string          `json:"status"`
	ImageRef         sql.NullString  `json:"image_ref"`
	ImageDigest      sql.NullString  `json:"image_digest"`
	Version          sql.NullString  `json:"version"`
	MaxConcurrent    int32           `json:"max_concurrent"`
	RunningTasks     int32           `json:"running_tasks"`
	AvailableSlots   int32           `json:"available_slots"`
	IsolationEnabled bool            `json:"isolation_enabled"`
	TotalStarted     int64           `json:"total_started"`
	TotalCompleted   int64           `json:"total_completed"`
	TotalErrors      int64           `json:"total_errors"`
	StartedAt        sql.NullTime    `json:"started_at"`
	FirstSeenAt      time.Time       `json:"first_seen_at"`
	LastSeenAt       time.Time       `json:"last_seen_at"`
	UpdatedAt        time.Time       `json:"updated_at"`
	Metadata         json.RawMessage `json:"metadata"`
}

type UpsertTriggerParams 

type UpsertTriggerParams struct {
	ID            string          `json:"id"`
	TeamID        sql.NullString  `json:"team_id"`
	Name          string          `json:"name"`
	TriggerType   string          `json:"trigger_type"`
	TriggerConfig json.RawMessage `json:"trigger_config"`
	CronExpr      string          `json:"cron_expr"`
	Prompt        string          `json:"prompt"`
	GitUrl        sql.NullString  `json:"git_url"`
	GitRef        sql.NullString  `json:"git_ref"`
	AgentImage    sql.NullString  `json:"agent_image"`
	Agent         sql.NullString  `json:"agent"`
	ProviderID    sql.NullString  `json:"provider_id"`
	ModelID       sql.NullString  `json:"model_id"`
	VariantID     sql.NullString  `json:"variant_id"`
	Harness       sql.NullString  `json:"harness"`
	Skills        json.RawMessage `json:"skills"`
	TimeoutSec    int32           `json:"timeout_sec"`
	Enabled       bool            `json:"enabled"`
	SourceID      sql.NullString  `json:"source_id"`
	CreatedAt     time.Time       `json:"created_at"`
	UpdatedAt     time.Time       `json:"updated_at"`
}

type User 

type User struct {
	ID        string    `json:"id"`
	Name      string    `json:"name"`
	TeamID    string    `json:"team_id"`
	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`
}

type UserPrompt 

type UserPrompt struct {
	ID                 string         `json:"id"`
	AgentSessionID     string         `json:"agent_session_id"`
	TaskID             string         `json:"task_id"`
	Status             string         `json:"status"`
	Prompt             string         `json:"prompt"`
	Summary            sql.NullString `json:"summary"`
	Error              sql.NullString `json:"error"`
	SessionExport      sql.NullString `json:"session_export"`
	CreatedAt          time.Time      `json:"created_at"`
	UpdatedAt          time.Time      `json:"updated_at"`
	StartedAt          sql.NullTime   `json:"started_at"`
	EndedAt            sql.NullTime   `json:"ended_at"`
	Sequence           int32          `json:"sequence"`
	SourceUserPromptID sql.NullString `json:"source_user_prompt_id"`
}

type UserTeamMembership 

type UserTeamMembership struct {
	UserID    string    `json:"user_id"`
	TeamID    string    `json:"team_id"`
	Source    string    `json:"source"`
	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`
}

type ValidateRunnerExecutionClaimParams 

type ValidateRunnerExecutionClaimParams struct {
	ExecutionID string         `json:"execution_id"`
	TaskID      string         `json:"task_id"`
	RunnerID    sql.NullString `json:"runner_id"`
	ClaimID     string         `json:"claim_id"`
}

type ValidateRunnerExecutionClaimRow 

type ValidateRunnerExecutionClaimRow struct {
	ExecutionAttemptID string         `json:"execution_attempt_id"`
	ClaimID            string         `json:"claim_id"`
	RunnerID           sql.NullString `json:"runner_id"`
	Status             string         `json:"status"`
	LeaseExpiresAt     sql.NullTime   `json:"lease_expires_at"`
	TaskID             string         `json:"task_id"`
	AgentSessionID     string         `json:"agent_session_id"`
	UserPromptID       string         `json:"user_prompt_id"`
}

type WebhookDelivery 

type WebhookDelivery struct {
	ID            string         `json:"id"`
	DeliveryID    string         `json:"delivery_id"`
	EventType     string         `json:"event_type"`
	EventAction   string         `json:"event_action"`
	Payload       string         `json:"payload"`
	Status        string         `json:"status"`
	Attempts      int32          `json:"attempts"`
	MaxAttempts   int32          `json:"max_attempts"`
	Error         sql.NullString `json:"error"`
	CreatedAt     time.Time      `json:"created_at"`
	UpdatedAt     time.Time      `json:"updated_at"`
	NextAttemptAt sql.NullTime   `json:"next_attempt_at"`
	ProcessedAt   sql.NullTime   `json:"processed_at"`
}

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.