testenv

Documentation

Overview

Package testenv contains Environment for use in testing.

Index

• Constants
• Variables
• type CLIExeRunner
  • func NewExeRunner(t *testing.T) *CLIExeRunner
  • func NewExeRunnerWithBinary(t *testing.T, exe string) *CLIExeRunner
  • func (e *CLIExeRunner) RemoveDefaultPassword()
  • func (e *CLIExeRunner) Start(t *testing.T, args []string) (stdout, stderr io.Reader, wait func() error, kill func())
• type CLIInProcRunner
  • func NewInProcRunner(t *testing.T) *CLIInProcRunner
  • func (e *CLIInProcRunner) Start(t *testing.T, args []string) (stdout, stderr io.Reader, wait func() error, kill func())
• type CLIRunner
• type CLITest
  • func NewCLITest(t *testing.T, repoCreateFlags []string, runner CLIRunner) *CLITest
  • func (e *CLITest) Run(t *testing.T, expectedError bool, args ...string) (stdout, stderr []string, err error)
  • func (e *CLITest) RunAndExpectFailure(t *testing.T, args ...string) []string
  • func (e *CLITest) RunAndExpectSuccess(t *testing.T, args ...string) []string
  • func (e *CLITest) RunAndExpectSuccessWithErrOut(t *testing.T, args ...string) (stdout, stderr []string)
  • func (e *CLITest) RunAndProcessStderr(t *testing.T, callback func(line string) bool, args ...string) (kill func())
  • func (e *CLITest) RunAndVerifyOutputLineCount(t *testing.T, wantLines int, args ...string) []string
• type FakeTimeServer
  • func NewFakeTimeServer(now func() time.Time) *FakeTimeServer
  • func (s *FakeTimeServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

Constants

const (
	// TestRepoPassword is a password for repositories created in tests.
	TestRepoPassword = "qWQPJ2hiiLgWRRCr"
)

Variables

var RepoFormatNotImportant []string

RepoFormatNotImportant chooses arbitrary format version where it's not important to the test.

Types

type CLIExeRunner

type CLIExeRunner struct {
	Exe               string
	Environment       []string
	PassthroughStderr bool      // this is for debugging only
	NextCommandStdin  io.Reader // this is used for stdin source tests
	LogsDir           string
}

CLIExeRunner is a CLIExeRunner that invokes the commands via external executable.

func NewExeRunner

func NewExeRunner(t *testing.T) *CLIExeRunner

NewExeRunner returns a CLIRunner that will execute kopia commands by launching subprocesses for each. The kopia executable must be passed via KOPIA_EXE environment variable. The test will be skipped if it's not provided (unless running inside an IDE in which case system-wide `kopia` will be used by default).

func NewExeRunnerWithBinary

func NewExeRunnerWithBinary(t *testing.T, exe string) *CLIExeRunner

NewExeRunnerWithBinary returns a CLIRunner that will execute kopia commands by launching subprocesses for each.

func (*CLIExeRunner) RemoveDefaultPassword

func (e *CLIExeRunner) RemoveDefaultPassword()

RemoveDefaultPassword prevents KOPIA_PASSWORD from being passed to kopia.

func (*CLIExeRunner) Start

func (e *CLIExeRunner) Start(t *testing.T, args []string) (stdout, stderr io.Reader, wait func() error, kill func())

Start implements CLIRunner.

type CLIInProcRunner

type CLIInProcRunner struct {
	RepoPassword string

	CustomizeApp func(a *cli.App, kp *kingpin.Application)
}

CLIInProcRunner is a CLIRunner that invokes provided commands in the current process.

func NewInProcRunner

func NewInProcRunner(t *testing.T) *CLIInProcRunner

NewInProcRunner returns a runner that executes CLI subcommands in the current process using cli.RunSubcommand().

func (*CLIInProcRunner) Start

func (e *CLIInProcRunner) Start(t *testing.T, args []string) (stdout, stderr io.Reader, wait func() error, kill func())

Start implements CLIRunner.

type CLIRunner

type CLIRunner interface {
	Start(t *testing.T, args []string) (stdout, stderr io.Reader, wait func() error, kill func())
}

CLIRunner encapsulates running kopia subcommands for testing purposes. It supports implementations that use subprocesses or in-process invocations.

type CLITest

type CLITest struct {
	RepoDir   string
	ConfigDir string

	Runner CLIRunner

	DefaultRepositoryCreateFlags []string
	// contains filtered or unexported fields
}

CLITest encapsulates state for a CLI-based test.

func NewCLITest

func NewCLITest(t *testing.T, repoCreateFlags []string, runner CLIRunner) *CLITest

NewCLITest creates a new instance of *CLITest.

func (*CLITest) Run

func (e *CLITest) Run(t *testing.T, expectedError bool, args ...string) (stdout, stderr []string, err error)

Run executes kopia with given arguments and returns the output lines.

func (*CLITest) RunAndExpectFailure

func (e *CLITest) RunAndExpectFailure(t *testing.T, args ...string) []string

RunAndExpectFailure runs the given command, expects it to fail and returns its output lines.

func (*CLITest) RunAndExpectSuccess

func (e *CLITest) RunAndExpectSuccess(t *testing.T, args ...string) []string

RunAndExpectSuccess runs the given command, expects it to succeed and returns its output lines.

func (*CLITest) RunAndExpectSuccessWithErrOut

func (e *CLITest) RunAndExpectSuccessWithErrOut(t *testing.T, args ...string) (stdout, stderr []string)

RunAndExpectSuccessWithErrOut runs the given command, expects it to succeed and returns its stdout and stderr lines.

func (*CLITest) RunAndProcessStderr

func (e *CLITest) RunAndProcessStderr(t *testing.T, callback func(line string) bool, args ...string) (kill func())

RunAndProcessStderr runs the given command, and streams its output line-by-line to a given function until it returns false.

func (*CLITest) RunAndVerifyOutputLineCount

func (e *CLITest) RunAndVerifyOutputLineCount(t *testing.T, wantLines int, args ...string) []string

RunAndVerifyOutputLineCount runs the given command and asserts it returns the given number of output lines, then returns them.

type FakeTimeServer

type FakeTimeServer struct {
	Now func() time.Time
}

FakeTimeServer serves fake time signal to instances of Kopia.

func NewFakeTimeServer

func NewFakeTimeServer(now func() time.Time) *FakeTimeServer

NewFakeTimeServer creates new time server that serves time over HTTP and locally.

func (*FakeTimeServer) ServeHTTP

func (s *FakeTimeServer) ServeHTTP(w http.ResponseWriter, r *http.Request)