38 const char *
plugin,
bool is_temporary,
39 bool is_physical,
bool reserve_wal,
48 bool use_new_option_syntax,
51 bool use_new_option_syntax,
52 char *option_name,
char *option_value);
54 bool use_new_option_syntax,
55 char *option_name,
int32 option_value);
63 long *secs,
int *microsecs);
static bool slot_exists_ok
static const char * plugin
static XLogRecPtr startpos
void AppendIntegerCommandOption(PQExpBuffer buf, bool use_new_option_syntax, char *option_name, int32 option_value)
PGconn * GetConnection(void)
bool RetrieveWalSegSize(PGconn *conn)
int64 fe_recvint64(char *buf)
bool CreateReplicationSlot(PGconn *conn, const char *slot_name, const char *plugin, bool is_temporary, bool is_physical, bool reserve_wal, bool slot_exists_ok, bool two_phase)
TimestampTz feGetCurrentTimestamp(void)
char * GetDbnameFromConnectionOptions(void)
void feTimestampDifference(TimestampTz start_time, TimestampTz stop_time, long *secs, int *microsecs)
void AppendPlainCommandOption(PQExpBuffer buf, bool use_new_option_syntax, char *option_name)
void AppendStringCommandOption(PQExpBuffer buf, bool use_new_option_syntax, char *option_name, char *option_value)
void fe_sendint64(int64 i, char *buf)
bool feTimestampDifferenceExceeds(TimestampTz start_time, TimestampTz stop_time, int msec)
bool GetSlotInformation(PGconn *conn, const char *slot_name, XLogRecPtr *restart_lsn, TimeLineID *restart_tli)
bool DropReplicationSlot(PGconn *conn, const char *slot_name)
bool RunIdentifySystem(PGconn *conn, char **sysid, TimeLineID *starttli, XLogRecPtr *startpos, char **db_name)