util

package
v0.0.0-...-f113805 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 29, 2024 License: Apache-2.0 Imports: 46 Imported by: 0

Documentation

Index

Constants

View Source 
const (

	// NodePortServiceType NodePort type of Kubernetes Service
	NodePortServiceType = "NodePort"

	// LoadBalancerServiceType LoadBalancer type of Kubernetes Service
	LoadBalancerServiceType = "LoadBalancer"
)

Variables

View Source 
var (
	// MockTestServer is used for the unit tests. Will be started once, terminated at the
	// end of the suite.
	MockTestServer *bootstrap.Server

	// MockPilotURL is the URL for the pilot http endpoint
	MockPilotURL string

	// MockPilotGrpcAddr is the address to be used for grpc connections.
	MockPilotGrpcAddr string

	// MockPilotSecureAddr is the address to be used for secure grpc connections.
	MockPilotSecureAddr string

	// MockPilotSecurePort is the secure port
	MockPilotSecurePort int

	// MockPilotHTTPPort is the dynamic port for pilot http
	MockPilotHTTPPort int

	// MockPilotGrpcPort is the dynamic port for pilot grpc
	MockPilotGrpcPort int
)
View Source 
var (
	// IstioTop has the top of the istio tree, matches the env variable from make.
	IstioTop = os.Getenv("TOP")

	// IstioSrc is the location if istio source ($TOP/src/istio.io/istio
	IstioSrc = os.Getenv("ISTIO_GO")

	// IstioBin is the location of the binary output directory
	IstioBin = os.Getenv("ISTIO_BIN")

	// IstioOut is the location of the output directory ($TOP/out)
	IstioOut = os.Getenv("ISTIO_OUT")

	// EnvoyOutWriter captures envoy output
	// Redirect out and err from envoy to buffer - coverage tests get confused if we write to out.
	// TODO: use files
	EnvoyOutWriter bytes.Buffer

	// EnvoyErrWriter captures envoy errors
	EnvoyErrWriter bytes.Buffer
)

Functions

func Backoff 

func Backoff(baseDelay, maxDelay time.Duration, retries int) time.Duration

Backoff returns a random value in [0, maxDelay] that increases exponentially with retries, starting from baseDelay. It is the Go equivalent to C++'s //util/time/backoff.cc.

func CheckDeployment 

func CheckDeployment(ctx context.Context, namespace, deployment string, kubeconfig string) error

CheckDeployment gets status of a deployment from a namespace

func CheckDeployments 

func CheckDeployments(namespace string, timeout time.Duration, kubeconfig string) error

CheckDeployments checks whether all deployment in a given namespace

func CheckDeploymentsReady 

func CheckDeploymentsReady(ns string, kubeconfig string) (int, error)

CheckDeploymentsReady checks if deployment resources are ready. get podsReady() sometimes gets pods created by the "Job" resource which never reach the "Running" steady state.

func CheckPodRunning 

func CheckPodRunning(n, name string, kubeconfig string) error

CheckPodRunning return if a given pod with labeled name in a namespace are in "Running" status

func CheckPodsRunning 

func CheckPodsRunning(n string, kubeconfig string) (ready bool)

CheckPodsRunning returns readiness of all pods within a namespace. It will wait for upto 2 mins. use WithMaxDuration to specify a duration.

func CheckPodsRunningWithMaxDuration 

func CheckPodsRunningWithMaxDuration(n string, maxDuration time.Duration, kubeconfig string) (ready bool)

CheckPodsRunningWithMaxDuration returns if all pods in a namespace are in "Running" status Also check container status to be running.

func Compare 

func Compare(out, model []byte) error

Compare compares two byte slices. It returns an error with a contextual diff if they are not equal.

func CompareFiles 

func CompareFiles(outFile, modelFile string) error

CompareFiles compares the content of two files

func CompareToFile 

func CompareToFile(out []byte, modelFile string) error

CompareToFile compares a content with a file

func CopyFile 

func CopyFile(src, dst string) error

CopyFile create a new file to src based on dst

func CreateAndFill 

func CreateAndFill(outDir, templateFile string, values interface{}) (string, error)

CreateAndFill fills in the given yaml template with the values and generates a temp file for the completed yaml.

func CreateMultiClusterSecrets 

func CreateMultiClusterSecrets(namespace string, KubeClient kubernetes.Interface, RemoteKubeConfig string, localKubeConfig string) error

CreateMultiClusterSecrets will create the secrets and configmap associated with the remote cluster

func CreateNamespace 

func CreateNamespace(n string, kubeconfig string) error

CreateNamespace create a kubernetes namespace

func CreateTLSSecret 

func CreateTLSSecret(secretName, n, keyFile, certFile string, kubeconfig string) (string, error)

CreateTLSSecret creates a secret from the provided cert and key files

func CreateTempfile 

func CreateTempfile(tmpDir, prefix, suffix string) (string, error)

CreateTempfile creates a tempfile string.

func DeleteDeployment 

func DeleteDeployment(d string, n string, kubeconfig string) error

DeleteDeployment deletes deployment from the specified namespace

func DeleteNamespace 

func DeleteNamespace(n string, kubeconfig string) error

DeleteNamespace delete a kubernetes namespace

func DownloadRelease 

func DownloadRelease(version, tmpDir string) (string, error)

DownloadRelease gets the specified release from istio repo to tmpDir.

func EnsureTestServer 

func EnsureTestServer() *bootstrap.Server

EnsureTestServer will ensure a pilot server is running in process and initializes the MockPilotUrl and MockPilotGrpcAddr to allow connections to the test pilot.

func ExtractTarGz 

func ExtractTarGz(gzipStream io.Reader) error

ExtractTarGz extracts a .tar.gz file into current dir.

func FetchAndSaveClusterLogs 

func FetchAndSaveClusterLogs(namespace string, tempDir string, kubeconfig string) error

FetchAndSaveClusterLogs will dump the logs for a cluster.

func Fill 

func Fill(outFile, inFile string, values interface{}) error

Fill complete a template with given values and generate a new output file

func GetAppPods 

func GetAppPods(n string, kubeconfig string) (map[string][]string, error)

GetAppPods gets a map of app names to the pods for the app, for the given namespace

func GetClusterSubnet 

func GetClusterSubnet() (string, error)

GetClusterSubnet returns the subnet (in CIDR form, e.g. "24") for the nodes in the cluster.

func GetConfigs 

func GetConfigs(kubeconfig string, names ...string) (string, error)

GetConfigs retrieves the configurations for the list of resources.

func GetHeadCommitSHA 

func GetHeadCommitSHA(org, repo, branch string) (string, error)

GetHeadCommitSHA finds the SHA of the commit to which the HEAD of branch points

func GetIngress 

func GetIngress(serviceName, podLabel, namespace, kubeconfig string, serviceType string) (string, error)

GetIngress get istio ingress ip and port. Could relate to either Istio Ingress or to Istio Ingress Gateway, by serviceName and podLabel. Handles two cases: when the Ingress/Ingress Gateway Kubernetes Service is a LoadBalancer or NodePort (for tests within the cluster, including for minikube)

func GetIngressPodNames 

func GetIngressPodNames(n string, kubeconfig string) ([]string, error)

GetIngressPodNames get the pod names for the Istio ingress deployment.

func GetKubeConfig 

func GetKubeConfig(filename string) error

GetKubeConfig will create a kubeconfig file based on the active environment the test is run in

func GetKubeMasterIP 

func GetKubeMasterIP() (string, error)

GetKubeMasterIP returns the IP address of the kubernetes master service. TODO update next 2 func to pass in the kubeconfig

func GetOsExt 

func GetOsExt() (string, error)

GetOsExt returns the current OS tag.

func GetPodLabelValues 

func GetPodLabelValues(n, label string, kubeconfig string) (map[string]string, error)

GetPodLabelValues gets a map of pod name to label value for the given label and namespace

func GetPodLogs 

func GetPodLogs(n, pod, container string, tail, alsoShowPreviousPodLogs bool, kubeconfig string) string

GetPodLogs retrieves the logs for the given namespace, pod and container.

func GetPodLogsForLabel 

func GetPodLogsForLabel(n, labelSelector string, container string, tail, alsoShowPreviousPodLogs bool, kubeconfig string) string

GetPodLogsForLabel gets the logs for the given label selector and container

func GetPodName 

func GetPodName(n, labelSelector string, kubeconfig string) (pod string, err error)

GetPodName gets the pod name for the given namespace and label selector

func GetPodNames 

func GetPodNames(n string) (pods []string, kubeconfig string)

GetPodNames gets names of all pods in specific namespace and return in a slice

func GetPodStatus 

func GetPodStatus(n, pod string, kubeconfig string) string

GetPodStatus gets status of a pod from a namespace Note: It is not enough to check pod phase, which only implies there is at least one container running. Use kubectl CLI to get status so that we can ensure that all containers are running.

func GetResourcePath 

func GetResourcePath(p string) string

GetResourcePath give "path from WORKSPACE", return absolute path at runtime

func GitRootDir 

func GitRootDir() (string, error)

GitRootDir returns the absolute path to the root directory of the git repo where this function is called

func HTTPDownload 

func HTTPDownload(dst string, src string) error

HTTPDownload download from src(url) and store into dst(local file)

func HelmDelete 

func HelmDelete(chartName string) error

HelmDelete helm del --purge a chart

func HelmInit 

func HelmInit(serviceAccount string) error

HelmInit init helm with a service account

func HelmInstall 

func HelmInstall(chartDir, chartName, namespace, setValue string) error

HelmInstall helm install from a chart for a given namespace 

--set stringArray        set values on the command line (can specify multiple or separate values with commas: key1=val1,key2=val2)

func HelmInstallDryRun 

func HelmInstallDryRun(chartDir, chartName, namespace, setValue string) error

HelmInstallDryRun helm install dry run from a chart for a given namespace

func IsProcessRunning 

func IsProcessRunning(p *os.Process) (bool, error)

IsProcessRunning check if a os.Process is running

func IsProcessRunningInt 

func IsProcessRunningInt(pid int) (bool, error)

IsProcessRunningInt check if a process of the given pid(int) is running

func IsProcessRunningString 

func IsProcessRunningString(pidS string) (bool, error)

IsProcessRunningString check if a process of the given pid(string) is running

func KillProcess 

func KillProcess(p *os.Process) (err error)

KillProcess kill a os.Process

func KubeApply 

func KubeApply(namespace, yamlFileName string, kubeconfig string) error

KubeApply kubectl apply from file

func KubeApplyContentSilent 

func KubeApplyContentSilent(namespace, yamlContents string, kubeconfig string) error

KubeApplyContentSilent kubectl apply from contents silently

func KubeApplyContents 

func KubeApplyContents(namespace, yamlContents string, kubeconfig string) error

KubeApplyContents kubectl apply from contents

func KubeApplySilent 

func KubeApplySilent(namespace, yamlFileName string, kubeconfig string) error

KubeApplySilent kubectl apply from file silently

func KubeDelete 

func KubeDelete(namespace, yamlFileName string, kubeconfig string) error

KubeDelete kubectl delete from file

func KubeDeleteContents 

func KubeDeleteContents(namespace, yamlContents string, kubeconfig string) error

KubeDeleteContents kubectl apply from contents

func NamespaceDeleted 

func NamespaceDeleted(n string, kubeconfig string) (bool, error)

NamespaceDeleted check if a kubernete namespace is deleted

func PodExec 

func PodExec(n, pod, container, command string, muteOutput bool, kubeconfig string) (string, error)

PodExec runs the specified command on the container for the specified namespace and pod

func Poll 

func Poll(interval time.Duration, numTrials int, do func() (bool, error)) error

Poll executes do() after time interval for a max of numTrials times. The bool returned by do() indicates if polling succeeds in that trial

func Record 

func Record(command, record string) error

Record run command and record output into a file

func RunBackground 

func RunBackground(format string, args ...interface{}) (*os.Process, error)

RunBackground starts a background process and return the Process if succeed

func RunGRPC 

func RunGRPC(port int, version, crt, key string)

RunGRPC runs the GRPC service, with optional TLS

func RunHTTP 

func RunHTTP(port int, version string)

RunHTTP runs the http echo service.

func Shell 

func Shell(format string, args ...interface{}) (string, error)

Shell run command on shell and get back output and error if get one

func ShellContext 

func ShellContext(ctx context.Context, format string, args ...interface{}) (string, error)

ShellContext run command on shell and get back output and error if get one

func ShellMuteOutput 

func ShellMuteOutput(format string, args ...interface{}) (string, error)

ShellMuteOutput run command on shell and get back output and error if get one without logging the output

func ShellSilent 

func ShellSilent(format string, args ...interface{}) (string, error)

ShellSilent runs command on shell and get back output and error if get one without logging the command or output.

func Teardown 

func Teardown()

Teardown will cleanup the temp dir and remove the test data.

func WaitForDeploymentsReady 

func WaitForDeploymentsReady(ns string, timeout time.Duration, kubeconfig string) error

WaitForDeploymentsReady wait up to 'timeout' duration return an error if deployments are not ready

func WriteTempfile 

func WriteTempfile(tmpDir, prefix, suffix, contents string) (string, error)

WriteTempfile creates a tempfile with the specified contents.

func WriteTextFile 

func WriteTextFile(filePath, content string) error

WriteTextFile overwrites the file on the given path with content

Types

type Break 

type Break struct {
	Err error
}

Break the retry loop if the error returned is of this type.

func (Break) Error 

func (e Break) Error() string

type EchoClient 

type EchoClient struct {
	// contains filtered or unexported fields
}

EchoClient controls the client

type Retrier 

type Retrier struct {
	// BaseDelay is the minimum delay between retry attempts.
	BaseDelay time.Duration
	// MaxDelay is the maximum delay allowed between retry attempts.
	MaxDelay time.Duration
	// MaxDuration is the maximum cumulative duration allowed for all retries
	MaxDuration time.Duration
	// Retries defines number of retry attempts
	Retries int
}

Retrier contains the retry configuration parameters.

func (Retrier) Retry 

func (r Retrier) Retry(ctx context.Context, fn func(ctx context.Context, retryIndex int) error) (int, error)

Retry calls the given function a number of times, unless it returns a nil or a Break

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.