replicationchannel

Documentation

Index

• type ReplicationChannel
  • func NewReplicationChannel(replicationContext *repcontext.ReplicationContext) (*ReplicationChannel, error)
  • func (rc *ReplicationChannel) StartReplicationChannel(replicationContext *repcontext.ReplicationContext, ...) error
  • func (rc *ReplicationChannel) StopReplicationChannel() error

Types

type ReplicationChannel

type ReplicationChannel struct {
	// contains filtered or unexported fields
}

ReplicationChannel represents the database connection and handler loop for the logical replication decoding subscriber.

func NewReplicationChannel

func NewReplicationChannel(replicationContext *repcontext.ReplicationContext) (*ReplicationChannel, error)

NewReplicationChannel instantiates a new instance of the ReplicationChannel.

func (*ReplicationChannel) StartReplicationChannel

func (rc *ReplicationChannel) StartReplicationChannel(
	replicationContext *repcontext.ReplicationContext, initialTables []systemcatalog.SystemEntity) error

StartReplicationChannel starts the replication channel, as well as initializes and starts the logical replication handler loop.

func (*ReplicationChannel) StopReplicationChannel

func (rc *ReplicationChannel) StopReplicationChannel() error

StopReplicationChannel initiates a clean shutdown of the replication channel and logical replication handler loop. This call will block until the loop is cleanly shut down.