26#ifndef BASEBACKUP_SINK_H
27#define BASEBACKUP_SINK_H
179 Assert(buffer_length > 0);
209 Assert(
len > 0 && len <= sink->bbs_buffer_length);
239 Assert(
len > 0 && len <= sink->bbs_buffer_length);
275 const char *archive_name);
static void bbsink_begin_backup(bbsink *sink, bbsink_state *state, int buffer_length)
bbsink * bbsink_zstd_new(bbsink *next, pg_compress_specification *)
void basebackup_progress_wait_checkpoint(void)
bbsink * bbsink_gzip_new(bbsink *next, pg_compress_specification *)
void bbsink_forward_begin_backup(bbsink *sink)
void bbsink_forward_begin_manifest(bbsink *sink)
bbsink * bbsink_progress_new(bbsink *next, bool estimate_backup_size)
bbsink * bbsink_copystream_new(bool send_to_client)
void bbsink_forward_end_backup(bbsink *sink, XLogRecPtr endptr, TimeLineID endtli)
bbsink * bbsink_throttle_new(bbsink *next, uint32 maxrate)
bbsink * bbsink_lz4_new(bbsink *next, pg_compress_specification *)
static void bbsink_begin_archive(bbsink *sink, const char *archive_name)
void bbsink_forward_cleanup(bbsink *sink)
void bbsink_forward_manifest_contents(bbsink *sink, size_t len)
static void bbsink_end_archive(bbsink *sink)
static void bbsink_begin_manifest(bbsink *sink)
struct bbsink_state bbsink_state
static void bbsink_end_backup(bbsink *sink, XLogRecPtr endptr, TimeLineID endtli)
void bbsink_forward_end_archive(bbsink *sink)
void bbsink_forward_archive_contents(bbsink *sink, size_t len)
static void bbsink_cleanup(bbsink *sink)
void basebackup_progress_wait_wal_archive(bbsink_state *)
void bbsink_forward_begin_archive(bbsink *sink, const char *archive_name)
static void bbsink_end_manifest(bbsink *sink)
void bbsink_forward_end_manifest(bbsink *sink)
static void bbsink_archive_contents(bbsink *sink, size_t len)
static void bbsink_manifest_contents(bbsink *sink, size_t len)
void basebackup_progress_done(void)
void basebackup_progress_transfer_wal(void)
void basebackup_progress_estimate_backup_size(void)
bbsink * bbsink_server_new(bbsink *next, char *pathname)
#define Assert(condition)
static int list_length(const List *l)
void(* begin_manifest)(bbsink *sink)
void(* cleanup)(bbsink *sink)
void(* end_manifest)(bbsink *sink)
void(* end_archive)(bbsink *sink)
void(* manifest_contents)(bbsink *sink, size_t len)
void(* begin_backup)(bbsink *sink)
void(* end_backup)(bbsink *sink, XLogRecPtr endptr, TimeLineID endtli)
void(* archive_contents)(bbsink *sink, size_t len)
void(* begin_archive)(bbsink *sink, const char *archive_name)
bool bytes_total_is_valid
const bbsink_ops * bbs_ops