Documentation
¶
Index ¶
- type APIKey
- type AbandonLeasedRunExecutionParams
- type AcceptInvitationParams
- type ActivateTaskDeploymentParams
- type ApiKeyGrant
- type AppendRunEventForExecutionParams
- type AppendRunEventParams
- type AppendRunLogChunkParams
- type AppendRunLogChunkRow
- type ApproveDeviceCodeParams
- type ArchiveWorkerGroupParams
- type AuthIdentity
- type AuthenticateWorkerCredentialParams
- type AuthenticateWorkerCredentialRow
- type AuthorizeAPIKeyPermissionParams
- type AuthorizeAPIKeyPermissionRow
- type AuthorizeWorkerCredentialParams
- type AuthorizeWorkerCredentialRow
- type CasObject
- type Checkpoint
- type CheckpointArtifact
- type CheckpointArtifactRole
- type CheckpointStatus
- type CompleteRunQueueEntryParams
- type CompleteWaitpointResponseTokenParams
- type CompleteWaitpointResponseTokenRow
- type ConsumeMagicLinkParams
- type CountRecentMagicLinksParams
- type CountRunsByStatusRow
- type CountScopedRunsByStatusParams
- type CountScopedRunsByStatusRow
- type CreateAPIKeyGrantParams
- type CreateDeployedTaskParams
- type CreateDeviceCodeParams
- type CreateEnvironmentParams
- type CreateEnvironmentWithDefaultWorkerGroupParams
- type CreateEnvironmentWithDefaultWorkerGroupRow
- type CreateInvitationParams
- type CreateMagicLinkParams
- type CreateOrganizationParams
- type CreateProjectParams
- type CreateProjectWithDefaultEnvironmentParams
- type CreateProjectWithDefaultEnvironmentRow
- type CreateRunParams
- type CreateRunRow
- type CreateScopedRunParams
- type CreateScopedRunRow
- type CreateSessionParams
- type CreateTaskDeploymentParams
- type CreateWaitpointDeliveryParams
- type CreateWaitpointForExecutionParams
- type CreateWaitpointForExecutionRow
- type CreateWaitpointPolicyParams
- type CreateWaitpointResponseTokenParams
- type CreateWorkerCredentialFromRegistrationParams
- type CreateWorkerCredentialFromRegistrationRow
- type CreateWorkerGroupParams
- type DBTX
- type DeadLetterRunQueueEntryParams
- type DeadLetterRunQueueEntryRow
- type DeleteAPIKeyGrantParams
- type DeleteAPIKeyGrantsForKeyParams
- type DeleteGitHubInstallationParams
- type DenyDeviceCodeParams
- type DeployedTask
- type DeviceCode
- type DeviceCodeStatus
- type DisableGitHubRepositoryConnectionParams
- type DisableGitHubRepositoryConnectionRow
- type DisableOrgMemberParams
- type DisableProjectWorkspaceRepositoryAccessParams
- type DisableWaitpointPolicyParams
- type EnableGitHubRepositoryConnectionParams
- type EnableProjectWorkspaceRepositoryAccessParams
- type EnsureOrgMemberParams
- type Environment
- type GetActiveDeployedTaskParams
- type GetActiveDeployedTaskRow
- type GetActiveGitHubRepositoryAccessTargetParams
- type GetActiveGitHubRepositoryAccessTargetRow
- type GetActiveInvitationByIDRow
- type GetActiveInvitationRow
- type GetActiveMagicLinkByTokenHashRow
- type GetActiveProjectWorkspaceRepositoryAccessByFullNameParams
- type GetActiveProjectWorkspaceRepositoryAccessByFullNameRow
- type GetActiveProjectWorkspaceRepositoryAccessParams
- type GetActiveProjectWorkspaceRepositoryAccessRow
- type GetActiveTaskDeploymentParams
- type GetActiveWaitpointResponseTokenParams
- type GetActiveWaitpointResponseTokenRow
- type GetDefaultEnvironmentParams
- type GetDefaultProjectEnvironmentRow
- type GetEnvironmentBySlugParams
- type GetEnvironmentParams
- type GetOrgMemberForManagementParams
- type GetOrgMemberForManagementRow
- type GetOrgMemberParams
- type GetOrgMemberRow
- type GetPendingInvitationByEmailParams
- type GetPendingInvitationByEmailRow
- type GetPendingWaitpointForRunParams
- type GetProjectBySlugParams
- type GetProjectParams
- type GetRevocableInvitationParams
- type GetRevocableInvitationRow
- type GetRunExecutionQueueLeaseParams
- type GetRunExecutionQueueLeaseRow
- type GetRunLogSnapshotParams
- type GetRunLogSnapshotRow
- type GetRunParams
- type GetRunRestorePayloadParams
- type GetRunRestorePayloadRow
- type GetRunSummaryParams
- type GetRunSummaryRow
- type GetScopedRunParams
- type GetScopedRunSummaryParams
- type GetScopedRunSummaryRow
- type GetScopedSecretByNameParams
- type GetSecretByNameParams
- type GetSessionByTokenHashRow
- type GetUserOnboardingStateRow
- type GetWaitpointPolicyByNameParams
- type GetWorkerGroupParams
- type GetWorkerHostQueueCapacityParams
- type GetWorkerHostQueueCapacityRow
- type GetWorkerHostStateParams
- type GetWorkerHostStateRow
- type GitHubAppInstallation
- type GithubRepository
- type GithubRepositoryConnection
- type Invitation
- type IssueAPIKeyParams
- type LeaseRunExecutionParams
- type LeaseRunExecutionRow
- type ListAPIKeyGrantsParams
- type ListAPIKeysParams
- type ListAPIKeysRow
- type ListActiveProjectWorkspaceRepositoryAccessParams
- type ListActiveProjectWorkspaceRepositoryAccessRow
- type ListDeployedTasksForDeploymentParams
- type ListEnvironmentsParams
- type ListGitHubInstallationRepositoriesParams
- type ListGitHubInstallationRepositoriesRow
- type ListInvitationsParams
- type ListInvitationsRow
- type ListOrgMembersRow
- type ListOrganizationIDsPageParams
- type ListQueuedRunQueueEntryCandidatesParams
- type ListQueuedRunQueueEntryCandidatesRow
- type ListRunEventsParams
- type ListRunSummariesParams
- type ListRunSummariesRow
- type ListRunsParams
- type ListScopedRunSummariesParams
- type ListScopedRunSummariesRow
- type ListScopedRunsParams
- type ListScopedSecretsParams
- type ListScopedSecretsRow
- type ListSecretsParams
- type ListSecretsRow
- type ListWaitpointDeliveriesParams
- type ListWorkerGroupsByScopeParams
- type ListWorkerHostsByWorkerGroupParams
- type MagicLink
- type MagicLinkPurpose
- type MarkGitHubRepositoriesDeletedByInstallationIDRow
- type MarkGitHubRepositoryDeletedParams
- type MarkGitHubRepositoryDeletedRow
- type MarkRunQueueEntryEnqueueErrorParams
- type MarkRunQueueEntryEnqueuedParams
- type MarkWaitpointCheckpointFailedParams
- type MarkWaitpointCheckpointFailedRow
- type MarkWaitpointCheckpointReadyParams
- type MarkWaitpointCheckpointReadyRow
- type MarkWaitpointDeliveryFailedParams
- type MarkWaitpointDeliverySentParams
- type NullCheckpointArtifactRole
- type NullCheckpointStatus
- type NullDeviceCodeStatus
- type NullMagicLinkPurpose
- type NullOrgMemberRole
- type NullRunExecutionStatus
- type NullRunLogStream
- type NullRunQueueStatus
- type NullRunStatus
- type NullTaskDeploymentStatus
- type NullWaitpointDeliveryStatus
- type NullWaitpointKind
- type NullWaitpointResponseTokenStatus
- type NullWaitpointStatus
- type NullWorkerGroupProvisioningMode
- type NullWorkerHostStatus
- type OrgMember
- type OrgMemberRole
- type Organization
- type PrepareQueuedRunQueueEntryParams
- type PrepareQueuedRunQueueEntryRow
- type Project
- type ProjectWorkspaceRepository
- type Querier
- type Queries
- func (q *Queries) AbandonLeasedRunExecution(ctx context.Context, arg AbandonLeasedRunExecutionParams) error
- func (q *Queries) AcceptInvitation(ctx context.Context, arg AcceptInvitationParams) (int64, error)
- func (q *Queries) ActivateTaskDeployment(ctx context.Context, arg ActivateTaskDeploymentParams) (TaskDeployment, error)
- func (q *Queries) AppendRunEvent(ctx context.Context, arg AppendRunEventParams) (RunEvent, error)
- func (q *Queries) AppendRunEventForExecution(ctx context.Context, arg AppendRunEventForExecutionParams) (RunEvent, error)
- func (q *Queries) AppendRunLogChunk(ctx context.Context, arg AppendRunLogChunkParams) (AppendRunLogChunkRow, error)
- func (q *Queries) ApproveDeviceCode(ctx context.Context, arg ApproveDeviceCodeParams) (DeviceCode, error)
- func (q *Queries) ArchiveWorkerGroup(ctx context.Context, arg ArchiveWorkerGroupParams) (WorkerGroup, error)
- func (q *Queries) AuthenticateWorkerCredential(ctx context.Context, arg AuthenticateWorkerCredentialParams) (AuthenticateWorkerCredentialRow, error)
- func (q *Queries) AuthorizeAPIKeyPermission(ctx context.Context, arg AuthorizeAPIKeyPermissionParams) (AuthorizeAPIKeyPermissionRow, error)
- func (q *Queries) AuthorizeWorkerCredential(ctx context.Context, arg AuthorizeWorkerCredentialParams) (AuthorizeWorkerCredentialRow, error)
- func (q *Queries) CompleteRunQueueEntry(ctx context.Context, arg CompleteRunQueueEntryParams) (RunQueueEntry, error)
- func (q *Queries) CompleteWaitpointResponseToken(ctx context.Context, arg CompleteWaitpointResponseTokenParams) (CompleteWaitpointResponseTokenRow, error)
- func (q *Queries) ConsumeDeviceCode(ctx context.Context, deviceCodeHash []byte) (DeviceCode, error)
- func (q *Queries) ConsumeMagicLink(ctx context.Context, arg ConsumeMagicLinkParams) (int64, error)
- func (q *Queries) CountRecentMagicLinks(ctx context.Context, arg CountRecentMagicLinksParams) (int64, error)
- func (q *Queries) CountRunsByStatus(ctx context.Context, orgID pgtype.UUID) (CountRunsByStatusRow, error)
- func (q *Queries) CountScopedRunsByStatus(ctx context.Context, arg CountScopedRunsByStatusParams) (CountScopedRunsByStatusRow, error)
- func (q *Queries) CreateAPIKeyGrant(ctx context.Context, arg CreateAPIKeyGrantParams) (ApiKeyGrant, error)
- func (q *Queries) CreateDeployedTask(ctx context.Context, arg CreateDeployedTaskParams) (DeployedTask, error)
- func (q *Queries) CreateDeviceCode(ctx context.Context, arg CreateDeviceCodeParams) (DeviceCode, error)
- func (q *Queries) CreateEnvironment(ctx context.Context, arg CreateEnvironmentParams) (Environment, error)
- func (q *Queries) CreateEnvironmentWithDefaultWorkerGroup(ctx context.Context, arg CreateEnvironmentWithDefaultWorkerGroupParams) (CreateEnvironmentWithDefaultWorkerGroupRow, error)
- func (q *Queries) CreateInvitation(ctx context.Context, arg CreateInvitationParams) (Invitation, error)
- func (q *Queries) CreateMagicLink(ctx context.Context, arg CreateMagicLinkParams) (MagicLink, error)
- func (q *Queries) CreateOrganization(ctx context.Context, arg CreateOrganizationParams) (Organization, error)
- func (q *Queries) CreateProject(ctx context.Context, arg CreateProjectParams) (Project, error)
- func (q *Queries) CreateProjectWithDefaultEnvironment(ctx context.Context, arg CreateProjectWithDefaultEnvironmentParams) (CreateProjectWithDefaultEnvironmentRow, error)
- func (q *Queries) CreateRun(ctx context.Context, arg CreateRunParams) (CreateRunRow, error)
- func (q *Queries) CreateScopedRun(ctx context.Context, arg CreateScopedRunParams) (CreateScopedRunRow, error)
- func (q *Queries) CreateSession(ctx context.Context, arg CreateSessionParams) (Session, error)
- func (q *Queries) CreateTaskDeployment(ctx context.Context, arg CreateTaskDeploymentParams) (TaskDeployment, error)
- func (q *Queries) CreateWaitpointDelivery(ctx context.Context, arg CreateWaitpointDeliveryParams) (WaitpointDelivery, error)
- func (q *Queries) CreateWaitpointForExecution(ctx context.Context, arg CreateWaitpointForExecutionParams) (CreateWaitpointForExecutionRow, error)
- func (q *Queries) CreateWaitpointPolicy(ctx context.Context, arg CreateWaitpointPolicyParams) (WaitpointPolicy, error)
- func (q *Queries) CreateWaitpointResponseToken(ctx context.Context, arg CreateWaitpointResponseTokenParams) (WaitpointResponseToken, error)
- func (q *Queries) CreateWorkerCredentialFromRegistration(ctx context.Context, arg CreateWorkerCredentialFromRegistrationParams) (CreateWorkerCredentialFromRegistrationRow, error)
- func (q *Queries) CreateWorkerGroup(ctx context.Context, arg CreateWorkerGroupParams) (WorkerGroup, error)
- func (q *Queries) DeadLetterRunQueueEntry(ctx context.Context, arg DeadLetterRunQueueEntryParams) (DeadLetterRunQueueEntryRow, error)
- func (q *Queries) DeleteAPIKeyGrant(ctx context.Context, arg DeleteAPIKeyGrantParams) (int64, error)
- func (q *Queries) DeleteAPIKeyGrantsForKey(ctx context.Context, arg DeleteAPIKeyGrantsForKeyParams) (int64, error)
- func (q *Queries) DeleteGitHubInstallation(ctx context.Context, arg DeleteGitHubInstallationParams) (GitHubAppInstallation, error)
- func (q *Queries) DeleteGitHubInstallationByInstallationID(ctx context.Context, installationID int64) ([]GitHubAppInstallation, error)
- func (q *Queries) DenyDeviceCode(ctx context.Context, arg DenyDeviceCodeParams) (DeviceCode, error)
- func (q *Queries) DisableGitHubRepositoryConnection(ctx context.Context, arg DisableGitHubRepositoryConnectionParams) (DisableGitHubRepositoryConnectionRow, error)
- func (q *Queries) DisableOrgMember(ctx context.Context, arg DisableOrgMemberParams) (OrgMember, error)
- func (q *Queries) DisableProjectWorkspaceRepositoryAccess(ctx context.Context, arg DisableProjectWorkspaceRepositoryAccessParams) (ProjectWorkspaceRepository, error)
- func (q *Queries) DisableWaitpointPolicy(ctx context.Context, arg DisableWaitpointPolicyParams) (int64, error)
- func (q *Queries) EnableGitHubRepositoryConnection(ctx context.Context, arg EnableGitHubRepositoryConnectionParams) (GithubRepositoryConnection, error)
- func (q *Queries) EnableProjectWorkspaceRepositoryAccess(ctx context.Context, arg EnableProjectWorkspaceRepositoryAccessParams) (ProjectWorkspaceRepository, error)
- func (q *Queries) EnsureOrgMember(ctx context.Context, arg EnsureOrgMemberParams) (OrgMember, error)
- func (q *Queries) ExpireDuePendingWaitpoints(ctx context.Context, orgID pgtype.UUID) error
- func (q *Queries) FailExpiredRunningRunExecutions(ctx context.Context, orgID pgtype.UUID) error
- func (q *Queries) GetActiveDeployedTask(ctx context.Context, arg GetActiveDeployedTaskParams) (GetActiveDeployedTaskRow, error)
- func (q *Queries) GetActiveGitHubRepositoryAccessTarget(ctx context.Context, arg GetActiveGitHubRepositoryAccessTargetParams) (GetActiveGitHubRepositoryAccessTargetRow, error)
- func (q *Queries) GetActiveInvitation(ctx context.Context, tokenHash []byte) (GetActiveInvitationRow, error)
- func (q *Queries) GetActiveInvitationByID(ctx context.Context, id pgtype.UUID) (GetActiveInvitationByIDRow, error)
- func (q *Queries) GetActiveMagicLinkByTokenHash(ctx context.Context, tokenHash []byte) (GetActiveMagicLinkByTokenHashRow, error)
- func (q *Queries) GetActiveProjectWorkspaceRepositoryAccess(ctx context.Context, arg GetActiveProjectWorkspaceRepositoryAccessParams) (GetActiveProjectWorkspaceRepositoryAccessRow, error)
- func (q *Queries) GetActiveProjectWorkspaceRepositoryAccessByFullName(ctx context.Context, ...) (GetActiveProjectWorkspaceRepositoryAccessByFullNameRow, error)
- func (q *Queries) GetActiveTaskDeployment(ctx context.Context, arg GetActiveTaskDeploymentParams) (TaskDeployment, error)
- func (q *Queries) GetActiveWaitpointResponseToken(ctx context.Context, arg GetActiveWaitpointResponseTokenParams) (GetActiveWaitpointResponseTokenRow, error)
- func (q *Queries) GetCasObject(ctx context.Context, digest string) (CasObject, error)
- func (q *Queries) GetDefaultEnvironment(ctx context.Context, arg GetDefaultEnvironmentParams) (Environment, error)
- func (q *Queries) GetDefaultProjectEnvironment(ctx context.Context, orgID pgtype.UUID) (GetDefaultProjectEnvironmentRow, error)
- func (q *Queries) GetDeviceCodeByUserCodeHash(ctx context.Context, userCodeHash []byte) (DeviceCode, error)
- func (q *Queries) GetDeviceCodeForPoll(ctx context.Context, deviceCodeHash []byte) (DeviceCode, error)
- func (q *Queries) GetEnvironment(ctx context.Context, arg GetEnvironmentParams) (Environment, error)
- func (q *Queries) GetEnvironmentBySlug(ctx context.Context, arg GetEnvironmentBySlugParams) (Environment, error)
- func (q *Queries) GetKnownGitHubInstallationByInstallationID(ctx context.Context, installationID int64) (GitHubAppInstallation, error)
- func (q *Queries) GetMagicLinkLoginUser(ctx context.Context, email pgtype.Text) (User, error)
- func (q *Queries) GetOrgMember(ctx context.Context, arg GetOrgMemberParams) (GetOrgMemberRow, error)
- func (q *Queries) GetOrgMemberForManagement(ctx context.Context, arg GetOrgMemberForManagementParams) (GetOrgMemberForManagementRow, error)
- func (q *Queries) GetOrganization(ctx context.Context, id pgtype.UUID) (Organization, error)
- func (q *Queries) GetPendingInvitationByEmail(ctx context.Context, arg GetPendingInvitationByEmailParams) (GetPendingInvitationByEmailRow, error)
- func (q *Queries) GetPendingWaitpointForRun(ctx context.Context, arg GetPendingWaitpointForRunParams) (Waitpoint, error)
- func (q *Queries) GetProject(ctx context.Context, arg GetProjectParams) (Project, error)
- func (q *Queries) GetProjectBySlug(ctx context.Context, arg GetProjectBySlugParams) (Project, error)
- func (q *Queries) GetRevocableInvitation(ctx context.Context, arg GetRevocableInvitationParams) (GetRevocableInvitationRow, error)
- func (q *Queries) GetRun(ctx context.Context, arg GetRunParams) (Run, error)
- func (q *Queries) GetRunExecutionQueueLease(ctx context.Context, arg GetRunExecutionQueueLeaseParams) (GetRunExecutionQueueLeaseRow, error)
- func (q *Queries) GetRunLogSnapshot(ctx context.Context, arg GetRunLogSnapshotParams) (GetRunLogSnapshotRow, error)
- func (q *Queries) GetRunRestorePayload(ctx context.Context, arg GetRunRestorePayloadParams) (GetRunRestorePayloadRow, error)
- func (q *Queries) GetRunSummary(ctx context.Context, arg GetRunSummaryParams) (GetRunSummaryRow, error)
- func (q *Queries) GetScopedRun(ctx context.Context, arg GetScopedRunParams) (Run, error)
- func (q *Queries) GetScopedRunSummary(ctx context.Context, arg GetScopedRunSummaryParams) (GetScopedRunSummaryRow, error)
- func (q *Queries) GetScopedSecretByName(ctx context.Context, arg GetScopedSecretByNameParams) (Secret, error)
- func (q *Queries) GetSecretByName(ctx context.Context, arg GetSecretByNameParams) (Secret, error)
- func (q *Queries) GetSessionByTokenHash(ctx context.Context, tokenHash []byte) (GetSessionByTokenHashRow, error)
- func (q *Queries) GetUserOnboardingState(ctx context.Context, userID pgtype.UUID) (GetUserOnboardingStateRow, error)
- func (q *Queries) GetWaitpointPolicyByName(ctx context.Context, arg GetWaitpointPolicyByNameParams) (WaitpointPolicy, error)
- func (q *Queries) GetWorkerGroup(ctx context.Context, arg GetWorkerGroupParams) (WorkerGroup, error)
- func (q *Queries) GetWorkerHostQueueCapacity(ctx context.Context, arg GetWorkerHostQueueCapacityParams) (GetWorkerHostQueueCapacityRow, error)
- func (q *Queries) GetWorkerHostState(ctx context.Context, arg GetWorkerHostStateParams) (GetWorkerHostStateRow, error)
- func (q *Queries) IssueAPIKey(ctx context.Context, arg IssueAPIKeyParams) (APIKey, error)
- func (q *Queries) LeaseRunExecution(ctx context.Context, arg LeaseRunExecutionParams) (LeaseRunExecutionRow, error)
- func (q *Queries) ListAPIKeyGrants(ctx context.Context, arg ListAPIKeyGrantsParams) ([]ApiKeyGrant, error)
- func (q *Queries) ListAPIKeys(ctx context.Context, arg ListAPIKeysParams) ([]ListAPIKeysRow, error)
- func (q *Queries) ListActiveProjectWorkspaceRepositoryAccess(ctx context.Context, arg ListActiveProjectWorkspaceRepositoryAccessParams) ([]ListActiveProjectWorkspaceRepositoryAccessRow, error)
- func (q *Queries) ListDeployedTasksForDeployment(ctx context.Context, arg ListDeployedTasksForDeploymentParams) ([]DeployedTask, error)
- func (q *Queries) ListEnvironments(ctx context.Context, arg ListEnvironmentsParams) ([]Environment, error)
- func (q *Queries) ListGitHubInstallationRepositories(ctx context.Context, arg ListGitHubInstallationRepositoriesParams) ([]ListGitHubInstallationRepositoriesRow, error)
- func (q *Queries) ListGitHubInstallations(ctx context.Context, orgID pgtype.UUID) ([]GitHubAppInstallation, error)
- func (q *Queries) ListInvitations(ctx context.Context, arg ListInvitationsParams) ([]ListInvitationsRow, error)
- func (q *Queries) ListOrgMembers(ctx context.Context, orgID pgtype.UUID) ([]ListOrgMembersRow, error)
- func (q *Queries) ListOrganizationIDs(ctx context.Context, rowLimit int32) ([]pgtype.UUID, error)
- func (q *Queries) ListOrganizationIDsPage(ctx context.Context, arg ListOrganizationIDsPageParams) ([]pgtype.UUID, error)
- func (q *Queries) ListProjects(ctx context.Context, orgID pgtype.UUID) ([]Project, error)
- func (q *Queries) ListQueuedRunQueueEntryCandidates(ctx context.Context, arg ListQueuedRunQueueEntryCandidatesParams) ([]ListQueuedRunQueueEntryCandidatesRow, error)
- func (q *Queries) ListRunEvents(ctx context.Context, arg ListRunEventsParams) ([]RunEvent, error)
- func (q *Queries) ListRunSummaries(ctx context.Context, arg ListRunSummariesParams) ([]ListRunSummariesRow, error)
- func (q *Queries) ListRuns(ctx context.Context, arg ListRunsParams) ([]Run, error)
- func (q *Queries) ListScopedRunSummaries(ctx context.Context, arg ListScopedRunSummariesParams) ([]ListScopedRunSummariesRow, error)
- func (q *Queries) ListScopedRuns(ctx context.Context, arg ListScopedRunsParams) ([]Run, error)
- func (q *Queries) ListScopedSecrets(ctx context.Context, arg ListScopedSecretsParams) ([]ListScopedSecretsRow, error)
- func (q *Queries) ListSecrets(ctx context.Context, arg ListSecretsParams) ([]ListSecretsRow, error)
- func (q *Queries) ListWaitpointDeliveries(ctx context.Context, arg ListWaitpointDeliveriesParams) ([]WaitpointDelivery, error)
- func (q *Queries) ListWaitpointPolicies(ctx context.Context, orgID pgtype.UUID) ([]WaitpointPolicy, error)
- func (q *Queries) ListWorkerGroupsByScope(ctx context.Context, arg ListWorkerGroupsByScopeParams) ([]WorkerGroup, error)
- func (q *Queries) ListWorkerHostsByWorkerGroup(ctx context.Context, arg ListWorkerHostsByWorkerGroupParams) ([]WorkerHost, error)
- func (q *Queries) MarkGitHubRepositoriesDeletedByInstallationID(ctx context.Context, installationID int64) ([]MarkGitHubRepositoriesDeletedByInstallationIDRow, error)
- func (q *Queries) MarkGitHubRepositoryDeleted(ctx context.Context, arg MarkGitHubRepositoryDeletedParams) (MarkGitHubRepositoryDeletedRow, error)
- func (q *Queries) MarkMagicLinkDeliveryFailed(ctx context.Context, id pgtype.UUID) (int64, error)
- func (q *Queries) MarkMagicLinkSent(ctx context.Context, id pgtype.UUID) (int64, error)
- func (q *Queries) MarkRunQueueEntryEnqueueError(ctx context.Context, arg MarkRunQueueEntryEnqueueErrorParams) (RunQueueEntry, error)
- func (q *Queries) MarkRunQueueEntryEnqueued(ctx context.Context, arg MarkRunQueueEntryEnqueuedParams) (RunQueueEntry, error)
- func (q *Queries) MarkWaitpointCheckpointFailed(ctx context.Context, arg MarkWaitpointCheckpointFailedParams) (MarkWaitpointCheckpointFailedRow, error)
- func (q *Queries) MarkWaitpointCheckpointReady(ctx context.Context, arg MarkWaitpointCheckpointReadyParams) (MarkWaitpointCheckpointReadyRow, error)
- func (q *Queries) MarkWaitpointDeliveryFailed(ctx context.Context, arg MarkWaitpointDeliveryFailedParams) (WaitpointDelivery, error)
- func (q *Queries) MarkWaitpointDeliverySent(ctx context.Context, arg MarkWaitpointDeliverySentParams) (WaitpointDelivery, error)
- func (q *Queries) OwnerExists(ctx context.Context, orgID pgtype.UUID) (bool, error)
- func (q *Queries) PrepareQueuedRunQueueEntry(ctx context.Context, arg PrepareQueuedRunQueueEntryParams) (PrepareQueuedRunQueueEntryRow, error)
- func (q *Queries) RefreshSession(ctx context.Context, arg RefreshSessionParams) error
- func (q *Queries) ReleaseRunExecution(ctx context.Context, arg ReleaseRunExecutionParams) (ReleaseRunExecutionRow, error)
- func (q *Queries) RenewRunExecutionLease(ctx context.Context, arg RenewRunExecutionLeaseParams) (RenewRunExecutionLeaseRow, error)
- func (q *Queries) RenewRunQueueReservation(ctx context.Context, arg RenewRunQueueReservationParams) (RunQueueEntry, error)
- func (q *Queries) RequeueExpiredLeasedRunExecutions(ctx context.Context, orgID pgtype.UUID) error
- func (q *Queries) RequeueRunQueueEntry(ctx context.Context, arg RequeueRunQueueEntryParams) (RunQueueEntry, error)
- func (q *Queries) ReserveRunQueueEntry(ctx context.Context, arg ReserveRunQueueEntryParams) (RunQueueEntry, error)
- func (q *Queries) ResolveWaitpoint(ctx context.Context, arg ResolveWaitpointParams) (ResolveWaitpointRow, error)
- func (q *Queries) RevokeAPIKey(ctx context.Context, arg RevokeAPIKeyParams) (int64, error)
- func (q *Queries) RevokeExpiredInvitationsByEmail(ctx context.Context, arg RevokeExpiredInvitationsByEmailParams) (int64, error)
- func (q *Queries) RevokeInvitation(ctx context.Context, arg RevokeInvitationParams) (int64, error)
- func (q *Queries) RevokeOpenMagicLinksForRecipient(ctx context.Context, arg RevokeOpenMagicLinksForRecipientParams) (int64, error)
- func (q *Queries) RevokeSessionByTokenHash(ctx context.Context, tokenHash []byte) (int64, error)
- func (q *Queries) RevokeSessionsForUser(ctx context.Context, userID pgtype.UUID) (int64, error)
- func (q *Queries) RevokeWaitpointResponseToken(ctx context.Context, arg RevokeWaitpointResponseTokenParams) (int64, error)
- func (q *Queries) RevokeWorkerCredential(ctx context.Context, arg RevokeWorkerCredentialParams) (int64, error)
- func (q *Queries) RevokeWorkerCredentialsByWorkerHostID(ctx context.Context, arg RevokeWorkerCredentialsByWorkerHostIDParams) (int64, error)
- func (q *Queries) RunExecutionDeliveryAttemptsExhausted(ctx context.Context, arg RunExecutionDeliveryAttemptsExhaustedParams) (bool, error)
- func (q *Queries) SetWorkerHostStatus(ctx context.Context, arg SetWorkerHostStatusParams) (WorkerHost, error)
- func (q *Queries) StartRunExecution(ctx context.Context, arg StartRunExecutionParams) (RunStatus, error)
- func (q *Queries) SuspendGitHubInstallation(ctx context.Context, arg SuspendGitHubInstallationParams) (GitHubAppInstallation, error)
- func (q *Queries) SuspendGitHubInstallationByInstallationID(ctx context.Context, installationID int64) ([]GitHubAppInstallation, error)
- func (q *Queries) TouchActiveAPIKeyByTokenHash(ctx context.Context, tokenHash []byte) (TouchActiveAPIKeyByTokenHashRow, error)
- func (q *Queries) UpdateOrgMemberRole(ctx context.Context, arg UpdateOrgMemberRoleParams) (OrgMember, error)
- func (q *Queries) UpdateProjectDetails(ctx context.Context, arg UpdateProjectDetailsParams) (Project, error)
- func (q *Queries) UpdateWaitpointPolicy(ctx context.Context, arg UpdateWaitpointPolicyParams) (WaitpointPolicy, error)
- func (q *Queries) UpsertAuthIdentity(ctx context.Context, arg UpsertAuthIdentityParams) (UpsertAuthIdentityRow, error)
- func (q *Queries) UpsertCasObject(ctx context.Context, arg UpsertCasObjectParams) (CasObject, error)
- func (q *Queries) UpsertGitHubInstallation(ctx context.Context, arg UpsertGitHubInstallationParams) (GitHubAppInstallation, error)
- func (q *Queries) UpsertGitHubRepository(ctx context.Context, arg UpsertGitHubRepositoryParams) (GithubRepository, error)
- func (q *Queries) UpsertMagicLinkAuthIdentity(ctx context.Context, arg UpsertMagicLinkAuthIdentityParams) (UpsertMagicLinkAuthIdentityRow, error)
- func (q *Queries) UpsertRunQueueEntryQueued(ctx context.Context, arg UpsertRunQueueEntryQueuedParams) (RunQueueEntry, error)
- func (q *Queries) UpsertRunRequirements(ctx context.Context, arg UpsertRunRequirementsParams) (RunRequirement, error)
- func (q *Queries) UpsertScopedSecret(ctx context.Context, arg UpsertScopedSecretParams) (Secret, error)
- func (q *Queries) UpsertSecret(ctx context.Context, arg UpsertSecretParams) (Secret, error)
- func (q *Queries) UpsertWorkerHostHeartbeat(ctx context.Context, arg UpsertWorkerHostHeartbeatParams) (WorkerHost, error)
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
- type RefreshSessionParams
- type ReleaseRunExecutionParams
- type ReleaseRunExecutionRow
- type RenewRunExecutionLeaseParams
- type RenewRunExecutionLeaseRow
- type RenewRunQueueReservationParams
- type RequeueRunQueueEntryParams
- type ReserveRunQueueEntryParams
- type ResolveWaitpointParams
- type ResolveWaitpointRow
- type RevokeAPIKeyParams
- type RevokeExpiredInvitationsByEmailParams
- type RevokeInvitationParams
- type RevokeOpenMagicLinksForRecipientParams
- type RevokeWaitpointResponseTokenParams
- type RevokeWorkerCredentialParams
- type RevokeWorkerCredentialsByWorkerHostIDParams
- type Run
- type RunEvent
- type RunExecution
- type RunExecutionDeliveryAttemptsExhaustedParams
- type RunExecutionStatus
- type RunLogChunk
- type RunLogStream
- type RunQueueEntry
- type RunQueueStatus
- type RunRequirement
- type RunStatus
- type Secret
- type Session
- type SetWorkerHostStatusParams
- type StartRunExecutionParams
- type SuspendGitHubInstallationParams
- type TaskDeployment
- type TaskDeploymentStatus
- type TouchActiveAPIKeyByTokenHashRow
- type UpdateOrgMemberRoleParams
- type UpdateProjectDetailsParams
- type UpdateWaitpointPolicyParams
- type UpsertAuthIdentityParams
- type UpsertAuthIdentityRow
- type UpsertCasObjectParams
- type UpsertGitHubInstallationParams
- type UpsertGitHubRepositoryParams
- type UpsertMagicLinkAuthIdentityParams
- type UpsertMagicLinkAuthIdentityRow
- type UpsertRunQueueEntryQueuedParams
- type UpsertRunRequirementsParams
- type UpsertScopedSecretParams
- type UpsertSecretParams
- type UpsertWorkerHostHeartbeatParams
- type User
- type Waitpoint
- type WaitpointDelivery
- type WaitpointDeliveryStatus
- type WaitpointKind
- type WaitpointPolicy
- type WaitpointResponseToken
- type WaitpointResponseTokenStatus
- type WaitpointStatus
- type WorkerCredential
- type WorkerGroup
- type WorkerGroupProvisioningMode
- type WorkerHost
- type WorkerHostStatus
- type WorkerRegistrationToken
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type APIKey ¶
type APIKey struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
CreatedByUserID pgtype.UUID `json:"created_by_user_id"`
Name string `json:"name"`
KeyPrefix string `json:"key_prefix"`
TokenHash []byte `json:"token_hash"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
LastUsedAt pgtype.Timestamptz `json:"last_used_at"`
ExpiresAt pgtype.Timestamptz `json:"expires_at"`
RevokedAt pgtype.Timestamptz `json:"revoked_at"`
}
type AcceptInvitationParams ¶
type ApiKeyGrant ¶
type ApiKeyGrant struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ApiKeyID pgtype.UUID `json:"api_key_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
Permission string `json:"permission"`
CreatedByUserID pgtype.UUID `json:"created_by_user_id"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
}
type AppendRunEventForExecutionParams ¶
type AppendRunEventForExecutionParams struct {
OrgID pgtype.UUID `json:"org_id"`
Kind string `json:"kind"`
Payload []byte `json:"payload"`
RunID pgtype.UUID `json:"run_id"`
ExecutionID pgtype.UUID `json:"execution_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
WorkerHostID pgtype.UUID `json:"worker_host_id"`
}
type AppendRunEventParams ¶
type AppendRunLogChunkParams ¶
type AppendRunLogChunkParams struct {
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
ExecutionID pgtype.UUID `json:"execution_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
WorkerHostID pgtype.UUID `json:"worker_host_id"`
Stream RunLogStream `json:"stream"`
ObservedSeq int64 `json:"observed_seq"`
Content []byte `json:"content"`
Kind string `json:"kind"`
Payload []byte `json:"payload"`
}
type AppendRunLogChunkRow ¶
type AppendRunLogChunkRow struct {
RunID pgtype.UUID `json:"run_id"`
ExecutionID pgtype.UUID `json:"execution_id"`
Stream RunLogStream `json:"stream"`
Seq int64 `json:"seq"`
ObservedSeq int64 `json:"observed_seq"`
Content []byte `json:"content"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
}
type ApproveDeviceCodeParams ¶
type AuthIdentity ¶
type AuthIdentity struct {
ID pgtype.UUID `json:"id"`
UserID pgtype.UUID `json:"user_id"`
Provider string `json:"provider"`
Subject string `json:"subject"`
Email pgtype.Text `json:"email"`
Claims []byte `json:"claims"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
LastLoginAt pgtype.Timestamptz `json:"last_login_at"`
}
type AuthenticateWorkerCredentialRow ¶
type AuthenticateWorkerCredentialRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
WorkerHostID string `json:"worker_host_id"`
ExternalID string `json:"external_id"`
}
type AuthorizeWorkerCredentialRow ¶
type AuthorizeWorkerCredentialRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
WorkerHostID string `json:"worker_host_id"`
ExternalID string `json:"external_id"`
}
type CasObject ¶
type CasObject struct {
Digest string `json:"digest"`
SizeBytes int64 `json:"size_bytes"`
MediaType string `json:"media_type"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
}
type Checkpoint ¶
type Checkpoint struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
ExecutionID pgtype.UUID `json:"execution_id"`
Status CheckpointStatus `json:"status"`
Reason string `json:"reason"`
RuntimeBackend pgtype.Text `json:"runtime_backend"`
RuntimeArch pgtype.Text `json:"runtime_arch"`
RuntimeABI pgtype.Text `json:"runtime_abi"`
KernelDigest pgtype.Text `json:"kernel_digest"`
RootfsDigest pgtype.Text `json:"rootfs_digest"`
RuntimeVcpus pgtype.Int4 `json:"runtime_vcpus"`
RuntimeMemoryMib pgtype.Int4 `json:"runtime_memory_mib"`
CniProfile pgtype.Text `json:"cni_profile"`
ImageKey pgtype.Text `json:"image_key"`
RuntimeConfigDigest pgtype.Text `json:"runtime_config_digest"`
Manifest []byte `json:"manifest"`
ErrorMessage pgtype.Text `json:"error_message"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
ReadyAt pgtype.Timestamptz `json:"ready_at"`
InvalidatedAt pgtype.Timestamptz `json:"invalidated_at"`
}
type CheckpointArtifact ¶
type CheckpointArtifact struct {
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
CheckpointID pgtype.UUID `json:"checkpoint_id"`
Role CheckpointArtifactRole `json:"role"`
Ordinal int32 `json:"ordinal"`
Digest string `json:"digest"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
}
type CheckpointArtifactRole ¶
type CheckpointArtifactRole string
const ( CheckpointArtifactRoleManifest CheckpointArtifactRole = "manifest" CheckpointArtifactRoleVMState CheckpointArtifactRole = "vm_state" CheckpointArtifactRoleWorkspaceUpper CheckpointArtifactRole = "workspace_upper" CheckpointArtifactRoleMemory CheckpointArtifactRole = "memory" )
func (*CheckpointArtifactRole) Scan ¶
func (e *CheckpointArtifactRole) Scan(src interface{}) error
type CheckpointStatus ¶
type CheckpointStatus string
const ( CheckpointStatusCreating CheckpointStatus = "creating" CheckpointStatusReady CheckpointStatus = "ready" CheckpointStatusRestoring CheckpointStatus = "restoring" CheckpointStatusInvalid CheckpointStatus = "invalid" )
func (*CheckpointStatus) Scan ¶
func (e *CheckpointStatus) Scan(src interface{}) error
type CompleteWaitpointResponseTokenParams ¶
type CompleteWaitpointResponseTokenParams struct {
ID pgtype.UUID `json:"id"`
TokenHash []byte `json:"token_hash"`
Action string `json:"action"`
Kind WaitpointKind `json:"kind"`
ResolutionKind pgtype.Text `json:"resolution_kind"`
Resolution []byte `json:"resolution"`
Payload []byte `json:"payload"`
CompletedByPrincipal pgtype.Text `json:"completed_by_principal"`
CompletedVia pgtype.Text `json:"completed_via"`
ExternalSubject pgtype.Text `json:"external_subject"`
Metadata []byte `json:"metadata"`
}
type CompleteWaitpointResponseTokenRow ¶
type CompleteWaitpointResponseTokenRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
WaitpointID pgtype.UUID `json:"waitpoint_id"`
TokenHash []byte `json:"token_hash"`
AllowedActions []string `json:"allowed_actions"`
Status WaitpointResponseTokenStatus `json:"status"`
ExpiresAt pgtype.Timestamptz `json:"expires_at"`
CompletedAt pgtype.Timestamptz `json:"completed_at"`
CompletedByPrincipal pgtype.Text `json:"completed_by_principal"`
CompletedVia pgtype.Text `json:"completed_via"`
ExternalSubject pgtype.Text `json:"external_subject"`
Metadata []byte `json:"metadata"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
}
type ConsumeMagicLinkParams ¶
type CountRecentMagicLinksParams ¶
type CountRecentMagicLinksParams struct {
Purpose MagicLinkPurpose `json:"purpose"`
Email string `json:"email"`
Since pgtype.Timestamptz `json:"since"`
}
type CountRunsByStatusRow ¶
type CreateAPIKeyGrantParams ¶
type CreateAPIKeyGrantParams struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ApiKeyID pgtype.UUID `json:"api_key_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
Permission string `json:"permission"`
CreatedByUserID pgtype.UUID `json:"created_by_user_id"`
}
type CreateDeployedTaskParams ¶
type CreateDeployedTaskParams struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
DeploymentID pgtype.UUID `json:"deployment_id"`
TaskID string `json:"task_id"`
ModulePath string `json:"module_path"`
ExportName string `json:"export_name"`
RequestedMilliCpu int64 `json:"requested_milli_cpu"`
RequestedMemoryMib int64 `json:"requested_memory_mib"`
}
type CreateDeviceCodeParams ¶
type CreateEnvironmentParams ¶
type CreateEnvironmentWithDefaultWorkerGroupRow ¶
type CreateEnvironmentWithDefaultWorkerGroupRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
Slug string `json:"slug"`
Name string `json:"name"`
IsDefault bool `json:"is_default"`
ArchivedAt pgtype.Timestamptz `json:"archived_at"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type CreateInvitationParams ¶
type CreateInvitationParams struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
InviteeEmail string `json:"invitee_email"`
Role OrgMemberRole `json:"role"`
InvitedByUserID pgtype.UUID `json:"invited_by_user_id"`
TokenHash []byte `json:"token_hash"`
ExpiresAt pgtype.Timestamptz `json:"expires_at"`
}
type CreateMagicLinkParams ¶
type CreateMagicLinkParams struct {
ID pgtype.UUID `json:"id"`
Purpose MagicLinkPurpose `json:"purpose"`
TokenHash []byte `json:"token_hash"`
Email string `json:"email"`
OrgID pgtype.UUID `json:"org_id"`
InvitationID pgtype.UUID `json:"invitation_id"`
RedirectAfter pgtype.Text `json:"redirect_after"`
ExpiresAt pgtype.Timestamptz `json:"expires_at"`
}
type CreateProjectParams ¶
type CreateProjectWithDefaultEnvironmentParams ¶
type CreateProjectWithDefaultEnvironmentParams struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
Slug string `json:"slug"`
Name string `json:"name"`
IsDefault bool `json:"is_default"`
EnvironmentID pgtype.UUID `json:"environment_id"`
RegistrationTokenID pgtype.UUID `json:"registration_token_id"`
RegistrationTokenHash []byte `json:"registration_token_hash"`
}
type CreateProjectWithDefaultEnvironmentRow ¶
type CreateProjectWithDefaultEnvironmentRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
Slug string `json:"slug"`
Name string `json:"name"`
IsDefault bool `json:"is_default"`
ArchivedAt pgtype.Timestamptz `json:"archived_at"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type CreateRunParams ¶
type CreateRunParams struct {
OrgID pgtype.UUID `json:"org_id"`
ID pgtype.UUID `json:"id"`
TaskDeploymentID pgtype.UUID `json:"task_deployment_id"`
DeployedTaskID pgtype.UUID `json:"deployed_task_id"`
TaskID string `json:"task_id"`
Payload []byte `json:"payload"`
SecretBindings []byte `json:"secret_bindings"`
WorkspaceRepository string `json:"workspace_repository"`
WorkspaceInstallationID int64 `json:"workspace_installation_id"`
WorkspaceGithubRepositoryID int64 `json:"workspace_github_repository_id"`
WorkspaceRef string `json:"workspace_ref"`
WorkspaceSha string `json:"workspace_sha"`
WorkspaceSubpath string `json:"workspace_subpath"`
MaxDurationSeconds int32 `json:"max_duration_seconds"`
EventPayload []byte `json:"event_payload"`
}
type CreateRunRow ¶
type CreateRunRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
TaskID string `json:"task_id"`
Status RunStatus `json:"status"`
ExitCode pgtype.Int4 `json:"exit_code"`
Output []byte `json:"output"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type CreateScopedRunParams ¶
type CreateScopedRunParams struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
TaskDeploymentID pgtype.UUID `json:"task_deployment_id"`
DeployedTaskID pgtype.UUID `json:"deployed_task_id"`
TaskID string `json:"task_id"`
Payload []byte `json:"payload"`
SecretBindings []byte `json:"secret_bindings"`
WorkspaceRepository string `json:"workspace_repository"`
WorkspaceInstallationID int64 `json:"workspace_installation_id"`
WorkspaceGithubRepositoryID int64 `json:"workspace_github_repository_id"`
WorkspaceRef string `json:"workspace_ref"`
WorkspaceSha string `json:"workspace_sha"`
WorkspaceSubpath string `json:"workspace_subpath"`
MaxDurationSeconds int32 `json:"max_duration_seconds"`
EventPayload []byte `json:"event_payload"`
}
type CreateScopedRunRow ¶
type CreateScopedRunRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
TaskID string `json:"task_id"`
Status RunStatus `json:"status"`
ExitCode pgtype.Int4 `json:"exit_code"`
Output []byte `json:"output"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type CreateSessionParams ¶
type CreateWaitpointDeliveryParams ¶
type CreateWaitpointDeliveryParams struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
WaitpointID pgtype.UUID `json:"waitpoint_id"`
ResponseTokenID pgtype.UUID `json:"response_token_id"`
Channel string `json:"channel"`
RecipientKind string `json:"recipient_kind"`
Recipient string `json:"recipient"`
Status WaitpointDeliveryStatus `json:"status"`
Metadata []byte `json:"metadata"`
}
type CreateWaitpointForExecutionParams ¶
type CreateWaitpointForExecutionParams struct {
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
ExecutionID pgtype.UUID `json:"execution_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
WorkerHostID pgtype.UUID `json:"worker_host_id"`
CorrelationID string `json:"correlation_id"`
CheckpointID pgtype.UUID `json:"checkpoint_id"`
CheckpointReason string `json:"checkpoint_reason"`
ID pgtype.UUID `json:"id"`
Kind WaitpointKind `json:"kind"`
Request []byte `json:"request"`
DisplayText string `json:"display_text"`
TimeoutSeconds pgtype.Int4 `json:"timeout_seconds"`
PolicyName pgtype.Text `json:"policy_name"`
PolicySnapshot []byte `json:"policy_snapshot"`
}
type CreateWaitpointForExecutionRow ¶
type CreateWaitpointForExecutionRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
ExecutionID pgtype.UUID `json:"execution_id"`
CheckpointID pgtype.UUID `json:"checkpoint_id"`
CorrelationID string `json:"correlation_id"`
Kind WaitpointKind `json:"kind"`
Request []byte `json:"request"`
DisplayText string `json:"display_text"`
TimeoutSeconds pgtype.Int4 `json:"timeout_seconds"`
PolicyName pgtype.Text `json:"policy_name"`
PolicySnapshot []byte `json:"policy_snapshot"`
Status WaitpointStatus `json:"status"`
ResolutionKind pgtype.Text `json:"resolution_kind"`
Resolution []byte `json:"resolution"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
RequestedAt pgtype.Timestamptz `json:"requested_at"`
ResolvedAt pgtype.Timestamptz `json:"resolved_at"`
}
type CreateWaitpointResponseTokenParams ¶
type CreateWaitpointResponseTokenParams struct {
ID pgtype.UUID `json:"id"`
TokenHash []byte `json:"token_hash"`
AllowedActions []string `json:"allowed_actions"`
ExpiresAt pgtype.Timestamptz `json:"expires_at"`
ExternalSubject pgtype.Text `json:"external_subject"`
Metadata []byte `json:"metadata"`
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
WaitpointID pgtype.UUID `json:"waitpoint_id"`
}
type CreateWorkerCredentialFromRegistrationParams ¶
type CreateWorkerCredentialFromRegistrationParams struct {
CredentialID pgtype.UUID `json:"credential_id"`
ExternalID string `json:"external_id"`
KeyPrefix string `json:"key_prefix"`
SecretHash []byte `json:"secret_hash"`
RegistrationTokenHash []byte `json:"registration_token_hash"`
WorkerHostID pgtype.UUID `json:"worker_host_id"`
}
type CreateWorkerCredentialFromRegistrationRow ¶
type CreateWorkerCredentialFromRegistrationRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
WorkerHostID string `json:"worker_host_id"`
ExternalID string `json:"external_id"`
KeyPrefix string `json:"key_prefix"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
}
type CreateWorkerGroupParams ¶
type CreateWorkerGroupParams struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
Slug string `json:"slug"`
Name string `json:"name"`
ProvisioningMode WorkerGroupProvisioningMode `json:"provisioning_mode"`
QueueName string `json:"queue_name"`
Region string `json:"region"`
Capabilities []byte `json:"capabilities"`
Metadata []byte `json:"metadata"`
}
type DeadLetterRunQueueEntryParams ¶
type DeadLetterRunQueueEntryParams struct {
LastError string `json:"last_error"`
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
QueueMessageID pgtype.Text `json:"queue_message_id"`
EventKind string `json:"event_kind"`
EventPayload []byte `json:"event_payload"`
}
type DeadLetterRunQueueEntryRow ¶
type DeadLetterRunQueueEntryRow struct {
RunID pgtype.UUID `json:"run_id"`
OrgID pgtype.UUID `json:"org_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
Status RunQueueStatus `json:"status"`
Priority int32 `json:"priority"`
QueueName string `json:"queue_name"`
QueueMessageID pgtype.Text `json:"queue_message_id"`
ReservedByWorkerHostID pgtype.UUID `json:"reserved_by_worker_host_id"`
ReservationExpiresAt pgtype.Timestamptz `json:"reservation_expires_at"`
DispatchGeneration int64 `json:"dispatch_generation"`
LastError string `json:"last_error"`
EnqueuedAt pgtype.Timestamptz `json:"enqueued_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
FinishedAt pgtype.Timestamptz `json:"finished_at"`
}
type DeleteAPIKeyGrantParams ¶
type DenyDeviceCodeParams ¶
type DeployedTask ¶
type DeployedTask struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
DeploymentID pgtype.UUID `json:"deployment_id"`
TaskID string `json:"task_id"`
ModulePath string `json:"module_path"`
ExportName string `json:"export_name"`
RequestedMilliCpu int64 `json:"requested_milli_cpu"`
RequestedMemoryMib int64 `json:"requested_memory_mib"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
}
type DeviceCode ¶
type DeviceCode struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
UserCodeHash []byte `json:"user_code_hash"`
DeviceCodeHash []byte `json:"device_code_hash"`
DecidedByUserID pgtype.UUID `json:"decided_by_user_id"`
Status DeviceCodeStatus `json:"status"`
ExpiresAt pgtype.Timestamptz `json:"expires_at"`
PollIntervalSeconds int32 `json:"poll_interval_seconds"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
DecidedAt pgtype.Timestamptz `json:"decided_at"`
ConsumedAt pgtype.Timestamptz `json:"consumed_at"`
}
type DeviceCodeStatus ¶
type DeviceCodeStatus string
const ( DeviceCodeStatusPending DeviceCodeStatus = "pending" DeviceCodeStatusApproved DeviceCodeStatus = "approved" DeviceCodeStatusDenied DeviceCodeStatus = "denied" DeviceCodeStatusConsumed DeviceCodeStatus = "consumed" )
func (*DeviceCodeStatus) Scan ¶
func (e *DeviceCodeStatus) Scan(src interface{}) error
type DisableGitHubRepositoryConnectionRow ¶
type DisableGitHubRepositoryConnectionRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
GithubRepositoryID int64 `json:"github_repository_id"`
EnabledByUserID pgtype.UUID `json:"enabled_by_user_id"`
DisabledAt pgtype.Timestamptz `json:"disabled_at"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type DisableOrgMemberParams ¶
type EnsureOrgMemberParams ¶
type Environment ¶
type Environment struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
Slug string `json:"slug"`
Name string `json:"name"`
IsDefault bool `json:"is_default"`
ArchivedAt pgtype.Timestamptz `json:"archived_at"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type GetActiveDeployedTaskRow ¶
type GetActiveDeployedTaskRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
DeploymentID pgtype.UUID `json:"deployment_id"`
TaskID string `json:"task_id"`
ModulePath string `json:"module_path"`
ExportName string `json:"export_name"`
RequestedMilliCpu int64 `json:"requested_milli_cpu"`
RequestedMemoryMib int64 `json:"requested_memory_mib"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
SourceDigest string `json:"source_digest"`
}
type GetActiveGitHubRepositoryAccessTargetRow ¶
type GetActiveGitHubRepositoryAccessTargetRow struct {
InstallationRowID pgtype.UUID `json:"installation_row_id"`
InstallationID int64 `json:"installation_id"`
AccountLogin string `json:"account_login"`
AccountType string `json:"account_type"`
RepositorySelection pgtype.Text `json:"repository_selection"`
InstallationHtmlUrl pgtype.Text `json:"installation_html_url"`
SuspendedAt pgtype.Timestamptz `json:"suspended_at"`
InstallationDeletedAt pgtype.Timestamptz `json:"installation_deleted_at"`
InstallationCreatedAt pgtype.Timestamptz `json:"installation_created_at"`
InstallationUpdatedAt pgtype.Timestamptz `json:"installation_updated_at"`
RepositoryRowID pgtype.UUID `json:"repository_row_id"`
GithubRepositoryID int64 `json:"github_repository_id"`
OwnerLogin string `json:"owner_login"`
RepositoryName string `json:"repository_name"`
FullName string `json:"full_name"`
Private bool `json:"private"`
Archived bool `json:"archived"`
DefaultBranch pgtype.Text `json:"default_branch"`
RepositoryHtmlUrl pgtype.Text `json:"repository_html_url"`
RepositoryDeletedAt pgtype.Timestamptz `json:"repository_deleted_at"`
RepositoryCreatedAt pgtype.Timestamptz `json:"repository_created_at"`
RepositoryUpdatedAt pgtype.Timestamptz `json:"repository_updated_at"`
ConnectionID pgtype.UUID `json:"connection_id"`
ConnectionDisabledAt pgtype.Timestamptz `json:"connection_disabled_at"`
ProjectWorkspaceRepositoryID pgtype.UUID `json:"project_workspace_repository_id"`
ProjectWorkspaceRepositoryProjectID pgtype.UUID `json:"project_workspace_repository_project_id"`
ProjectWorkspaceRepositoryDisabledAt pgtype.Timestamptz `json:"project_workspace_repository_disabled_at"`
}
type GetActiveInvitationRow ¶
type GetActiveMagicLinkByTokenHashRow ¶
type GetActiveMagicLinkByTokenHashRow struct {
ID pgtype.UUID `json:"id"`
Purpose MagicLinkPurpose `json:"purpose"`
Email string `json:"email"`
OrgID pgtype.UUID `json:"org_id"`
InvitationID pgtype.UUID `json:"invitation_id"`
RedirectAfter pgtype.Text `json:"redirect_after"`
ExpiresAt pgtype.Timestamptz `json:"expires_at"`
}
type GetActiveProjectWorkspaceRepositoryAccessByFullNameRow ¶
type GetActiveProjectWorkspaceRepositoryAccessByFullNameRow struct {
WorkspaceRepositoryID pgtype.UUID `json:"workspace_repository_id"`
InstallationID int64 `json:"installation_id"`
GithubRepositoryID int64 `json:"github_repository_id"`
FullName string `json:"full_name"`
RepositoryName string `json:"repository_name"`
}
type GetActiveProjectWorkspaceRepositoryAccessRow ¶
type GetActiveProjectWorkspaceRepositoryAccessRow struct {
WorkspaceRepositoryID pgtype.UUID `json:"workspace_repository_id"`
InstallationID int64 `json:"installation_id"`
GithubRepositoryID int64 `json:"github_repository_id"`
FullName string `json:"full_name"`
RepositoryName string `json:"repository_name"`
}
type GetActiveWaitpointResponseTokenRow ¶
type GetActiveWaitpointResponseTokenRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
WaitpointID pgtype.UUID `json:"waitpoint_id"`
TokenHash []byte `json:"token_hash"`
AllowedActions []string `json:"allowed_actions"`
Status WaitpointResponseTokenStatus `json:"status"`
ExpiresAt pgtype.Timestamptz `json:"expires_at"`
CompletedAt pgtype.Timestamptz `json:"completed_at"`
CompletedByPrincipal pgtype.Text `json:"completed_by_principal"`
CompletedVia pgtype.Text `json:"completed_via"`
ExternalSubject pgtype.Text `json:"external_subject"`
Metadata []byte `json:"metadata"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
WaitpointKind WaitpointKind `json:"waitpoint_kind"`
WaitpointDisplayText string `json:"waitpoint_display_text"`
}
type GetEnvironmentParams ¶
type GetOrgMemberForManagementRow ¶
type GetOrgMemberForManagementRow struct {
OrgID pgtype.UUID `json:"org_id"`
UserID pgtype.UUID `json:"user_id"`
Role OrgMemberRole `json:"role"`
DisplayName pgtype.Text `json:"display_name"`
PrimaryEmail pgtype.Text `json:"primary_email"`
DisabledAt pgtype.Timestamptz `json:"disabled_at"`
UserDisabledAt pgtype.Timestamptz `json:"user_disabled_at"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type GetOrgMemberParams ¶
type GetOrgMemberRow ¶
type GetOrgMemberRow struct {
OrgID pgtype.UUID `json:"org_id"`
UserID pgtype.UUID `json:"user_id"`
Role OrgMemberRole `json:"role"`
DisplayName pgtype.Text `json:"display_name"`
DisabledAt pgtype.Timestamptz `json:"disabled_at"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
UserDisplayName string `json:"user_display_name"`
ProfileImageUrl pgtype.Text `json:"profile_image_url"`
}
type GetProjectBySlugParams ¶
type GetProjectParams ¶
type GetRunExecutionQueueLeaseRow ¶
type GetRunExecutionQueueLeaseRow struct {
ID pgtype.UUID `json:"id"`
RunID pgtype.UUID `json:"run_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
WorkerHostID pgtype.UUID `json:"worker_host_id"`
QueueMessageID string `json:"queue_message_id"`
QueueLeaseID string `json:"queue_lease_id"`
DeliveryAttempt int32 `json:"delivery_attempt"`
LeaseExpiresAt pgtype.Timestamptz `json:"lease_expires_at"`
QueueName string `json:"queue_name"`
}
type GetRunLogSnapshotParams ¶
type GetRunLogSnapshotRow ¶
type GetRunLogSnapshotRow struct {
RunID pgtype.UUID `json:"run_id"`
Stdout []byte `json:"stdout"`
Stderr []byte `json:"stderr"`
Truncated pgtype.Bool `json:"truncated"`
StdoutCursor int64 `json:"stdout_cursor"`
StderrCursor int64 `json:"stderr_cursor"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type GetRunParams ¶
type GetRunRestorePayloadRow ¶
type GetRunRestorePayloadRow struct {
CheckpointID pgtype.UUID `json:"checkpoint_id"`
RuntimeBackend pgtype.Text `json:"runtime_backend"`
RuntimeArch pgtype.Text `json:"runtime_arch"`
RuntimeABI pgtype.Text `json:"runtime_abi"`
KernelDigest pgtype.Text `json:"kernel_digest"`
RootfsDigest pgtype.Text `json:"rootfs_digest"`
ImageKey pgtype.Text `json:"image_key"`
RuntimeConfigDigest pgtype.Text `json:"runtime_config_digest"`
ManifestDigest pgtype.Text `json:"manifest_digest"`
VMStateDigest pgtype.Text `json:"vm_state_digest"`
WorkspaceUpperDigest pgtype.Text `json:"workspace_upper_digest"`
MemoryDigests []byte `json:"memory_digests"`
Manifest []byte `json:"manifest"`
WaitpointID pgtype.UUID `json:"waitpoint_id"`
WaitpointKind WaitpointKind `json:"waitpoint_kind"`
ResolutionKind pgtype.Text `json:"resolution_kind"`
Resolution []byte `json:"resolution"`
}
type GetRunSummaryParams ¶
type GetRunSummaryRow ¶
type GetRunSummaryRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
TaskID string `json:"task_id"`
Status RunStatus `json:"status"`
ExitCode pgtype.Int4 `json:"exit_code"`
Output []byte `json:"output"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type GetScopedRunParams ¶
type GetScopedRunSummaryRow ¶
type GetScopedRunSummaryRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
TaskID string `json:"task_id"`
Status RunStatus `json:"status"`
ExitCode pgtype.Int4 `json:"exit_code"`
Output []byte `json:"output"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type GetSecretByNameParams ¶
type GetSessionByTokenHashRow ¶
type GetSessionByTokenHashRow struct {
ID pgtype.UUID `json:"id"`
UserID pgtype.UUID `json:"user_id"`
DisplayName string `json:"display_name"`
ProfileImageUrl pgtype.Text `json:"profile_image_url"`
OrgID pgtype.UUID `json:"org_id"`
Role string `json:"role"`
MemberDisplayName string `json:"member_display_name"`
ExpiresAt pgtype.Timestamptz `json:"expires_at"`
}
type GetUserOnboardingStateRow ¶
type GetUserOnboardingStateRow struct {
UserID pgtype.UUID `json:"user_id"`
DisplayName string `json:"display_name"`
ProfileImageUrl pgtype.Text `json:"profile_image_url"`
OrgID pgtype.UUID `json:"org_id"`
OrgName pgtype.Text `json:"org_name"`
OrgSlug pgtype.Text `json:"org_slug"`
Role string `json:"role"`
HasProjects bool `json:"has_projects"`
}
type GetWorkerGroupParams ¶
type GetWorkerHostStateRow ¶
type GetWorkerHostStateRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
ExternalID string `json:"external_id"`
Status WorkerHostStatus `json:"status"`
Region string `json:"region"`
TotalMilliCpu int64 `json:"total_milli_cpu"`
TotalMemoryMib int64 `json:"total_memory_mib"`
TotalDiskMib int64 `json:"total_disk_mib"`
TotalExecutionSlots int32 `json:"total_execution_slots"`
AvailableMilliCpu int64 `json:"available_milli_cpu"`
AvailableMemoryMib int64 `json:"available_memory_mib"`
AvailableDiskMib int64 `json:"available_disk_mib"`
AvailableExecutionSlots int32 `json:"available_execution_slots"`
Labels []byte `json:"labels"`
Heartbeat []byte `json:"heartbeat"`
FirstSeenAt pgtype.Timestamptz `json:"first_seen_at"`
LastSeenAt pgtype.Timestamptz `json:"last_seen_at"`
DrainedAt pgtype.Timestamptz `json:"drained_at"`
ActiveExecutions int32 `json:"active_executions"`
}
type GitHubAppInstallation ¶
type GitHubAppInstallation struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
InstallationID int64 `json:"installation_id"`
AccountLogin string `json:"account_login"`
AccountType string `json:"account_type"`
RepositorySelection pgtype.Text `json:"repository_selection"`
HtmlUrl pgtype.Text `json:"html_url"`
SuspendedAt pgtype.Timestamptz `json:"suspended_at"`
DeletedAt pgtype.Timestamptz `json:"deleted_at"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type GithubRepository ¶
type GithubRepository struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
InstallationID int64 `json:"installation_id"`
GithubRepositoryID int64 `json:"github_repository_id"`
OwnerLogin string `json:"owner_login"`
Name string `json:"name"`
FullName string `json:"full_name"`
Private bool `json:"private"`
Archived bool `json:"archived"`
DefaultBranch pgtype.Text `json:"default_branch"`
HtmlUrl pgtype.Text `json:"html_url"`
DeletedAt pgtype.Timestamptz `json:"deleted_at"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type GithubRepositoryConnection ¶
type GithubRepositoryConnection struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
GithubRepositoryID int64 `json:"github_repository_id"`
EnabledByUserID pgtype.UUID `json:"enabled_by_user_id"`
DisabledAt pgtype.Timestamptz `json:"disabled_at"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type Invitation ¶
type Invitation struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
InviteeEmail string `json:"invitee_email"`
Role OrgMemberRole `json:"role"`
InvitedByUserID pgtype.UUID `json:"invited_by_user_id"`
TokenHash []byte `json:"token_hash"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
ExpiresAt pgtype.Timestamptz `json:"expires_at"`
AcceptedAt pgtype.Timestamptz `json:"accepted_at"`
AcceptedByUserID pgtype.UUID `json:"accepted_by_user_id"`
RevokedAt pgtype.Timestamptz `json:"revoked_at"`
RevokedByUserID pgtype.UUID `json:"revoked_by_user_id"`
}
type IssueAPIKeyParams ¶
type LeaseRunExecutionParams ¶
type LeaseRunExecutionParams struct {
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
WorkerHostID pgtype.UUID `json:"worker_host_id"`
QueueMessageID pgtype.Text `json:"queue_message_id"`
ExecutionID pgtype.UUID `json:"execution_id"`
QueueLeaseID string `json:"queue_lease_id"`
DeliveryAttempt int32 `json:"delivery_attempt"`
LeaseExpiresAt pgtype.Timestamptz `json:"lease_expires_at"`
}
type LeaseRunExecutionRow ¶
type LeaseRunExecutionRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
TaskID string `json:"task_id"`
Status RunStatus `json:"status"`
Payload []byte `json:"payload"`
SecretBindings []byte `json:"secret_bindings"`
DeployedTaskID pgtype.UUID `json:"deployed_task_id"`
DeployedTaskModulePath string `json:"deployed_task_module_path"`
DeployedTaskExportName string `json:"deployed_task_export_name"`
TaskSourceDigest string `json:"task_source_digest"`
WorkspaceRepository string `json:"workspace_repository"`
WorkspaceInstallationID int64 `json:"workspace_installation_id"`
WorkspaceGithubRepositoryID int64 `json:"workspace_github_repository_id"`
WorkspaceRef string `json:"workspace_ref"`
WorkspaceSha string `json:"workspace_sha"`
WorkspaceSubpath string `json:"workspace_subpath"`
MaxDurationSeconds int32 `json:"max_duration_seconds"`
ExitCode pgtype.Int4 `json:"exit_code"`
ErrorMessage pgtype.Text `json:"error_message"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
StartedAt pgtype.Timestamptz `json:"started_at"`
FinishedAt pgtype.Timestamptz `json:"finished_at"`
ExecutionID pgtype.UUID `json:"execution_id"`
ExecutionWorkerGroupID pgtype.UUID `json:"execution_worker_group_id"`
ExecutionWorkerHostID pgtype.UUID `json:"execution_worker_host_id"`
ExecutionQueueMessageID string `json:"execution_queue_message_id"`
ExecutionQueueLeaseID string `json:"execution_queue_lease_id"`
ExecutionDeliveryAttempt int32 `json:"execution_delivery_attempt"`
ExecutionLeaseExpiresAt pgtype.Timestamptz `json:"execution_lease_expires_at"`
ActiveDurationMs int64 `json:"active_duration_ms"`
}
type ListAPIKeyGrantsParams ¶
type ListAPIKeysParams ¶
type ListAPIKeysRow ¶
type ListAPIKeysRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
CreatedByUserID pgtype.UUID `json:"created_by_user_id"`
Name string `json:"name"`
KeyPrefix string `json:"key_prefix"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
LastUsedAt pgtype.Timestamptz `json:"last_used_at"`
ExpiresAt pgtype.Timestamptz `json:"expires_at"`
RevokedAt pgtype.Timestamptz `json:"revoked_at"`
}
type ListActiveProjectWorkspaceRepositoryAccessRow ¶
type ListActiveProjectWorkspaceRepositoryAccessRow struct {
WorkspaceRepositoryID pgtype.UUID `json:"workspace_repository_id"`
InstallationID int64 `json:"installation_id"`
GithubRepositoryID int64 `json:"github_repository_id"`
FullName string `json:"full_name"`
RepositoryName string `json:"repository_name"`
}
type ListEnvironmentsParams ¶
type ListGitHubInstallationRepositoriesRow ¶
type ListGitHubInstallationRepositoriesRow struct {
InstallationRowID pgtype.UUID `json:"installation_row_id"`
InstallationID int64 `json:"installation_id"`
AccountLogin string `json:"account_login"`
AccountType string `json:"account_type"`
RepositorySelection pgtype.Text `json:"repository_selection"`
InstallationHtmlUrl pgtype.Text `json:"installation_html_url"`
SuspendedAt pgtype.Timestamptz `json:"suspended_at"`
InstallationDeletedAt pgtype.Timestamptz `json:"installation_deleted_at"`
InstallationCreatedAt pgtype.Timestamptz `json:"installation_created_at"`
InstallationUpdatedAt pgtype.Timestamptz `json:"installation_updated_at"`
RepositoryRowID pgtype.UUID `json:"repository_row_id"`
GithubRepositoryID int64 `json:"github_repository_id"`
OwnerLogin string `json:"owner_login"`
RepositoryName string `json:"repository_name"`
FullName string `json:"full_name"`
Private bool `json:"private"`
Archived bool `json:"archived"`
DefaultBranch pgtype.Text `json:"default_branch"`
RepositoryHtmlUrl pgtype.Text `json:"repository_html_url"`
RepositoryDeletedAt pgtype.Timestamptz `json:"repository_deleted_at"`
RepositoryCreatedAt pgtype.Timestamptz `json:"repository_created_at"`
RepositoryUpdatedAt pgtype.Timestamptz `json:"repository_updated_at"`
ConnectionID pgtype.UUID `json:"connection_id"`
ConnectionDisabledAt pgtype.Timestamptz `json:"connection_disabled_at"`
ProjectWorkspaceRepositoryID pgtype.UUID `json:"project_workspace_repository_id"`
ProjectWorkspaceRepositoryProjectID pgtype.UUID `json:"project_workspace_repository_project_id"`
ProjectWorkspaceRepositoryDisabledAt pgtype.Timestamptz `json:"project_workspace_repository_disabled_at"`
}
type ListInvitationsParams ¶
type ListInvitationsRow ¶
type ListInvitationsRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
InviteeEmail string `json:"invitee_email"`
Role OrgMemberRole `json:"role"`
InvitedByUserID pgtype.UUID `json:"invited_by_user_id"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
ExpiresAt pgtype.Timestamptz `json:"expires_at"`
AcceptedAt pgtype.Timestamptz `json:"accepted_at"`
AcceptedByUserID pgtype.UUID `json:"accepted_by_user_id"`
RevokedAt pgtype.Timestamptz `json:"revoked_at"`
RevokedByUserID pgtype.UUID `json:"revoked_by_user_id"`
}
type ListOrgMembersRow ¶
type ListOrgMembersRow struct {
OrgID pgtype.UUID `json:"org_id"`
UserID pgtype.UUID `json:"user_id"`
Role OrgMemberRole `json:"role"`
DisplayName string `json:"display_name"`
PrimaryEmail pgtype.Text `json:"primary_email"`
DisabledAt pgtype.Timestamptz `json:"disabled_at"`
UserDisabledAt pgtype.Timestamptz `json:"user_disabled_at"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type ListRunEventsParams ¶
type ListRunSummariesParams ¶
type ListRunSummariesRow ¶
type ListRunSummariesRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
TaskID string `json:"task_id"`
Status RunStatus `json:"status"`
ExitCode pgtype.Int4 `json:"exit_code"`
Output []byte `json:"output"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type ListRunsParams ¶
type ListScopedRunSummariesRow ¶
type ListScopedRunSummariesRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
TaskID string `json:"task_id"`
Status RunStatus `json:"status"`
ExitCode pgtype.Int4 `json:"exit_code"`
Output []byte `json:"output"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type ListScopedRunsParams ¶
type ListScopedSecretsParams ¶
type ListScopedSecretsRow ¶
type ListScopedSecretsRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
Name string `json:"name"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type ListSecretsParams ¶
type ListSecretsRow ¶
type ListSecretsRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
Name string `json:"name"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type MagicLink ¶
type MagicLink struct {
ID pgtype.UUID `json:"id"`
Purpose MagicLinkPurpose `json:"purpose"`
TokenHash []byte `json:"token_hash"`
Email string `json:"email"`
OrgID pgtype.UUID `json:"org_id"`
InvitationID pgtype.UUID `json:"invitation_id"`
RedirectAfter pgtype.Text `json:"redirect_after"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
SentAt pgtype.Timestamptz `json:"sent_at"`
DeliveryFailedAt pgtype.Timestamptz `json:"delivery_failed_at"`
ExpiresAt pgtype.Timestamptz `json:"expires_at"`
ConsumedAt pgtype.Timestamptz `json:"consumed_at"`
ConsumedByUserID pgtype.UUID `json:"consumed_by_user_id"`
RevokedAt pgtype.Timestamptz `json:"revoked_at"`
}
type MagicLinkPurpose ¶
type MagicLinkPurpose string
const ( MagicLinkPurposeLogin MagicLinkPurpose = "login" MagicLinkPurposeInviteAccept MagicLinkPurpose = "invite_accept" )
func (*MagicLinkPurpose) Scan ¶
func (e *MagicLinkPurpose) Scan(src interface{}) error
type MarkGitHubRepositoriesDeletedByInstallationIDRow ¶
type MarkGitHubRepositoriesDeletedByInstallationIDRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
InstallationID int64 `json:"installation_id"`
GithubRepositoryID int64 `json:"github_repository_id"`
OwnerLogin string `json:"owner_login"`
Name string `json:"name"`
FullName string `json:"full_name"`
Private bool `json:"private"`
Archived bool `json:"archived"`
DefaultBranch pgtype.Text `json:"default_branch"`
HtmlUrl pgtype.Text `json:"html_url"`
DeletedAt pgtype.Timestamptz `json:"deleted_at"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type MarkGitHubRepositoryDeletedRow ¶
type MarkGitHubRepositoryDeletedRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
InstallationID int64 `json:"installation_id"`
GithubRepositoryID int64 `json:"github_repository_id"`
OwnerLogin string `json:"owner_login"`
Name string `json:"name"`
FullName string `json:"full_name"`
Private bool `json:"private"`
Archived bool `json:"archived"`
DefaultBranch pgtype.Text `json:"default_branch"`
HtmlUrl pgtype.Text `json:"html_url"`
DeletedAt pgtype.Timestamptz `json:"deleted_at"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type MarkWaitpointCheckpointFailedParams ¶
type MarkWaitpointCheckpointFailedParams struct {
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
ExecutionID pgtype.UUID `json:"execution_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
WorkerHostID pgtype.UUID `json:"worker_host_id"`
WaitpointID pgtype.UUID `json:"waitpoint_id"`
CheckpointID pgtype.UUID `json:"checkpoint_id"`
ErrorMessage pgtype.Text `json:"error_message"`
}
type MarkWaitpointCheckpointFailedRow ¶
type MarkWaitpointCheckpointFailedRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
ExecutionID pgtype.UUID `json:"execution_id"`
CheckpointID pgtype.UUID `json:"checkpoint_id"`
CorrelationID string `json:"correlation_id"`
Kind WaitpointKind `json:"kind"`
Request []byte `json:"request"`
DisplayText string `json:"display_text"`
TimeoutSeconds pgtype.Int4 `json:"timeout_seconds"`
PolicyName pgtype.Text `json:"policy_name"`
PolicySnapshot []byte `json:"policy_snapshot"`
Status WaitpointStatus `json:"status"`
ResolutionKind pgtype.Text `json:"resolution_kind"`
Resolution []byte `json:"resolution"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
RequestedAt pgtype.Timestamptz `json:"requested_at"`
ResolvedAt pgtype.Timestamptz `json:"resolved_at"`
}
type MarkWaitpointCheckpointReadyParams ¶
type MarkWaitpointCheckpointReadyParams struct {
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
ExecutionID pgtype.UUID `json:"execution_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
WorkerHostID pgtype.UUID `json:"worker_host_id"`
WaitpointID pgtype.UUID `json:"waitpoint_id"`
CheckpointID pgtype.UUID `json:"checkpoint_id"`
CasObjects []byte `json:"cas_objects"`
Manifest []byte `json:"manifest"`
RuntimeBackend pgtype.Text `json:"runtime_backend"`
RuntimeArch pgtype.Text `json:"runtime_arch"`
RuntimeABI pgtype.Text `json:"runtime_abi"`
KernelDigest pgtype.Text `json:"kernel_digest"`
RootfsDigest pgtype.Text `json:"rootfs_digest"`
RuntimeVcpus pgtype.Int4 `json:"runtime_vcpus"`
RuntimeMemoryMib pgtype.Int4 `json:"runtime_memory_mib"`
CniProfile pgtype.Text `json:"cni_profile"`
ImageKey pgtype.Text `json:"image_key"`
RuntimeConfigDigest pgtype.Text `json:"runtime_config_digest"`
ManifestDigest pgtype.Text `json:"manifest_digest"`
VMStateDigest pgtype.Text `json:"vm_state_digest"`
WorkspaceUpperDigest pgtype.Text `json:"workspace_upper_digest"`
MemoryDigests []byte `json:"memory_digests"`
ActiveDurationMs int64 `json:"active_duration_ms"`
CheckpointPayload []byte `json:"checkpoint_payload"`
}
type MarkWaitpointCheckpointReadyRow ¶
type MarkWaitpointCheckpointReadyRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
ExecutionID pgtype.UUID `json:"execution_id"`
CheckpointID pgtype.UUID `json:"checkpoint_id"`
CorrelationID string `json:"correlation_id"`
Kind WaitpointKind `json:"kind"`
Request []byte `json:"request"`
DisplayText string `json:"display_text"`
TimeoutSeconds pgtype.Int4 `json:"timeout_seconds"`
PolicyName pgtype.Text `json:"policy_name"`
PolicySnapshot []byte `json:"policy_snapshot"`
Status WaitpointStatus `json:"status"`
ResolutionKind pgtype.Text `json:"resolution_kind"`
Resolution []byte `json:"resolution"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
RequestedAt pgtype.Timestamptz `json:"requested_at"`
ResolvedAt pgtype.Timestamptz `json:"resolved_at"`
}
type NullCheckpointArtifactRole ¶
type NullCheckpointArtifactRole struct {
CheckpointArtifactRole CheckpointArtifactRole `json:"checkpoint_artifact_role"`
Valid bool `json:"valid"` // Valid is true if CheckpointArtifactRole is not NULL
}
func (*NullCheckpointArtifactRole) Scan ¶
func (ns *NullCheckpointArtifactRole) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullCheckpointStatus ¶
type NullCheckpointStatus struct {
CheckpointStatus CheckpointStatus `json:"checkpoint_status"`
Valid bool `json:"valid"` // Valid is true if CheckpointStatus is not NULL
}
func (*NullCheckpointStatus) Scan ¶
func (ns *NullCheckpointStatus) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullDeviceCodeStatus ¶
type NullDeviceCodeStatus struct {
DeviceCodeStatus DeviceCodeStatus `json:"device_code_status"`
Valid bool `json:"valid"` // Valid is true if DeviceCodeStatus is not NULL
}
func (*NullDeviceCodeStatus) Scan ¶
func (ns *NullDeviceCodeStatus) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullMagicLinkPurpose ¶
type NullMagicLinkPurpose struct {
MagicLinkPurpose MagicLinkPurpose `json:"magic_link_purpose"`
Valid bool `json:"valid"` // Valid is true if MagicLinkPurpose is not NULL
}
func (*NullMagicLinkPurpose) Scan ¶
func (ns *NullMagicLinkPurpose) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullOrgMemberRole ¶
type NullOrgMemberRole struct {
OrgMemberRole OrgMemberRole `json:"org_member_role"`
Valid bool `json:"valid"` // Valid is true if OrgMemberRole is not NULL
}
func (*NullOrgMemberRole) Scan ¶
func (ns *NullOrgMemberRole) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullRunExecutionStatus ¶
type NullRunExecutionStatus struct {
RunExecutionStatus RunExecutionStatus `json:"run_execution_status"`
Valid bool `json:"valid"` // Valid is true if RunExecutionStatus is not NULL
}
func (*NullRunExecutionStatus) Scan ¶
func (ns *NullRunExecutionStatus) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullRunLogStream ¶
type NullRunLogStream struct {
RunLogStream RunLogStream `json:"run_log_stream"`
Valid bool `json:"valid"` // Valid is true if RunLogStream is not NULL
}
func (*NullRunLogStream) Scan ¶
func (ns *NullRunLogStream) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullRunQueueStatus ¶
type NullRunQueueStatus struct {
RunQueueStatus RunQueueStatus `json:"run_queue_status"`
Valid bool `json:"valid"` // Valid is true if RunQueueStatus is not NULL
}
func (*NullRunQueueStatus) Scan ¶
func (ns *NullRunQueueStatus) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullRunStatus ¶
type NullRunStatus struct {
RunStatus RunStatus `json:"run_status"`
Valid bool `json:"valid"` // Valid is true if RunStatus is not NULL
}
func (*NullRunStatus) Scan ¶
func (ns *NullRunStatus) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullTaskDeploymentStatus ¶
type NullTaskDeploymentStatus struct {
TaskDeploymentStatus TaskDeploymentStatus `json:"task_deployment_status"`
Valid bool `json:"valid"` // Valid is true if TaskDeploymentStatus is not NULL
}
func (*NullTaskDeploymentStatus) Scan ¶
func (ns *NullTaskDeploymentStatus) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullWaitpointDeliveryStatus ¶
type NullWaitpointDeliveryStatus struct {
WaitpointDeliveryStatus WaitpointDeliveryStatus `json:"waitpoint_delivery_status"`
Valid bool `json:"valid"` // Valid is true if WaitpointDeliveryStatus is not NULL
}
func (*NullWaitpointDeliveryStatus) Scan ¶
func (ns *NullWaitpointDeliveryStatus) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullWaitpointKind ¶
type NullWaitpointKind struct {
WaitpointKind WaitpointKind `json:"waitpoint_kind"`
Valid bool `json:"valid"` // Valid is true if WaitpointKind is not NULL
}
func (*NullWaitpointKind) Scan ¶
func (ns *NullWaitpointKind) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullWaitpointResponseTokenStatus ¶
type NullWaitpointResponseTokenStatus struct {
WaitpointResponseTokenStatus WaitpointResponseTokenStatus `json:"waitpoint_response_token_status"`
Valid bool `json:"valid"` // Valid is true if WaitpointResponseTokenStatus is not NULL
}
func (*NullWaitpointResponseTokenStatus) Scan ¶
func (ns *NullWaitpointResponseTokenStatus) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullWaitpointStatus ¶
type NullWaitpointStatus struct {
WaitpointStatus WaitpointStatus `json:"waitpoint_status"`
Valid bool `json:"valid"` // Valid is true if WaitpointStatus is not NULL
}
func (*NullWaitpointStatus) Scan ¶
func (ns *NullWaitpointStatus) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullWorkerGroupProvisioningMode ¶
type NullWorkerGroupProvisioningMode struct {
WorkerGroupProvisioningMode WorkerGroupProvisioningMode `json:"worker_group_provisioning_mode"`
Valid bool `json:"valid"` // Valid is true if WorkerGroupProvisioningMode is not NULL
}
func (*NullWorkerGroupProvisioningMode) Scan ¶
func (ns *NullWorkerGroupProvisioningMode) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullWorkerHostStatus ¶
type NullWorkerHostStatus struct {
WorkerHostStatus WorkerHostStatus `json:"worker_host_status"`
Valid bool `json:"valid"` // Valid is true if WorkerHostStatus is not NULL
}
func (*NullWorkerHostStatus) Scan ¶
func (ns *NullWorkerHostStatus) Scan(value interface{}) error
Scan implements the Scanner interface.
type OrgMember ¶
type OrgMember struct {
OrgID pgtype.UUID `json:"org_id"`
UserID pgtype.UUID `json:"user_id"`
Role OrgMemberRole `json:"role"`
DisplayName pgtype.Text `json:"display_name"`
DisabledAt pgtype.Timestamptz `json:"disabled_at"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type OrgMemberRole ¶
type OrgMemberRole string
const ( OrgMemberRoleOwner OrgMemberRole = "owner" OrgMemberRoleAdmin OrgMemberRole = "admin" OrgMemberRoleDeveloper OrgMemberRole = "developer" OrgMemberRoleViewer OrgMemberRole = "viewer" )
func (*OrgMemberRole) Scan ¶
func (e *OrgMemberRole) Scan(src interface{}) error
type Organization ¶
type PrepareQueuedRunQueueEntryRow ¶
type PrepareQueuedRunQueueEntryRow struct {
RunID pgtype.UUID `json:"run_id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
QueueName string `json:"queue_name"`
Priority int32 `json:"priority"`
DispatchGeneration int64 `json:"dispatch_generation"`
EnqueuedAt pgtype.Timestamptz `json:"enqueued_at"`
RequestedMilliCpu int64 `json:"requested_milli_cpu"`
RequestedMemoryMib int64 `json:"requested_memory_mib"`
RequestedDiskMib int64 `json:"requested_disk_mib"`
RequestedExecutionSlots int32 `json:"requested_execution_slots"`
RuntimeArch string `json:"runtime_arch"`
RuntimeABI string `json:"runtime_abi"`
KernelDigest string `json:"kernel_digest"`
RootfsDigest string `json:"rootfs_digest"`
CniProfile string `json:"cni_profile"`
NetworkPolicy []byte `json:"network_policy"`
Placement []byte `json:"placement"`
}
type Project ¶
type Project struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
Slug string `json:"slug"`
Name string `json:"name"`
IsDefault bool `json:"is_default"`
ArchivedAt pgtype.Timestamptz `json:"archived_at"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type ProjectWorkspaceRepository ¶
type ProjectWorkspaceRepository struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
GithubRepositoryID int64 `json:"github_repository_id"`
EnabledByUserID pgtype.UUID `json:"enabled_by_user_id"`
DisabledAt pgtype.Timestamptz `json:"disabled_at"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type Querier ¶
type Querier interface {
AbandonLeasedRunExecution(ctx context.Context, arg AbandonLeasedRunExecutionParams) error
AcceptInvitation(ctx context.Context, arg AcceptInvitationParams) (int64, error)
ActivateTaskDeployment(ctx context.Context, arg ActivateTaskDeploymentParams) (TaskDeployment, error)
AppendRunEvent(ctx context.Context, arg AppendRunEventParams) (RunEvent, error)
AppendRunEventForExecution(ctx context.Context, arg AppendRunEventForExecutionParams) (RunEvent, error)
AppendRunLogChunk(ctx context.Context, arg AppendRunLogChunkParams) (AppendRunLogChunkRow, error)
ApproveDeviceCode(ctx context.Context, arg ApproveDeviceCodeParams) (DeviceCode, error)
ArchiveWorkerGroup(ctx context.Context, arg ArchiveWorkerGroupParams) (WorkerGroup, error)
AuthenticateWorkerCredential(ctx context.Context, arg AuthenticateWorkerCredentialParams) (AuthenticateWorkerCredentialRow, error)
AuthorizeAPIKeyPermission(ctx context.Context, arg AuthorizeAPIKeyPermissionParams) (AuthorizeAPIKeyPermissionRow, error)
AuthorizeWorkerCredential(ctx context.Context, arg AuthorizeWorkerCredentialParams) (AuthorizeWorkerCredentialRow, error)
CompleteRunQueueEntry(ctx context.Context, arg CompleteRunQueueEntryParams) (RunQueueEntry, error)
CompleteWaitpointResponseToken(ctx context.Context, arg CompleteWaitpointResponseTokenParams) (CompleteWaitpointResponseTokenRow, error)
ConsumeDeviceCode(ctx context.Context, deviceCodeHash []byte) (DeviceCode, error)
ConsumeMagicLink(ctx context.Context, arg ConsumeMagicLinkParams) (int64, error)
CountRecentMagicLinks(ctx context.Context, arg CountRecentMagicLinksParams) (int64, error)
CountRunsByStatus(ctx context.Context, orgID pgtype.UUID) (CountRunsByStatusRow, error)
CountScopedRunsByStatus(ctx context.Context, arg CountScopedRunsByStatusParams) (CountScopedRunsByStatusRow, error)
CreateAPIKeyGrant(ctx context.Context, arg CreateAPIKeyGrantParams) (ApiKeyGrant, error)
CreateDeployedTask(ctx context.Context, arg CreateDeployedTaskParams) (DeployedTask, error)
CreateDeviceCode(ctx context.Context, arg CreateDeviceCodeParams) (DeviceCode, error)
CreateEnvironment(ctx context.Context, arg CreateEnvironmentParams) (Environment, error)
CreateEnvironmentWithDefaultWorkerGroup(ctx context.Context, arg CreateEnvironmentWithDefaultWorkerGroupParams) (CreateEnvironmentWithDefaultWorkerGroupRow, error)
CreateInvitation(ctx context.Context, arg CreateInvitationParams) (Invitation, error)
CreateMagicLink(ctx context.Context, arg CreateMagicLinkParams) (MagicLink, error)
CreateOrganization(ctx context.Context, arg CreateOrganizationParams) (Organization, error)
CreateProject(ctx context.Context, arg CreateProjectParams) (Project, error)
CreateProjectWithDefaultEnvironment(ctx context.Context, arg CreateProjectWithDefaultEnvironmentParams) (CreateProjectWithDefaultEnvironmentRow, error)
CreateRun(ctx context.Context, arg CreateRunParams) (CreateRunRow, error)
CreateScopedRun(ctx context.Context, arg CreateScopedRunParams) (CreateScopedRunRow, error)
CreateSession(ctx context.Context, arg CreateSessionParams) (Session, error)
CreateTaskDeployment(ctx context.Context, arg CreateTaskDeploymentParams) (TaskDeployment, error)
CreateWaitpointDelivery(ctx context.Context, arg CreateWaitpointDeliveryParams) (WaitpointDelivery, error)
CreateWaitpointForExecution(ctx context.Context, arg CreateWaitpointForExecutionParams) (CreateWaitpointForExecutionRow, error)
CreateWaitpointPolicy(ctx context.Context, arg CreateWaitpointPolicyParams) (WaitpointPolicy, error)
CreateWaitpointResponseToken(ctx context.Context, arg CreateWaitpointResponseTokenParams) (WaitpointResponseToken, error)
CreateWorkerCredentialFromRegistration(ctx context.Context, arg CreateWorkerCredentialFromRegistrationParams) (CreateWorkerCredentialFromRegistrationRow, error)
CreateWorkerGroup(ctx context.Context, arg CreateWorkerGroupParams) (WorkerGroup, error)
DeadLetterRunQueueEntry(ctx context.Context, arg DeadLetterRunQueueEntryParams) (DeadLetterRunQueueEntryRow, error)
DeleteAPIKeyGrant(ctx context.Context, arg DeleteAPIKeyGrantParams) (int64, error)
DeleteAPIKeyGrantsForKey(ctx context.Context, arg DeleteAPIKeyGrantsForKeyParams) (int64, error)
DeleteGitHubInstallation(ctx context.Context, arg DeleteGitHubInstallationParams) (GitHubAppInstallation, error)
DeleteGitHubInstallationByInstallationID(ctx context.Context, installationID int64) ([]GitHubAppInstallation, error)
DenyDeviceCode(ctx context.Context, arg DenyDeviceCodeParams) (DeviceCode, error)
DisableGitHubRepositoryConnection(ctx context.Context, arg DisableGitHubRepositoryConnectionParams) (DisableGitHubRepositoryConnectionRow, error)
DisableOrgMember(ctx context.Context, arg DisableOrgMemberParams) (OrgMember, error)
DisableProjectWorkspaceRepositoryAccess(ctx context.Context, arg DisableProjectWorkspaceRepositoryAccessParams) (ProjectWorkspaceRepository, error)
DisableWaitpointPolicy(ctx context.Context, arg DisableWaitpointPolicyParams) (int64, error)
EnableGitHubRepositoryConnection(ctx context.Context, arg EnableGitHubRepositoryConnectionParams) (GithubRepositoryConnection, error)
EnableProjectWorkspaceRepositoryAccess(ctx context.Context, arg EnableProjectWorkspaceRepositoryAccessParams) (ProjectWorkspaceRepository, error)
EnsureOrgMember(ctx context.Context, arg EnsureOrgMemberParams) (OrgMember, error)
ExpireDuePendingWaitpoints(ctx context.Context, orgID pgtype.UUID) error
FailExpiredRunningRunExecutions(ctx context.Context, orgID pgtype.UUID) error
GetActiveDeployedTask(ctx context.Context, arg GetActiveDeployedTaskParams) (GetActiveDeployedTaskRow, error)
GetActiveGitHubRepositoryAccessTarget(ctx context.Context, arg GetActiveGitHubRepositoryAccessTargetParams) (GetActiveGitHubRepositoryAccessTargetRow, error)
GetActiveInvitation(ctx context.Context, tokenHash []byte) (GetActiveInvitationRow, error)
GetActiveInvitationByID(ctx context.Context, id pgtype.UUID) (GetActiveInvitationByIDRow, error)
GetActiveMagicLinkByTokenHash(ctx context.Context, tokenHash []byte) (GetActiveMagicLinkByTokenHashRow, error)
GetActiveProjectWorkspaceRepositoryAccess(ctx context.Context, arg GetActiveProjectWorkspaceRepositoryAccessParams) (GetActiveProjectWorkspaceRepositoryAccessRow, error)
GetActiveProjectWorkspaceRepositoryAccessByFullName(ctx context.Context, arg GetActiveProjectWorkspaceRepositoryAccessByFullNameParams) (GetActiveProjectWorkspaceRepositoryAccessByFullNameRow, error)
GetActiveTaskDeployment(ctx context.Context, arg GetActiveTaskDeploymentParams) (TaskDeployment, error)
GetActiveWaitpointResponseToken(ctx context.Context, arg GetActiveWaitpointResponseTokenParams) (GetActiveWaitpointResponseTokenRow, error)
GetCasObject(ctx context.Context, digest string) (CasObject, error)
GetDefaultEnvironment(ctx context.Context, arg GetDefaultEnvironmentParams) (Environment, error)
GetDefaultProjectEnvironment(ctx context.Context, orgID pgtype.UUID) (GetDefaultProjectEnvironmentRow, error)
GetDeviceCodeByUserCodeHash(ctx context.Context, userCodeHash []byte) (DeviceCode, error)
GetDeviceCodeForPoll(ctx context.Context, deviceCodeHash []byte) (DeviceCode, error)
GetEnvironment(ctx context.Context, arg GetEnvironmentParams) (Environment, error)
GetEnvironmentBySlug(ctx context.Context, arg GetEnvironmentBySlugParams) (Environment, error)
GetKnownGitHubInstallationByInstallationID(ctx context.Context, installationID int64) (GitHubAppInstallation, error)
GetMagicLinkLoginUser(ctx context.Context, email pgtype.Text) (User, error)
GetOrgMember(ctx context.Context, arg GetOrgMemberParams) (GetOrgMemberRow, error)
GetOrgMemberForManagement(ctx context.Context, arg GetOrgMemberForManagementParams) (GetOrgMemberForManagementRow, error)
GetOrganization(ctx context.Context, id pgtype.UUID) (Organization, error)
GetPendingInvitationByEmail(ctx context.Context, arg GetPendingInvitationByEmailParams) (GetPendingInvitationByEmailRow, error)
GetPendingWaitpointForRun(ctx context.Context, arg GetPendingWaitpointForRunParams) (Waitpoint, error)
GetProject(ctx context.Context, arg GetProjectParams) (Project, error)
GetProjectBySlug(ctx context.Context, arg GetProjectBySlugParams) (Project, error)
GetRevocableInvitation(ctx context.Context, arg GetRevocableInvitationParams) (GetRevocableInvitationRow, error)
GetRun(ctx context.Context, arg GetRunParams) (Run, error)
GetRunExecutionQueueLease(ctx context.Context, arg GetRunExecutionQueueLeaseParams) (GetRunExecutionQueueLeaseRow, error)
GetRunLogSnapshot(ctx context.Context, arg GetRunLogSnapshotParams) (GetRunLogSnapshotRow, error)
GetRunRestorePayload(ctx context.Context, arg GetRunRestorePayloadParams) (GetRunRestorePayloadRow, error)
GetRunSummary(ctx context.Context, arg GetRunSummaryParams) (GetRunSummaryRow, error)
GetScopedRun(ctx context.Context, arg GetScopedRunParams) (Run, error)
GetScopedRunSummary(ctx context.Context, arg GetScopedRunSummaryParams) (GetScopedRunSummaryRow, error)
GetScopedSecretByName(ctx context.Context, arg GetScopedSecretByNameParams) (Secret, error)
GetSecretByName(ctx context.Context, arg GetSecretByNameParams) (Secret, error)
GetSessionByTokenHash(ctx context.Context, tokenHash []byte) (GetSessionByTokenHashRow, error)
GetUserOnboardingState(ctx context.Context, userID pgtype.UUID) (GetUserOnboardingStateRow, error)
GetWaitpointPolicyByName(ctx context.Context, arg GetWaitpointPolicyByNameParams) (WaitpointPolicy, error)
GetWorkerGroup(ctx context.Context, arg GetWorkerGroupParams) (WorkerGroup, error)
GetWorkerHostQueueCapacity(ctx context.Context, arg GetWorkerHostQueueCapacityParams) (GetWorkerHostQueueCapacityRow, error)
GetWorkerHostState(ctx context.Context, arg GetWorkerHostStateParams) (GetWorkerHostStateRow, error)
IssueAPIKey(ctx context.Context, arg IssueAPIKeyParams) (APIKey, error)
LeaseRunExecution(ctx context.Context, arg LeaseRunExecutionParams) (LeaseRunExecutionRow, error)
ListAPIKeyGrants(ctx context.Context, arg ListAPIKeyGrantsParams) ([]ApiKeyGrant, error)
ListAPIKeys(ctx context.Context, arg ListAPIKeysParams) ([]ListAPIKeysRow, error)
ListActiveProjectWorkspaceRepositoryAccess(ctx context.Context, arg ListActiveProjectWorkspaceRepositoryAccessParams) ([]ListActiveProjectWorkspaceRepositoryAccessRow, error)
ListDeployedTasksForDeployment(ctx context.Context, arg ListDeployedTasksForDeploymentParams) ([]DeployedTask, error)
ListEnvironments(ctx context.Context, arg ListEnvironmentsParams) ([]Environment, error)
ListGitHubInstallationRepositories(ctx context.Context, arg ListGitHubInstallationRepositoriesParams) ([]ListGitHubInstallationRepositoriesRow, error)
ListGitHubInstallations(ctx context.Context, orgID pgtype.UUID) ([]GitHubAppInstallation, error)
ListInvitations(ctx context.Context, arg ListInvitationsParams) ([]ListInvitationsRow, error)
ListOrgMembers(ctx context.Context, orgID pgtype.UUID) ([]ListOrgMembersRow, error)
ListOrganizationIDs(ctx context.Context, rowLimit int32) ([]pgtype.UUID, error)
ListOrganizationIDsPage(ctx context.Context, arg ListOrganizationIDsPageParams) ([]pgtype.UUID, error)
ListProjects(ctx context.Context, orgID pgtype.UUID) ([]Project, error)
ListQueuedRunQueueEntryCandidates(ctx context.Context, arg ListQueuedRunQueueEntryCandidatesParams) ([]ListQueuedRunQueueEntryCandidatesRow, error)
ListRunEvents(ctx context.Context, arg ListRunEventsParams) ([]RunEvent, error)
ListRunSummaries(ctx context.Context, arg ListRunSummariesParams) ([]ListRunSummariesRow, error)
ListRuns(ctx context.Context, arg ListRunsParams) ([]Run, error)
ListScopedRunSummaries(ctx context.Context, arg ListScopedRunSummariesParams) ([]ListScopedRunSummariesRow, error)
ListScopedRuns(ctx context.Context, arg ListScopedRunsParams) ([]Run, error)
ListScopedSecrets(ctx context.Context, arg ListScopedSecretsParams) ([]ListScopedSecretsRow, error)
ListSecrets(ctx context.Context, arg ListSecretsParams) ([]ListSecretsRow, error)
ListWaitpointDeliveries(ctx context.Context, arg ListWaitpointDeliveriesParams) ([]WaitpointDelivery, error)
ListWaitpointPolicies(ctx context.Context, orgID pgtype.UUID) ([]WaitpointPolicy, error)
ListWorkerGroupsByScope(ctx context.Context, arg ListWorkerGroupsByScopeParams) ([]WorkerGroup, error)
ListWorkerHostsByWorkerGroup(ctx context.Context, arg ListWorkerHostsByWorkerGroupParams) ([]WorkerHost, error)
MarkGitHubRepositoriesDeletedByInstallationID(ctx context.Context, installationID int64) ([]MarkGitHubRepositoriesDeletedByInstallationIDRow, error)
MarkGitHubRepositoryDeleted(ctx context.Context, arg MarkGitHubRepositoryDeletedParams) (MarkGitHubRepositoryDeletedRow, error)
MarkMagicLinkDeliveryFailed(ctx context.Context, id pgtype.UUID) (int64, error)
MarkMagicLinkSent(ctx context.Context, id pgtype.UUID) (int64, error)
MarkRunQueueEntryEnqueueError(ctx context.Context, arg MarkRunQueueEntryEnqueueErrorParams) (RunQueueEntry, error)
MarkRunQueueEntryEnqueued(ctx context.Context, arg MarkRunQueueEntryEnqueuedParams) (RunQueueEntry, error)
MarkWaitpointCheckpointFailed(ctx context.Context, arg MarkWaitpointCheckpointFailedParams) (MarkWaitpointCheckpointFailedRow, error)
MarkWaitpointCheckpointReady(ctx context.Context, arg MarkWaitpointCheckpointReadyParams) (MarkWaitpointCheckpointReadyRow, error)
MarkWaitpointDeliveryFailed(ctx context.Context, arg MarkWaitpointDeliveryFailedParams) (WaitpointDelivery, error)
MarkWaitpointDeliverySent(ctx context.Context, arg MarkWaitpointDeliverySentParams) (WaitpointDelivery, error)
OwnerExists(ctx context.Context, orgID pgtype.UUID) (bool, error)
PrepareQueuedRunQueueEntry(ctx context.Context, arg PrepareQueuedRunQueueEntryParams) (PrepareQueuedRunQueueEntryRow, error)
RefreshSession(ctx context.Context, arg RefreshSessionParams) error
ReleaseRunExecution(ctx context.Context, arg ReleaseRunExecutionParams) (ReleaseRunExecutionRow, error)
RenewRunExecutionLease(ctx context.Context, arg RenewRunExecutionLeaseParams) (RenewRunExecutionLeaseRow, error)
RenewRunQueueReservation(ctx context.Context, arg RenewRunQueueReservationParams) (RunQueueEntry, error)
RequeueExpiredLeasedRunExecutions(ctx context.Context, orgID pgtype.UUID) error
RequeueRunQueueEntry(ctx context.Context, arg RequeueRunQueueEntryParams) (RunQueueEntry, error)
ReserveRunQueueEntry(ctx context.Context, arg ReserveRunQueueEntryParams) (RunQueueEntry, error)
ResolveWaitpoint(ctx context.Context, arg ResolveWaitpointParams) (ResolveWaitpointRow, error)
RevokeAPIKey(ctx context.Context, arg RevokeAPIKeyParams) (int64, error)
RevokeExpiredInvitationsByEmail(ctx context.Context, arg RevokeExpiredInvitationsByEmailParams) (int64, error)
RevokeInvitation(ctx context.Context, arg RevokeInvitationParams) (int64, error)
RevokeOpenMagicLinksForRecipient(ctx context.Context, arg RevokeOpenMagicLinksForRecipientParams) (int64, error)
RevokeSessionByTokenHash(ctx context.Context, tokenHash []byte) (int64, error)
RevokeSessionsForUser(ctx context.Context, userID pgtype.UUID) (int64, error)
RevokeWaitpointResponseToken(ctx context.Context, arg RevokeWaitpointResponseTokenParams) (int64, error)
RevokeWorkerCredential(ctx context.Context, arg RevokeWorkerCredentialParams) (int64, error)
RevokeWorkerCredentialsByWorkerHostID(ctx context.Context, arg RevokeWorkerCredentialsByWorkerHostIDParams) (int64, error)
RunExecutionDeliveryAttemptsExhausted(ctx context.Context, arg RunExecutionDeliveryAttemptsExhaustedParams) (bool, error)
SetWorkerHostStatus(ctx context.Context, arg SetWorkerHostStatusParams) (WorkerHost, error)
StartRunExecution(ctx context.Context, arg StartRunExecutionParams) (RunStatus, error)
SuspendGitHubInstallation(ctx context.Context, arg SuspendGitHubInstallationParams) (GitHubAppInstallation, error)
SuspendGitHubInstallationByInstallationID(ctx context.Context, installationID int64) ([]GitHubAppInstallation, error)
TouchActiveAPIKeyByTokenHash(ctx context.Context, tokenHash []byte) (TouchActiveAPIKeyByTokenHashRow, error)
UpdateOrgMemberRole(ctx context.Context, arg UpdateOrgMemberRoleParams) (OrgMember, error)
UpdateProjectDetails(ctx context.Context, arg UpdateProjectDetailsParams) (Project, error)
UpdateWaitpointPolicy(ctx context.Context, arg UpdateWaitpointPolicyParams) (WaitpointPolicy, error)
UpsertAuthIdentity(ctx context.Context, arg UpsertAuthIdentityParams) (UpsertAuthIdentityRow, error)
UpsertCasObject(ctx context.Context, arg UpsertCasObjectParams) (CasObject, error)
UpsertGitHubInstallation(ctx context.Context, arg UpsertGitHubInstallationParams) (GitHubAppInstallation, error)
UpsertGitHubRepository(ctx context.Context, arg UpsertGitHubRepositoryParams) (GithubRepository, error)
UpsertMagicLinkAuthIdentity(ctx context.Context, arg UpsertMagicLinkAuthIdentityParams) (UpsertMagicLinkAuthIdentityRow, error)
UpsertRunQueueEntryQueued(ctx context.Context, arg UpsertRunQueueEntryQueuedParams) (RunQueueEntry, error)
UpsertRunRequirements(ctx context.Context, arg UpsertRunRequirementsParams) (RunRequirement, error)
UpsertScopedSecret(ctx context.Context, arg UpsertScopedSecretParams) (Secret, error)
UpsertSecret(ctx context.Context, arg UpsertSecretParams) (Secret, error)
UpsertWorkerHostHeartbeat(ctx context.Context, arg UpsertWorkerHostHeartbeatParams) (WorkerHost, error)
}
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) AbandonLeasedRunExecution ¶
func (q *Queries) AbandonLeasedRunExecution(ctx context.Context, arg AbandonLeasedRunExecutionParams) error
func (*Queries) AcceptInvitation ¶
func (*Queries) ActivateTaskDeployment ¶
func (q *Queries) ActivateTaskDeployment(ctx context.Context, arg ActivateTaskDeploymentParams) (TaskDeployment, error)
func (*Queries) AppendRunEvent ¶
func (*Queries) AppendRunEventForExecution ¶
func (*Queries) AppendRunLogChunk ¶
func (q *Queries) AppendRunLogChunk(ctx context.Context, arg AppendRunLogChunkParams) (AppendRunLogChunkRow, error)
func (*Queries) ApproveDeviceCode ¶
func (q *Queries) ApproveDeviceCode(ctx context.Context, arg ApproveDeviceCodeParams) (DeviceCode, error)
func (*Queries) ArchiveWorkerGroup ¶
func (q *Queries) ArchiveWorkerGroup(ctx context.Context, arg ArchiveWorkerGroupParams) (WorkerGroup, error)
func (*Queries) AuthenticateWorkerCredential ¶
func (q *Queries) AuthenticateWorkerCredential(ctx context.Context, arg AuthenticateWorkerCredentialParams) (AuthenticateWorkerCredentialRow, error)
func (*Queries) AuthorizeAPIKeyPermission ¶
func (q *Queries) AuthorizeAPIKeyPermission(ctx context.Context, arg AuthorizeAPIKeyPermissionParams) (AuthorizeAPIKeyPermissionRow, error)
func (*Queries) AuthorizeWorkerCredential ¶
func (q *Queries) AuthorizeWorkerCredential(ctx context.Context, arg AuthorizeWorkerCredentialParams) (AuthorizeWorkerCredentialRow, error)
func (*Queries) CompleteRunQueueEntry ¶
func (q *Queries) CompleteRunQueueEntry(ctx context.Context, arg CompleteRunQueueEntryParams) (RunQueueEntry, error)
func (*Queries) CompleteWaitpointResponseToken ¶
func (q *Queries) CompleteWaitpointResponseToken(ctx context.Context, arg CompleteWaitpointResponseTokenParams) (CompleteWaitpointResponseTokenRow, error)
func (*Queries) ConsumeDeviceCode ¶
func (*Queries) ConsumeMagicLink ¶
func (*Queries) CountRecentMagicLinks ¶
func (*Queries) CountRunsByStatus ¶
func (*Queries) CountScopedRunsByStatus ¶
func (q *Queries) CountScopedRunsByStatus(ctx context.Context, arg CountScopedRunsByStatusParams) (CountScopedRunsByStatusRow, error)
func (*Queries) CreateAPIKeyGrant ¶
func (q *Queries) CreateAPIKeyGrant(ctx context.Context, arg CreateAPIKeyGrantParams) (ApiKeyGrant, error)
func (*Queries) CreateDeployedTask ¶
func (q *Queries) CreateDeployedTask(ctx context.Context, arg CreateDeployedTaskParams) (DeployedTask, error)
func (*Queries) CreateDeviceCode ¶
func (q *Queries) CreateDeviceCode(ctx context.Context, arg CreateDeviceCodeParams) (DeviceCode, error)
func (*Queries) CreateEnvironment ¶
func (q *Queries) CreateEnvironment(ctx context.Context, arg CreateEnvironmentParams) (Environment, error)
func (*Queries) CreateEnvironmentWithDefaultWorkerGroup ¶
func (q *Queries) CreateEnvironmentWithDefaultWorkerGroup(ctx context.Context, arg CreateEnvironmentWithDefaultWorkerGroupParams) (CreateEnvironmentWithDefaultWorkerGroupRow, error)
func (*Queries) CreateInvitation ¶
func (q *Queries) CreateInvitation(ctx context.Context, arg CreateInvitationParams) (Invitation, error)
func (*Queries) CreateMagicLink ¶
func (*Queries) CreateOrganization ¶
func (q *Queries) CreateOrganization(ctx context.Context, arg CreateOrganizationParams) (Organization, error)
func (*Queries) CreateProject ¶
func (*Queries) CreateProjectWithDefaultEnvironment ¶
func (q *Queries) CreateProjectWithDefaultEnvironment(ctx context.Context, arg CreateProjectWithDefaultEnvironmentParams) (CreateProjectWithDefaultEnvironmentRow, error)
func (*Queries) CreateRun ¶
func (q *Queries) CreateRun(ctx context.Context, arg CreateRunParams) (CreateRunRow, error)
func (*Queries) CreateScopedRun ¶
func (q *Queries) CreateScopedRun(ctx context.Context, arg CreateScopedRunParams) (CreateScopedRunRow, error)
func (*Queries) CreateSession ¶
func (*Queries) CreateTaskDeployment ¶
func (q *Queries) CreateTaskDeployment(ctx context.Context, arg CreateTaskDeploymentParams) (TaskDeployment, error)
func (*Queries) CreateWaitpointDelivery ¶
func (q *Queries) CreateWaitpointDelivery(ctx context.Context, arg CreateWaitpointDeliveryParams) (WaitpointDelivery, error)
func (*Queries) CreateWaitpointForExecution ¶
func (q *Queries) CreateWaitpointForExecution(ctx context.Context, arg CreateWaitpointForExecutionParams) (CreateWaitpointForExecutionRow, error)
func (*Queries) CreateWaitpointPolicy ¶
func (q *Queries) CreateWaitpointPolicy(ctx context.Context, arg CreateWaitpointPolicyParams) (WaitpointPolicy, error)
func (*Queries) CreateWaitpointResponseToken ¶
func (q *Queries) CreateWaitpointResponseToken(ctx context.Context, arg CreateWaitpointResponseTokenParams) (WaitpointResponseToken, error)
func (*Queries) CreateWorkerCredentialFromRegistration ¶
func (q *Queries) CreateWorkerCredentialFromRegistration(ctx context.Context, arg CreateWorkerCredentialFromRegistrationParams) (CreateWorkerCredentialFromRegistrationRow, error)
func (*Queries) CreateWorkerGroup ¶
func (q *Queries) CreateWorkerGroup(ctx context.Context, arg CreateWorkerGroupParams) (WorkerGroup, error)
func (*Queries) DeadLetterRunQueueEntry ¶
func (q *Queries) DeadLetterRunQueueEntry(ctx context.Context, arg DeadLetterRunQueueEntryParams) (DeadLetterRunQueueEntryRow, error)
func (*Queries) DeleteAPIKeyGrant ¶
func (*Queries) DeleteAPIKeyGrantsForKey ¶
func (*Queries) DeleteGitHubInstallation ¶
func (q *Queries) DeleteGitHubInstallation(ctx context.Context, arg DeleteGitHubInstallationParams) (GitHubAppInstallation, error)
func (*Queries) DeleteGitHubInstallationByInstallationID ¶
func (*Queries) DenyDeviceCode ¶
func (q *Queries) DenyDeviceCode(ctx context.Context, arg DenyDeviceCodeParams) (DeviceCode, error)
func (*Queries) DisableGitHubRepositoryConnection ¶
func (q *Queries) DisableGitHubRepositoryConnection(ctx context.Context, arg DisableGitHubRepositoryConnectionParams) (DisableGitHubRepositoryConnectionRow, error)
func (*Queries) DisableOrgMember ¶
func (*Queries) DisableProjectWorkspaceRepositoryAccess ¶
func (q *Queries) DisableProjectWorkspaceRepositoryAccess(ctx context.Context, arg DisableProjectWorkspaceRepositoryAccessParams) (ProjectWorkspaceRepository, error)
func (*Queries) DisableWaitpointPolicy ¶
func (*Queries) EnableGitHubRepositoryConnection ¶
func (q *Queries) EnableGitHubRepositoryConnection(ctx context.Context, arg EnableGitHubRepositoryConnectionParams) (GithubRepositoryConnection, error)
func (*Queries) EnableProjectWorkspaceRepositoryAccess ¶
func (q *Queries) EnableProjectWorkspaceRepositoryAccess(ctx context.Context, arg EnableProjectWorkspaceRepositoryAccessParams) (ProjectWorkspaceRepository, error)
func (*Queries) EnsureOrgMember ¶
func (*Queries) ExpireDuePendingWaitpoints ¶
func (*Queries) FailExpiredRunningRunExecutions ¶
func (*Queries) GetActiveDeployedTask ¶
func (q *Queries) GetActiveDeployedTask(ctx context.Context, arg GetActiveDeployedTaskParams) (GetActiveDeployedTaskRow, error)
func (*Queries) GetActiveGitHubRepositoryAccessTarget ¶
func (q *Queries) GetActiveGitHubRepositoryAccessTarget(ctx context.Context, arg GetActiveGitHubRepositoryAccessTargetParams) (GetActiveGitHubRepositoryAccessTargetRow, error)
func (*Queries) GetActiveInvitation ¶
func (*Queries) GetActiveInvitationByID ¶
func (*Queries) GetActiveMagicLinkByTokenHash ¶
func (*Queries) GetActiveProjectWorkspaceRepositoryAccess ¶
func (q *Queries) GetActiveProjectWorkspaceRepositoryAccess(ctx context.Context, arg GetActiveProjectWorkspaceRepositoryAccessParams) (GetActiveProjectWorkspaceRepositoryAccessRow, error)
func (*Queries) GetActiveProjectWorkspaceRepositoryAccessByFullName ¶
func (q *Queries) GetActiveProjectWorkspaceRepositoryAccessByFullName(ctx context.Context, arg GetActiveProjectWorkspaceRepositoryAccessByFullNameParams) (GetActiveProjectWorkspaceRepositoryAccessByFullNameRow, error)
func (*Queries) GetActiveTaskDeployment ¶
func (q *Queries) GetActiveTaskDeployment(ctx context.Context, arg GetActiveTaskDeploymentParams) (TaskDeployment, error)
func (*Queries) GetActiveWaitpointResponseToken ¶
func (q *Queries) GetActiveWaitpointResponseToken(ctx context.Context, arg GetActiveWaitpointResponseTokenParams) (GetActiveWaitpointResponseTokenRow, error)
func (*Queries) GetCasObject ¶
func (*Queries) GetDefaultEnvironment ¶
func (q *Queries) GetDefaultEnvironment(ctx context.Context, arg GetDefaultEnvironmentParams) (Environment, error)
func (*Queries) GetDefaultProjectEnvironment ¶
func (*Queries) GetDeviceCodeByUserCodeHash ¶
func (*Queries) GetDeviceCodeForPoll ¶
func (*Queries) GetEnvironment ¶
func (q *Queries) GetEnvironment(ctx context.Context, arg GetEnvironmentParams) (Environment, error)
func (*Queries) GetEnvironmentBySlug ¶
func (q *Queries) GetEnvironmentBySlug(ctx context.Context, arg GetEnvironmentBySlugParams) (Environment, error)
func (*Queries) GetKnownGitHubInstallationByInstallationID ¶
func (*Queries) GetMagicLinkLoginUser ¶
func (*Queries) GetOrgMember ¶
func (q *Queries) GetOrgMember(ctx context.Context, arg GetOrgMemberParams) (GetOrgMemberRow, error)
func (*Queries) GetOrgMemberForManagement ¶
func (q *Queries) GetOrgMemberForManagement(ctx context.Context, arg GetOrgMemberForManagementParams) (GetOrgMemberForManagementRow, error)
func (*Queries) GetOrganization ¶
func (*Queries) GetPendingInvitationByEmail ¶
func (q *Queries) GetPendingInvitationByEmail(ctx context.Context, arg GetPendingInvitationByEmailParams) (GetPendingInvitationByEmailRow, error)
func (*Queries) GetPendingWaitpointForRun ¶
func (*Queries) GetProject ¶
func (*Queries) GetProjectBySlug ¶
func (*Queries) GetRevocableInvitation ¶
func (q *Queries) GetRevocableInvitation(ctx context.Context, arg GetRevocableInvitationParams) (GetRevocableInvitationRow, error)
func (*Queries) GetRunExecutionQueueLease ¶
func (q *Queries) GetRunExecutionQueueLease(ctx context.Context, arg GetRunExecutionQueueLeaseParams) (GetRunExecutionQueueLeaseRow, error)
func (*Queries) GetRunLogSnapshot ¶
func (q *Queries) GetRunLogSnapshot(ctx context.Context, arg GetRunLogSnapshotParams) (GetRunLogSnapshotRow, error)
func (*Queries) GetRunRestorePayload ¶
func (q *Queries) GetRunRestorePayload(ctx context.Context, arg GetRunRestorePayloadParams) (GetRunRestorePayloadRow, error)
func (*Queries) GetRunSummary ¶
func (q *Queries) GetRunSummary(ctx context.Context, arg GetRunSummaryParams) (GetRunSummaryRow, error)
func (*Queries) GetScopedRun ¶
func (*Queries) GetScopedRunSummary ¶
func (q *Queries) GetScopedRunSummary(ctx context.Context, arg GetScopedRunSummaryParams) (GetScopedRunSummaryRow, error)
func (*Queries) GetScopedSecretByName ¶
func (*Queries) GetSecretByName ¶
func (*Queries) GetSessionByTokenHash ¶
func (*Queries) GetUserOnboardingState ¶
func (*Queries) GetWaitpointPolicyByName ¶
func (q *Queries) GetWaitpointPolicyByName(ctx context.Context, arg GetWaitpointPolicyByNameParams) (WaitpointPolicy, error)
func (*Queries) GetWorkerGroup ¶
func (q *Queries) GetWorkerGroup(ctx context.Context, arg GetWorkerGroupParams) (WorkerGroup, error)
func (*Queries) GetWorkerHostQueueCapacity ¶
func (q *Queries) GetWorkerHostQueueCapacity(ctx context.Context, arg GetWorkerHostQueueCapacityParams) (GetWorkerHostQueueCapacityRow, error)
func (*Queries) GetWorkerHostState ¶
func (q *Queries) GetWorkerHostState(ctx context.Context, arg GetWorkerHostStateParams) (GetWorkerHostStateRow, error)
func (*Queries) IssueAPIKey ¶
func (*Queries) LeaseRunExecution ¶
func (q *Queries) LeaseRunExecution(ctx context.Context, arg LeaseRunExecutionParams) (LeaseRunExecutionRow, error)
func (*Queries) ListAPIKeyGrants ¶
func (q *Queries) ListAPIKeyGrants(ctx context.Context, arg ListAPIKeyGrantsParams) ([]ApiKeyGrant, error)
func (*Queries) ListAPIKeys ¶
func (q *Queries) ListAPIKeys(ctx context.Context, arg ListAPIKeysParams) ([]ListAPIKeysRow, error)
func (*Queries) ListActiveProjectWorkspaceRepositoryAccess ¶
func (q *Queries) ListActiveProjectWorkspaceRepositoryAccess(ctx context.Context, arg ListActiveProjectWorkspaceRepositoryAccessParams) ([]ListActiveProjectWorkspaceRepositoryAccessRow, error)
func (*Queries) ListDeployedTasksForDeployment ¶
func (q *Queries) ListDeployedTasksForDeployment(ctx context.Context, arg ListDeployedTasksForDeploymentParams) ([]DeployedTask, error)
func (*Queries) ListEnvironments ¶
func (q *Queries) ListEnvironments(ctx context.Context, arg ListEnvironmentsParams) ([]Environment, error)
func (*Queries) ListGitHubInstallationRepositories ¶
func (q *Queries) ListGitHubInstallationRepositories(ctx context.Context, arg ListGitHubInstallationRepositoriesParams) ([]ListGitHubInstallationRepositoriesRow, error)
func (*Queries) ListGitHubInstallations ¶
func (*Queries) ListInvitations ¶
func (q *Queries) ListInvitations(ctx context.Context, arg ListInvitationsParams) ([]ListInvitationsRow, error)
func (*Queries) ListOrgMembers ¶
func (*Queries) ListOrganizationIDs ¶
func (*Queries) ListOrganizationIDsPage ¶
func (*Queries) ListProjects ¶
func (*Queries) ListQueuedRunQueueEntryCandidates ¶
func (q *Queries) ListQueuedRunQueueEntryCandidates(ctx context.Context, arg ListQueuedRunQueueEntryCandidatesParams) ([]ListQueuedRunQueueEntryCandidatesRow, error)
func (*Queries) ListRunEvents ¶
func (*Queries) ListRunSummaries ¶
func (q *Queries) ListRunSummaries(ctx context.Context, arg ListRunSummariesParams) ([]ListRunSummariesRow, error)
func (*Queries) ListScopedRunSummaries ¶
func (q *Queries) ListScopedRunSummaries(ctx context.Context, arg ListScopedRunSummariesParams) ([]ListScopedRunSummariesRow, error)
func (*Queries) ListScopedRuns ¶
func (*Queries) ListScopedSecrets ¶
func (q *Queries) ListScopedSecrets(ctx context.Context, arg ListScopedSecretsParams) ([]ListScopedSecretsRow, error)
func (*Queries) ListSecrets ¶
func (q *Queries) ListSecrets(ctx context.Context, arg ListSecretsParams) ([]ListSecretsRow, error)
func (*Queries) ListWaitpointDeliveries ¶
func (q *Queries) ListWaitpointDeliveries(ctx context.Context, arg ListWaitpointDeliveriesParams) ([]WaitpointDelivery, error)
func (*Queries) ListWaitpointPolicies ¶
func (*Queries) ListWorkerGroupsByScope ¶
func (q *Queries) ListWorkerGroupsByScope(ctx context.Context, arg ListWorkerGroupsByScopeParams) ([]WorkerGroup, error)
func (*Queries) ListWorkerHostsByWorkerGroup ¶
func (q *Queries) ListWorkerHostsByWorkerGroup(ctx context.Context, arg ListWorkerHostsByWorkerGroupParams) ([]WorkerHost, error)
func (*Queries) MarkGitHubRepositoriesDeletedByInstallationID ¶
func (*Queries) MarkGitHubRepositoryDeleted ¶
func (q *Queries) MarkGitHubRepositoryDeleted(ctx context.Context, arg MarkGitHubRepositoryDeletedParams) (MarkGitHubRepositoryDeletedRow, error)
func (*Queries) MarkMagicLinkDeliveryFailed ¶
func (*Queries) MarkMagicLinkSent ¶
func (*Queries) MarkRunQueueEntryEnqueueError ¶
func (q *Queries) MarkRunQueueEntryEnqueueError(ctx context.Context, arg MarkRunQueueEntryEnqueueErrorParams) (RunQueueEntry, error)
func (*Queries) MarkRunQueueEntryEnqueued ¶
func (q *Queries) MarkRunQueueEntryEnqueued(ctx context.Context, arg MarkRunQueueEntryEnqueuedParams) (RunQueueEntry, error)
func (*Queries) MarkWaitpointCheckpointFailed ¶
func (q *Queries) MarkWaitpointCheckpointFailed(ctx context.Context, arg MarkWaitpointCheckpointFailedParams) (MarkWaitpointCheckpointFailedRow, error)
func (*Queries) MarkWaitpointCheckpointReady ¶
func (q *Queries) MarkWaitpointCheckpointReady(ctx context.Context, arg MarkWaitpointCheckpointReadyParams) (MarkWaitpointCheckpointReadyRow, error)
func (*Queries) MarkWaitpointDeliveryFailed ¶
func (q *Queries) MarkWaitpointDeliveryFailed(ctx context.Context, arg MarkWaitpointDeliveryFailedParams) (WaitpointDelivery, error)
func (*Queries) MarkWaitpointDeliverySent ¶
func (q *Queries) MarkWaitpointDeliverySent(ctx context.Context, arg MarkWaitpointDeliverySentParams) (WaitpointDelivery, error)
func (*Queries) OwnerExists ¶
func (*Queries) PrepareQueuedRunQueueEntry ¶
func (q *Queries) PrepareQueuedRunQueueEntry(ctx context.Context, arg PrepareQueuedRunQueueEntryParams) (PrepareQueuedRunQueueEntryRow, error)
func (*Queries) RefreshSession ¶
func (q *Queries) RefreshSession(ctx context.Context, arg RefreshSessionParams) error
func (*Queries) ReleaseRunExecution ¶
func (q *Queries) ReleaseRunExecution(ctx context.Context, arg ReleaseRunExecutionParams) (ReleaseRunExecutionRow, error)
func (*Queries) RenewRunExecutionLease ¶
func (q *Queries) RenewRunExecutionLease(ctx context.Context, arg RenewRunExecutionLeaseParams) (RenewRunExecutionLeaseRow, error)
func (*Queries) RenewRunQueueReservation ¶
func (q *Queries) RenewRunQueueReservation(ctx context.Context, arg RenewRunQueueReservationParams) (RunQueueEntry, error)
func (*Queries) RequeueExpiredLeasedRunExecutions ¶
func (*Queries) RequeueRunQueueEntry ¶
func (q *Queries) RequeueRunQueueEntry(ctx context.Context, arg RequeueRunQueueEntryParams) (RunQueueEntry, error)
func (*Queries) ReserveRunQueueEntry ¶
func (q *Queries) ReserveRunQueueEntry(ctx context.Context, arg ReserveRunQueueEntryParams) (RunQueueEntry, error)
func (*Queries) ResolveWaitpoint ¶
func (q *Queries) ResolveWaitpoint(ctx context.Context, arg ResolveWaitpointParams) (ResolveWaitpointRow, error)
func (*Queries) RevokeAPIKey ¶
func (*Queries) RevokeExpiredInvitationsByEmail ¶
func (*Queries) RevokeInvitation ¶
func (*Queries) RevokeOpenMagicLinksForRecipient ¶
func (*Queries) RevokeSessionByTokenHash ¶
func (*Queries) RevokeSessionsForUser ¶
func (*Queries) RevokeWaitpointResponseToken ¶
func (*Queries) RevokeWorkerCredential ¶
func (*Queries) RevokeWorkerCredentialsByWorkerHostID ¶
func (*Queries) RunExecutionDeliveryAttemptsExhausted ¶
func (*Queries) SetWorkerHostStatus ¶
func (q *Queries) SetWorkerHostStatus(ctx context.Context, arg SetWorkerHostStatusParams) (WorkerHost, error)
func (*Queries) StartRunExecution ¶
func (*Queries) SuspendGitHubInstallation ¶
func (q *Queries) SuspendGitHubInstallation(ctx context.Context, arg SuspendGitHubInstallationParams) (GitHubAppInstallation, error)
func (*Queries) SuspendGitHubInstallationByInstallationID ¶
func (*Queries) TouchActiveAPIKeyByTokenHash ¶
func (*Queries) UpdateOrgMemberRole ¶
func (*Queries) UpdateProjectDetails ¶
func (*Queries) UpdateWaitpointPolicy ¶
func (q *Queries) UpdateWaitpointPolicy(ctx context.Context, arg UpdateWaitpointPolicyParams) (WaitpointPolicy, error)
func (*Queries) UpsertAuthIdentity ¶
func (q *Queries) UpsertAuthIdentity(ctx context.Context, arg UpsertAuthIdentityParams) (UpsertAuthIdentityRow, error)
func (*Queries) UpsertCasObject ¶
func (*Queries) UpsertGitHubInstallation ¶
func (q *Queries) UpsertGitHubInstallation(ctx context.Context, arg UpsertGitHubInstallationParams) (GitHubAppInstallation, error)
func (*Queries) UpsertGitHubRepository ¶
func (q *Queries) UpsertGitHubRepository(ctx context.Context, arg UpsertGitHubRepositoryParams) (GithubRepository, error)
func (*Queries) UpsertMagicLinkAuthIdentity ¶
func (q *Queries) UpsertMagicLinkAuthIdentity(ctx context.Context, arg UpsertMagicLinkAuthIdentityParams) (UpsertMagicLinkAuthIdentityRow, error)
func (*Queries) UpsertRunQueueEntryQueued ¶
func (q *Queries) UpsertRunQueueEntryQueued(ctx context.Context, arg UpsertRunQueueEntryQueuedParams) (RunQueueEntry, error)
func (*Queries) UpsertRunRequirements ¶
func (q *Queries) UpsertRunRequirements(ctx context.Context, arg UpsertRunRequirementsParams) (RunRequirement, error)
func (*Queries) UpsertScopedSecret ¶
func (*Queries) UpsertSecret ¶
func (*Queries) UpsertWorkerHostHeartbeat ¶
func (q *Queries) UpsertWorkerHostHeartbeat(ctx context.Context, arg UpsertWorkerHostHeartbeatParams) (WorkerHost, error)
type RefreshSessionParams ¶
type RefreshSessionParams struct {
ExpiresAt pgtype.Timestamptz `json:"expires_at"`
ID pgtype.UUID `json:"id"`
}
type ReleaseRunExecutionParams ¶
type ReleaseRunExecutionParams struct {
ExecutionID pgtype.UUID `json:"execution_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
WorkerHostID pgtype.UUID `json:"worker_host_id"`
QueueMessageID string `json:"queue_message_id"`
QueueLeaseID string `json:"queue_lease_id"`
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
Status RunStatus `json:"status"`
ExitCode pgtype.Int4 `json:"exit_code"`
Output []byte `json:"output"`
ErrorMessage pgtype.Text `json:"error_message"`
TerminalEventKind string `json:"terminal_event_kind"`
TerminalEventPayload []byte `json:"terminal_event_payload"`
}
type ReleaseRunExecutionRow ¶
type ReleaseRunExecutionRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
TaskDeploymentID pgtype.UUID `json:"task_deployment_id"`
DeployedTaskID pgtype.UUID `json:"deployed_task_id"`
TaskID string `json:"task_id"`
Status RunStatus `json:"status"`
Payload []byte `json:"payload"`
Output []byte `json:"output"`
SecretBindings []byte `json:"secret_bindings"`
WorkspaceRepository string `json:"workspace_repository"`
WorkspaceInstallationID int64 `json:"workspace_installation_id"`
WorkspaceGithubRepositoryID int64 `json:"workspace_github_repository_id"`
WorkspaceRef string `json:"workspace_ref"`
WorkspaceSha string `json:"workspace_sha"`
WorkspaceSubpath string `json:"workspace_subpath"`
MaxDurationSeconds int32 `json:"max_duration_seconds"`
CurrentExecutionID pgtype.UUID `json:"current_execution_id"`
LatestCheckpointID pgtype.UUID `json:"latest_checkpoint_id"`
ExitCode pgtype.Int4 `json:"exit_code"`
ErrorMessage pgtype.Text `json:"error_message"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
StartedAt pgtype.Timestamptz `json:"started_at"`
FinishedAt pgtype.Timestamptz `json:"finished_at"`
}
type RenewRunExecutionLeaseParams ¶
type RenewRunExecutionLeaseParams struct {
LeaseExpiresAt pgtype.Timestamptz `json:"lease_expires_at"`
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
ExecutionID pgtype.UUID `json:"execution_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
WorkerHostID pgtype.UUID `json:"worker_host_id"`
QueueMessageID string `json:"queue_message_id"`
QueueLeaseID string `json:"queue_lease_id"`
}
type RenewRunExecutionLeaseRow ¶
type RenewRunExecutionLeaseRow struct {
ID pgtype.UUID `json:"id"`
WorkerHostID pgtype.UUID `json:"worker_host_id"`
QueueMessageID string `json:"queue_message_id"`
QueueLeaseID string `json:"queue_lease_id"`
DeliveryAttempt int32 `json:"delivery_attempt"`
LeaseExpiresAt pgtype.Timestamptz `json:"lease_expires_at"`
}
type RenewRunQueueReservationParams ¶
type RenewRunQueueReservationParams struct {
ReservationExpiresAt pgtype.Timestamptz `json:"reservation_expires_at"`
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
WorkerHostID pgtype.UUID `json:"worker_host_id"`
QueueMessageID pgtype.Text `json:"queue_message_id"`
}
type RequeueRunQueueEntryParams ¶
type RequeueRunQueueEntryParams struct {
LastError string `json:"last_error"`
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
WorkerHostID pgtype.UUID `json:"worker_host_id"`
QueueMessageID pgtype.Text `json:"queue_message_id"`
}
type ReserveRunQueueEntryParams ¶
type ReserveRunQueueEntryParams struct {
QueueMessageID pgtype.Text `json:"queue_message_id"`
WorkerHostID pgtype.UUID `json:"worker_host_id"`
ReservationExpiresAt pgtype.Timestamptz `json:"reservation_expires_at"`
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
}
type ResolveWaitpointParams ¶
type ResolveWaitpointRow ¶
type ResolveWaitpointRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
ExecutionID pgtype.UUID `json:"execution_id"`
CheckpointID pgtype.UUID `json:"checkpoint_id"`
CorrelationID string `json:"correlation_id"`
Kind WaitpointKind `json:"kind"`
Request []byte `json:"request"`
DisplayText string `json:"display_text"`
TimeoutSeconds pgtype.Int4 `json:"timeout_seconds"`
PolicyName pgtype.Text `json:"policy_name"`
PolicySnapshot []byte `json:"policy_snapshot"`
Status WaitpointStatus `json:"status"`
ResolutionKind pgtype.Text `json:"resolution_kind"`
Resolution []byte `json:"resolution"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
RequestedAt pgtype.Timestamptz `json:"requested_at"`
ResolvedAt pgtype.Timestamptz `json:"resolved_at"`
}
type RevokeAPIKeyParams ¶
type RevokeInvitationParams ¶
type Run ¶
type Run struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
TaskDeploymentID pgtype.UUID `json:"task_deployment_id"`
DeployedTaskID pgtype.UUID `json:"deployed_task_id"`
TaskID string `json:"task_id"`
Status RunStatus `json:"status"`
Payload []byte `json:"payload"`
Output []byte `json:"output"`
SecretBindings []byte `json:"secret_bindings"`
WorkspaceRepository string `json:"workspace_repository"`
WorkspaceInstallationID int64 `json:"workspace_installation_id"`
WorkspaceGithubRepositoryID int64 `json:"workspace_github_repository_id"`
WorkspaceRef string `json:"workspace_ref"`
WorkspaceSha string `json:"workspace_sha"`
WorkspaceSubpath string `json:"workspace_subpath"`
MaxDurationSeconds int32 `json:"max_duration_seconds"`
CurrentExecutionID pgtype.UUID `json:"current_execution_id"`
LatestCheckpointID pgtype.UUID `json:"latest_checkpoint_id"`
ExitCode pgtype.Int4 `json:"exit_code"`
ErrorMessage pgtype.Text `json:"error_message"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
StartedAt pgtype.Timestamptz `json:"started_at"`
FinishedAt pgtype.Timestamptz `json:"finished_at"`
}
type RunExecution ¶
type RunExecution struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
WorkerHostID pgtype.UUID `json:"worker_host_id"`
QueueMessageID string `json:"queue_message_id"`
QueueLeaseID string `json:"queue_lease_id"`
DeliveryAttempt int32 `json:"delivery_attempt"`
Status RunExecutionStatus `json:"status"`
LeaseExpiresAt pgtype.Timestamptz `json:"lease_expires_at"`
ActiveDurationMs int64 `json:"active_duration_ms"`
RestoreCheckpointID pgtype.UUID `json:"restore_checkpoint_id"`
LeasedAt pgtype.Timestamptz `json:"leased_at"`
StartedAt pgtype.Timestamptz `json:"started_at"`
RenewedAt pgtype.Timestamptz `json:"renewed_at"`
ReleasedAt pgtype.Timestamptz `json:"released_at"`
LostAt pgtype.Timestamptz `json:"lost_at"`
}
type RunExecutionStatus ¶
type RunExecutionStatus string
const ( RunExecutionStatusLeased RunExecutionStatus = "leased" RunExecutionStatusRunning RunExecutionStatus = "running" RunExecutionStatusDetached RunExecutionStatus = "detached" RunExecutionStatusReleased RunExecutionStatus = "released" RunExecutionStatusLost RunExecutionStatus = "lost" )
func (*RunExecutionStatus) Scan ¶
func (e *RunExecutionStatus) Scan(src interface{}) error
type RunLogChunk ¶
type RunLogChunk struct {
RunID pgtype.UUID `json:"run_id"`
ExecutionID pgtype.UUID `json:"execution_id"`
Stream RunLogStream `json:"stream"`
Seq int64 `json:"seq"`
ObservedSeq int64 `json:"observed_seq"`
Content []byte `json:"content"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
}
type RunLogStream ¶
type RunLogStream string
const ( RunLogStreamStdout RunLogStream = "stdout" RunLogStreamStderr RunLogStream = "stderr" )
func (*RunLogStream) Scan ¶
func (e *RunLogStream) Scan(src interface{}) error
type RunQueueEntry ¶
type RunQueueEntry struct {
RunID pgtype.UUID `json:"run_id"`
OrgID pgtype.UUID `json:"org_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
Status RunQueueStatus `json:"status"`
Priority int32 `json:"priority"`
QueueName string `json:"queue_name"`
QueueMessageID pgtype.Text `json:"queue_message_id"`
ReservedByWorkerHostID pgtype.UUID `json:"reserved_by_worker_host_id"`
ReservationExpiresAt pgtype.Timestamptz `json:"reservation_expires_at"`
DispatchGeneration int64 `json:"dispatch_generation"`
LastError string `json:"last_error"`
EnqueuedAt pgtype.Timestamptz `json:"enqueued_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
FinishedAt pgtype.Timestamptz `json:"finished_at"`
}
type RunQueueStatus ¶
type RunQueueStatus string
const ( RunQueueStatusQueued RunQueueStatus = "queued" RunQueueStatusPublished RunQueueStatus = "published" RunQueueStatusReserved RunQueueStatus = "reserved" RunQueueStatusSuspended RunQueueStatus = "suspended" RunQueueStatusCompleted RunQueueStatus = "completed" RunQueueStatusCancelled RunQueueStatus = "cancelled" RunQueueStatusDeadLettered RunQueueStatus = "dead_lettered" )
func (*RunQueueStatus) Scan ¶
func (e *RunQueueStatus) Scan(src interface{}) error
type RunRequirement ¶
type RunRequirement struct {
RunID pgtype.UUID `json:"run_id"`
OrgID pgtype.UUID `json:"org_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
RequestedMilliCpu int64 `json:"requested_milli_cpu"`
RequestedMemoryMib int64 `json:"requested_memory_mib"`
RequestedDiskMib int64 `json:"requested_disk_mib"`
RequestedExecutionSlots int32 `json:"requested_execution_slots"`
RuntimeArch string `json:"runtime_arch"`
RuntimeABI string `json:"runtime_abi"`
KernelDigest string `json:"kernel_digest"`
RootfsDigest string `json:"rootfs_digest"`
CniProfile string `json:"cni_profile"`
NetworkPolicy []byte `json:"network_policy"`
Placement []byte `json:"placement"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type Secret ¶
type Secret struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
Name string `json:"name"`
KeyID string `json:"key_id"`
Nonce []byte `json:"nonce"`
Ciphertext []byte `json:"ciphertext"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
DeletedAt pgtype.Timestamptz `json:"deleted_at"`
}
type Session ¶
type Session struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
UserID pgtype.UUID `json:"user_id"`
TokenHash []byte `json:"token_hash"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
LastSeenAt pgtype.Timestamptz `json:"last_seen_at"`
ExpiresAt pgtype.Timestamptz `json:"expires_at"`
RevokedAt pgtype.Timestamptz `json:"revoked_at"`
}
type StartRunExecutionParams ¶
type TaskDeployment ¶
type TaskDeployment struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
SourceDigest string `json:"source_digest"`
Status TaskDeploymentStatus `json:"status"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
DeployedAt pgtype.Timestamptz `json:"deployed_at"`
ArchivedAt pgtype.Timestamptz `json:"archived_at"`
}
type TaskDeploymentStatus ¶
type TaskDeploymentStatus string
const ( TaskDeploymentStatusCreating TaskDeploymentStatus = "creating" TaskDeploymentStatusActive TaskDeploymentStatus = "active" TaskDeploymentStatusArchived TaskDeploymentStatus = "archived" )
func (*TaskDeploymentStatus) Scan ¶
func (e *TaskDeploymentStatus) Scan(src interface{}) error
type TouchActiveAPIKeyByTokenHashRow ¶
type TouchActiveAPIKeyByTokenHashRow struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
CreatedByUserID pgtype.UUID `json:"created_by_user_id"`
Name string `json:"name"`
KeyPrefix string `json:"key_prefix"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
LastUsedAt pgtype.Timestamptz `json:"last_used_at"`
ExpiresAt pgtype.Timestamptz `json:"expires_at"`
Role string `json:"role"`
Grants []byte `json:"grants"`
}
type UpdateOrgMemberRoleParams ¶
type UpdateOrgMemberRoleParams struct {
Role OrgMemberRole `json:"role"`
OrgID pgtype.UUID `json:"org_id"`
UserID pgtype.UUID `json:"user_id"`
ExpectedRole OrgMemberRole `json:"expected_role"`
ActorIsOwner bool `json:"actor_is_owner"`
}
type UpsertAuthIdentityParams ¶
type UpsertAuthIdentityParams struct {
Email pgtype.Text `json:"email"`
Claims []byte `json:"claims"`
IdentityProvider string `json:"identity_provider"`
IdentitySubject string `json:"identity_subject"`
UserID pgtype.UUID `json:"user_id"`
DisplayName string `json:"display_name"`
ProfileImageUrl pgtype.Text `json:"profile_image_url"`
IdentityID pgtype.UUID `json:"identity_id"`
}
type UpsertAuthIdentityRow ¶
type UpsertAuthIdentityRow struct {
ID pgtype.UUID `json:"id"`
DisplayName string `json:"display_name"`
ProfileImageUrl pgtype.Text `json:"profile_image_url"`
PrimaryEmail pgtype.Text `json:"primary_email"`
DisabledAt pgtype.Timestamptz `json:"disabled_at"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type UpsertCasObjectParams ¶
type UpsertGitHubInstallationParams ¶
type UpsertGitHubInstallationParams struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
InstallationID int64 `json:"installation_id"`
AccountLogin string `json:"account_login"`
AccountType string `json:"account_type"`
RepositorySelection pgtype.Text `json:"repository_selection"`
HtmlUrl pgtype.Text `json:"html_url"`
}
type UpsertGitHubRepositoryParams ¶
type UpsertGitHubRepositoryParams struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
InstallationID int64 `json:"installation_id"`
GithubRepositoryID int64 `json:"github_repository_id"`
OwnerLogin string `json:"owner_login"`
Name string `json:"name"`
FullName string `json:"full_name"`
Private bool `json:"private"`
Archived bool `json:"archived"`
DefaultBranch pgtype.Text `json:"default_branch"`
HtmlUrl pgtype.Text `json:"html_url"`
}
type UpsertMagicLinkAuthIdentityParams ¶
type UpsertMagicLinkAuthIdentityParams struct {
Email pgtype.Text `json:"email"`
Claims []byte `json:"claims"`
IdentityProvider string `json:"identity_provider"`
IdentitySubject string `json:"identity_subject"`
UserID pgtype.UUID `json:"user_id"`
DisplayName string `json:"display_name"`
ProfileImageUrl pgtype.Text `json:"profile_image_url"`
IdentityID pgtype.UUID `json:"identity_id"`
}
type UpsertMagicLinkAuthIdentityRow ¶
type UpsertMagicLinkAuthIdentityRow struct {
ID pgtype.UUID `json:"id"`
DisplayName string `json:"display_name"`
ProfileImageUrl pgtype.Text `json:"profile_image_url"`
PrimaryEmail pgtype.Text `json:"primary_email"`
DisabledAt pgtype.Timestamptz `json:"disabled_at"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type UpsertRunRequirementsParams ¶
type UpsertRunRequirementsParams struct {
RunID pgtype.UUID `json:"run_id"`
OrgID pgtype.UUID `json:"org_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
RequestedMilliCpu int64 `json:"requested_milli_cpu"`
RequestedMemoryMib int64 `json:"requested_memory_mib"`
RequestedDiskMib int64 `json:"requested_disk_mib"`
RequestedExecutionSlots int32 `json:"requested_execution_slots"`
RuntimeArch string `json:"runtime_arch"`
RuntimeABI string `json:"runtime_abi"`
KernelDigest string `json:"kernel_digest"`
RootfsDigest string `json:"rootfs_digest"`
CniProfile string `json:"cni_profile"`
NetworkPolicy []byte `json:"network_policy"`
Placement []byte `json:"placement"`
}
type UpsertScopedSecretParams ¶
type UpsertScopedSecretParams struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
Name string `json:"name"`
KeyID string `json:"key_id"`
Nonce []byte `json:"nonce"`
Ciphertext []byte `json:"ciphertext"`
}
type UpsertSecretParams ¶
type UpsertWorkerHostHeartbeatParams ¶
type UpsertWorkerHostHeartbeatParams struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
ExternalID string `json:"external_id"`
Region string `json:"region"`
TotalMilliCpu int64 `json:"total_milli_cpu"`
TotalMemoryMib int64 `json:"total_memory_mib"`
TotalDiskMib int64 `json:"total_disk_mib"`
TotalExecutionSlots int32 `json:"total_execution_slots"`
AvailableMilliCpu int64 `json:"available_milli_cpu"`
AvailableMemoryMib int64 `json:"available_memory_mib"`
AvailableDiskMib int64 `json:"available_disk_mib"`
AvailableExecutionSlots int32 `json:"available_execution_slots"`
Labels []byte `json:"labels"`
Heartbeat []byte `json:"heartbeat"`
}
type User ¶
type User struct {
ID pgtype.UUID `json:"id"`
DisplayName string `json:"display_name"`
ProfileImageUrl pgtype.Text `json:"profile_image_url"`
PrimaryEmail pgtype.Text `json:"primary_email"`
DisabledAt pgtype.Timestamptz `json:"disabled_at"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type Waitpoint ¶
type Waitpoint struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
ExecutionID pgtype.UUID `json:"execution_id"`
CheckpointID pgtype.UUID `json:"checkpoint_id"`
CorrelationID string `json:"correlation_id"`
Kind WaitpointKind `json:"kind"`
Request []byte `json:"request"`
DisplayText string `json:"display_text"`
TimeoutSeconds pgtype.Int4 `json:"timeout_seconds"`
PolicyName pgtype.Text `json:"policy_name"`
PolicySnapshot []byte `json:"policy_snapshot"`
Status WaitpointStatus `json:"status"`
ResolutionKind pgtype.Text `json:"resolution_kind"`
Resolution []byte `json:"resolution"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
RequestedAt pgtype.Timestamptz `json:"requested_at"`
ResolvedAt pgtype.Timestamptz `json:"resolved_at"`
}
type WaitpointDelivery ¶
type WaitpointDelivery struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
WaitpointID pgtype.UUID `json:"waitpoint_id"`
ResponseTokenID pgtype.UUID `json:"response_token_id"`
Channel string `json:"channel"`
RecipientKind string `json:"recipient_kind"`
Recipient string `json:"recipient"`
Status WaitpointDeliveryStatus `json:"status"`
LastError pgtype.Text `json:"last_error"`
Metadata []byte `json:"metadata"`
SentAt pgtype.Timestamptz `json:"sent_at"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type WaitpointDeliveryStatus ¶
type WaitpointDeliveryStatus string
const ( WaitpointDeliveryStatusQueued WaitpointDeliveryStatus = "queued" WaitpointDeliveryStatusSent WaitpointDeliveryStatus = "sent" WaitpointDeliveryStatusFailed WaitpointDeliveryStatus = "failed" )
func (*WaitpointDeliveryStatus) Scan ¶
func (e *WaitpointDeliveryStatus) Scan(src interface{}) error
type WaitpointKind ¶
type WaitpointKind string
const ( WaitpointKindApproval WaitpointKind = "approval" WaitpointKindMessage WaitpointKind = "message" )
func (*WaitpointKind) Scan ¶
func (e *WaitpointKind) Scan(src interface{}) error
type WaitpointPolicy ¶
type WaitpointPolicy struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
Name string `json:"name"`
Label string `json:"label"`
Config []byte `json:"config"`
DisabledAt pgtype.Timestamptz `json:"disabled_at"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}
type WaitpointResponseToken ¶
type WaitpointResponseToken struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
RunID pgtype.UUID `json:"run_id"`
WaitpointID pgtype.UUID `json:"waitpoint_id"`
TokenHash []byte `json:"token_hash"`
AllowedActions []string `json:"allowed_actions"`
Status WaitpointResponseTokenStatus `json:"status"`
ExpiresAt pgtype.Timestamptz `json:"expires_at"`
CompletedAt pgtype.Timestamptz `json:"completed_at"`
CompletedByPrincipal pgtype.Text `json:"completed_by_principal"`
CompletedVia pgtype.Text `json:"completed_via"`
ExternalSubject pgtype.Text `json:"external_subject"`
Metadata []byte `json:"metadata"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
}
type WaitpointResponseTokenStatus ¶
type WaitpointResponseTokenStatus string
const ( WaitpointResponseTokenStatusPending WaitpointResponseTokenStatus = "pending" WaitpointResponseTokenStatusCompleted WaitpointResponseTokenStatus = "completed" WaitpointResponseTokenStatusRevoked WaitpointResponseTokenStatus = "revoked" )
func (*WaitpointResponseTokenStatus) Scan ¶
func (e *WaitpointResponseTokenStatus) Scan(src interface{}) error
type WaitpointStatus ¶
type WaitpointStatus string
const ( WaitpointStatusCreating WaitpointStatus = "creating" WaitpointStatusPending WaitpointStatus = "pending" WaitpointStatusResolved WaitpointStatus = "resolved" WaitpointStatusCancelled WaitpointStatus = "cancelled" )
func (*WaitpointStatus) Scan ¶
func (e *WaitpointStatus) Scan(src interface{}) error
type WorkerCredential ¶
type WorkerCredential struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
WorkerHostID string `json:"worker_host_id"`
ExternalID string `json:"external_id"`
KeyPrefix string `json:"key_prefix"`
SecretHash []byte `json:"secret_hash"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
LastUsedAt pgtype.Timestamptz `json:"last_used_at"`
RevokedAt pgtype.Timestamptz `json:"revoked_at"`
}
type WorkerGroup ¶
type WorkerGroup struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
Slug string `json:"slug"`
Name string `json:"name"`
ProvisioningMode WorkerGroupProvisioningMode `json:"provisioning_mode"`
QueueName string `json:"queue_name"`
Region string `json:"region"`
Capabilities []byte `json:"capabilities"`
Metadata []byte `json:"metadata"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
UpdatedAt pgtype.Timestamptz `json:"updated_at"`
ArchivedAt pgtype.Timestamptz `json:"archived_at"`
}
type WorkerGroupProvisioningMode ¶
type WorkerGroupProvisioningMode string
const ( WorkerGroupProvisioningModeHelmrManaged WorkerGroupProvisioningMode = "helmr_managed" WorkerGroupProvisioningModeCustomerManaged WorkerGroupProvisioningMode = "customer_managed" )
func (*WorkerGroupProvisioningMode) Scan ¶
func (e *WorkerGroupProvisioningMode) Scan(src interface{}) error
type WorkerHost ¶
type WorkerHost struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
ExternalID string `json:"external_id"`
Status WorkerHostStatus `json:"status"`
Region string `json:"region"`
TotalMilliCpu int64 `json:"total_milli_cpu"`
TotalMemoryMib int64 `json:"total_memory_mib"`
TotalDiskMib int64 `json:"total_disk_mib"`
TotalExecutionSlots int32 `json:"total_execution_slots"`
AvailableMilliCpu int64 `json:"available_milli_cpu"`
AvailableMemoryMib int64 `json:"available_memory_mib"`
AvailableDiskMib int64 `json:"available_disk_mib"`
AvailableExecutionSlots int32 `json:"available_execution_slots"`
Labels []byte `json:"labels"`
Heartbeat []byte `json:"heartbeat"`
FirstSeenAt pgtype.Timestamptz `json:"first_seen_at"`
LastSeenAt pgtype.Timestamptz `json:"last_seen_at"`
DrainedAt pgtype.Timestamptz `json:"drained_at"`
}
type WorkerHostStatus ¶
type WorkerHostStatus string
const ( WorkerHostStatusActive WorkerHostStatus = "active" WorkerHostStatusDraining WorkerHostStatus = "draining" WorkerHostStatusUnschedulable WorkerHostStatus = "unschedulable" WorkerHostStatusOffline WorkerHostStatus = "offline" )
func (*WorkerHostStatus) Scan ¶
func (e *WorkerHostStatus) Scan(src interface{}) error
type WorkerRegistrationToken ¶
type WorkerRegistrationToken struct {
ID pgtype.UUID `json:"id"`
OrgID pgtype.UUID `json:"org_id"`
ProjectID pgtype.UUID `json:"project_id"`
EnvironmentID pgtype.UUID `json:"environment_id"`
WorkerGroupID pgtype.UUID `json:"worker_group_id"`
TokenHash []byte `json:"token_hash"`
CreatedAt pgtype.Timestamptz `json:"created_at"`
LastUsedAt pgtype.Timestamptz `json:"last_used_at"`
LastUsedByWorkerHostID pgtype.Text `json:"last_used_by_worker_host_id"`
RevokedAt pgtype.Timestamptz `json:"revoked_at"`
}
Source Files
¶
- api_keys.sql.go
- auth_identities.sql.go
- cas_objects.sql.go
- checkpoints.sql.go
- compute_dispatch.sql.go
- db.go
- device_codes.sql.go
- github_installations.sql.go
- github_repositories.sql.go
- invitations.sql.go
- magic_links.sql.go
- models.go
- org_members.sql.go
- organizations.sql.go
- project_workspace_repositories.sql.go
- projects.sql.go
- querier.go
- run_events.sql.go
- run_executions.sql.go
- run_log_chunks.sql.go
- runs.sql.go
- secrets.sql.go
- sessions.sql.go
- task_deployments.sql.go
- waitpoint_deliveries.sql.go
- waitpoint_policies.sql.go
- waitpoint_response_tokens.sql.go
- waitpoints.sql.go
- worker_credentials.sql.go
Click to show internal directories.
Click to hide internal directories.