fetch

May 3, 2024

Changes in this version

+ func GetTypeConvMap(customizedTypeMapPath string, logger zerolog.Logger) (typeconv.TableTypeMap, error)

+ func MaybeCheckMultiRegionLocality(ctx context.Context, logger zerolog.Logger, conns dbconn.OrderedConns, ...) (checked bool, err error)

type Config

+ AllowCockroachReplication bool

+ CustomizedTypeMapPath string

+ IsExportConcurrencySet bool

+ IsTableConcurrencySet bool

+ OngoingReplication bool

+ ReplicatorFlags string

+ UsingDockerBackend bool

Mar 22, 2024

Changes in this version

type Config

+ TableConcurrency int

+ UseCopy bool

Mar 12, 2024

Changes in this version

+ func GetColumnTypes(ctx context.Context, logger zerolog.Logger, conn dbconn.Conn, ...) (columnsWithType, error)

+ func GetConstraints(ctx context.Context, logger zerolog.Logger, conn dbconn.Conn, ...) ([]string, error)

+ func GetCreateTableStmt(ctx context.Context, logger zerolog.Logger, conn dbconn.Conn, ...) (string, error)

+ func GetDropTableStmt(table dbtable.DBTable) (string, error)

+ func IsClearContinuationTokenMode(cfg Config) bool

+ func IsImportCopyOnlyMode(cfg Config) bool

+ func ListContinuationTokens(ctx context.Context, testOnly bool, targetPgxConn *pgx.Conn, numResults int) (string, error)

type Config

+ ContinuationFileName string

+ ContinuationToken string

+ DropAndRecreateNewSchema bool

+ FetchID string

+ NonInteractive bool

+ Shards int

+ TestOnly bool

+ type PGIface interface

+ Exec func(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error)

+ type Pipe struct

+ func NewPipe(b *bytes.Buffer) *Pipe

+ func (p *Pipe) Close() error

+ func (p *Pipe) CloseWithError(err error) error

+ func (p *Pipe) Read(b []byte) (int, error)

+ func (p *Pipe) Write(b []byte) (int, error)

Nov 1, 2023

Changes in this version

type Config

+ Compression compression.Flag

+ FlushRows int

Sep 23, 2023

Changes in this version

+ func Fetch(ctx context.Context, cfg Config, logger zerolog.Logger, ...) error

+ type Config struct

+ Cleanup bool

+ Concurrency int

+ ExportSettings dataexport.Settings

+ FlushSize int

+ Live bool

+ Truncate bool

+ type CopyResult struct

+ EndTime time.Time

+ StartTime time.Time

+ func Copy(ctx context.Context, baseConn dbconn.Conn, logger zerolog.Logger, ...) (CopyResult, error)