mirror of
https://github.com/postgres/postgres.git
synced 2025-11-09 06:21:09 +03:00
cf2655a902
This new option instructs pg_recvlogical to create the logical replication slot with the failover option enabled. It can be used in conjunction with the --create-slot option. Author: Hayato Kuroda <kuroda.hayato@fujitsu.com> Reviewed-by: Michael Banck <mbanck@gmx.net> Reviewed-by: Masahiko Sawada <sawada.mshk@gmail.com> Discussion: https://postgr.es/m/OSCPR01MB14966C54097FC83AF19F3516BF5AC2@OSCPR01MB14966.jpnprd01.prod.outlook.com
70 lines
2.2 KiB
C
70 lines
2.2 KiB
C
/*-------------------------------------------------------------------------
|
|
*
|
|
* streamutil.h
|
|
*
|
|
* Portions Copyright (c) 1996-2025, PostgreSQL Global Development Group
|
|
*
|
|
* IDENTIFICATION
|
|
* src/bin/pg_basebackup/streamutil.h
|
|
*-------------------------------------------------------------------------
|
|
*/
|
|
|
|
#ifndef STREAMUTIL_H
|
|
#define STREAMUTIL_H
|
|
|
|
#include "access/xlogdefs.h"
|
|
#include "datatype/timestamp.h"
|
|
#include "libpq-fe.h"
|
|
#include "pqexpbuffer.h"
|
|
|
|
extern const char *progname;
|
|
extern char *connection_string;
|
|
extern char *dbhost;
|
|
extern char *dbuser;
|
|
extern char *dbport;
|
|
extern char *dbname;
|
|
extern int dbgetpassword;
|
|
extern int WalSegSz;
|
|
|
|
/* Connection kept global so we can disconnect easily */
|
|
extern PGconn *conn;
|
|
|
|
extern PGconn *GetConnection(void);
|
|
|
|
/* Replication commands */
|
|
extern 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,
|
|
bool failover);
|
|
extern bool DropReplicationSlot(PGconn *conn, const char *slot_name);
|
|
extern bool RunIdentifySystem(PGconn *conn, char **sysid,
|
|
TimeLineID *starttli,
|
|
XLogRecPtr *startpos,
|
|
char **db_name);
|
|
|
|
extern void AppendPlainCommandOption(PQExpBuffer buf,
|
|
bool use_new_option_syntax,
|
|
char *option_name);
|
|
extern void AppendStringCommandOption(PQExpBuffer buf,
|
|
bool use_new_option_syntax,
|
|
char *option_name, char *option_value);
|
|
extern void AppendIntegerCommandOption(PQExpBuffer buf,
|
|
bool use_new_option_syntax,
|
|
char *option_name, int32 option_value);
|
|
|
|
extern bool GetSlotInformation(PGconn *conn, const char *slot_name,
|
|
XLogRecPtr *restart_lsn,
|
|
TimeLineID *restart_tli);
|
|
extern bool RetrieveWalSegSize(PGconn *conn);
|
|
extern TimestampTz feGetCurrentTimestamp(void);
|
|
extern void feTimestampDifference(TimestampTz start_time, TimestampTz stop_time,
|
|
long *secs, int *microsecs);
|
|
|
|
extern bool feTimestampDifferenceExceeds(TimestampTz start_time, TimestampTz stop_time,
|
|
int msec);
|
|
extern void fe_sendint64(int64 i, char *buf);
|
|
extern int64 fe_recvint64(char *buf);
|
|
|
|
#endif /* STREAMUTIL_H */
|