ApplyFileIncrement changes pages according to supplied change map file.

ConfigureWalUploader connects to storage and creates an uploader.

Connect establishes a connection to postgres using a UNIX socket.

CreateFileFromIncrement writes the pages from the increment to local file and write empty blocks in place of pages which are not present in the increment.

ExtractDeleteGarbagePredicate extracts delete modifier the "delete garbage" command.

ExtractPgControl extract pg_control data of cluster by storage.

FindLastCommonPoint get the last common LSN and timeline between two slices of history records.

GetMissingWals collect the slice of WAL filenames by last LSN, last timeline, current timeline, history records and folder.

GetNextWalFilename computes name of next WAL segment.

HandleCatchupFetch is invoked to perform wal-g catchup-fetch.

HandleCatchupPush is invoked to perform a wal-g catchup-push.

HandleCopy copy specific or all backups from one storage to another.

HandleDaemon is invoked to perform daemon mode.

TODO : unit tests.

TODO : unit tests HandleWALFetch is invoked to performa wal-g wal-fetch.

TODO : unit tests HandleWALPrefetch is invoked by wal-fetch command to speed up database restoration.

TODO : unit tests HandleWALPush is invoked to perform wal-g wal-push.

HandleWALReceive is invoked to receive wal with a replication connection and push.

HandleWALRestore is invoked to perform wal-g wal-restore.

HandleWalShow gets the list of files inside WAL folder, detects the available WAL segments, groups WAL segments by the timeline and shows detailed info about each timeline stored in storage.

HandleWalVerify builds a check runner for each check type and writes the check results to the provided output writer.

Listen is used for listening connection and processing messages.

NewBackupArguments creates a BackupArgument object to hold the arguments from the cmd.

NewBackupHandler returns a backup handler object, which can handle the backup.

NewBgUploader creates a new BgUploader which looks for WAL files adjacent to walFilePath.

TODO: use DiskDataFolder.

NewPgQueryRunner builds QueryRunner from available connection.

NewPhysicalSlot is a helper function to declare a new PhysicalSlot object and set vaues from the parsed arguments.

NewStreamingBaseBackup will define a new StreamingBaseBackup object.

NewTimeLineHistFile is a helper function to define a new TimeLineHistFile.

NewWalSegment is a helper function to declare a new WalSegment.

ParseWALFilename extracts numeric parts from WAL file name.

PrepareDirs makes sure all dirs exist.

QueryCurrentWalSegment() gets start WAL segment from Postgres cluster.

RestoreMissingPages restores missing pages (zero blocks) of local file with their base backup version.

ValidateSlotName validates pgSlotName to be a valid slot name.

VerifyPagedFileBase verifies pages of a standard paged file.

VerifyPagedFileIncrement verifies pages of an increment.

TODO : unit tests.

WritePagesFromIncrement writes pages from delta backup according to diffMap.

TODO : unit tests.

prime multiplier of FNV-1a hash.

Segment exists in storage.

Surely lost missing segment.

number of checksums to calculate in parallel.

page header checksum length (in bytes).

page header checksum offset.

Missing but probably delayed segment.

Missing but probably still uploading segment.

These are the multiple results that the methods can return.

These are the multiple results that the methods can return.

These are the multiple results that the methods can return.

These are the multiple results that the methods can return.

These are the multiple results that the methods can return.

These are the multiple results that the methods can return.

Sets standbyMessageTimeout in Streaming Replication Protocol.

ExcludedFilenames is a list of excluded members from the bundled backup.

IncrementFileHeader contains "wi" at the head which stands for "wal-g increment" format version "1", signature magic number.

WalSegmentSize is the size of one WAL file.

Backup contains information about a valid Postgres backup generated and uploaded by WAL-G.

BackupArguments holds all arguments parsed from cmd to this handler class.

BackupDetails is used to append ExtendedMetadataDto details to BackupTime struct.

BackupHandler is the main struct which is handling the backup process.

BackupPgInfo holds the PostgreSQL info that the handler queries before running the backup.

BackupSentinelDto describes file structure of json sentinel.

BackupSentinelDtoV2 is the future version of the backup sentinel.

BackupWorkers holds the external objects that the handler uses to get the backup data / write the backup data.

BgUploader represents the state of concurrent WAL upload.

A Bundle represents the directory to be walked.

CatchupFileUnwrapper is used for catchup (catchup-push) backups.

CurBackupInfo holds all information that is harvest during the backup process.

TODO : add tables to info.

DefaultFileUnwrapper is used for default (backup-push) backups.

Extended metadata should describe backup in more details, but be small enough to be downloaded often.

FilesMetadataDto contains the information about the backup files.

FileTarInterpreter extracts input to disk.

IncrementalPageReader constructs difference map during initialization and than re-read file Diff map may consist of 1Gb/PostgresBlockSize elements == 512Kb.

IntegrityCheckRunner queries the current cluster WAL segment and timeline and travels through WAL segments in storage in reversed chronological order (starting from that segment) to find any missing WAL segments that could potentially fail the PITR procedure.

IntegrityScanSegmentSequence is a continuous sequence of segments with the same timeline and Status.

InvalidBlockError indicates that file contain invalid page and cannot be archived incrementally.

PgControlData represents data contained in pg_control file.

PgQueryRunner is implementation for controlling PostgreSQL 9.0+.

The PhysicalSlot represents a Physical Replication Slot.

PrevBackupInfo holds all information that is harvest during the backup process.

RatingTarBallComposer receives all files and tar headers that are going to be written to the backup, and composes the tarballs by placing the files with similar update rating in the same tarballs.

SegmentScanConfig is used to configure the single Scan() call of the WalSegmentScanner.

StatBundleFiles contains the bundle files.

The StreamingBaseBackup object represents a Postgres BASE_BACKUP, connecting to Postgres, and streaming backup data.

The mandatory keys for this map are "base_prefix" and "tablespaces".

TarBallFilePackerImpl is used to pack bundle file into tarball.

TarballStreamer is used to modify tar files which are received streaming.

TarFilesCollection stores the files which are going to be written to the same tarball.

TimelineCheckRunner is used to verify that the current timeline is the highest among the storage timelines.

The TimeLineHistFile struct represents a TimeLineHistory file containing TimeLineHistFileRows.

The TimeLineHistFileRow struct represents one line in the TimeLineHistory file.

TimelineHistoryRecord represents entry in .history file.

TimelineInfo contains information about some timeline in storage.

UnwrapResult stores information about the result of single backup unwrap operation.

In case of recording error WalDeltaRecordingReader stops recording, but continues reading data correctly.

The WalSegment object represents a Postgres Wal Segment, holding all wal data for a wal file.

WalSegmentRunner is used for sequential iteration over WAL segments in the storage.

WalSegmentScanner is used to scan the WAL segments storage.

WalSegmentsSequence represents some collection of wal segments with the same timeline.

WalShowJsonOutputWriter writes the detailed JSON output.

WalShowTableOutputWriter writes the output in compact pretty table.

WalUploader extends uploader with wal specific functionality.

WalVerifyCheckResult contains the result of some WalVerifyCheckRunner run.

WalVerifyJsonOutputWriter writes the detailed JSON output.

WalVerifyTableOutputWriter writes the output as pretty table.

Cleaner interface serves to separate file system logic from prefetch clean logic to make it testable.

The QueryRunner interface for controlling database during backup.

TarBallComposerMaker is used to make an instance of TarBallComposer.

WalShowOutputWriter writes the output of wal-show command execution result.

WalVerifyCheckRunner performs the check of WAL storage.

WalVerifyOutputWriter writes the output of wal-verify command execution result.

PgChecksummablePage represents single database page divided by NSums blocks for checksum calculation.

PgDatabasePage represents single database page.

The ProcessMessageResult is an enum representing possible results from the methods processing the messages as received from Postgres into the wal segment.