ApplyPgDumpPostSteps takes the given dump and applies post-steps defined in transfer source ONLY for homogenous PG-PG transfers.

ApplyPgDumpPreSteps takes the given dump and applies pre-steps defined in transfer source ONLY for homogenous PG-PG transfers.

BeginTx starts a transaction for the given pool with the given options and automatically composes sufficient rollback object.

BeginTxWithSnapshot starts a transaction at the given connection with the given snapshot and automatically composes a sufficient rollback object.

CreateSchemaQueryOptional returns a query to create schema if it is absent.

CurrentTxStartTime returns the start time of the current transaction at the given connection.

ExtractPgDumpSchema returns the dump ONLY for homogenous PG-PG transfers.

FallbackBitAsBytes implements backward compatibility for https://st.yandex-team.ru/TM-5445#640b22b5af0c626bd522d179 WARNING: this fallback violates type strictness!.

FallbackTimestampToUTC implements https://st.yandex-team.ru/TM-5092.

Returns whether name is a keyword or not according to a well-known keywords list.

ListSequencesWithDependants returns a mapping with sequence information.

MinusToBC checks if the given string starts with a minus and if so, trims it and adds a "BC" suffix.

NewChangeItemsFetcher constructs minimal working fetcher.

NewDate constructs a DATE representation which supports BC years TODO: remove this when https://st.yandex-team.ru/TM-5127 is done.

NewPgConnPoolConfig creates a connection pool.

NewSlotMonitor constructs a slot monitor, but does NOT start it.

NewTimestamp constructs a TIMESTAMP WITHOUT TIME ZONE representation which supports BC years TODO: this type must become significantly simpler after https://st.yandex-team.ru/TM-5127 is done.

NewTimestamptz constructs a TIMESTAMP WITH TIME ZONE representation which supports BC years TODO: remove this when https://st.yandex-team.ru/TM-5127 is done.

RollbackFuncForPgxTx returns a function which ROLLBACKs the given `pgx.Tx` and if an error happens, logs it with the given logger at WARNING level.

RowCount queries the storage and returns the exact number of rows in the given table.

Sanitize sanitizes the given identifier so that it can be used safely in queries to PostgreSQL.

TimeWithTimeZoneToTime converts the given (valid) PostgreSQL TIME WITH TIME ZONE into a time.Time whose time zone and time are set to valid values All resulting time.Times are guaranteed to be properly comparable among themselves.

PostgreSQL error codes from https://www.postgresql.org/docs/12/errcodes-appendix.html.

PostgreSQL error codes from https://www.postgresql.org/docs/12/errcodes-appendix.html.

PostgreSQL error codes from https://www.postgresql.org/docs/12/errcodes-appendix.html.

PostgreSQL error codes from https://www.postgresql.org/docs/12/errcodes-appendix.html.

PostgreSQL error codes from https://www.postgresql.org/docs/12/errcodes-appendix.html.

PostgreSQL error codes from https://www.postgresql.org/docs/12/errcodes-appendix.html.

PostgreSQL error codes from https://www.postgresql.org/docs/12/errcodes-appendix.html.

"__consumer_keeper".

"__data_transfer_lsn".

TimeZoneParameterStatusKey is the identifier of the PostgreSQL connection property containing time zone.

ChangeItemsFetcher consolidates multiple objects (of which most important is pgx.Rows) into a single one, providing bufferized fetching and parsing of rows from a postgres source.

The Go type for PostgreSQL types of which pgx driver is unaware.

GenericArray is based on ArrayType https://github.com/doublecloud/transfer/arc_vcs/vendor/github.com/jackc/pgtype/array_type.go?rev=r8263453#L15.

SequenceInfo is a description of a PostgreSQL sequence.

Text representation of PostgreSQL type from pg_type catalog, opposed to OID: https://www.postgresql.org/docs/current/catalog-pg-type.html.

Unmarshaller converts data from the PostgreSQL format to the Data Transfer format.

This is basically an abstract.ChangeItem, but with two additional fields: * columntypeoids * oldkeys.keytypeoids Note that historically abstract.ChangeItem's structure was exactly the same as the structure of objects we received from wal2json, since PostgreSQL was one of the first endpoints implemented in DataTransfer.

go-sumtype:decl DataTypesOption.

go-sumtype:decl StorageOpt.

SequenceMap is a mapping of sequence identifiers to their descriptions.