pitr

Documentation

Index

• Constants
• type ErrOpMoved
  • func (e ErrOpMoved) Error() string
• type IBackup
  • func NewBackup(rs string, cn *pbm.PBM, node *pbm.Node) *IBackup
  • func (i *IBackup) Catchup() error
  • func (i *IBackup) Stream(ctx context.Context, ep pbm.Epoch, wakeupSig <-chan struct{}, ...) error

Constants

const LogStartMsg = "start_ok"

LogStartMsg message to log on successful streaming start

Types

type ErrOpMoved

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

ErrOpMoved is the error signaling that slicing op now being run by the other node

func (ErrOpMoved) Error

func (e ErrOpMoved) Error() string

type IBackup

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

IBackup is an incremental backup object

func NewBackup

func NewBackup(rs string, cn *pbm.PBM, node *pbm.Node) *IBackup

NewBackup creates an incremental backup object

func (*IBackup) Catchup

func (i *IBackup) Catchup() error

Catchup seeks for the last saved (backuped) TS - the starting point. It should be run only if the timeline was lost (e.g. on (re)start or another node's fail). The starting point sets to the last backup's or last PITR chunk's TS whichever is the most recent. It also checks if there is no restore intercepted the timeline (hence there are no restores after the most recent backup)

func (*IBackup) Stream

func (i *IBackup) Stream(ctx context.Context, ep pbm.Epoch, wakeupSig <-chan struct{}, to storage.Storage, compression pbm.CompressionType) error

Stream streaming (saving) chunks of the oplog to the given storage