sqlrunner

type Config struct {
	Sources           []SourceConfig
	DefaultDriverName string
	PingOnStart       bool
}

type Executor struct {
	// contains filtered or unexported fields
}

type SourceConfig struct {
	SourceID   string
	DB         *sql.DB
	DriverName string
	DSN        string
	DSNEnv     string
	Tables     []datasource.TableConfig
	BatchSize  int
}

type StreamRowsOptions struct {
	BatchSize int
}