Struct postgresql_commands::pg_receivewal::PgReceiveWalBuilder

pub struct PgReceiveWalBuilder { /* private fields */ }

pg_receivewal receives PostgreSQL streaming write-ahead logs.

Implementations

impl PgReceiveWalBuilder

pub fn new() -> Self

Create a new PgReceiveWalBuilder

pub fn from(settings: &dyn Settings) -> Self

Create a new PgReceiveWalBuilder from Settings

pub fn program_dir<P: Into<PathBuf>>(self, path: P) -> Self

Location of the program binary

pub fn directory<S: AsRef<OsStr>>(self, directory: S) -> Self

receive write-ahead log files into this directory

pub fn endpos<S: AsRef<OsStr>>(self, endpos: S) -> Self

exit after receiving the specified LSN

pub fn if_not_exists(self) -> Self

do not error if slot already exists when creating a slot

pub fn no_loop(self) -> Self

do not loop on connection lost

pub fn no_sync(self) -> Self

do not wait for changes to be written safely to disk

pub fn status_interval<S: AsRef<OsStr>>(self, status_interval: S) -> Self

time between status packets sent to server (default: 10)

pub fn slot<S: AsRef<OsStr>>(self, slot: S) -> Self

replication slot to use

pub fn synchronous(self) -> Self

flush write-ahead log immediately after writing

pub fn verbose(self) -> Self

output verbose messages

pub fn version(self) -> Self

output version information, then exit

pub fn compress<S: AsRef<OsStr>>(self, compress: S) -> Self

compress as specified

pub fn help(self) -> Self

show help, then exit

pub fn dbname<S: AsRef<OsStr>>(self, dbname: S) -> Self

connection string

pub fn host<S: AsRef<OsStr>>(self, host: S) -> Self

database server host or socket directory

pub fn port(self, port: u16) -> Self

database server port number

pub fn username<S: AsRef<OsStr>>(self, username: S) -> Self

connect as specified database user

pub fn no_password(self) -> Self

never prompt for password

pub fn password(self) -> Self

force password prompt (should happen automatically)

pub fn pg_password<S: AsRef<OsStr>>(self, pg_password: S) -> Self

user password

pub fn create_slot(self) -> Self

create a new replication slot (for the slot’s name see –slot)

pub fn drop_slot(self) -> Self

drop the replication slot (for the slot’s name see –slot)

Trait Implementations

impl Clone for PgReceiveWalBuilder

fn clone(&self) -> PgReceiveWalBuilder

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl CommandBuilder for PgReceiveWalBuilder

fn get_program(&self) -> &'static OsStr

Get the program name

fn get_program_dir(&self) -> &Option<PathBuf>

Location of the program binary

fn get_args(&self) -> Vec<OsString>

Get the arguments for the command

fn get_envs(&self) -> Vec<(OsString, OsString)>

Get the environment variables for the command

fn env<S: AsRef<OsStr>>(self, key: S, value: S) -> Self

Set an environment variable for the command

fn get_program_file(&self) -> PathBuf

Fully qualified path to the program binary

fn build(self) -> Command

where Self: Sized,

Build a standard Command

impl Debug for PgReceiveWalBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PgReceiveWalBuilder

fn default() -> PgReceiveWalBuilder

Returns the “default value” for a type.