replicationchannel

Documentation

Index

• type ReplicationChannel
  • func NewReplicationChannel(replicationContext replicationcontext.ReplicationContext, ...) (*ReplicationChannel, error)
  • func (rc *ReplicationChannel) StartReplicationChannel(initialTables []systemcatalog.SystemEntity) 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 replicationcontext.ReplicationContext, typeManager pgtypes.TypeManager,
	taskManager task.TaskManager, publicationManager publication.PublicationManager,
	statsService *stats.Service,
) (*ReplicationChannel, error)

NewReplicationChannel instantiates a new instance of the ReplicationChannel.

func (*ReplicationChannel) StartReplicationChannel

func (rc *ReplicationChannel) StartReplicationChannel(
	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.