replicationconnection

Documentation

Index

• type ReplicationConnection
  • func NewReplicationConnection(replicationContext replicationcontext.ReplicationContext) (*ReplicationConnection, error)
  • func (rc *ReplicationConnection) Close() error
  • func (rc *ReplicationConnection) CreateReplicationSlot() (slotName, snapshotName string, created bool, err error)
  • func (rc *ReplicationConnection) DropReplicationSlot() error
  • func (rc *ReplicationConnection) ReceiveMessage(deadline time.Time) (pgproto3.BackendMessage, error)
  • func (rc *ReplicationConnection) SendStatusUpdate() error
  • func (rc *ReplicationConnection) StartReplication(pluginArguments []string) (pgtypes.LSN, error)
  • func (rc *ReplicationConnection) StopReplication() error

Types

type ReplicationConnection

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

func NewReplicationConnection

func NewReplicationConnection(
	replicationContext replicationcontext.ReplicationContext,
) (*ReplicationConnection, error)

func (*ReplicationConnection) Close

func (rc *ReplicationConnection) Close() error

func (*ReplicationConnection) CreateReplicationSlot

func (rc *ReplicationConnection) CreateReplicationSlot() (slotName, snapshotName string, created bool, err error)

func (*ReplicationConnection) DropReplicationSlot

func (rc *ReplicationConnection) DropReplicationSlot() error

func (*ReplicationConnection) ReceiveMessage

func (rc *ReplicationConnection) ReceiveMessage(
	deadline time.Time,
) (pgproto3.BackendMessage, error)

func (*ReplicationConnection) SendStatusUpdate

func (rc *ReplicationConnection) SendStatusUpdate() error

func (*ReplicationConnection) StartReplication

func (rc *ReplicationConnection) StartReplication(
	pluginArguments []string,
) (pgtypes.LSN, error)

func (*ReplicationConnection) StopReplication

func (rc *ReplicationConnection) StopReplication() error