183 #define SlotIsPhysical(slot) ((slot)->data.database == InvalidOid)
184 #define SlotIsLogical(slot) ((slot)->data.database != InvalidOid)
ReplicationSlot * SearchNamedReplicationSlot(const char *name, bool need_lock)
int ReplicationSlotIndex(ReplicationSlot *slot)
struct ReplicationSlotCtlData ReplicationSlotCtlData
PGDLLIMPORT ReplicationSlot * MyReplicationSlot
void ReplicationSlotCleanup(void)
void ReplicationSlotMarkDirty(void)
void ReplicationSlotReserveWal(void)
bool ReplicationSlotsCountDBSlots(Oid dboid, int *nslots, int *nactive)
void ReplicationSlotAcquire(const char *name, bool nowait)
bool InvalidateObsoleteReplicationSlots(ReplicationSlotInvalidationCause cause, XLogSegNo oldestSegno, Oid dboid, TransactionId snapshotConflictHorizon)
void ReplicationSlotsDropDBSlots(Oid dboid)
XLogRecPtr ReplicationSlotsComputeLogicalRestartLSN(void)
void ReplicationSlotsComputeRequiredXmin(bool already_locked)
void ReplicationSlotPersist(void)
void ReplicationSlotDrop(const char *name, bool nowait)
struct ReplicationSlotPersistentData ReplicationSlotPersistentData
ReplicationSlotPersistency
void ReplicationSlotSave(void)
void ReplicationSlotNameForTablesync(Oid suboid, Oid relid, char *syncslotname, Size szslot)
void CheckSlotPermissions(void)
bool ReplicationSlotName(int index, Name name)
void ReplicationSlotsShmemInit(void)
void ReplicationSlotRelease(void)
void CheckPointReplicationSlots(void)
PGDLLIMPORT ReplicationSlotCtlData * ReplicationSlotCtl
ReplicationSlotInvalidationCause
void ReplicationSlotsComputeRequiredLSN(void)
void ReplicationSlotInitialize(void)
PGDLLIMPORT int max_replication_slots
struct ReplicationSlot ReplicationSlot
void StartupReplicationSlots(void)
void ReplicationSlotCreate(const char *name, bool db_specific, ReplicationSlotPersistency persistency, bool two_phase)
void ReplicationSlotDropAtPubNode(WalReceiverConn *wrconn, char *slotname, bool missing_ok)
void CheckSlotRequirements(void)
Size ReplicationSlotsShmemSize(void)
bool ReplicationSlotValidateName(const char *name, int elevel)
ReplicationSlot replication_slots[1]
TransactionId catalog_xmin
XLogRecPtr confirmed_flush
ReplicationSlotPersistency persistency
ReplicationSlotInvalidationCause invalidated
XLogRecPtr candidate_xmin_lsn
TransactionId effective_catalog_xmin
XLogRecPtr candidate_restart_valid
TransactionId effective_xmin
XLogRecPtr candidate_restart_lsn
LWLock io_in_progress_lock
ConditionVariable active_cv
TransactionId candidate_catalog_xmin
ReplicationSlotPersistentData data
static WalReceiverConn * wrconn