kopiarunner

Documentation

Overview

Package kopiarunner wraps the execution of the kopia binary.

Index

• Variables
• type KopiaSnapshotter
  • func NewKopiaSnapshotter(baseDir string) (*KopiaSnapshotter, error)
  • func (ks *KopiaSnapshotter) Cleanup()
  • func (ks *KopiaSnapshotter) ConnectOrCreateFilesystem(repoPath string) error
  • func (ks *KopiaSnapshotter) ConnectOrCreateFilesystemWithServer(serverAddr, repoPath string) (*exec.Cmd, error)
  • func (ks *KopiaSnapshotter) ConnectOrCreateRepo(args ...string) error
  • func (ks *KopiaSnapshotter) ConnectOrCreateS3(bucketName, pathPrefix string) error
  • func (ks *KopiaSnapshotter) ConnectOrCreateS3WithServer(serverAddr, bucketName, pathPrefix string) (*exec.Cmd, error)
  • func (ks *KopiaSnapshotter) ConnectRepo(args ...string) (err error)
  • func (ks *KopiaSnapshotter) ConnectServer(addr string, args ...string) error
  • func (ks *KopiaSnapshotter) CreateRepo(args ...string) (err error)
  • func (ks *KopiaSnapshotter) CreateServer(addr string, args ...string) (*exec.Cmd, error)
  • func (ks *KopiaSnapshotter) CreateSnapshot(source string) (snapID string, err error)
  • func (ks *KopiaSnapshotter) DeleteSnapshot(snapID string) (err error)
  • func (ks *KopiaSnapshotter) ListSnapshots() ([]string, error)
  • func (ks *KopiaSnapshotter) RestoreSnapshot(snapID, restoreDir string) (err error)
  • func (ks *KopiaSnapshotter) Run(args ...string) (stdout, stderr string, err error)
  • func (ks *KopiaSnapshotter) RunGC() (err error)
• type Runner
  • func NewRunner(baseDir string) (*Runner, error)
  • func (kr *Runner) Cleanup()
  • func (kr *Runner) Run(args ...string) (stdout, stderr string, err error)
  • func (kr *Runner) RunAsync(args ...string) (*exec.Cmd, error)

Variables

var ErrExeVariableNotSet = errors.New("KOPIA_EXE variable has not been set")

ErrExeVariableNotSet is an exported error.

Types

type KopiaSnapshotter

type KopiaSnapshotter struct {
	Runner *Runner
}

KopiaSnapshotter implements the Snapshotter interface using Kopia commands.

func NewKopiaSnapshotter

func NewKopiaSnapshotter(baseDir string) (*KopiaSnapshotter, error)

NewKopiaSnapshotter instantiates a new KopiaSnapshotter and returns its pointer.

func (*KopiaSnapshotter) Cleanup

func (ks *KopiaSnapshotter) Cleanup()

Cleanup cleans up the kopia Runner.

func (*KopiaSnapshotter) ConnectOrCreateFilesystem

func (ks *KopiaSnapshotter) ConnectOrCreateFilesystem(repoPath string) error

ConnectOrCreateFilesystem attempts to connect to a kopia repo in the local filesystem at the path provided. It will attempt to create one there if connection was unsuccessful.

func (*KopiaSnapshotter) ConnectOrCreateFilesystemWithServer

func (ks *KopiaSnapshotter) ConnectOrCreateFilesystemWithServer(serverAddr, repoPath string) (*exec.Cmd, error)

ConnectOrCreateFilesystemWithServer attempts to connect or create repo in local filesystem, but with TLS server/client Model.

func (*KopiaSnapshotter) ConnectOrCreateRepo

func (ks *KopiaSnapshotter) ConnectOrCreateRepo(args ...string) error

ConnectOrCreateRepo attempts to connect to a repo described by the provided arguments, and attempts to create it if connection was unsuccessful.

func (*KopiaSnapshotter) ConnectOrCreateS3

func (ks *KopiaSnapshotter) ConnectOrCreateS3(bucketName, pathPrefix string) error

ConnectOrCreateS3 attempts to connect to a kopia repo in the s3 bucket identified by the provided bucketName, at the provided path prefix. It will attempt to create one there if connection was unsuccessful.

func (*KopiaSnapshotter) ConnectOrCreateS3WithServer

func (ks *KopiaSnapshotter) ConnectOrCreateS3WithServer(serverAddr, bucketName, pathPrefix string) (*exec.Cmd, error)

ConnectOrCreateS3WithServer attempts to connect or create S3 bucket, but with TLS client/server Model.

func (*KopiaSnapshotter) ConnectRepo

func (ks *KopiaSnapshotter) ConnectRepo(args ...string) (err error)

ConnectRepo connects to the repository described by the provided arguments.

func (*KopiaSnapshotter) ConnectServer

func (ks *KopiaSnapshotter) ConnectServer(addr string, args ...string) error

ConnectServer creates a new client, and connect it to Kopia Server with provided address.

func (*KopiaSnapshotter) CreateRepo

func (ks *KopiaSnapshotter) CreateRepo(args ...string) (err error)

CreateRepo creates a kopia repository with the provided arguments.

func (*KopiaSnapshotter) CreateServer

func (ks *KopiaSnapshotter) CreateServer(addr string, args ...string) (*exec.Cmd, error)

CreateServer creates a new instance of Kopia Server with provided address.

func (*KopiaSnapshotter) CreateSnapshot

func (ks *KopiaSnapshotter) CreateSnapshot(source string) (snapID string, err error)

CreateSnapshot implements the Snapshotter interface, issues a kopia snapshot create command on the provided source path.

func (*KopiaSnapshotter) DeleteSnapshot

func (ks *KopiaSnapshotter) DeleteSnapshot(snapID string) (err error)

DeleteSnapshot implements the Snapshotter interface, issues a kopia snapshot delete of the provided snapshot ID.

func (*KopiaSnapshotter) ListSnapshots

func (ks *KopiaSnapshotter) ListSnapshots() ([]string, error)

ListSnapshots implements the Snapshotter interface, issues a kopia snapshot list and parses the snapshot IDs.

func (*KopiaSnapshotter) RestoreSnapshot

func (ks *KopiaSnapshotter) RestoreSnapshot(snapID, restoreDir string) (err error)

RestoreSnapshot implements the Snapshotter interface, issues a kopia snapshot restore command of the provided snapshot ID to the provided restore destination.

func (*KopiaSnapshotter) Run

func (ks *KopiaSnapshotter) Run(args ...string) (stdout, stderr string, err error)

Run implements the Snapshotter interface, issues an arbitrary kopia command and returns the output.

func (*KopiaSnapshotter) RunGC

func (ks *KopiaSnapshotter) RunGC() (err error)

RunGC implements the Snapshotter interface, issues a gc command to the kopia repo.

type Runner

type Runner struct {
	Exe       string
	ConfigDir string
	// contains filtered or unexported fields
}

Runner is a helper for running kopia commands.

func NewRunner

func NewRunner(baseDir string) (*Runner, error)

NewRunner initializes a new kopia runner and returns its pointer.

func (*Runner) Cleanup

func (kr *Runner) Cleanup()

Cleanup cleans up the directories managed by the kopia Runner.

func (*Runner) Run

func (kr *Runner) Run(args ...string) (stdout, stderr string, err error)

Run will execute the kopia command with the given args.

func (*Runner) RunAsync

func (kr *Runner) RunAsync(args ...string) (*exec.Cmd, error)

RunAsync will execute the kopia command with the given args in background.