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(bcp 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) HbStatus()
  • func (a *Agent) InitLogger(cn *pbm.PBM)
  • 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) ResyncStorage(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(bcp 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) HbStatus

func (a *Agent) HbStatus()

func (*Agent) InitLogger

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

func (*Agent) PITR

func (a *Agent) PITR()

PITR starts PITR prcessing 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)

Restore starts the restore

func (*Agent) ResyncStorage

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

ResyncStorage uploads a backup list from the remote store

func (*Agent) Start

func (a *Agent) Start() error

Start starts listening the commands stream.