pitr

package
v1.8.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 27, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const LogStartMsg = "start_ok"

LogStartMsg message to log on successful streaming start

Variables

This section is empty.

Functions

This section is empty.

Types

type ErrOpMoved added in v1.3.2

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 added in v1.3.2

func (e ErrOpMoved) Error() string

type Slicer added in v1.6.0

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

Slicer is an incremental backup object

func NewSlicer added in v1.6.0

func NewSlicer(rs string, cn *pbm.PBM, node *pbm.Node, to storage.Storage, ep pbm.Epoch) *Slicer

NewSlicer creates an incremental backup object

func (*Slicer) Catchup added in v1.6.0

func (s *Slicer) Catchup() error

Catchup seeks for the last saved (backed up) TS - the starting point. It should be run only if the timeline was lost (e.g. on (re)start, restart after backup, node's fail). The starting point sets to the last backup's or last PITR chunk's TS whichever is the most recent. If there is a chunk behind the last backup it will try to fill the gaps from the chunk to the starting point. While filling gaps it checks the oplog for sufficiency. It also checks if there is no restore intercepted the timeline (hence there are no restores after the most recent backup)

func (*Slicer) GetSpan added in v1.6.0

func (s *Slicer) GetSpan() time.Duration

func (*Slicer) OplogOnlyCatchup added in v1.8.0

func (s *Slicer) OplogOnlyCatchup() (err error)

func (*Slicer) SetSpan added in v1.6.0

func (s *Slicer) SetSpan(d time.Duration)

SetSpan sets span duration. Streaming will recognise the change and adjust on the next iteration.

func (*Slicer) Stream added in v1.6.0

func (s *Slicer) Stream(ctx context.Context, backupSig <-chan *pbm.OPID, compression pbm.CompressionType, level *int) error

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL