Documentation ¶
Index ¶
- Variables
- func DeduplicatePipelineVersions(ctx context.Context, env migrations.Env) error
- func Migrate(state migrations.State) migrations.State
- func Migrate_v2_10_BeforeDuplicates(state migrations.State) migrations.State
- func UpdateJobPipelineVersions(ctx context.Context, tx *pachsql.Tx, ...) error
- func UpdatePipelineRows(ctx context.Context, tx *pachsql.Tx, pipUpdates []*PipUpdateRow) error
- func VersionKey(project, pipeline string, version uint64) string
- type PipUpdateRow
Constants ¶
This section is empty.
Variables ¶
View Source
var CopyJobsTable = `
CREATE TABLE collections.pre_2_10_jobs AS TABLE collections.jobs;
`
View Source
var CopyPipelinesTable = `
CREATE TABLE collections.pre_2_10_pipelines AS TABLE collections.pipelines;
`
View Source
var CreateUniqueIndex = `
CREATE UNIQUE INDEX pip_version_idx ON collections.pipelines(idx_version);
`
View Source
var UpdatesBatchSize = 100
Functions ¶
func DeduplicatePipelineVersions ¶
func DeduplicatePipelineVersions(ctx context.Context, env migrations.Env) error
func Migrate ¶
func Migrate(state migrations.State) migrations.State
func Migrate_v2_10_BeforeDuplicates ¶
func Migrate_v2_10_BeforeDuplicates(state migrations.State) migrations.State
func UpdatePipelineRows ¶
func VersionKey ¶
COPIED from src/internal/ppsdb/ppsdb.go
Types ¶
type PipUpdateRow ¶
Click to show internal directories.
Click to hide internal directories.