pitr

Documentation

Index

• Constants
• type ErrOpMoved
  • func (e ErrOpMoved) Error() string
• type Slicer
  • func NewSlicer(rs string, cn *pbm.PBM, node *pbm.Node, to storage.Storage, ep pbm.Epoch) *Slicer
  • func (s *Slicer) Catchup() error
  • func (s *Slicer) GetSpan() time.Duration
  • func (s *Slicer) OplogOnlyCatchup() (err error)
  • func (s *Slicer) SetSpan(d time.Duration)
  • func (s *Slicer) Stream(ctx context.Context, backupSig <-chan *pbm.OPID, ...) 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 Slicer

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

Slicer is an incremental backup object

func NewSlicer

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

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

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

func (*Slicer) OplogOnlyCatchup

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

func (*Slicer) SetSpan

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

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