testutils

Documentation

Index

• func CRDBConnStr() string
• func CRDBTargetConnStr() string
• func ExecConnQuery(ctx context.Context, q string, conn dbconn.Conn) (res string, err error)
• func ExecConnTestdata(t *testing.T, d *datadriven.TestData, conns dbconn.OrderedConns) string
• func GetCmdArgsStr(in []datadriven.CmdArg) string
• func GetLocalStoreAddrs(dialect string, port string) (localStoreListenAddr string, localStoreCrdbAccessAddr string)
• func MySQLConnStr() string
• func PGConnStr() string
• func QueryConnCommand(t *testing.T, d *datadriven.TestData, conns dbconn.OrderedConns) string
• type CDCSinkKnob
• type Dialect
  • func (i Dialect) String() string
• type FailedEstablishSrcConnForExportKnob
• type FailedWriteToBucketKnob
• type FetchTestingKnobs
• type HistoryRetentionKnob

Functions

func CRDBConnStr

func CRDBConnStr() string

func CRDBTargetConnStr

func CRDBTargetConnStr() string

func ExecConnQuery

func ExecConnQuery(ctx context.Context, q string, conn dbconn.Conn) (res string, err error)

func ExecConnTestdata

func ExecConnTestdata(t *testing.T, d *datadriven.TestData, conns dbconn.OrderedConns) string

func GetCmdArgsStr

func GetCmdArgsStr(in []datadriven.CmdArg) string

func GetLocalStoreAddrs

func GetLocalStoreAddrs(
	dialect string, port string,
) (localStoreListenAddr string, localStoreCrdbAccessAddr string)

func MySQLConnStr

func MySQLConnStr() string

func PGConnStr

func PGConnStr() string

func QueryConnCommand

func QueryConnCommand(t *testing.T, d *datadriven.TestData, conns dbconn.OrderedConns) string

Types

type CDCSinkKnob

type CDCSinkKnob struct {
	PollingFunction   func(conns dbconn.OrderedConns, sentinelFileName string, sigintChan chan os.Signal) (err error)
	SentinelFileName  string
	ForceCDCSinkError bool
	LocalhostName     string
}

type Dialect

type Dialect int

const (
	PostgresDialect Dialect = iota
	MySQLDialect
	CRDBSourceDialect
)

func (Dialect) String

func (i Dialect) String() string

type FailedEstablishSrcConnForExportKnob

type FailedEstablishSrcConnForExportKnob struct {
	SleepDuration time.Duration
}

type FailedWriteToBucketKnob

type FailedWriteToBucketKnob struct {
	FailedBeforeReadFromPipe bool
	FailedAfterReadFromPipe  bool
}

type FetchTestingKnobs

type FetchTestingKnobs struct {
	// Used to simulate testing when the CSV input file is wrong.
	TriggerCorruptCSVFile bool

	FailedWriteToBucket FailedWriteToBucketKnob

	FailedEstablishSrcConnForExport *FailedEstablishSrcConnForExportKnob

	HistoryRetention *HistoryRetentionKnob

	CDCSink *CDCSinkKnob
}

type HistoryRetentionKnob

type HistoryRetentionKnob struct {
	ExtensionFrequency time.Duration
	ExtensionCnt       *int64
	Cancelled          bool
	JobID              *string
}