var testTimeout … var resultsDir … const archiveName … func copyKubeletConfigIfExists(kubeletConfigFile, dstDir string) error { … } // CreateTestArchive creates the archive package for the node e2e test. func CreateTestArchive(suite TestSuite, systemSpecName, kubeletConfigFile string) (string, error) { … } type RunRemoteConfig … func RunRemote(cfg RunRemoteConfig) (string, bool, error) { … } const workspaceDirPrefix … const timestampFormat … func getTimestamp() string { … } func newWorkspaceDir() string { … } // GetTimestampFromWorkspaceDir 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 GetTimestampFromWorkspaceDir(dir string) string { … } func getTestArtifacts(host, testDir string) error { … } // collectSystemLog is a temporary hack to collect system log when encountered on // unexpected error. func collectSystemLog(host string) { … } // 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. func WriteLog(host, filename, content string) error { … }