runner

Documentation

Overview

Package runner contains the runner that replicates slots from the primary to the replicas

Index

• type Replicator
  • func NewReplicator(instance *postgres.Instance) *Replicator
  • func (sr *Replicator) Start(ctx context.Context) error

Types

type Replicator

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

A Replicator is a runner that keeps replication slots in sync between the primary and this replica

func NewReplicator

func NewReplicator(instance *postgres.Instance) *Replicator

NewReplicator creates a new slot Replicator

func (*Replicator) Start

func (sr *Replicator) Start(ctx context.Context) error

Start starts running the slot Replicator