v2_10_0

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

Variables

var CopyJobsTable = `
  CREATE TABLE collections.pre_2_10_jobs AS TABLE collections.jobs;
`

var CopyPipelinesTable = `
  CREATE TABLE collections.pre_2_10_pipelines AS TABLE collections.pipelines;
`

var CreateUniqueIndex = `
  CREATE UNIQUE INDEX pip_version_idx ON collections.pipelines(idx_version);
`

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 UpdateJobPipelineVersions

func UpdateJobPipelineVersions(ctx context.Context, tx *pachsql.Tx, pipVersionChanges map[string]map[uint64]uint64) error

func UpdatePipelineRows

func UpdatePipelineRows(ctx context.Context, tx *pachsql.Tx, pipUpdates []*PipUpdateRow) error

func VersionKey

func VersionKey(project, pipeline string, version uint64) string

COPIED from src/internal/ppsdb/ppsdb.go

Types

type PipUpdateRow

type PipUpdateRow struct {
	Key        string
	Proto      []byte
	IdxVersion string
}