Search Results for

    Show / Hide Table of Contents

    Class LogicalReplicationConnection

    Represents a logical replication connection to a PostgreSQL server.

    Inheritance
    object
    ReplicationConnection
    LogicalReplicationConnection
    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(uint, CancellationToken)
    ReplicationConnection.SetReplicationStatus(NpgsqlLogSequenceNumber)
    ReplicationConnection.SendStatusUpdate(CancellationToken)
    ReplicationConnection.DropReplicationSlot(string, bool, CancellationToken)
    Namespace: Npgsql.Replication
    Assembly: Npgsql.dll
    Syntax
    public sealed class LogicalReplicationConnection : ReplicationConnection

    Constructors

    | Improve this Doc View Source

    LogicalReplicationConnection()

    Initializes a new instance of LogicalReplicationConnection.

    Declaration
    public LogicalReplicationConnection()
    | Improve this Doc View Source

    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.

    Extension Methods

    LogicalReplicationConnectionExtensions.CreateLogicalReplicationSlot(LogicalReplicationConnection, string, string, bool, LogicalSlotSnapshotInitMode?, bool, CancellationToken)
    LogicalReplicationConnectionExtensions.StartLogicalReplication(LogicalReplicationConnection, LogicalReplicationSlot, CancellationToken, NpgsqlLogSequenceNumber?, IEnumerable<KeyValuePair<string, string?>>?, bool)
    PgOutputConnectionExtensions.CreatePgOutputReplicationSlot(LogicalReplicationConnection, string, bool, LogicalSlotSnapshotInitMode?, bool, CancellationToken)
    PgOutputConnectionExtensions.StartReplication(LogicalReplicationConnection, PgOutputReplicationSlot, PgOutputReplicationOptions, CancellationToken, NpgsqlLogSequenceNumber?)
    TestDecodingConnectionExtensions.CreateTestDecodingReplicationSlot(LogicalReplicationConnection, string, bool, LogicalSlotSnapshotInitMode?, bool, CancellationToken)
    TestDecodingConnectionExtensions.StartReplication(LogicalReplicationConnection, TestDecodingReplicationSlot, CancellationToken, TestDecodingOptions?, NpgsqlLogSequenceNumber?)
    • Improve this Doc
    • View Source
    In This Article
    Back to top © Copyright 2023 The Npgsql Development Team