PostgreSQL Source Code git master
•All Data Structures Namespaces Files Functions Variables Typedefs Enumerations Enumerator Macros Pages
Data Fields
ReplicationSlotPersistentData Struct Reference

#include <slot.h>

Data Fields

NameData name
 
Oid database
 
ReplicationSlotPersistency persistency
 
TransactionId xmin
 
TransactionId catalog_xmin
 
XLogRecPtr restart_lsn
 
ReplicationSlotInvalidationCause invalidated
 
XLogRecPtr confirmed_flush
 
XLogRecPtr two_phase_at
 
bool two_phase
 
NameData plugin
 
char synced
 
bool failover
 

Detailed Description

Definition at line 70 of file slot.h.

Field Documentation

◆ catalog_xmin

TransactionId ReplicationSlotPersistentData::catalog_xmin

Definition at line 97 of file slot.h.

Referenced by copy_replication_slot(), CreateInitDecodingContext(), LogicalConfirmReceivedLocation(), LogicalIncreaseXminForSlot(), pg_get_replication_slots(), PhysicalReplicationSlotNewXmin(), RestoreSlotFromDisk(), synchronize_one_slot(), and update_local_synced_slot().

◆ confirmed_flush

XLogRecPtr ReplicationSlotPersistentData::confirmed_flush

Definition at line 111 of file slot.h.

Referenced by CheckPointReplicationSlots(), copy_replication_slot(), CreateDecodingContext(), CreateReplicationSlot(), DecodingContextFindStartpoint(), LogicalConfirmReceivedLocation(), LogicalIncreaseRestartDecodingForSlot(), LogicalIncreaseXminForSlot(), LogicalSlotAdvanceAndCheckSnapState(), pg_create_logical_replication_slot(), pg_get_replication_slots(), pg_replication_slot_advance(), RestoreSlotFromDisk(), SaveSlotToPath(), StartLogicalReplication(), synchronize_one_slot(), and update_local_synced_slot().

◆ database

Oid ReplicationSlotPersistentData::database

Definition at line 76 of file slot.h.

Referenced by CreateDecodingContext(), CreateInitDecodingContext(), DecodeDelete(), DecodeInsert(), DecodeMultiInsert(), DecodeSpecConfirm(), DecodeTruncate(), DecodeTXNNeedSkip(), DecodeUpdate(), DetermineSlotInvalidationCause(), logicalmsg_decode(), pg_get_replication_slots(), pg_replication_slot_advance(), ReadReplicationSlot(), ReplicationSlotCreate(), ReplicationSlotsCountDBSlots(), ReplicationSlotsDropDBSlots(), RestoreSlotFromDisk(), synchronize_one_slot(), and update_local_synced_slot().

◆ failover

bool ReplicationSlotPersistentData::failover

Definition at line 136 of file slot.h.

Referenced by NeedToWaitForStandbys(), pg_get_replication_slots(), ReplicationSlotAlter(), ReplicationSlotCreate(), update_local_synced_slot(), and WaitForStandbyConfirmation().

◆ invalidated

ReplicationSlotInvalidationCause ReplicationSlotPersistentData::invalidated

Definition at line 103 of file slot.h.

Referenced by binary_upgrade_logical_slot_has_caught_up(), CheckPointReplicationSlots(), copy_replication_slot(), CreateDecodingContext(), InvalidatePossiblyObsoleteSlot(), local_sync_slot_required(), pg_get_replication_slots(), ReplicationSlotAcquire(), ReplicationSlotsComputeLogicalRestartLSN(), ReplicationSlotsComputeRequiredLSN(), ReplicationSlotsComputeRequiredXmin(), ReplicationSlotSetInactiveSince(), StandbySlotsHaveCaughtup(), synchronize_one_slot(), and update_local_synced_slot().

◆ name

NameData ReplicationSlotPersistentData::name

Definition at line 73 of file slot.h.

Referenced by CheckPointReplicationSlots(), copy_replication_slot(), CreateDecodingContext(), CreateInitDecodingContext(), CreateReplicationSlot(), CreateSlotOnDisk(), InvalidatePossiblyObsoleteSlot(), local_sync_slot_required(), pg_create_logical_replication_slot(), pg_create_physical_replication_slot(), pg_get_replication_slots(), pg_replication_slot_advance(), PhysicalWakeupLogicalWalSnd(), ReorderBufferAllocate(), ReorderBufferFree(), ReorderBufferSerializedPath(), ReplicationSlotAcquire(), ReplicationSlotCreate(), ReplicationSlotDropPtr(), ReplicationSlotName(), ReplicationSlotRelease(), ReplicationSlotSave(), ReplicationSlotsDropDBSlots(), RestoreSlotFromDisk(), and SearchNamedReplicationSlot().

◆ persistency

ReplicationSlotPersistency ReplicationSlotPersistentData::persistency

Definition at line 81 of file slot.h.

Referenced by copy_replication_slot(), pg_get_replication_slots(), ReplicationSlotAlter(), ReplicationSlotCleanup(), ReplicationSlotCreate(), ReplicationSlotDropPtr(), ReplicationSlotPersist(), ReplicationSlotRelease(), RestoreSlotFromDisk(), synchronize_one_slot(), and update_local_synced_slot().

◆ plugin

NameData ReplicationSlotPersistentData::plugin

Definition at line 125 of file slot.h.

Referenced by copy_replication_slot(), CreateInitDecodingContext(), pg_get_replication_slots(), pg_logical_slot_get_changes_guts(), StartupDecodingContext(), synchronize_one_slot(), and update_local_synced_slot().

◆ restart_lsn

XLogRecPtr ReplicationSlotPersistentData::restart_lsn

Definition at line 100 of file slot.h.

Referenced by CanInvalidateIdleSlot(), copy_replication_slot(), create_physical_replication_slot(), CreateDecodingContext(), CreateInitDecodingContext(), DecodingContextFindStartpoint(), InvalidatePossiblyObsoleteSlot(), LogicalConfirmReceivedLocation(), LogicalReplicationSlotHasPendingWal(), LogicalSlotAdvanceAndCheckSnapState(), pg_create_physical_replication_slot(), pg_get_replication_slots(), pg_logical_slot_get_changes_guts(), pg_physical_replication_slot_advance(), pg_replication_slot_advance(), PhysicalConfirmReceivedLocation(), ReadReplicationSlot(), ReplicationSlotReserveWal(), ReplicationSlotsComputeLogicalRestartLSN(), ReplicationSlotsComputeRequiredLSN(), reserve_wal_for_local_slot(), StandbySlotsHaveCaughtup(), StartLogicalReplication(), update_and_persist_local_synced_slot(), and update_local_synced_slot().

◆ synced

char ReplicationSlotPersistentData::synced

Definition at line 130 of file slot.h.

Referenced by CanInvalidateIdleSlot(), CreateDecodingContext(), get_local_synced_slots(), pg_get_replication_slots(), ReplicationSlotAlter(), ReplicationSlotCleanup(), ReplicationSlotCreate(), ReplicationSlotDrop(), synchronize_one_slot(), and update_synced_slots_inactive_since().

◆ two_phase

bool ReplicationSlotPersistentData::two_phase

Definition at line 122 of file slot.h.

Referenced by CreateDecodingContext(), CreateInitDecodingContext(), DecodingContextFindStartpoint(), pg_get_replication_slots(), ReplicationSlotAlter(), ReplicationSlotCreate(), and update_local_synced_slot().

◆ two_phase_at

XLogRecPtr ReplicationSlotPersistentData::two_phase_at

Definition at line 117 of file slot.h.

Referenced by CreateDecodingContext(), DecodingContextFindStartpoint(), pg_get_replication_slots(), ReplicationSlotCreate(), StartupDecodingContext(), and update_local_synced_slot().

◆ xmin

TransactionId ReplicationSlotPersistentData::xmin

Definition at line 89 of file slot.h.

Referenced by copy_replication_slot(), pg_get_replication_slots(), PhysicalReplicationSlotNewXmin(), ReplicationSlotRelease(), and RestoreSlotFromDisk().

The documentation for this struct was generated from the following file: