onlineddl

Documentation

Index

• func CheckCancelAllMigrations(t *testing.T, vtParams *mysql.ConnParams, expectCount int)
• func CheckCancelMigration(t *testing.T, vtParams *mysql.ConnParams, shards []cluster.Shard, uuid string, ...)
• func CheckMigrationArtifacts(t *testing.T, vtParams *mysql.ConnParams, shards []cluster.Shard, uuid string, ...)
• func CheckMigrationStatus(t *testing.T, vtParams *mysql.ConnParams, shards []cluster.Shard, uuid string, ...)
• func CheckRetryMigration(t *testing.T, vtParams *mysql.ConnParams, shards []cluster.Shard, uuid string, ...)
• func PrintQueryResult(writer io.Writer, qr *sqltypes.Result)
• func VtgateExecDDL(t *testing.T, vtParams *mysql.ConnParams, ddlStrategy string, query string, ...) *sqltypes.Result
• func VtgateExecQuery(t *testing.T, vtParams *mysql.ConnParams, query string, expectError string) *sqltypes.Result

Functions

func CheckCancelAllMigrations

func CheckCancelAllMigrations(t *testing.T, vtParams *mysql.ConnParams, expectCount int)

CheckCancelAllMigrations cancels all pending migrations and expect number of affected rows

func CheckCancelMigration

func CheckCancelMigration(t *testing.T, vtParams *mysql.ConnParams, shards []cluster.Shard, uuid string, expectCancelPossible bool)

CheckCancelMigration attempts to cancel a migration, and expects success/failure by counting affected rows

func CheckMigrationArtifacts

func CheckMigrationArtifacts(t *testing.T, vtParams *mysql.ConnParams, shards []cluster.Shard, uuid string, expectArtifacts bool)

CheckMigrationArtifacts verifies given migration exists, and checks if it has artifacts

func CheckMigrationStatus

func CheckMigrationStatus(t *testing.T, vtParams *mysql.ConnParams, shards []cluster.Shard, uuid string, expectStatus schema.OnlineDDLStatus)

CheckMigrationStatus verifies that the migration indicated by given UUID has the given expected status

func CheckRetryMigration

func CheckRetryMigration(t *testing.T, vtParams *mysql.ConnParams, shards []cluster.Shard, uuid string, expectRetryPossible bool)

CheckRetryMigration attempts to retry a migration, and expects success/failure by counting affected rows

func PrintQueryResult

func PrintQueryResult(writer io.Writer, qr *sqltypes.Result)

PrintQueryResult will pretty-print a QueryResult to the logger.

func VtgateExecDDL

func VtgateExecDDL(t *testing.T, vtParams *mysql.ConnParams, ddlStrategy string, query string, expectError string) *sqltypes.Result

VtgateExecDDL executes a DDL query with given strategy

func VtgateExecQuery

func VtgateExecQuery(t *testing.T, vtParams *mysql.ConnParams, query string, expectError string) *sqltypes.Result

VtgateExecQuery runs a query on VTGate using given query params