client

Documentation

Index

• type Replicator
  • func New(shutdownHandler shutdown.ShutdownHandler, statsChan chan stats.Stat, ...) Replicator
  • func (c *Replicator) GetOutputChan() chan *replication.WalMessage
  • func (c *Replicator) GetStoppedChan() chan struct{}
  • func (c *Replicator) Start(progressChan <-chan uint64)

Types

type Replicator

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

func New

func New(shutdownHandler shutdown.ShutdownHandler,
	statsChan chan stats.Stat,
	connManager conn.ManagerInterface,
	clientBufferSize int) Replicator

New a simple constructor to create a replication.client with postgres configurations.

func (*Replicator) GetOutputChan

func (c *Replicator) GetOutputChan() chan *replication.WalMessage

GetOutputChan returns the outputChan

func (*Replicator) GetStoppedChan

func (c *Replicator) GetStoppedChan() chan struct{}

GetStoppedChan returns stoppedChan

func (*Replicator) Start

func (c *Replicator) Start(progressChan <-chan uint64)

Start loops on serially updating overallProgress from the progress channel, reading in a pgx.ReplicationMessages from the API, and sending out converted replication.WalMessages on the output Channel. Additionally it sends back a StandbyStatus when requested from postgres. Start needs to be provided a progressChan because we need to initialize all the modules first to produce a progressChan needed for the replication.client