Documentation
¶
Index ¶
- type ActiveEnv
- type AddTeamMemberParams
- type ApplyProjectLimitsProjectionParams
- type CheckAliasExistsInNamespaceParams
- type Cluster
- type CreateActiveTemplateBuildParams
- type CreateOrUpdateTemplateParams
- type CreateSnapshotTemplateEnvParams
- type CreateTemplateAliasParams
- type CreateTemplateBuildAssignmentParams
- type CreateTemplateBuildParams
- type CreateVolumeParams
- type DBTX
- type DeleteTemplateTagsParams
- type DeleteVolumeParams
- type EnvAlias
- type EnvBuild
- type FailTemplateBuildAndDeactivateParams
- type FinishTemplateBuildParams
- type GetActiveClustersRow
- type GetBuildInfoByTeamAndBuildIDParams
- type GetBuildInfoByTeamAndBuildIDRow
- type GetBuildsStatusesByTeamParams
- type GetBuildsStatusesByTeamRow
- type GetCancellableTemplateBuildsByTeamRow
- type GetConcurrentTemplateBuildsParams
- type GetExclusiveBuildsForTemplateDeletionRow
- type GetInProgressTemplateBuildsByTeamParams
- type GetInProgressTemplateBuildsRow
- type GetLastSnapshotRow
- type GetSandboxRecordByTeamAndSandboxIDParams
- type GetSandboxRecordByTeamAndSandboxIDRow
- type GetSnapshotBuildsParams
- type GetSnapshotBuildsRow
- type GetSnapshotsByTemplateWithCursorAscParams
- type GetSnapshotsByTemplateWithCursorAscRow
- type GetSnapshotsByTemplateWithCursorParams
- type GetSnapshotsByTemplateWithCursorRow
- type GetSnapshotsWithCursorAscParams
- type GetSnapshotsWithCursorAscRow
- type GetSnapshotsWithCursorParams
- type GetSnapshotsWithCursorRow
- type GetTeamBuildsPageByBuildIDParams
- type GetTeamBuildsPageByBuildIDRow
- type GetTeamBuildsPageByTemplateAliasParams
- type GetTeamBuildsPageByTemplateAliasRow
- type GetTeamBuildsPageByTemplateIDParams
- type GetTeamBuildsPageByTemplateIDRow
- type GetTeamBuildsPageParams
- type GetTeamBuildsPageRow
- type GetTeamMemberRelationParams
- type GetTeamMembersRow
- type GetTeamTemplateParams
- type GetTeamTemplateRow
- type GetTeamTemplatesRow
- type GetTeamTemplatesWithCursorParams
- type GetTeamTemplatesWithCursorRow
- type GetTemplateAliasByAliasRow
- type GetTemplateAliasesRow
- type GetTemplateBuildWithTemplateParams
- type GetTemplateBuildWithTemplateRow
- type GetTemplateBuildsParams
- type GetTemplateByAliasParams
- type GetTemplateByAliasRow
- type GetTemplateByIDWithAliasesRow
- type GetTemplateByIdRow
- type GetTemplateForAliasRebuildParams
- type GetTemplateForAliasRebuildRow
- type GetTemplateWithBuildByTagParams
- type GetTemplateWithBuildByTagRow
- type GetVolumeParams
- type GetVolumesByNameParams
- type InvalidateUnstartedTemplateBuildsParams
- type ListTeamSnapshotTemplatesParams
- type ListTeamSnapshotTemplatesRow
- type ListTemplateTagsRow
- type Queries
- func (q *Queries) AddTeamMember(ctx context.Context, arg AddTeamMemberParams) error
- func (q *Queries) ApplyProjectLimitsProjection(ctx context.Context, arg ApplyProjectLimitsProjectionParams) (bool, error)
- func (q *Queries) CheckAliasConflictsWithTemplateID(ctx context.Context, alias string) (bool, error)
- func (q *Queries) CheckAliasExistsInNamespace(ctx context.Context, arg CheckAliasExistsInNamespaceParams) (EnvAlias, error)
- func (q *Queries) CreateActiveTemplateBuild(ctx context.Context, arg CreateActiveTemplateBuildParams) error
- func (q *Queries) CreateOrUpdateTemplate(ctx context.Context, arg CreateOrUpdateTemplateParams) (string, error)
- func (q *Queries) CreateSnapshotTemplateEnv(ctx context.Context, arg CreateSnapshotTemplateEnvParams) (string, error)
- func (q *Queries) CreateTemplateAlias(ctx context.Context, arg CreateTemplateAliasParams) error
- func (q *Queries) CreateTemplateBuild(ctx context.Context, arg CreateTemplateBuildParams) error
- func (q *Queries) CreateTemplateBuildAssignment(ctx context.Context, arg CreateTemplateBuildAssignmentParams) (int64, error)
- func (q *Queries) CreateVolume(ctx context.Context, arg CreateVolumeParams) (Volume, error)
- func (q *Queries) DeleteActiveTemplateBuild(ctx context.Context, buildID uuid.UUID) error
- func (q *Queries) DeleteActiveTemplateBuilds(ctx context.Context, templateID string) error
- func (q *Queries) DeleteOtherTemplateAliases(ctx context.Context, envID string) ([]string, error)
- func (q *Queries) DeleteTemplateTags(ctx context.Context, arg DeleteTemplateTagsParams) error
- func (q *Queries) DeleteVolume(ctx context.Context, arg DeleteVolumeParams) error
- func (q *Queries) ExistsTemplateSnapshots(ctx context.Context, envID string) (bool, error)
- func (q *Queries) FailTemplateBuildAndDeactivate(ctx context.Context, arg FailTemplateBuildAndDeactivateParams) (bool, error)
- func (q *Queries) FindVolumesByTeamID(ctx context.Context, teamID uuid.UUID) ([]Volume, error)
- func (q *Queries) FinishTemplateBuild(ctx context.Context, arg FinishTemplateBuildParams) error
- func (q *Queries) GetActiveClusters(ctx context.Context) ([]GetActiveClustersRow, error)
- func (q *Queries) GetBuildInfoByTeamAndBuildID(ctx context.Context, arg GetBuildInfoByTeamAndBuildIDParams) (GetBuildInfoByTeamAndBuildIDRow, error)
- func (q *Queries) GetBuildsStatusesByTeam(ctx context.Context, arg GetBuildsStatusesByTeamParams) ([]GetBuildsStatusesByTeamRow, error)
- func (q *Queries) GetCancellableTemplateBuildsByTeam(ctx context.Context, teamID uuid.UUID) ([]GetCancellableTemplateBuildsByTeamRow, error)
- func (q *Queries) GetConcurrentTemplateBuilds(ctx context.Context, arg GetConcurrentTemplateBuildsParams) ([]EnvBuild, error)
- func (q *Queries) GetExclusiveBuildsForTemplateDeletion(ctx context.Context, templateID string) ([]GetExclusiveBuildsForTemplateDeletionRow, error)
- func (q *Queries) GetInProgressTemplateBuilds(ctx context.Context) ([]GetInProgressTemplateBuildsRow, error)
- func (q *Queries) GetInProgressTemplateBuildsByTeam(ctx context.Context, arg GetInProgressTemplateBuildsByTeamParams) (int64, error)
- func (q *Queries) GetLastSnapshot(ctx context.Context, sandboxID string) (GetLastSnapshotRow, error)
- func (q *Queries) GetPublicUserID(ctx context.Context, id uuid.UUID) (uuid.UUID, error)
- func (q *Queries) GetSandboxRecordByTeamAndSandboxID(ctx context.Context, arg GetSandboxRecordByTeamAndSandboxIDParams) (GetSandboxRecordByTeamAndSandboxIDRow, error)
- func (q *Queries) GetSnapshotBuilds(ctx context.Context, arg GetSnapshotBuildsParams) ([]GetSnapshotBuildsRow, error)
- func (q *Queries) GetSnapshotsByTemplateWithCursor(ctx context.Context, arg GetSnapshotsByTemplateWithCursorParams) ([]GetSnapshotsByTemplateWithCursorRow, error)
- func (q *Queries) GetSnapshotsByTemplateWithCursorAsc(ctx context.Context, arg GetSnapshotsByTemplateWithCursorAscParams) ([]GetSnapshotsByTemplateWithCursorAscRow, error)
- func (q *Queries) GetSnapshotsWithCursor(ctx context.Context, arg GetSnapshotsWithCursorParams) ([]GetSnapshotsWithCursorRow, error)
- func (q *Queries) GetSnapshotsWithCursorAsc(ctx context.Context, arg GetSnapshotsWithCursorAscParams) ([]GetSnapshotsWithCursorAscRow, error)
- func (q *Queries) GetTeamBuildsPage(ctx context.Context, arg GetTeamBuildsPageParams) ([]GetTeamBuildsPageRow, error)
- func (q *Queries) GetTeamBuildsPageByBuildID(ctx context.Context, arg GetTeamBuildsPageByBuildIDParams) ([]GetTeamBuildsPageByBuildIDRow, error)
- func (q *Queries) GetTeamBuildsPageByTemplateAlias(ctx context.Context, arg GetTeamBuildsPageByTemplateAliasParams) ([]GetTeamBuildsPageByTemplateAliasRow, error)
- func (q *Queries) GetTeamBuildsPageByTemplateID(ctx context.Context, arg GetTeamBuildsPageByTemplateIDParams) ([]GetTeamBuildsPageByTemplateIDRow, error)
- func (q *Queries) GetTeamClusterForTemplateBuild(ctx context.Context, teamID uuid.UUID) (*uuid.UUID, error)
- func (q *Queries) GetTeamMemberRelation(ctx context.Context, arg GetTeamMemberRelationParams) (UsersTeam, error)
- func (q *Queries) GetTeamMembers(ctx context.Context, teamID uuid.UUID) ([]GetTeamMembersRow, error)
- func (q *Queries) GetTeamTemplate(ctx context.Context, arg GetTeamTemplateParams) (GetTeamTemplateRow, error)
- func (q *Queries) GetTeamTemplates(ctx context.Context, teamID uuid.UUID) ([]GetTeamTemplatesRow, error)
- func (q *Queries) GetTeamTemplatesWithCursor(ctx context.Context, arg GetTeamTemplatesWithCursorParams) ([]GetTeamTemplatesWithCursorRow, error)
- func (q *Queries) GetTemplateAliasByAlias(ctx context.Context, alias string) (GetTemplateAliasByAliasRow, error)
- func (q *Queries) GetTemplateAliases(ctx context.Context, envIds []string) ([]GetTemplateAliasesRow, error)
- func (q *Queries) GetTemplateBuildWithTemplate(ctx context.Context, arg GetTemplateBuildWithTemplateParams) (GetTemplateBuildWithTemplateRow, error)
- func (q *Queries) GetTemplateBuilds(ctx context.Context, arg GetTemplateBuildsParams) ([]EnvBuild, error)
- func (q *Queries) GetTemplateByAlias(ctx context.Context, arg GetTemplateByAliasParams) (GetTemplateByAliasRow, error)
- func (q *Queries) GetTemplateByIDWithAliases(ctx context.Context, id string) (GetTemplateByIDWithAliasesRow, error)
- func (q *Queries) GetTemplateById(ctx context.Context, templateID string) (GetTemplateByIdRow, error)
- func (q *Queries) GetTemplateForAliasRebuild(ctx context.Context, arg GetTemplateForAliasRebuildParams) (GetTemplateForAliasRebuildRow, error)
- func (q *Queries) GetTemplateWithBuildByTag(ctx context.Context, arg GetTemplateWithBuildByTagParams) (GetTemplateWithBuildByTagRow, error)
- func (q *Queries) GetVolume(ctx context.Context, arg GetVolumeParams) (Volume, error)
- func (q *Queries) GetVolumesByName(ctx context.Context, arg GetVolumesByNameParams) ([]Volume, error)
- func (q *Queries) InvalidateUnstartedTemplateBuilds(ctx context.Context, arg InvalidateUnstartedTemplateBuildsParams) error
- func (q *Queries) ListTeamSnapshotTemplates(ctx context.Context, arg ListTeamSnapshotTemplatesParams) ([]ListTeamSnapshotTemplatesRow, error)
- func (q *Queries) ListTemplateTags(ctx context.Context, templateID string) ([]ListTemplateTagsRow, error)
- func (q *Queries) LockManagedProject(ctx context.Context, id uuid.UUID) (uuid.UUID, error)
- func (q *Queries) LockTeamMembersForUpdate(ctx context.Context, teamID uuid.UUID) ([]uuid.UUID, error)
- func (q *Queries) ReleaseTemplateAliases(ctx context.Context, templateID string) ([]string, error)
- func (q *Queries) RemoveTeamMember(ctx context.Context, arg RemoveTeamMemberParams) error
- func (q *Queries) ReplaceTemplateAlias(ctx context.Context, arg ReplaceTemplateAliasParams) (int64, error)
- func (q *Queries) ResolveTeamBySlugAndUser(ctx context.Context, arg ResolveTeamBySlugAndUserParams) (ResolveTeamBySlugAndUserRow, error)
- func (q *Queries) SoftDeleteTemplate(ctx context.Context, arg SoftDeleteTemplateParams) (string, error)
- func (q *Queries) UpdateEnvBuildStatus(ctx context.Context, arg UpdateEnvBuildStatusParams) error
- func (q *Queries) UpdateSnapshotOriginNode(ctx context.Context, arg UpdateSnapshotOriginNodeParams) error
- func (q *Queries) UpdateTemplate(ctx context.Context, arg UpdateTemplateParams) (string, error)
- func (q *Queries) UpdateTemplateBuild(ctx context.Context, arg UpdateTemplateBuildParams) error
- func (q *Queries) UpdateTemplateSpawnCount(ctx context.Context, arg UpdateTemplateSpawnCountParams) error
- func (q *Queries) UpsertProjectLimits(ctx context.Context, arg UpsertProjectLimitsParams) error
- func (q *Queries) UpsertSnapshot(ctx context.Context, arg UpsertSnapshotParams) (UpsertSnapshotRow, error)
- func (q *Queries) UpsertTemplateAliasIfNotExists(ctx context.Context, arg UpsertTemplateAliasIfNotExistsParams) (string, error)
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
- type RemoveTeamMemberParams
- type ReplaceTemplateAliasParams
- type ResolveTeamBySlugAndUserParams
- type ResolveTeamBySlugAndUserRow
- type Snapshot
- type SoftDeleteTemplateParams
- type UpdateEnvBuildStatusParams
- type UpdateSnapshotOriginNodeParams
- type UpdateTemplateBuildParams
- type UpdateTemplateParams
- type UpdateTemplateSpawnCountParams
- type UpsertProjectLimitsParams
- type UpsertSnapshotParams
- type UpsertSnapshotRow
- type UpsertTemplateAliasIfNotExistsParams
- type UsersTeam
- type Volume
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AddTeamMemberParams ¶
type CreateVolumeParams ¶
type EnvBuild ¶
type EnvBuild struct {
ID uuid.UUID
CreatedAt time.Time
UpdatedAt time.Time
FinishedAt *time.Time
Status types.BuildStatus
Dockerfile *string
StartCmd *string
Vcpu int64
RamMb int64
FreeDiskSizeMb int64
TotalDiskSizeMb *int64
KernelVersion string
FirecrackerVersion string
EnvID *string
EnvdVersion *string
ReadyCmd *string
ClusterNodeID *string
Reason types.BuildReason
Version *string
CpuArchitecture *string
CpuFamily *string
CpuModel *string
CpuModelName *string
CpuFlags []string
StatusGroup types.BuildStatusGroup
TeamID *uuid.UUID
}
type FailTemplateBuildAndDeactivateParams ¶
type FailTemplateBuildAndDeactivateParams struct {
Status types.BuildStatus
FinishedAt *time.Time
Reason types.BuildReason
Version *string
BuildID uuid.UUID
}
type GetActiveClustersRow ¶
type GetActiveClustersRow struct {
Cluster Cluster
}
type GetBuildInfoByTeamAndBuildIDRow ¶
type GetBuildInfoByTeamAndBuildIDRow struct {
CreatedAt time.Time
FinishedAt *time.Time
Status types.BuildStatus
Reason types.BuildReason
Names []string
}
type GetBuildsStatusesByTeamRow ¶
type GetBuildsStatusesByTeamRow struct {
ID uuid.UUID
StatusGroup types.BuildStatusGroup
Reason types.BuildReason
FinishedAt *time.Time
}
type GetLastSnapshotRow ¶
type GetSnapshotBuildsParams ¶
type GetSnapshotBuildsRow ¶
type GetSnapshotsWithCursorAscParams ¶
type GetSnapshotsWithCursorAscParams struct {
Limit int32
TeamID uuid.UUID
Metadata types.JSONBStringMap
StartedAfter time.Time
CursorTime pgtype.Timestamptz
CursorID string
}
type GetSnapshotsWithCursorParams ¶
type GetSnapshotsWithCursorParams struct {
Limit int32
TeamID uuid.UUID
Metadata types.JSONBStringMap
StartedAfter time.Time
CursorID string
CursorTime pgtype.Timestamptz
}
type GetTeamBuildsPageParams ¶
type GetTeamBuildsPageRow ¶
type GetTeamMembersRow ¶
type GetTeamTemplateParams ¶
type GetTeamTemplateRow ¶
type GetTeamTemplatesRow ¶
type GetTeamTemplatesWithCursorRow ¶
type GetTeamTemplatesWithCursorRow struct {
TemplateID string
CreatedAt time.Time
UpdatedAt time.Time
Public bool
BuildCount int32
SpawnCount int64
LastSpawnedAt *time.Time
CreatorID *uuid.UUID
BuildID uuid.UUID
BuildVcpu int64
BuildRamMb int64
BuildTotalDiskSizeMb *int64
BuildEnvdVersion *string
BuildStatus types.BuildStatusGroup
Aliases []string
Names []string
}
type GetTemplateAliasesRow ¶
type GetTemplateBuildsParams ¶
type GetTemplateByAliasRow ¶
type GetTemplateByIdRow ¶
type GetVolumesByNameParams ¶
type InvalidateUnstartedTemplateBuildsParams ¶
type InvalidateUnstartedTemplateBuildsParams struct {
Reason types.BuildReason
TemplateID string
Tags []string
}
type ListTemplateTagsRow ¶
type ListTemplateTagsRow struct {
Tag string
BuildID uuid.UUID
CreatedAt pgtype.Timestamptz
}
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) AddTeamMember ¶
func (q *Queries) AddTeamMember(ctx context.Context, arg AddTeamMemberParams) error
func (*Queries) ApplyProjectLimitsProjection ¶
func (q *Queries) ApplyProjectLimitsProjection(ctx context.Context, arg ApplyProjectLimitsProjectionParams) (bool, error)
Advances the ledger that decides whether a delivery gets to write, and answers whether it did.
The guard is what makes a delayed retry safe: a delivery carrying a revision at or below the one recorded arrived after a newer one, so it is dropped and the values it carried are never written. The caller cannot enforce this on its own -- it fences what it sends, and two deliveries in flight arrive in whichever order the network gives them.
The conflict action takes a row lock held to commit, so a second delivery for the same project waits here and is compared against the winner's revision rather than against what it read.
func (*Queries) CheckAliasConflictsWithTemplateID ¶
func (*Queries) CheckAliasExistsInNamespace ¶
func (q *Queries) CheckAliasExistsInNamespace(ctx context.Context, arg CheckAliasExistsInNamespaceParams) (EnvAlias, error)
Check if alias exists within a specific namespace. Used for namespace-aware lookups. Returns the alias if found.
func (*Queries) CreateActiveTemplateBuild ¶
func (q *Queries) CreateActiveTemplateBuild(ctx context.Context, arg CreateActiveTemplateBuildParams) error
func (*Queries) CreateOrUpdateTemplate ¶
func (q *Queries) CreateOrUpdateTemplate(ctx context.Context, arg CreateOrUpdateTemplateParams) (string, error)
Soft-delete is permanent: skip the update for a deleted env so no row is returned and the build registration fails instead of resurrecting it.
func (*Queries) CreateSnapshotTemplateEnv ¶
func (q *Queries) CreateSnapshotTemplateEnv(ctx context.Context, arg CreateSnapshotTemplateEnvParams) (string, error)
Creates a snapshot_template env entry with source='snapshot_template' and links it to an existing build This is used after UpsertSnapshot to create a persistent snapshot template
func (*Queries) CreateTemplateAlias ¶
func (q *Queries) CreateTemplateAlias(ctx context.Context, arg CreateTemplateAliasParams) error
func (*Queries) CreateTemplateBuild ¶
func (q *Queries) CreateTemplateBuild(ctx context.Context, arg CreateTemplateBuildParams) error
kernel_version and firecracker_version are populated here for backwards compatibility with consumers that read the env_builds row before the build completes. The template-manager reports the versions it actually used via TemplateBuildMetadata, and FinishTemplateBuild overwrites these fields with the reported values.
func (*Queries) CreateTemplateBuildAssignment ¶
func (q *Queries) CreateTemplateBuildAssignment(ctx context.Context, arg CreateTemplateBuildAssignmentParams) (int64, error)
FOR SHARE serializes against a concurrent DeleteTemplate so a build can't be attached to a soft-deleted env. 0 rows affected means the template is gone.
func (*Queries) CreateVolume ¶
func (*Queries) DeleteActiveTemplateBuild ¶
func (*Queries) DeleteActiveTemplateBuilds ¶
Clears in-flight build tracking (active_template_builds no longer cascades since the env row is kept) so a deleted template stops counting toward the team build concurrency limit.
func (*Queries) DeleteOtherTemplateAliases ¶
func (*Queries) DeleteTemplateTags ¶
func (q *Queries) DeleteTemplateTags(ctx context.Context, arg DeleteTemplateTagsParams) error
Deletes tag assignments from a template (env)
func (*Queries) DeleteVolume ¶
func (q *Queries) DeleteVolume(ctx context.Context, arg DeleteVolumeParams) error
func (*Queries) ExistsTemplateSnapshots ¶
func (*Queries) FailTemplateBuildAndDeactivate ¶
func (q *Queries) FailTemplateBuildAndDeactivate(ctx context.Context, arg FailTemplateBuildAndDeactivateParams) (bool, error)
Several pollers watch the same build, and it keeps the first terminal outcome recorded. A write that loses must not release the team's concurrency slot either, so the deactivation reads from the update instead of running on its own.
func (*Queries) FindVolumesByTeamID ¶
func (*Queries) FinishTemplateBuild ¶
func (q *Queries) FinishTemplateBuild(ctx context.Context, arg FinishTemplateBuildParams) error
kernel_version and firecracker_version are overwritten with whatever the template-manager reports back in TemplateBuildMetadata. Old template-managers that do not populate those fields end up passing an empty string; the NULLIF + COALESCE trick leaves the row's existing values untouched in that case so we do not clobber the values the API seeded at build registration. The build keeps the first terminal outcome recorded: a build failed for running out of time has had its artifacts deleted, so a later success must not publish it.
func (*Queries) GetActiveClusters ¶
func (q *Queries) GetActiveClusters(ctx context.Context) ([]GetActiveClustersRow, error)
func (*Queries) GetBuildInfoByTeamAndBuildID ¶
func (q *Queries) GetBuildInfoByTeamAndBuildID(ctx context.Context, arg GetBuildInfoByTeamAndBuildIDParams) (GetBuildInfoByTeamAndBuildIDRow, error)
func (*Queries) GetBuildsStatusesByTeam ¶
func (q *Queries) GetBuildsStatusesByTeam(ctx context.Context, arg GetBuildsStatusesByTeamParams) ([]GetBuildsStatusesByTeamRow, error)
func (*Queries) GetCancellableTemplateBuildsByTeam ¶
func (q *Queries) GetCancellableTemplateBuildsByTeam(ctx context.Context, teamID uuid.UUID) ([]GetCancellableTemplateBuildsByTeamRow, error)
Relies on active_template_builds table (migration 20260305130000).
func (*Queries) GetConcurrentTemplateBuilds ¶
func (*Queries) GetExclusiveBuildsForTemplateDeletion ¶
func (q *Queries) GetExclusiveBuildsForTemplateDeletion(ctx context.Context, templateID string) ([]GetExclusiveBuildsForTemplateDeletionRow, error)
Returns builds that are ONLY assigned to this template (safe to delete). Builds shared with other templates are excluded. DISTINCT needed because builds may have multiple tag assignments to the same template.
func (*Queries) GetInProgressTemplateBuilds ¶
func (q *Queries) GetInProgressTemplateBuilds(ctx context.Context) ([]GetInProgressTemplateBuildsRow, error)
func (*Queries) GetInProgressTemplateBuildsByTeam ¶
func (q *Queries) GetInProgressTemplateBuildsByTeam(ctx context.Context, arg GetInProgressTemplateBuildsByTeamParams) (int64, error)
Relies on active_template_builds table (migration 20260305130000).
func (*Queries) GetLastSnapshot ¶
func (*Queries) GetPublicUserID ¶
func (*Queries) GetSandboxRecordByTeamAndSandboxID ¶
func (q *Queries) GetSandboxRecordByTeamAndSandboxID(ctx context.Context, arg GetSandboxRecordByTeamAndSandboxIDParams) (GetSandboxRecordByTeamAndSandboxIDRow, error)
func (*Queries) GetSnapshotBuilds ¶
func (q *Queries) GetSnapshotBuilds(ctx context.Context, arg GetSnapshotBuildsParams) ([]GetSnapshotBuildsRow, error)
func (*Queries) GetSnapshotsByTemplateWithCursor ¶
func (q *Queries) GetSnapshotsByTemplateWithCursor(ctx context.Context, arg GetSnapshotsByTemplateWithCursorParams) ([]GetSnapshotsByTemplateWithCursorRow, error)
func (*Queries) GetSnapshotsByTemplateWithCursorAsc ¶
func (q *Queries) GetSnapshotsByTemplateWithCursorAsc(ctx context.Context, arg GetSnapshotsByTemplateWithCursorAscParams) ([]GetSnapshotsByTemplateWithCursorAscRow, error)
func (*Queries) GetSnapshotsWithCursor ¶
func (q *Queries) GetSnapshotsWithCursor(ctx context.Context, arg GetSnapshotsWithCursorParams) ([]GetSnapshotsWithCursorRow, error)
func (*Queries) GetSnapshotsWithCursorAsc ¶
func (q *Queries) GetSnapshotsWithCursorAsc(ctx context.Context, arg GetSnapshotsWithCursorAscParams) ([]GetSnapshotsWithCursorAscRow, error)
Ascending counterpart of GetSnapshotsWithCursor. It is the exact reverse order (started_at ASC, sandbox_id DESC) which maps onto a backward scan of the idx_snapshots_team_time_id (team_id, sandbox_started_at DESC, sandbox_id) index.
func (*Queries) GetTeamBuildsPage ¶
func (q *Queries) GetTeamBuildsPage(ctx context.Context, arg GetTeamBuildsPageParams) ([]GetTeamBuildsPageRow, error)
func (*Queries) GetTeamBuildsPageByBuildID ¶
func (q *Queries) GetTeamBuildsPageByBuildID(ctx context.Context, arg GetTeamBuildsPageByBuildIDParams) ([]GetTeamBuildsPageByBuildIDRow, error)
func (*Queries) GetTeamBuildsPageByTemplateAlias ¶
func (q *Queries) GetTeamBuildsPageByTemplateAlias(ctx context.Context, arg GetTeamBuildsPageByTemplateAliasParams) ([]GetTeamBuildsPageByTemplateAliasRow, error)
func (*Queries) GetTeamBuildsPageByTemplateID ¶
func (q *Queries) GetTeamBuildsPageByTemplateID(ctx context.Context, arg GetTeamBuildsPageByTemplateIDParams) ([]GetTeamBuildsPageByTemplateIDRow, error)
func (*Queries) GetTeamClusterForTemplateBuild ¶
func (*Queries) GetTeamMemberRelation ¶
func (*Queries) GetTeamMembers ¶
func (*Queries) GetTeamTemplate ¶
func (q *Queries) GetTeamTemplate(ctx context.Context, arg GetTeamTemplateParams) (GetTeamTemplateRow, error)
func (*Queries) GetTeamTemplates ¶
func (*Queries) GetTeamTemplatesWithCursor ¶
func (q *Queries) GetTeamTemplatesWithCursor(ctx context.Context, arg GetTeamTemplatesWithCursorParams) ([]GetTeamTemplatesWithCursorRow, error)
Cursor-paginated team template listing for the CLI (GET /v2/templates).
Same projection as GetTeamTemplates (two build laterals: latest default-tag build for build_status, latest ready default-tag build for the displayed resources), with keyset pagination added: ordered created_at DESC (newest first) and bounded by the (created_at, id) cursor and LIMIT.
func (*Queries) GetTemplateAliasByAlias ¶
func (*Queries) GetTemplateAliases ¶
func (*Queries) GetTemplateBuildWithTemplate ¶
func (q *Queries) GetTemplateBuildWithTemplate(ctx context.Context, arg GetTemplateBuildWithTemplateParams) (GetTemplateBuildWithTemplateRow, error)
func (*Queries) GetTemplateBuilds ¶
func (*Queries) GetTemplateByAlias ¶
func (q *Queries) GetTemplateByAlias(ctx context.Context, arg GetTemplateByAliasParams) (GetTemplateByAliasRow, error)
Resolves a template by alias and namespace @alias: the alias to look up @namespace: the namespace to scope the lookup (NULL for promoted templates)
func (*Queries) GetTemplateByIDWithAliases ¶
func (*Queries) GetTemplateById ¶
func (q *Queries) GetTemplateById(ctx context.Context, templateID string) (GetTemplateByIdRow, error)
Looks up a template by its ID directly @template_id: the template ID to look up
func (*Queries) GetTemplateForAliasRebuild ¶
func (q *Queries) GetTemplateForAliasRebuild(ctx context.Context, arg GetTemplateForAliasRebuildParams) (GetTemplateForAliasRebuildRow, error)
func (*Queries) GetTemplateWithBuildByTag ¶
func (q *Queries) GetTemplateWithBuildByTag(ctx context.Context, arg GetTemplateWithBuildByTagParams) (GetTemplateWithBuildByTagRow, error)
Fetches a template with its build by template ID and tag. @template_id: the template ID to look up @tag: defaults to 'default' if not provided
func (*Queries) GetVolumesByName ¶
func (*Queries) InvalidateUnstartedTemplateBuilds ¶
func (q *Queries) InvalidateUnstartedTemplateBuilds(ctx context.Context, arg InvalidateUnstartedTemplateBuildsParams) error
func (*Queries) ListTeamSnapshotTemplates ¶
func (q *Queries) ListTeamSnapshotTemplates(ctx context.Context, arg ListTeamSnapshotTemplatesParams) ([]ListTeamSnapshotTemplatesRow, error)
Lists all persistent snapshot templates for a team with cursor-based pagination. Snapshot templates are envs with source='snapshot_template'.
func (*Queries) ListTemplateTags ¶
func (q *Queries) ListTemplateTags(ctx context.Context, templateID string) ([]ListTemplateTagsRow, error)
Lists the latest tag assignment per tag for a given template. Multiple assignments can exist per tag; only the most recent is returned. @template_id: the template ID to look up
func (*Queries) LockManagedProject ¶
Taken first, so the branch is decided by whether the project exists rather than by an insert failing.
func (*Queries) LockTeamMembersForUpdate ¶
func (*Queries) ReleaseTemplateAliases ¶
Releases the env's aliases (so the name is reusable) and returns their cache keys.
func (*Queries) RemoveTeamMember ¶
func (q *Queries) RemoveTeamMember(ctx context.Context, arg RemoveTeamMemberParams) error
func (*Queries) ReplaceTemplateAlias ¶
func (*Queries) ResolveTeamBySlugAndUser ¶
func (q *Queries) ResolveTeamBySlugAndUser(ctx context.Context, arg ResolveTeamBySlugAndUserParams) (ResolveTeamBySlugAndUserRow, error)
func (*Queries) SoftDeleteTemplate ¶
func (q *Queries) SoftDeleteTemplate(ctx context.Context, arg SoftDeleteTemplateParams) (string, error)
Step 1 of soft delete (run in a tx). The UPDATE locks the env row, so a concurrent build registration holding that lock commits first; this then soft-deletes. Returns the id (no row if already deleted or not owned). The alias/active-build cleanup runs as separate statements afterwards so their fresh snapshots see rows that racing registration committed during the wait.
func (*Queries) UpdateEnvBuildStatus ¶
func (q *Queries) UpdateEnvBuildStatus(ctx context.Context, arg UpdateEnvBuildStatusParams) error
func (*Queries) UpdateSnapshotOriginNode ¶
func (q *Queries) UpdateSnapshotOriginNode(ctx context.Context, arg UpdateSnapshotOriginNodeParams) error
Repoints a snapshot's origin node, used on resume to pin a retry to the node whose local cache is warming after a previous resume attempt timed out.
func (*Queries) UpdateTemplate ¶
func (*Queries) UpdateTemplateBuild ¶
func (q *Queries) UpdateTemplateBuild(ctx context.Context, arg UpdateTemplateBuildParams) error
func (*Queries) UpdateTemplateSpawnCount ¶
func (q *Queries) UpdateTemplateSpawnCount(ctx context.Context, arg UpdateTemplateSpawnCountParams) error
func (*Queries) UpsertProjectLimits ¶
func (q *Queries) UpsertProjectLimits(ctx context.Context, arg UpsertProjectLimitsParams) error
UpsertProjectLimits records a project's effective limits, which the team_limits view reads in preference to the tier-plus-addons arithmetic.
Every column is supplied on every call: the caller sends a complete set, so there is no partial update to merge and no prior row to read first.
max_disk_size_mb and max_free_disk_size_mb are the same ceiling under the old and the new name, and the table holds them equal. Both are written here so a receiver of this version keeps the compatibility bridge in application code.
Which deliveries reach this statement is the ledger's decision, and the two writes share a transaction. Nothing here compares revisions.
func (*Queries) UpsertSnapshot ¶
func (q *Queries) UpsertSnapshot(ctx context.Context, arg UpsertSnapshotParams) (UpsertSnapshotRow, error)
Create a new snapshot or update an existing one Create a new build for the snapshot, copying CPU info from the source build so a pause keeps the snapshot's CPU compatibility pinned to the original build instead of the node the pause happened to run on. Scalar subqueries are used so the row is always inserted (CPU info is NULL if the source build is missing). Create the build assignment edge (explicit, not relying on trigger)
func (*Queries) UpsertTemplateAliasIfNotExists ¶
func (q *Queries) UpsertTemplateAliasIfNotExists(ctx context.Context, arg UpsertTemplateAliasIfNotExistsParams) (string, error)
Attempts to create an alias. Returns the env_id that the alias points to. If the alias already exists, returns the existing env_id without modifying it. Uses ON CONFLICT DO NOTHING to avoid race conditions.
type RemoveTeamMemberParams ¶
type Snapshot ¶
type Snapshot struct {
CreatedAt pgtype.Timestamptz
EnvID string
SandboxID string
ID uuid.UUID
Metadata types.JSONBStringMap
BaseEnvID string
SandboxStartedAt pgtype.Timestamptz
EnvSecure bool
OriginNodeID string
AllowInternetAccess *bool
AutoPause bool
TeamID uuid.UUID
Config *types.PausedSandboxConfig
}
type UpdateEnvBuildStatusParams ¶
type UpdateEnvBuildStatusParams struct {
Status types.BuildStatus
FinishedAt *time.Time
Reason types.BuildReason
Version *string
BuildID uuid.UUID
}
type UpdateTemplateParams ¶
type UpsertSnapshotParams ¶
type UpsertSnapshotParams struct {
TemplateID string
TeamID uuid.UUID
ClusterID *uuid.UUID
SandboxID string
BaseTemplateID string
Metadata types.JSONBStringMap
StartedAt pgtype.Timestamptz
Secure bool
AllowInternetAccess *bool
OriginNodeID string
AutoPause bool
Config *types.PausedSandboxConfig
Vcpu int64
RamMb int64
FreeDiskSizeMb int64
KernelVersion string
FirecrackerVersion string
EnvdVersion *string
Status types.BuildStatus
TotalDiskSizeMb *int64
SourceBuildID uuid.UUID
}
type UpsertSnapshotRow ¶
Source Files
¶
- active_template_builds.sql.go
- check_alias_exists.sql.go
- create_alias.sql.go
- create_new_snapshot.sql.go
- create_snapshot_template_env.sql.go
- create_template.sql.go
- create_template_build_assignment.sql.go
- db.go
- delete_old_aliases.sql.go
- delete_template.sql.go
- delete_template_build_assignment.sql.go
- exists_template_snapshots.sql.go
- finish_template_build.sql.go
- get_active_clusters.sql.go
- get_build_info.sql.go
- get_builds_paginated.sql.go
- get_builds_statuses.sql.go
- get_concurrent_template_builds.sql.go
- get_exclusive_builds_for_template_deletion.sql.go
- get_inprogress_builds.sql.go
- get_last_snapshot.sql.go
- get_sandbox_record.sql.go
- get_snapshot_builds.sql.go
- get_snapshots_with_cursor.sql.go
- get_team_template.sql.go
- get_team_templates.sql.go
- get_team_templates_with_cursor.sql.go
- get_template.sql.go
- get_template_aliases.sql.go
- get_template_build.sql.go
- get_template_by_id.sql.go
- get_template_with_build_by_tag.sql.go
- get_template_with_builds.sql.go
- get_templatealias_by_alias.sql.go
- list_team_snapshot_templates.sql.go
- list_template_tags.sql.go
- models.go
- project_limits.sql.go
- replace_template_alias.sql.go
- resolve_team.sql.go
- team_members.sql.go
- update_snapshot_origin_node.sql.go
- update_template.sql.go
- update_template_build_status.sql.go
- update_template_spawns.sql.go
- upsert_alias.sql.go
- volumes.sql.go