Search Results for

    Show / Hide Table of Contents

    Class LogicalReplicationConnection

    Represents a logical replication connection to a PostgreSQL server.

    Inheritance
    Object
    ReplicationConnection
    LogicalReplicationConnection
    Implements
    IAsyncDisposable
    Inherited Members
    ReplicationConnection.ConnectionString
    ReplicationConnection.LastReceivedLsn
    ReplicationConnection.LastFlushedLsn
    ReplicationConnection.LastAppliedLsn
    ReplicationConnection.WalReceiverStatusInterval
    ReplicationConnection.WalReceiverTimeout
    ReplicationConnection.PostgreSqlVersion
    ReplicationConnection.ServerVersion
    ReplicationConnection.CommandTimeout
    ReplicationConnection.Encoding
    ReplicationConnection.ProcessID
    ReplicationConnection.Open(CancellationToken)
    ReplicationConnection.DisposeAsync()
    ReplicationConnection.IdentifySystem(CancellationToken)
    ReplicationConnection.Show(String, CancellationToken)
    ReplicationConnection.TimelineHistory(UInt32, CancellationToken)
    ReplicationConnection.SetReplicationStatus(NpgsqlLogSequenceNumber)
    ReplicationConnection.SendStatusUpdate(CancellationToken)
    ReplicationConnection.DropReplicationSlot(String, Boolean, CancellationToken)
    Object.Equals(Object)
    Object.Equals(Object, Object)
    Object.GetHashCode()
    Object.GetType()
    Object.MemberwiseClone()
    Object.ReferenceEquals(Object, Object)
    Object.ToString()
    Namespace: Npgsql.Replication
    Assembly: Npgsql.dll
    Syntax
    public sealed class LogicalReplicationConnection : ReplicationConnection, IAsyncDisposable

    Constructors

    LogicalReplicationConnection()

    Initializes a new instance of LogicalReplicationConnection.

    Declaration
    public LogicalReplicationConnection()

    LogicalReplicationConnection(String)

    Initializes a new instance of LogicalReplicationConnection with the given connection string.

    Declaration
    public LogicalReplicationConnection(string connectionString)
    Parameters
    Type Name Description
    String connectionString

    The connection used to open the PostgreSQL database.

    Implements

    System.IAsyncDisposable

    Extension Methods

    PgOutputConnectionExtensions.CreatePgOutputReplicationSlot(LogicalReplicationConnection, String, Boolean, Nullable<LogicalSlotSnapshotInitMode>, CancellationToken)
    PgOutputConnectionExtensions.StartReplication(LogicalReplicationConnection, PgOutputReplicationSlot, PgOutputReplicationOptions, CancellationToken, Nullable<NpgsqlLogSequenceNumber>)
    TestDecodingConnectionExtensions.CreateTestDecodingReplicationSlot(LogicalReplicationConnection, String, Boolean, Nullable<LogicalSlotSnapshotInitMode>, CancellationToken)
    TestDecodingConnectionExtensions.StartReplication(LogicalReplicationConnection, TestDecodingReplicationSlot, CancellationToken, TestDecodingOptions, Nullable<NpgsqlLogSequenceNumber>)
    LogicalReplicationConnectionExtensions.CreateLogicalReplicationSlot(LogicalReplicationConnection, String, String, Boolean, Nullable<LogicalSlotSnapshotInitMode>, CancellationToken)
    LogicalReplicationConnectionExtensions.StartLogicalReplication(LogicalReplicationConnection, LogicalReplicationSlot, CancellationToken, Nullable<NpgsqlLogSequenceNumber>, IEnumerable<KeyValuePair<String, String>>, Boolean)
    In This Article
    Back to top © Copyright 2022 The Npgsql Development Team