PostgreSQL Source Code git master
|
#include <slot.h>
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().
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().
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().
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().
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().
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().
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().
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().
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().
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().
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().
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().
TransactionId ReplicationSlotPersistentData::xmin |
Definition at line 89 of file slot.h.
Referenced by copy_replication_slot(), pg_get_replication_slots(), PhysicalReplicationSlotNewXmin(), ReplicationSlotRelease(), and RestoreSlotFromDisk().