executor

Documentation

Index

• Constants
• Variables
• type Executor
  • func NewS3Executor(repo *Repository) *Executor
  • func (executor *Executor) Backup(ctx context.Context) (*webserver.BackupResultData, error)
  • func (executor *Executor) GetBeginWal() string
  • func (executor *Executor) GetEndWal() string
• type Repository
  • func NewRepository(bucket string, path string) (*Repository, error)
  • func (repo *Repository) Restore(ctx context.Context, backupName string) error
  • func (repo *Repository) Snapshot(ctx context.Context) error

Constants

const (
	PGDumpall        = "pg_dumpall"
	Psql             = "psql"
	BackupTimeFormat = "20060102150405"
)

Variables

var (
	ErrBackupNotStarted = errors.New("backup not started")
	ErrBackupNotStopped = errors.New("backup not stopped")
)

Types

type Executor

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

Executor manages the execution of a backup

func NewS3Executor

func NewS3Executor(repo *Repository) *Executor

NewS3Executor creates a new backup Executor

func (*Executor) Backup

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

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

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

type Repository

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

Repository represents a backup repository where base directories are stored

func NewRepository

func NewRepository(bucket string, path string) (*Repository, error)

NewRepository creates a new repository ensuring that the repository is initialized and ready to accept backups

func (*Repository) Restore

func (repo *Repository) Restore(ctx context.Context, backupName string) error

func (*Repository) Snapshot

func (repo *Repository) Snapshot(ctx context.Context) error

Snapshot takes a Snapshot of the Postgres cluster