recovery

Documentation

Index

• Variables
• func InsertData(t *testing.T, tablet *cluster.Vttablet, index int, keyspaceName string)
• func RestoreTablet(t *testing.T, localCluster *cluster.LocalProcessCluster, ...)
• func VerifyQueriesUsingVtgate(t *testing.T, session *vtgateconn.VTGateSession, query string, value string)

Variables

var (

	// UseXb flag to use extra backup for recovery teseting.
	UseXb = false
	// XbArgs are the arguments for specifying xtrabackup.
	XbArgs = []string{
		"--backup_engine_implementation", "xtrabackup",
		"--xtrabackup_stream_mode=xbstream",
		"--xtrabackup_user=vt_dba",
		"--xtrabackup_backup_flags", fmt.Sprintf("--password=%s", dbPassword),
	}
)

Functions

func InsertData

func InsertData(t *testing.T, tablet *cluster.Vttablet, index int, keyspaceName string)

InsertData inserts data.

func RestoreTablet

func RestoreTablet(t *testing.T, localCluster *cluster.LocalProcessCluster, tablet *cluster.Vttablet, restoreKSName string, shardName string, keyspaceName string, commonTabletArg []string, restoreTime time.Time)

RestoreTablet performs a PITR restore.

func VerifyQueriesUsingVtgate

func VerifyQueriesUsingVtgate(t *testing.T, session *vtgateconn.VTGateSession, query string, value string)

VerifyQueriesUsingVtgate verifies queries using vtgate.