data

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: 8 Imported by: 0

Documentation

Overview

Package data selects the generated repository for the active SQL dialect.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Queries 

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

Queries delegates PostgreSQL operations to repositorypostgres. The generated facade methods retain repository's model and parameter types for callers.

func (*Queries) AbandonAgentSession 

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

func (*Queries) AbandonUserPrompt 

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

func (*Queries) AddTokenTeam 

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

func (*Queries) AddUserTeamMembership 

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

func (*Queries) CancelExecutionAttemptsByTask 

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

func (*Queries) CancelPendingExecutionAttempts 

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

func (*Queries) CancelTask 

func (q *Queries) CancelTask(ctx context.Context, arg repository.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 repository.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 repository.CreateTeamParams) error

func (*Queries) CreateToken 

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

func (*Queries) CreateTrigger 

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

func (*Queries) CreateUser 

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

func (*Queries) DB 

func (q *Queries) DB() *sql.DB

DB exposes the pool when this facade was constructed from one.

func (*Queries) DeactivateDefinitionsBySource 

func (q *Queries) DeactivateDefinitionsBySource(ctx context.Context, arg repository.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 repository.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 repository.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 repository.ExpirePausedSessionsParams) (int64, error)

func (*Queries) ExtendActiveExecutionAttemptTimeout 

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

func (*Queries) FailAllExpiredExecutionAttempts 

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

func (*Queries) FailExpiredExecutionAttempts 

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

func (*Queries) FailExpiredLeases 

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

func (*Queries) FailPendingExecutionAttemptsForMissingRunner 

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

func (*Queries) FailPendingIsolationAttemptsWithoutCapableRunner 

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

func (*Queries) FailPendingIsolationTasks 

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

func (*Queries) FailPendingResumeTasksForMissingRunner 

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

func (*Queries) FailPendingUserPromptsForUnavailableRunner 

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

func (*Queries) GetActiveModelCatalog 

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

func (*Queries) GetAgentSessionByID 

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

func (*Queries) GetAgentSessionByTaskID 

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

func (*Queries) GetClaimableExecutionAttemptForUpdate 

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

func (*Queries) GetDefinitionBySourceTypeName 

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

func (*Queries) GetDefinitionChangeProposal 

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

func (*Queries) GetDefinitionChangeProposalByPR 

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

func (*Queries) GetDefinitionSource 

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

func (*Queries) GetDefinitionSourceByName 

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

func (*Queries) GetEventCallbackByID 

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

func (*Queries) GetEventCallbackByName 

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

func (*Queries) GetExecutionAttemptByID 

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

func (*Queries) GetExecutionAttemptContext 

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

func (*Queries) GetExecutionAttemptUsageByTask 

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

func (*Queries) GetGitHubExecutionContext 

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

func (*Queries) GetLatestAgentSessionCheckpoint 

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

func (*Queries) GetLatestAgentSessionCheckpointByTaskID 

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

func (*Queries) GetLatestTaskEvent 

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

func (*Queries) GetModelCatalogByName 

func (q *Queries) GetModelCatalogByName(ctx context.Context, name string) (repository.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 repository.GetPausedSessionByArtifactParams) (repository.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) (repository.Task, error)

func (*Queries) GetTeamByID 

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

func (*Queries) GetTeamByName 

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

func (*Queries) GetTokenByHash 

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

func (*Queries) GetTriggerByID 

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

func (*Queries) GetTriggerByName 

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

func (*Queries) GetUserByID 

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

func (*Queries) GetUserPromptByID 

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

func (*Queries) GetUserPromptByTaskID 

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

func (*Queries) InsertAgentSession 

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

func (*Queries) InsertAgentSessionCheckpoint 

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

func (*Queries) InsertAuditLog 

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

func (*Queries) InsertDefinitionChangeProposal 

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

func (*Queries) InsertDefinitionSyncRun 

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

func (*Queries) InsertEventCallback 

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

func (*Queries) InsertExecutionAttempt 

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

func (*Queries) InsertModelCatalog 

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

func (*Queries) InsertPendingExecutionAttempt 

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

func (*Queries) InsertTask 

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

func (*Queries) InsertTaskArtifact 

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

func (*Queries) InsertTaskEvent 

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

func (*Queries) InsertTriggerRun 

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

func (*Queries) InsertUserPrompt 

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

func (*Queries) IsRunnerAlive 

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

func (*Queries) ListAgentSessions 

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

func (*Queries) ListAgentSessionsByTeams 

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

func (*Queries) ListAuditLog 

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

ListAuditLog consolidates sqlc's duplicated MySQL filter parameters into the PostgreSQL query's single parameter per filter.

func (*Queries) ListDefinitionChangeProposals 

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

func (*Queries) ListDefinitionSources 

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

func (*Queries) ListDefinitionSyncRuns 

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

func (*Queries) ListDefinitions 

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

func (*Queries) ListEnabledEventCallbacksForEvent 

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

func (*Queries) ListEnabledIssueTriggersByRepo 

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

func (*Queries) ListEnabledPRReviewTriggersByRepo 

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

func (*Queries) ListEnabledTriggers 

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

func (*Queries) ListEnabledTriggersByTeam 

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

func (*Queries) ListEnabledTriggersByTeams 

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

func (*Queries) ListEnabledTriggersByType 

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

func (*Queries) ListEventCallbacks 

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

func (*Queries) ListEventCallbacksByTeams 

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

func (*Queries) ListExecutionAttemptsByPrompt 

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

func (*Queries) ListExecutionAttemptsForHeartbeat 

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

func (*Queries) ListLiveRunners 

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

func (*Queries) ListModelCatalogs 

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

func (*Queries) ListReclaimableExecutionAttemptsForUpdate 

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

func (*Queries) ListTaskArtifacts 

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

func (*Queries) ListTaskEvents 

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

func (*Queries) ListTaskEventsSince 

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

func (*Queries) ListTasksBySelfTestRun 

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

func (*Queries) ListTasksByStatus 

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

func (*Queries) ListTasksByStatusAndTeam 

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

func (*Queries) ListTasksByStatusAndTeams 

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

func (*Queries) ListTeams 

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

func (*Queries) ListTokens 

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

func (*Queries) ListTriggerRunsByTeam 

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

func (*Queries) ListTriggerRunsByTeams 

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

func (*Queries) ListTriggerRunsByTrigger 

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

func (*Queries) ListTriggers 

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

func (*Queries) ListTriggersByTeam 

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

func (*Queries) ListTriggersByTeams 

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

func (*Queries) ListUserPromptsBySession 

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

func (*Queries) ListUsers 

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

func (*Queries) ListUsersByTeam 

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

func (*Queries) MarkAgentSessionResuming 

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

func (*Queries) MarkAgentSessionTerminalByTask 

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

func (*Queries) MarkDefinitionSourceSynced 

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

func (*Queries) MarkExecutionAttemptClaimed 

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

func (*Queries) MarkExecutionAttemptLost 

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

func (*Queries) MarkResumingSessionsFailedForUnavailableRunner 

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

func (*Queries) MarkTaskRunning 

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

func (*Queries) MarkUserPromptRunningByTask 

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

func (*Queries) MarkUserPromptTerminalByTask 

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

func (*Queries) PauseAgentSessionByTaskID 

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

func (*Queries) PinTaskGitHubInstallation 

func (q *Queries) PinTaskGitHubInstallation(ctx context.Context, arg repository.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 repository.RenewExecutionAttemptLeaseParams) (int64, error)

func (*Queries) RequeueTaskAfterExecutionAttemptLost 

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

func (*Queries) RequeueTaskForPrompt 

func (q *Queries) RequeueTaskForPrompt(ctx context.Context, arg repository.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 repository.SearchAgentSessionsParams) ([]repository.AgentSession, error)

func (*Queries) SearchAgentSessionsByTeams 

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

func (*Queries) SearchAuditLog 

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

func (*Queries) SearchTaskArtifacts 

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

func (*Queries) SearchTasks 

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

SearchTasks has PostgreSQL-specific nullable filters and pagination names. Keep that generated difference isolated here while callers use repository's established parameter type.

func (*Queries) SearchTasksByTeams 

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

func (*Queries) SetTriggerLastRun 

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

func (*Queries) SetTriggerNextRun 

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

func (*Queries) UpdateAgentSessionFromRunnerEvent 

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

func (*Queries) UpdateDefinitionChangeProposalStatus 

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

func (*Queries) UpdateEventCallback 

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

func (*Queries) UpdateExecutionAttemptFromRunnerEvent 

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

func (*Queries) UpdateTaskAggregateFromRunnerEvent 

func (q *Queries) UpdateTaskAggregateFromRunnerEvent(ctx context.Context, arg repository.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 repository.UpdateTriggerParams) error

func (*Queries) UpdateTriggerRunStatusByTask 

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

func (*Queries) UpsertDefinition 

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

func (*Queries) UpsertDefinitionSource 

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

func (*Queries) UpsertRunnerHeartbeat 

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

func (*Queries) UpsertTrigger 

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

func (*Queries) ValidateRunnerExecutionClaim 

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

type Repository 

type Repository interface {
	DB() *sql.DB
	SearchTasks(context.Context, repository.SearchTasksParams) ([]repository.Task, error)
	ListAuditLog(context.Context, repository.ListAuditLogParams) ([]repository.ListAuditLogRow, error)
	ListTaskArtifacts(context.Context, repository.ListTaskArtifactsParams) ([]repository.ListTaskArtifactsRow, error)
	AbandonAgentSession(ctx context.Context, arg repository.AbandonAgentSessionParams) (int64, error)
	AbandonUserPrompt(ctx context.Context, arg repository.AbandonUserPromptParams) (int64, error)
	AddTokenTeam(ctx context.Context, arg repository.AddTokenTeamParams) error
	AddUserTeamMembership(ctx context.Context, arg repository.AddUserTeamMembershipParams) error
	CancelExecutionAttemptsByTask(ctx context.Context, arg repository.CancelExecutionAttemptsByTaskParams) (int64, error)
	CancelPendingExecutionAttempts(ctx context.Context, arg repository.CancelPendingExecutionAttemptsParams) (int64, error)
	CancelTask(ctx context.Context, arg repository.CancelTaskParams) (int64, error)
	ClearExpiredExecutionAttemptExports(ctx context.Context, ttlSeconds interface{}) (int64, error)
	ClearExpiredSessionCheckpoints(ctx context.Context, ttlSeconds interface{}) (int64, error)
	ClearExpiredUserPromptExports(ctx context.Context, ttlSeconds interface{}) (int64, error)
	ClearPendingTasks(ctx context.Context, arg repository.ClearPendingTasksParams) (int64, error)
	CountExecutionAttemptsByTask(ctx context.Context, taskID string) (int64, error)
	CreateTeam(ctx context.Context, arg repository.CreateTeamParams) error
	CreateToken(ctx context.Context, arg repository.CreateTokenParams) error
	CreateTrigger(ctx context.Context, arg repository.CreateTriggerParams) error
	CreateUser(ctx context.Context, arg repository.CreateUserParams) error
	DeactivateDefinitionsBySource(ctx context.Context, arg repository.DeactivateDefinitionsBySourceParams) error
	DeactivateModelCatalogs(ctx context.Context, updatedAt time.Time) error
	DeleteEventCallback(ctx context.Context, arg repository.DeleteEventCallbackParams) (int64, error)
	DeleteTeam(ctx context.Context, name string) error
	DeleteToken(ctx context.Context, name string) error
	DeleteTokenTeamsByTeam(ctx context.Context, teamID string) error
	DeleteTokensByTeam(ctx context.Context, arg repository.DeleteTokensByTeamParams) error
	DeleteTrigger(ctx context.Context, name string) error
	DeleteTriggersBySource(ctx context.Context, sourceID sql.NullString) error
	DeleteUserTeamMembershipsByTeam(ctx context.Context, teamID string) error
	DeleteUsersByTeam(ctx context.Context, teamID string) error
	ExpirePausedSessions(ctx context.Context, arg repository.ExpirePausedSessionsParams) (int64, error)
	ExtendActiveExecutionAttemptTimeout(ctx context.Context, arg repository.ExtendActiveExecutionAttemptTimeoutParams) (int64, error)
	FailAllExpiredExecutionAttempts(ctx context.Context, arg repository.FailAllExpiredExecutionAttemptsParams) (int64, error)
	FailExpiredExecutionAttempts(ctx context.Context, arg repository.FailExpiredExecutionAttemptsParams) (int64, error)
	FailExpiredLeases(ctx context.Context, arg repository.FailExpiredLeasesParams) (int64, error)
	FailPendingExecutionAttemptsForMissingRunner(ctx context.Context, arg repository.FailPendingExecutionAttemptsForMissingRunnerParams) (int64, error)
	FailPendingIsolationAttemptsWithoutCapableRunner(ctx context.Context, arg repository.FailPendingIsolationAttemptsWithoutCapableRunnerParams) (int64, error)
	FailPendingIsolationTasks(ctx context.Context, arg repository.FailPendingIsolationTasksParams) (int64, error)
	FailPendingResumeTasksForMissingRunner(ctx context.Context, arg repository.FailPendingResumeTasksForMissingRunnerParams) (int64, error)
	FailPendingUserPromptsForUnavailableRunner(ctx context.Context, arg repository.FailPendingUserPromptsForUnavailableRunnerParams) (int64, error)
	GetActiveModelCatalog(ctx context.Context) (repository.ModelCatalog, error)
	GetAgentSessionByID(ctx context.Context, id string) (repository.AgentSession, error)
	GetAgentSessionByTaskID(ctx context.Context, taskID string) (repository.AgentSession, error)
	GetClaimableExecutionAttemptForUpdate(ctx context.Context, arg repository.GetClaimableExecutionAttemptForUpdateParams) (repository.GetClaimableExecutionAttemptForUpdateRow, error)
	GetDefinitionBySourceTypeName(ctx context.Context, arg repository.GetDefinitionBySourceTypeNameParams) (repository.Definition, error)
	GetDefinitionChangeProposal(ctx context.Context, id string) (repository.DefinitionChangeProposal, error)
	GetDefinitionChangeProposalByPR(ctx context.Context, arg repository.GetDefinitionChangeProposalByPRParams) (repository.DefinitionChangeProposal, error)
	GetDefinitionSource(ctx context.Context, id string) (repository.DefinitionSource, error)
	GetDefinitionSourceByName(ctx context.Context, name string) (repository.DefinitionSource, error)
	GetEventCallbackByID(ctx context.Context, id string) (repository.EventCallback, error)
	GetEventCallbackByName(ctx context.Context, arg repository.GetEventCallbackByNameParams) (repository.EventCallback, error)
	GetExecutionAttemptByID(ctx context.Context, id string) (repository.ExecutionAttempt, error)
	GetExecutionAttemptContext(ctx context.Context, id string) (repository.GetExecutionAttemptContextRow, error)
	GetExecutionAttemptUsageByTask(ctx context.Context, taskID string) (repository.GetExecutionAttemptUsageByTaskRow, error)
	GetGitHubExecutionContext(ctx context.Context, id string) (repository.GetGitHubExecutionContextRow, error)
	GetLatestAgentSessionCheckpoint(ctx context.Context, agentSessionID string) (repository.AgentSessionCheckpoint, error)
	GetLatestAgentSessionCheckpointByTaskID(ctx context.Context, taskID string) (repository.AgentSessionCheckpoint, error)
	GetLatestTaskEvent(ctx context.Context, taskID string) (repository.TaskEvent, error)
	GetModelCatalogByName(ctx context.Context, name string) (repository.ModelCatalog, error)
	GetNextAgentSessionSequence(ctx context.Context, taskID string) (int32, error)
	GetNextExecutionAttemptSequence(ctx context.Context, userPromptID string) (int32, error)
	GetNextUserPromptSequence(ctx context.Context, agentSessionID string) (int32, error)
	GetPausedSessionByArtifact(ctx context.Context, arg repository.GetPausedSessionByArtifactParams) (repository.AgentSession, error)
	GetRunnerHeartbeatMetadata(ctx context.Context, id string) (json.RawMessage, error)
	GetRunnerIsolationEnabled(ctx context.Context, id string) (bool, error)
	GetTaskByID(ctx context.Context, id string) (repository.Task, error)
	GetTeamByID(ctx context.Context, id string) (repository.Team, error)
	GetTeamByName(ctx context.Context, name string) (repository.Team, error)
	GetTokenByHash(ctx context.Context, tokenHash string) (repository.GetTokenByHashRow, error)
	GetTriggerByID(ctx context.Context, id string) (repository.Trigger, error)
	GetTriggerByName(ctx context.Context, name string) (repository.Trigger, error)
	GetUserByID(ctx context.Context, id string) (repository.User, error)
	GetUserPromptByID(ctx context.Context, id string) (repository.UserPrompt, error)
	GetUserPromptByTaskID(ctx context.Context, taskID string) (repository.UserPrompt, error)
	InsertAgentSession(ctx context.Context, arg repository.InsertAgentSessionParams) error
	InsertAgentSessionCheckpoint(ctx context.Context, arg repository.InsertAgentSessionCheckpointParams) error
	InsertAuditLog(ctx context.Context, arg repository.InsertAuditLogParams) error
	InsertDefinitionChangeProposal(ctx context.Context, arg repository.InsertDefinitionChangeProposalParams) error
	InsertDefinitionSyncRun(ctx context.Context, arg repository.InsertDefinitionSyncRunParams) error
	InsertEventCallback(ctx context.Context, arg repository.InsertEventCallbackParams) error
	InsertExecutionAttempt(ctx context.Context, arg repository.InsertExecutionAttemptParams) error
	InsertModelCatalog(ctx context.Context, arg repository.InsertModelCatalogParams) error
	InsertPendingExecutionAttempt(ctx context.Context, arg repository.InsertPendingExecutionAttemptParams) error
	InsertTask(ctx context.Context, arg repository.InsertTaskParams) error
	InsertTaskArtifact(ctx context.Context, arg repository.InsertTaskArtifactParams) error
	InsertTaskEvent(ctx context.Context, arg repository.InsertTaskEventParams) error
	InsertTriggerRun(ctx context.Context, arg repository.InsertTriggerRunParams) error
	InsertUserPrompt(ctx context.Context, arg repository.InsertUserPromptParams) error
	IsRunnerAlive(ctx context.Context, arg repository.IsRunnerAliveParams) (bool, error)
	ListAgentSessions(ctx context.Context, arg repository.ListAgentSessionsParams) ([]repository.AgentSession, error)
	ListAgentSessionsByTeams(ctx context.Context, arg repository.ListAgentSessionsByTeamsParams) ([]repository.AgentSession, error)
	ListDefinitionChangeProposals(ctx context.Context, arg repository.ListDefinitionChangeProposalsParams) ([]repository.DefinitionChangeProposal, error)
	ListDefinitionSources(ctx context.Context) ([]repository.DefinitionSource, error)
	ListDefinitionSyncRuns(ctx context.Context, arg repository.ListDefinitionSyncRunsParams) ([]repository.DefinitionSyncRun, error)
	ListDefinitions(ctx context.Context, arg repository.ListDefinitionsParams) ([]repository.Definition, error)
	ListEnabledEventCallbacksForEvent(ctx context.Context, arg repository.ListEnabledEventCallbacksForEventParams) ([]repository.EventCallback, error)
	ListEnabledIssueTriggersByRepo(ctx context.Context, repo json.RawMessage) ([]repository.Trigger, error)
	ListEnabledPRReviewTriggersByRepo(ctx context.Context, repo json.RawMessage) ([]repository.Trigger, error)
	ListEnabledTriggers(ctx context.Context) ([]repository.Trigger, error)
	ListEnabledTriggersByTeam(ctx context.Context, teamID sql.NullString) ([]repository.Trigger, error)
	ListEnabledTriggersByTeams(ctx context.Context, teamIds []sql.NullString) ([]repository.Trigger, error)
	ListEnabledTriggersByType(ctx context.Context, triggerType string) ([]repository.Trigger, error)
	ListEventCallbacks(ctx context.Context, arg repository.ListEventCallbacksParams) ([]repository.EventCallback, error)
	ListEventCallbacksByTeams(ctx context.Context, arg repository.ListEventCallbacksByTeamsParams) ([]repository.EventCallback, error)
	ListExecutionAttemptsByPrompt(ctx context.Context, userPromptID string) ([]repository.ExecutionAttempt, error)
	ListExecutionAttemptsForHeartbeat(ctx context.Context, arg repository.ListExecutionAttemptsForHeartbeatParams) ([]repository.ListExecutionAttemptsForHeartbeatRow, error)
	ListLiveRunners(ctx context.Context, lastSeenAt time.Time) ([]repository.ListLiveRunnersRow, error)
	ListModelCatalogs(ctx context.Context) ([]repository.ModelCatalog, error)
	ListReclaimableExecutionAttemptsForUpdate(ctx context.Context, leaseExpiresAt sql.NullTime) ([]repository.ListReclaimableExecutionAttemptsForUpdateRow, error)
	ListTaskEvents(ctx context.Context, arg repository.ListTaskEventsParams) ([]repository.TaskEvent, error)
	ListTaskEventsSince(ctx context.Context, arg repository.ListTaskEventsSinceParams) ([]repository.TaskEvent, error)
	ListTasksBySelfTestRun(ctx context.Context, selfTestRunID sql.NullString) ([]repository.Task, error)
	ListTasksByStatus(ctx context.Context, arg repository.ListTasksByStatusParams) ([]repository.Task, error)
	ListTasksByStatusAndTeam(ctx context.Context, arg repository.ListTasksByStatusAndTeamParams) ([]repository.Task, error)
	ListTasksByStatusAndTeams(ctx context.Context, arg repository.ListTasksByStatusAndTeamsParams) ([]repository.Task, error)
	ListTeams(ctx context.Context) ([]repository.Team, error)
	ListTokens(ctx context.Context) ([]repository.ListTokensRow, error)
	ListTriggerRunsByTeam(ctx context.Context, arg repository.ListTriggerRunsByTeamParams) ([]repository.ListTriggerRunsByTeamRow, error)
	ListTriggerRunsByTeams(ctx context.Context, arg repository.ListTriggerRunsByTeamsParams) ([]repository.ListTriggerRunsByTeamsRow, error)
	ListTriggerRunsByTrigger(ctx context.Context, arg repository.ListTriggerRunsByTriggerParams) ([]repository.ListTriggerRunsByTriggerRow, error)
	ListTriggers(ctx context.Context) ([]repository.Trigger, error)
	ListTriggersByTeam(ctx context.Context, teamID sql.NullString) ([]repository.Trigger, error)
	ListTriggersByTeams(ctx context.Context, teamIds []sql.NullString) ([]repository.Trigger, error)
	ListUserPromptsBySession(ctx context.Context, agentSessionID string) ([]repository.UserPrompt, error)
	ListUsers(ctx context.Context) ([]repository.ListUsersRow, error)
	ListUsersByTeam(ctx context.Context, teamID string) ([]repository.ListUsersByTeamRow, error)
	MarkAgentSessionResuming(ctx context.Context, arg repository.MarkAgentSessionResumingParams) (int64, error)
	MarkAgentSessionTerminalByTask(ctx context.Context, arg repository.MarkAgentSessionTerminalByTaskParams) (int64, error)
	MarkDefinitionSourceSynced(ctx context.Context, arg repository.MarkDefinitionSourceSyncedParams) error
	MarkExecutionAttemptClaimed(ctx context.Context, arg repository.MarkExecutionAttemptClaimedParams) (int64, error)
	MarkExecutionAttemptLost(ctx context.Context, arg repository.MarkExecutionAttemptLostParams) (int64, error)
	MarkResumingSessionsFailedForUnavailableRunner(ctx context.Context, arg repository.MarkResumingSessionsFailedForUnavailableRunnerParams) (int64, error)
	MarkTaskRunning(ctx context.Context, arg repository.MarkTaskRunningParams) (int64, error)
	MarkUserPromptRunningByTask(ctx context.Context, arg repository.MarkUserPromptRunningByTaskParams) (int64, error)
	MarkUserPromptTerminalByTask(ctx context.Context, arg repository.MarkUserPromptTerminalByTaskParams) (int64, error)
	PauseAgentSessionByTaskID(ctx context.Context, arg repository.PauseAgentSessionByTaskIDParams) (int64, error)
	PinTaskGitHubInstallation(ctx context.Context, arg repository.PinTaskGitHubInstallationParams) (int64, error)
	ReapStaleSessionsForTerminalRuns(ctx context.Context) (int64, error)
	ReapStaleUserPrompts(ctx context.Context) (int64, error)
	RenewExecutionAttemptLease(ctx context.Context, arg repository.RenewExecutionAttemptLeaseParams) (int64, error)
	RequeueTaskAfterExecutionAttemptLost(ctx context.Context, arg repository.RequeueTaskAfterExecutionAttemptLostParams) (int64, error)
	RequeueTaskForPrompt(ctx context.Context, arg repository.RequeueTaskForPromptParams) (int64, error)
	RevertOrphanedRunningUserPrompts(ctx context.Context) (int64, error)
	SearchAgentSessions(ctx context.Context, arg repository.SearchAgentSessionsParams) ([]repository.AgentSession, error)
	SearchAgentSessionsByTeams(ctx context.Context, arg repository.SearchAgentSessionsByTeamsParams) ([]repository.AgentSession, error)
	SearchAuditLog(ctx context.Context, arg repository.SearchAuditLogParams) ([]repository.SearchAuditLogRow, error)
	SearchTaskArtifacts(ctx context.Context, arg repository.SearchTaskArtifactsParams) ([]repository.SearchTaskArtifactsRow, error)
	SearchTasksByTeams(ctx context.Context, arg repository.SearchTasksByTeamsParams) ([]repository.Task, error)
	SetTriggerLastRun(ctx context.Context, arg repository.SetTriggerLastRunParams) error
	SetTriggerNextRun(ctx context.Context, arg repository.SetTriggerNextRunParams) error
	UpdateAgentSessionFromRunnerEvent(ctx context.Context, arg repository.UpdateAgentSessionFromRunnerEventParams) (int64, error)
	UpdateDefinitionChangeProposalStatus(ctx context.Context, arg repository.UpdateDefinitionChangeProposalStatusParams) error
	UpdateEventCallback(ctx context.Context, arg repository.UpdateEventCallbackParams) (int64, error)
	UpdateExecutionAttemptFromRunnerEvent(ctx context.Context, arg repository.UpdateExecutionAttemptFromRunnerEventParams) (int64, error)
	UpdateTaskAggregateFromRunnerEvent(ctx context.Context, arg repository.UpdateTaskAggregateFromRunnerEventParams) (int64, error)
	UpdateTaskSearchText(ctx context.Context, id string) error
	UpdateTrigger(ctx context.Context, arg repository.UpdateTriggerParams) error
	UpdateTriggerRunStatusByTask(ctx context.Context, arg repository.UpdateTriggerRunStatusByTaskParams) error
	UpsertDefinition(ctx context.Context, arg repository.UpsertDefinitionParams) error
	UpsertDefinitionSource(ctx context.Context, arg repository.UpsertDefinitionSourceParams) error
	UpsertRunnerHeartbeat(ctx context.Context, arg repository.UpsertRunnerHeartbeatParams) error
	UpsertTrigger(ctx context.Context, arg repository.UpsertTriggerParams) error
	ValidateRunnerExecutionClaim(ctx context.Context, arg repository.ValidateRunnerExecutionClaimParams) (repository.ValidateRunnerExecutionClaimRow, error)
}

Repository is the database-independent query surface used by services.

func New 

func New(db *sql.DB, dialect store.Dialect) Repository

New returns the generated repository matching dialect. Its public types are always repository types so callers do not need database-specific conversions.

func NewTx 

func NewTx(tx *sql.Tx, dialect store.Dialect) Repository

NewTx returns a repository bound to tx for transaction retries.

Source Files

View all Source files

Directories

Path Synopsis
cmd
genfacade command
Command genfacade creates the stable repository facade from sqlc output.
 Command genfacade creates the stable repository facade from sqlc output.

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.