agent

Documentation

Index

• type Agent
  • func New(pbm *pbm.PBM) *Agent
  • func (a *Agent) AddNode(ctx context.Context, curi string, dumpConns int) (err error)
  • func (a *Agent) Backup(cmd pbm.BackupCmd, opid pbm.OPID, ep pbm.Epoch)
  • func (a *Agent) CancelBackup()
  • func (a *Agent) Delete(d pbm.DeleteBackupCmd, opid pbm.OPID, ep pbm.Epoch)
  • func (a *Agent) DeletePITR(d pbm.DeletePITRCmd, opid pbm.OPID, ep pbm.Epoch)
  • func (a *Agent) HbIsRun() bool
  • func (a *Agent) HbPause()
  • func (a *Agent) HbResume()
  • func (a *Agent) HbStatus()
  • func (a *Agent) InitLogger(cn *pbm.PBM)
  • func (a *Agent) OplogReplay(r pbm.ReplayCmd, opID pbm.OPID, ep pbm.Epoch)
  • func (a *Agent) PITR()
  • func (a *Agent) PITRestore(r pbm.PITRestoreCmd, opid pbm.OPID, ep pbm.Epoch)
  • func (a *Agent) Restore(r pbm.RestoreCmd, opid pbm.OPID, ep pbm.Epoch)
  • func (a *Agent) Resync(opid pbm.OPID, ep pbm.Epoch)
  • func (a *Agent) Start() error

Types

type Agent

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

func New

func New(pbm *pbm.PBM) *Agent

func (*Agent) AddNode

func (a *Agent) AddNode(ctx context.Context, curi string, dumpConns int) (err error)

func (*Agent) Backup

func (a *Agent) Backup(cmd pbm.BackupCmd, opid pbm.OPID, ep pbm.Epoch)

Backup starts backup

func (*Agent) CancelBackup

func (a *Agent) CancelBackup()

CancelBackup cancels current backup

func (*Agent) Delete

func (a *Agent) Delete(d pbm.DeleteBackupCmd, opid pbm.OPID, ep pbm.Epoch)

Delete deletes backup(s) from the store and cleans up its metadata

func (*Agent) DeletePITR

func (a *Agent) DeletePITR(d pbm.DeletePITRCmd, opid pbm.OPID, ep pbm.Epoch)

DeletePITR deletes PITR chunks from the store and cleans up its metadata

func (*Agent) HbIsRun

func (a *Agent) HbIsRun() bool

func (*Agent) HbPause

func (a *Agent) HbPause()

func (*Agent) HbResume

func (a *Agent) HbResume()

func (*Agent) HbStatus

func (a *Agent) HbStatus()

func (*Agent) InitLogger

func (a *Agent) InitLogger(cn *pbm.PBM)

func (*Agent) OplogReplay

func (a *Agent) OplogReplay(r pbm.ReplayCmd, opID pbm.OPID, ep pbm.Epoch)

OplogReplay replays oplog between r.Start and r.End timestamps (wall time in UTC tz)

func (*Agent) PITR

func (a *Agent) PITR()

PITR starts PITR processing routine

func (*Agent) PITRestore

func (a *Agent) PITRestore(r pbm.PITRestoreCmd, opid pbm.OPID, ep pbm.Epoch)

PITRestore starts the point-in-time recovery

func (*Agent) Restore

func (a *Agent) Restore(r pbm.RestoreCmd, opid pbm.OPID, ep pbm.Epoch)

func (*Agent) Resync

func (a *Agent) Resync(opid pbm.OPID, ep pbm.Epoch)

Resync uploads a backup list from the remote store

func (*Agent) Start

func (a *Agent) Start() error

Start starts listening the commands stream.