executor

Documentation

Overview

Package executor contains the logic of taking a backup

Index

• type Executor
  • func NewLocalExecutor(cluster *apiv1.Cluster, backup *apiv1.Backup, repo *Repository) *Executor
  • func (executor *Executor) GetBeginWal() string
  • func (executor *Executor) GetEndWal() string
  • func (executor *Executor) TakeBackup(ctx context.Context) (*webserver.BackupResultData, error)
• type Repository
  • func NewRepository(ctx context.Context, path string, configFile string, cacheDirectory string) (*Repository, error)

Types

type Executor

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

Executor manages the execution of a backup

func NewLocalExecutor

func NewLocalExecutor(cluster *apiv1.Cluster, backup *apiv1.Backup, repo *Repository) *Executor

NewLocalExecutor creates a new backup Executor

func (*Executor) GetBeginWal

func (executor *Executor) GetBeginWal() string

GetBeginWal returns the beginWal value, panics if the executor was not executed

func (*Executor) GetEndWal

func (executor *Executor) GetEndWal() string

GetEndWal returns the endWal value, panics if the executor was not executed

func (*Executor) TakeBackup

func (executor *Executor) TakeBackup(ctx context.Context) (*webserver.BackupResultData, error)

TakeBackup executes a backup. Returns the result and any error encountered

type Repository

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

Repository represents a backup repository where base directories are stored

func NewRepository

func NewRepository(ctx context.Context, path string, configFile string, cacheDirectory string) (*Repository, error)

NewRepository creates a new repository in a certain path, ensuring that the repository is initialized and ready to accept backups