remote

Documentation

Overview

Package remote contains implementations of the TestSuite interface, which specify how to run various node test suites remotely.

Index

• func AddHostnameIp(hostname, ip string)
• func CreateTestArchive(suite TestSuite, systemSpecName string) (string, error)
• func GetHostnameOrIp(hostname string) string
• func GetTimestampFromWorkspaceDir(dir string) string
• func RunRemote(suite TestSuite, archive string, host string, cleanup bool, ...) (string, bool, error)
• func SSH(host string, cmd ...string) (string, error)
• func SSHNoSudo(host string, cmd ...string) (string, error)
• func WriteLog(host, filename, content string) error
• type CAdvisorE2ERemote
  • func (n *CAdvisorE2ERemote) RunTest(...) (string, error)
  • func (n *CAdvisorE2ERemote) SetupTestPackage(tardir, systemSpecName string) error
• type ConformanceRemote
  • func (c *ConformanceRemote) RunTest(host, workspace, results, imageDesc, junitFilePrefix, testArgs, _, ... string, ...) (string, error)
  • func (c *ConformanceRemote) SetupTestPackage(tardir, systemSpecName string) error
• type NodeE2ERemote
  • func (n *NodeE2ERemote) RunTest(...) (string, error)
  • func (n *NodeE2ERemote) SetupTestPackage(tardir, systemSpecName string) error
• type TestSuite
  • func InitCAdvisorE2ERemote() TestSuite
  • func InitConformanceRemote() TestSuite
  • func InitNodeE2ERemote() TestSuite

Functions

func AddHostnameIp

func AddHostnameIp(hostname, ip string)

func CreateTestArchive

func CreateTestArchive(suite TestSuite, systemSpecName string) (string, error)

func GetHostnameOrIp

func GetHostnameOrIp(hostname string) string

GetHostnameOrIp converts hostname into ip and apply user if necessary.

func GetTimestampFromWorkspaceDir

func GetTimestampFromWorkspaceDir(dir string) string

Parses the workspace directory name and gets the timestamp part of it. This can later be used to name other artifacts (such as the kubelet-${instance}.service systemd transient service used to launch Kubelet) so that they can be matched to each other.

func RunRemote

func RunRemote(suite TestSuite, archive string, host string, cleanup bool, imageDesc, junitFilePrefix string, testArgs string, ginkgoArgs string, systemSpecName string) (string, bool, error)

Returns the command output, whether the exit was ok, and any errors TODO(random-liu): junitFilePrefix is not prefix actually, the file name is junit-junitFilePrefix.xml. Change the variable name.

func SSH

func SSH(host string, cmd ...string) (string, error)

SSH executes ssh command with runSSHCommand as root. The `sudo` makes sure that all commands are executed by root, so that there won't be permission mismatch between different commands.

func SSHNoSudo

func SSHNoSudo(host string, cmd ...string) (string, error)

SSHNoSudo executes ssh command with runSSHCommand as normal user. Sometimes we need this, for example creating a directory that we'll copy files there with scp.

func WriteLog

func WriteLog(host, filename, content string) error

WriteLog is a temporary function to make it possible to write log in the runner. This is used to collect serial console log. TODO(random-liu): Use the log-dump script in cluster e2e.

Types

type CAdvisorE2ERemote

type CAdvisorE2ERemote struct{}

CAdvisorE2ERemote contains the specific functions in the cadvisor e2e test suite.

func (*CAdvisorE2ERemote) RunTest

func (n *CAdvisorE2ERemote) RunTest(host, workspace, results, imageDesc, junitFilePrefix, testArgs, ginkgoArgs, systemSpecName string, timeout time.Duration) (string, error)

RunTest implements TestSuite.RunTest

func (*CAdvisorE2ERemote) SetupTestPackage

func (n *CAdvisorE2ERemote) SetupTestPackage(tardir, systemSpecName string) error

SetupTestPackage implements TestSuite.SetupTestPackage

type ConformanceRemote

type ConformanceRemote struct{}

ConformanceRemote contains the specific functions in the node conformance test suite.

func (*ConformanceRemote) RunTest

func (c *ConformanceRemote) RunTest(host, workspace, results, imageDesc, junitFilePrefix, testArgs, _, systemSpecName string, timeout time.Duration) (string, error)

RunTest runs test on the node.

func (*ConformanceRemote) SetupTestPackage

func (c *ConformanceRemote) SetupTestPackage(tardir, systemSpecName string) error

SetupTestPackage sets up the test package with binaries k8s required for node conformance test

type NodeE2ERemote

type NodeE2ERemote struct{}

NodeE2ERemote contains the specific functions in the node e2e test suite.

func (*NodeE2ERemote) RunTest

func (n *NodeE2ERemote) RunTest(host, workspace, results, imageDesc, junitFilePrefix, testArgs, ginkgoArgs, systemSpecName string, timeout time.Duration) (string, error)

RunTest runs test on the node.

func (*NodeE2ERemote) SetupTestPackage

func (n *NodeE2ERemote) SetupTestPackage(tardir, systemSpecName string) error

SetupTestPackage sets up the test package with binaries k8s required for node e2e tests

type TestSuite

type TestSuite interface {
	// SetupTestPackage setup the test package in the given directory. TestSuite
	// should put all necessary binaries and dependencies into the path. The caller
	// will:
	// * create a tarball with the directory.
	// * deploy the tarball to the testing host.
	// * untar the tarball to the testing workspace on the testing host.
	SetupTestPackage(path, systemSpecName string) error
	// RunTest runs test on the node in the given workspace and returns test output
	// and test error if there is any.
	// * host is the target node to run the test.
	// * workspace is the directory on the testing host the test is running in. Note
	//   that the test package is unpacked in the workspace before running the test.
	// * results is the directory the test should write result into. All logs should be
	//   saved as *.log, all junit file should start with junit*.
	// * imageDesc is the description of the image the test is running on.
	//   It will be used for logging purpose only.
	// * junitFilePrefix is the prefix of output junit file.
	// * testArgs is the arguments passed to test.
	// * ginkgoArgs is the arguments passed to ginkgo.
	// * systemSpecName is the name of the system spec used for validating the
	//   image on which the test runs.
	// * timeout is the test timeout.
	RunTest(host, workspace, results, imageDesc, junitFilePrefix, testArgs, ginkgoArgs, systemSpecName string, timeout time.Duration) (string, error)
}

TestSuite is the interface of a test suite, such as node e2e, node conformance, node soaking, cri validation etc.

func InitCAdvisorE2ERemote

func InitCAdvisorE2ERemote() TestSuite

InitCAdvisorE2ERemote performs initialization for cadvisor remote testing

func InitConformanceRemote

func InitConformanceRemote() TestSuite

func InitNodeE2ERemote

func InitNodeE2ERemote() TestSuite