Database.PostgreSQL.Replicant.ReplicationSlot

This module contains the PostgreSQL queries, types, and functions for working with querying, creating, and working with replication slots.

Documentation

data ReplicationSlotInfo

Constructors

ReplicationSlotInfo

Fields

• slotName :: ByteString
• slotPlugin :: ByteString
• slotType :: ReplicationSlotType
• slotActive :: ReplicationSlotActive
• slotRestart :: LSN

Instances

Eq ReplicationSlotInfo

Defined in Database.PostgreSQL.Replicant.ReplicationSlot

Methods

(==) :: ReplicationSlotInfo -> ReplicationSlotInfo -> Bool

(/=) :: ReplicationSlotInfo -> ReplicationSlotInfo -> Bool

Show ReplicationSlotInfo

Defined in Database.PostgreSQL.Replicant.ReplicationSlot

Methods

showsPrec :: Int -> ReplicationSlotInfo -> ShowS

show :: ReplicationSlotInfo -> String

showList :: [ReplicationSlotInfo] -> ShowS

data ReplicationSlotType

Constructors

Logical

Physical

UnknownSlotType

Instances

Eq ReplicationSlotType

Defined in Database.PostgreSQL.Replicant.ReplicationSlot

Methods

(==) :: ReplicationSlotType -> ReplicationSlotType -> Bool

(/=) :: ReplicationSlotType -> ReplicationSlotType -> Bool

Show ReplicationSlotType

Defined in Database.PostgreSQL.Replicant.ReplicationSlot

Methods

showsPrec :: Int -> ReplicationSlotType -> ShowS

show :: ReplicationSlotType -> String

showList :: [ReplicationSlotType] -> ShowS

parseSlotType :: ByteString -> ReplicationSlotType

data ReplicationSlotActive

Constructors

Active

Inactive

Instances

Eq ReplicationSlotActive

Defined in Database.PostgreSQL.Replicant.ReplicationSlot

Methods

(==) :: ReplicationSlotActive -> ReplicationSlotActive -> Bool

(/=) :: ReplicationSlotActive -> ReplicationSlotActive -> Bool

Show ReplicationSlotActive

Defined in Database.PostgreSQL.Replicant.ReplicationSlot

Methods

showsPrec :: Int -> ReplicationSlotActive -> ShowS

show :: ReplicationSlotActive -> String

showList :: [ReplicationSlotActive] -> ShowS

parseSlotActive :: ByteString -> ReplicationSlotActive

createReplicationSlotCommand :: ReplicantConnection -> ByteString -> IO ByteString

createReplicationSlotSync :: ReplicantConnection -> ByteString -> IO ReplicationSlotInfo

Create a replication slot using synchronous query execution.

May throw an exception if the command fails.

getReplicationSlotInfoCommand :: ReplicantConnection -> ByteString -> IO ByteString

getReplicationSlotSync :: ReplicantConnection -> ByteString -> IO (Maybe ReplicationSlotInfo)

Get information about an existing replication slot. Returns Nothing when the requested slot cannot be found.

May throw an exception if the command query fails.

setupReplicationSlot :: ReplicantConnection -> ByteString -> IO ReplicationSlotInfo

Create replication slot or retrieve an existing slot.

Can throw exceptions from getReplicationSlotSync or createReplicationSlotSync.