testutils

May 3, 2024

Changes in this version

+ type CDCSinkKnob struct

+ ForceCDCSinkError bool

+ LocalhostName string

+ PollingFunction func(conns dbconn.OrderedConns, sentinelFileName string, sigintChan chan os.Signal) (err error)

+ SentinelFileName string

+ type FailedEstablishSrcConnForExportKnob struct

+ SleepDuration time.Duration

type FetchTestingKnobs

+ CDCSink *CDCSinkKnob

+ HistoryRetention *HistoryRetentionKnob

+ type HistoryRetentionKnob struct

+ Cancelled bool

+ ExtensionCnt *int64

+ ExtensionFrequency time.Duration

+ JobID *string

Mar 22, 2024

Changes in this version

type FetchTestingKnobs

+ FailedEstablishSrcConnForExport bool

Mar 12, 2024

Changes in this version

+ 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)

+ type Dialect int

+ const CRDBSourceDialect

+ const MySQLDialect

+ const PostgresDialect

+ func (i *Dialect) String() string

+ type FailedWriteToBucketKnob struct

+ FailedAfterReadFromPipe bool

+ FailedBeforeReadFromPipe bool

+ type FetchTestingKnobs struct

+ FailedWriteToBucket FailedWriteToBucketKnob

+ TriggerCorruptCSVFile bool

Sep 23, 2023

Changes in this version

+ func CRDBConnStr() string

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

+ func MySQLConnStr() string

+ func PGConnStr() string

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