e2e

package

v1.26.3-rke2r1-build20... Latest Latest Go to latest Published: Mar 17, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/rancher/rke2

Documentation ¶

Index ¶

func CountOfStringInSlice(str string, pods []Pod) int
func CreateCluster(nodeOS string, serverCount int, agentCount int) ([]string, []string, error)
func DeleteWorkload(workload, kubeconfig string) error
func DeployWorkload(workload string, kubeconfig string) (string, error)
func DestroyCluster() error
func FetchClusterIP(kubeconfig string, servicename string, dualStack bool) (string, error)
func FetchIngressIP(kubeconfig string) ([]string, error)
func FetchNodeExternalIP(nodename string) (string, error)
func GenKubeConfigFile(serverName string) (string, error)
func GenReport(specReport ginkgo.SpecReport)
func GetVagrantLog(cErr error) string
func PodIPsUsingLabel(kubeConfigFile string, label string) ([]string, error)
func RestartCluster(nodeNames []string) error
func RunCmdOnNode(cmd string, nodename string) (string, error)
func RunCommand(cmd string) (string, error)
func UpgradeCluster(serverNodenames []string, agentNodenames []string) error
type Node
- func ParseNodes(kubeConfig string, print bool) ([]Node, error)
type NodeError
- func (ne *NodeError) Error() string
- func (ne *NodeError) Unwrap() error
type Pod
- func ParsePods(kubeconfig string, print bool) ([]Pod, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CountOfStringInSlice ¶

func CountOfStringInSlice(str string, pods []Pod) int

func CreateCluster ¶

func CreateCluster(nodeOS string, serverCount int, agentCount int) ([]string, []string, error)

func DeleteWorkload ¶

func DeleteWorkload(workload, kubeconfig string) error

DeleteWorkload Deletes the content of a manifest file previously applied

func DeployWorkload ¶

func DeployWorkload(workload string, kubeconfig string) (string, error)

func DestroyCluster ¶

func DestroyCluster() error

func FetchClusterIP ¶

func FetchClusterIP(kubeconfig string, servicename string, dualStack bool) (string, error)

func FetchIngressIP ¶

func FetchIngressIP(kubeconfig string) ([]string, error)

func FetchNodeExternalIP ¶

func FetchNodeExternalIP(nodename string) (string, error)

func GenKubeConfigFile ¶

func GenKubeConfigFile(serverName string) (string, error)

func GenReport ¶

func GenReport(specReport ginkgo.SpecReport)

GenReport returns the relevant lines from test results in json format

func GetVagrantLog ¶

func GetVagrantLog(cErr error) string

GetVagrantLog returns the logs of on vagrant commands that initialize the nodes and provision RKE2 on each node. It also attempts to fetch the systemctl logs of RKE2 on nodes where the rke2.service failed.

func PodIPsUsingLabel ¶

func PodIPsUsingLabel(kubeConfigFile string, label string) ([]string, error)

PodIPsUsingLabel returns the IPs of the pods with a label (only single-stack supported)

func RestartCluster ¶

func RestartCluster(nodeNames []string) error

RestartCluster restarts the rke2 service on each server-agent given

func RunCmdOnNode ¶

func RunCmdOnNode(cmd string, nodename string) (string, error)

RunCmdOnNode executes a command from within the given node

func RunCommand ¶

func RunCommand(cmd string) (string, error)

RunCommand execute a command on the host

func UpgradeCluster ¶

func UpgradeCluster(serverNodenames []string, agentNodenames []string) error

Types ¶

type Node ¶

type Node struct {
	Name       string
	Status     string
	Roles      string
	InternalIP string
	ExternalIP string
}

func ParseNodes ¶

func ParseNodes(kubeConfig string, print bool) ([]Node, error)

type NodeError ¶

type NodeError struct {
	Node string
	Cmd  string
	Err  error
}

func (*NodeError) Error ¶

func (ne *NodeError) Error() string

func (*NodeError) Unwrap ¶

func (ne *NodeError) Unwrap() error

type Pod ¶

type Pod struct {
	NameSpace string
	Name      string
	Ready     string
	Status    string
	Restarts  string
	NodeIP    string
	Node      string
}

func ParsePods ¶

func ParsePods(kubeconfig string, print bool) ([]Pod, error)

Source Files ¶

View all Source files

testutils.go

Directories ¶

Path	Synopsis
createreport

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL