╬ї│h$%UсЎ !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~АБВГДЕЖЗИЙКЛМНОПРСТУФХЦЧШЩЪЫЬЭЮЯабвгдежзийклмноп░▒▓│┤╡╢╖╕╣║╗╝╜╛┐└┴┬├─┼╞╟╚╔╩╦╠═╬╧╨╤╥╙╘╒╓╫ ╪ ┘ ┌ █ ▄ ▌ ▐ ▀ р с т у ф х ц ч ш щ ъ ыьэюяЁёЄєЇї Safe-Inferred '(8рьЙ Safe-Inferred '(8рь╝!Bounded and unbounded FIFO queues(c) James King, 2020, 2021BSD3james@agentultra.comexperimentalPOSIX Safe-Inferred '(8рьОpostgresql-replicantReturn True if the queue is emptypostgresql-replicant3Remove an item from the end of the non-empty queue.postgresql-replicant&Put an item on the front of the queue.postgresql-replicant╞Put an item on the end of the queue so that it will be dequeued first. None '(8рь+postgresql-replicantConsume the rest of the Get a input as a ByteStringTypes and parsers for LSNs(c) James King, 2020, 2021BSD3james@agentultra.comexperimentalPOSIXNone '(8рь postgresql-replicantFilepartpostgresql-replicantOffset postgresql-replicant"Convert an LSN to a 64-bit integer!postgresql-replicant"Convert a 64-bit integer to an LSN$postgresql-replicantгNote that as of bytestring ~0.10.12.0 we don't have upper-case hex encoders but the patch to add them has been merged and when available we should switch to them%postgresql-replicantAdd a number of bytes to an LSN&postgresql-replicant&Subtract a number of bytes from an LSN'postgresql-replicant╞Subtract two LSN's to calculate the difference of bytes between them. !"#$%&' !"#$%&'!Internal replication stream state(c) James King, 2020, 2021BSD3james@agentultra.comexperimentalPOSIXNone '(8рь ║./01432501432./5Replication slot query commands(c) James King, 2020, 2021BSD3james@agentultra.comexperimentalPOSIXNone '(8рь WIpostgresql-replicantGet information about an existing replication slot. Returns Nothing) when the requested slot cannot be found.2May throw an exception if the command query fails.Lpostgresql-replicant5Create replication slot or retrieve an existing slot.Can throw exceptions from getReplicationSlotSync or createReplicationSlotSync.8:9;>==?@ABCDEEFGHIJKLMNOPQRSTUVWXXYZ[\]^_``abcddefghhijkllmnopqrrstuvwxyz{|}~~АБВВГДЕЖЗЗИЙКЛМННОПРСТУФХЦЧШЩЪЫЬЭЮЯабвгдежзийклмноп░▒▓│┤╡╢╖╕╣║╗╝╜╛┐└┴┬├─┼╞╟╚╔╩╦╠═╬╧╨╤ ╥ ╥ ╙ ╘ ╒ ╓ ╫ ╪ ┘ ┌ █ ▄ ▌ ▐ ▀ р с т у фххцчшщъыьэюяЁёЄєЇїЎў3postgresql-replicant-0.1.0.1-8lCgV3GxTz94C3yAKiXHKL'Database.PostgreSQL.Replicant.Exception+Database.PostgreSQL.Replicant.PostgresUtils#Database.PostgreSQL.Replicant.Queue'Database.PostgreSQL.Replicant.Serialize'Database.PostgreSQL.Replicant.Types.Lsn#Database.PostgreSQL.Replicant.State-Database.PostgreSQL.Replicant.ReplicationSlot%Database.PostgreSQL.Replicant.Message&Database.PostgreSQL.Replicant.Protocol"Database.PostgreSQL.Replicant.UtilDatabase.PostgreSQL.ReplicantPaths_postgresql_replicantReplicantException$fExceptionReplicantException$fShowReplicantException postgresEpoch mkUTCTime FifoQueueBoundedQueueExceptionBoundedQueueOverflowBoundedFifoQueueBoundedFifoQueueMetaboundedFifoQueueSizeboundedFifoQueueemptyBoundedenqueueBoundedemptynulldequeueenqueueenqueueRight$fEqBoundedQueueException$fShowBoundedQueueException$fEqBoundedFifoQueueMeta$fShowBoundedFifoQueueMetaconsumeByteStringToEndLSNfilepartoffsettoInt64 fromInt64 lsnParserfromByteStringtoByteStringaddsubsubLsn $fFromJSONLSN$fToJSONLSN$fSerializeLSN$fOrdLSN $fShowLSN$fEqLSNWalProgressStateWalProgresswalProgressReceivedwalProgressFlushedwalProgressAppliedupdateWalProgress$fEqWalProgress$fShowWalProgressReplicationSlotActiveActiveInactiveReplicationSlotTypeLogicalPhysicalUnknownSlotTypeReplicationSlotInfoslotName slotPluginslotType slotActiveslotRestart parseSlotTypeparseSlotActivecreateReplicationSlotCommandcreateReplicationSlotSyncgetReplicationSlotInfoCommandgetReplicationSlotSyncsetupReplicationSlot$fEqReplicationSlotInfo$fShowReplicationSlotInfo$fEqReplicationSlotActive$fShowReplicationSlotActive$fEqReplicationSlotType$fShowReplicationSlotTypeChange changeNextLSNchangeDeltas WalLogDataWInsertWUpdateWDeleteWMessageMessagemessageTransactional messagePrefixmessageContentDeletedeleteSchemadeleteTable deleteColumnsUpdateupdateSchemaupdateTable updateColumnsInsertinsertSchemainsertTable insertColumnsColumnParseErrorColumnLengthMatchErrorColumn columnName columnTypecolumnValueWalValue WalString WalNumberWalBoolWalNullWalCopyData XLogDataM KeepAliveMHotStandbyFeedback hotStandbyFeedbackClientSendTimehotStandbyFeedbackCurrentXminhotStandbyFeedbackCurrentEpochXLogDataxLogDataWalStartxLogDataWalEndxLogDataSendTimexLogDataWalDataStandbyStatusUpdate%standbyStatuUpdateLastWalByteReceived%standbyStatusUpdateLastWalByteFlushed%standbyStatusUpdateLastWalByteAppliedstandbyStatusUpdateSendTime&standbyStatusUpdateResponseExpectationPrimaryKeepAliveprimaryKeepAliveWalEndprimaryKeepAliveSendTime#primaryKeepAliveResponseExpectationResponseExpectation ShouldRespondDoNotRespondcolumns fromColumnfromColumns$fSerializeResponseExpectation$fSerializePrimaryKeepAlive$fSerializeStandbyStatusUpdate$fSerializeXLogData$fSerializeHotStandbyFeedback$fSerializeWalCopyData$fToJSONWalValue$fFromJSONWalValue$fToJSONInsert$fFromJSONInsert$fToJSONUpdate$fFromJSONUpdate$fToJSONDelete$fFromJSONDelete$fToJSONMessage$fFromJSONMessage$fFromJSONWalLogData$fToJSONWalLogData$fFromJSONChange$fToJSONChange $fEqChange$fGenericChange$fShowChange$fEqWalLogData$fGenericWalLogData$fShowWalLogData$fEqMessage $fShowMessage $fEqDelete$fShowDelete $fEqUpdate$fShowUpdate $fEqInsert$fShowInsert$fEqColumnParseError$fShowColumnParseError $fEqColumn$fShowColumn$fEqWalValue$fGenericWalValue$fShowWalValue$fEqWalCopyData$fGenericWalCopyData$fShowWalCopyData$fEqHotStandbyFeedback$fGenericHotStandbyFeedback$fShowHotStandbyFeedback$fEqXLogData$fGenericXLogData$fShowXLogData$fEqStandbyStatusUpdate$fGenericStandbyStatusUpdate$fShowStandbyStatusUpdate$fEqPrimaryKeepAlive$fGenericPrimaryKeepAlive$fShowPrimaryKeepAlive$fEqResponseExpectation$fGenericResponseExpectation$fShowResponseExpectationIdentifySystemidentifySystemSytemIdidentifySystemTimelineidentifySystemLogPosidentifySystemDbNameidentifySystemCommandidentifySystemSyncstartReplicationCommandhandleCopyOutDatahandleReplicationRowhandleReplicationErrorhandleReplicationNoopstartReplicationStreamkeepAliveHandlersendStatusUpdate$fEqIdentifySystem$fShowIdentifySystemmkInt64 maybeThrow PgSettingspgUserpgDbNamepgHostpgPort pgSlotName pgUpdateDelaywithLogicalStream$fEqPgSettings$fShowPgSettingsversion getBinDir getLibDirgetDynLibDir getDataDir getLibexecDir getSysconfDirgetDataFileName