testing

package

v0.0.1 Latest Latest Go to latest Published: Sep 25, 2020 License: Apache-2.0 Imports: 15 Imported by: 1

Documentation ¶

Index ¶

Constants
func Apply(namespace string, yamlFilePath string) error
func Create(namespace string, yamlFilePath string) error
func CreateNamespace(name string) error
func CreateSecretFromLiteral(namespace string, secretName string, literalValues map[string]string) error
func Delete(namespace string, yamlFilePath string) error
func DeleteLabelFilter(namespace string, resourceName string, labelName string) error
func DeleteNamespace(ns string) error
func DeleteResource(namespace string, resourceName string, name string) error
func DeleteSecret(namespace string, secretName string) error
func DeleteWebhooks(ns string) error
func GetData(namespace string, resourceName string, name string, templatePath string) ([]byte, error)
func HelmBinaryVersion() (string, error)
func NewContext() context.Context
func PatchNamespace(name string, patch string) error
func RestartOperator(namespace string) error
func RunCommandWithOutput(namespace string, podName string, commandInPod string) (string, error)
func RunHelmBinaryWithCustomErr(args ...string) error
func SecretCheckData(namespace string, secretName string, fieldPath string) error
func TriggerQJob(namespace, qjob string) error
type BDPL
type ClusterCrd
- func GetCRDs() (*ClusterCrd, error)
- func (c *ClusterCrd) ContainsElement(element string) bool
type ConfigMap
type CustomError
- func (e *CustomError) Error() string
type Kubectl
- func NewKubectl() *Kubectl
- func (k *Kubectl) ApplyYAML(namespace string, name string, v interface{}) error
- func (k *Kubectl) CreateRoleBinding(namespace string, clusterrole, serviceaccount, role string) error
- func (k *Kubectl) CreateServiceAccount(namespace string, serviceaccount string) error
- func (k *Kubectl) Delete(args ...string) error
- func (k *Kubectl) DeleteRoleBinding(namespace string, role string) error
- func (k *Kubectl) DeleteServiceAccount(namespace string, serviceaccount string) error
- func (k *Kubectl) Exists(namespace, resource, name string) (bool, error)
- func (k *Kubectl) GetBoshDeployment(namespace string, name string) (BDPL, error)
- func (k *Kubectl) GetConfigMap(namespace string, name string) (ConfigMap, error)
- func (k *Kubectl) GetPodNames(namespace string, selector string) ([]string, error)
- func (k *Kubectl) PodExists(namespace string, labelName string, podName string) (bool, error)
- func (k *Kubectl) PodStatus(namespace string, podName string) (*v1.PodStatus, error)
- func (k *Kubectl) RunCommandWithCheckString(namespace string, podName string, commandInPod string, result string) error
- func (k *Kubectl) SecretExists(namespace string, secretName string) (bool, error)
- func (k *Kubectl) Service(namespace string, serviceName string) (v1.Service, error)
- func (k *Kubectl) ServiceExists(namespace string, serviceName string) (bool, error)
- func (k *Kubectl) Wait(namespace string, requiredStatus string, resourceName string, ...) error
- func (k *Kubectl) WaitForData(namespace string, resourceName string, name string, template string, ...) error
- func (k *Kubectl) WaitForPVC(namespace string, pvcName string) error
- func (k *Kubectl) WaitForPod(namespace string, labelName string, podName string) error
- func (k *Kubectl) WaitForPodDelete(namespace string, podName string) error
- func (k *Kubectl) WaitForSecret(namespace string, secretName string) error
- func (k *Kubectl) WaitForService(namespace string, serviceName string) error
- func (k *Kubectl) WaitLabelFilter(namespace string, requiredStatus string, resourceName string, labelName string) error

Constants ¶

const (
	// CFOperatorRelease is the default cf-operator release name
	CFOperatorRelease = "cf-operator"
)

Variables ¶

This section is empty.

Functions ¶

func Apply ¶

func Apply(namespace string, yamlFilePath string) error

Apply updates the resource using kubectl command

func Create ¶

func Create(namespace string, yamlFilePath string) error

Create creates the resource using kubectl command

func CreateNamespace ¶

func CreateNamespace(name string) error

CreateNamespace create the namespace using kubectl command

func CreateSecretFromLiteral ¶

func CreateSecretFromLiteral(namespace string, secretName string, literalValues map[string]string) error

CreateSecretFromLiteral creates a generic type secret using kubectl command

func Delete ¶

func Delete(namespace string, yamlFilePath string) error

Delete creates the resource using kubectl command

func DeleteLabelFilter ¶

func DeleteLabelFilter(namespace string, resourceName string, labelName string) error

DeleteLabelFilter deletes the resource based on label using kubectl command

func DeleteNamespace ¶

func DeleteNamespace(ns string) error

DeleteNamespace removes existing ns

func DeleteResource ¶

func DeleteResource(namespace string, resourceName string, name string) error

DeleteResource deletes the resource using kubectl command

func DeleteSecret ¶

func DeleteSecret(namespace string, secretName string) error

DeleteSecret deletes the namespace using kubectl command

func DeleteWebhooks ¶

func DeleteWebhooks(ns string) error

DeleteWebhooks removes existing webhookconfiguration and validatingwebhookconfiguration

func GetData ¶

func GetData(namespace string, resourceName string, name string, templatePath string) ([]byte, error)

GetData fetches the specified output by the given templatePath

func HelmBinaryVersion ¶

func HelmBinaryVersion() (string, error)

HelmBinaryVersion executes helm version and return 2 or 3

func NewContext ¶

func NewContext() context.Context

NewContext returns a non-nil empty context, for usage when it is unclear which context to use. Mostly used in tests.

func PatchNamespace ¶

func PatchNamespace(name string, patch string) error

PatchNamespace patche the namespace resource using kubectl command

func RestartOperator ¶

func RestartOperator(namespace string) error

RestartOperator restart Operator Deployment

func RunCommandWithOutput ¶

func RunCommandWithOutput(namespace string, podName string, commandInPod string) (string, error)

RunCommandWithOutput runs the command specified in the container and returns output

func RunHelmBinaryWithCustomErr ¶

func RunHelmBinaryWithCustomErr(args ...string) error

RunHelmBinaryWithCustomErr executes a desire binary

func SecretCheckData ¶

func SecretCheckData(namespace string, secretName string, fieldPath string) error

SecretCheckData checks the field specified in the given field

func TriggerQJob ¶

func TriggerQJob(namespace, qjob string) error

TriggerQJob triggers a qjob

Types ¶

type BDPL ¶

type BDPL struct {
	APIVersion string `json:"apiVersion" yaml:"apiVersion"`
	Kind       string `json:"kind" yaml:"kind"`
	Metadata   struct {
		Name string `json:"name" yaml:"name"`
	} `json:"metadata" yaml:"metadata"`
	Spec struct {
		Manifest map[string]string   `json:"manifest" yaml:"manifest"`
		Ops      []map[string]string `json:"ops" yaml:"ops"`
	} `json:"spec" yaml:"spec"`
}

BDPL defines a bdpl

type ClusterCrd ¶

type ClusterCrd struct {
	Items []struct {
		APIVersion string `json:"apiVersion"`
		Kind       string `json:"kind"`
		Metadata   struct {
			Name string `json:"name"`
		} `json:"metadata"`
	} `json:"items"`
}

ClusterCrd defines a list of CRDs

func GetCRDs ¶

func GetCRDs() (*ClusterCrd, error)

GetCRDs returns all CRDs

func (*ClusterCrd) ContainsElement ¶

func (c *ClusterCrd) ContainsElement(element string) bool

ContainsElement verify if a CRD exist

type ConfigMap ¶

type ConfigMap struct {
	APIVersion string `json:"apiVersion" yaml:"apiVersion"`
	Kind       string `json:"kind" yaml:"kind"`
	Metadata   struct {
		Name string `json:"name" yaml:"name"`
	} `json:"metadata" yaml:"metadata"`
	Data map[string]string `json:"data" yaml:"data"`
}

ConfigMap defines a kube ConfigMap

type CustomError ¶

type CustomError struct {
	Msg    string
	StdOut string
	Err    error
}

CustomError containing stdOutput of a binary execution

func (*CustomError) Error ¶

func (e *CustomError) Error() string

type Kubectl ¶

type Kubectl struct {
	Log         *zap.SugaredLogger
	Namespace   string
	PollTimeout time.Duration
	// contains filtered or unexported fields
}

Kubectl is used as a command to test e2e tests

func NewKubectl ¶

func NewKubectl() *Kubectl

NewKubectl returns a new CfOperatorkubectl command

func (*Kubectl) ApplyYAML ¶

func (k *Kubectl) ApplyYAML(namespace string, name string, v interface{}) error

ApplyYAML applies arbitrary interfaces with kubectl.

func (*Kubectl) CreateRoleBinding ¶

func (k *Kubectl) CreateRoleBinding(namespace string, clusterrole, serviceaccount, role string) error

CreateRoleBinding Create a new rolebinding in a namespace from a cluster role

func (*Kubectl) CreateServiceAccount ¶

func (k *Kubectl) CreateServiceAccount(namespace string, serviceaccount string) error

CreateServiceAccount Create a new serviceaccount in a namespace

func (*Kubectl) Delete ¶

func (k *Kubectl) Delete(args ...string) error

Delete calls kubectl with the given arguments

func (*Kubectl) DeleteRoleBinding ¶

func (k *Kubectl) DeleteRoleBinding(namespace string, role string) error

DeleteRoleBinding Deletes a rolebinding in a namespace

func (*Kubectl) DeleteServiceAccount ¶

func (k *Kubectl) DeleteServiceAccount(namespace string, serviceaccount string) error

DeleteServiceAccount Deletes a serviceaccount in a namespace

func (*Kubectl) Exists ¶

func (k *Kubectl) Exists(namespace, resource, name string) (bool, error)

Exists returns true if the resource by that name exists

func (*Kubectl) GetBoshDeployment ¶

func (k *Kubectl) GetBoshDeployment(namespace string, name string) (BDPL, error)

GetBoshDeployment returns a BDPL

func (*Kubectl) GetConfigMap ¶

func (k *Kubectl) GetConfigMap(namespace string, name string) (ConfigMap, error)

GetConfigMap blocks until the specified data is available. It fails after the timeout.

func (*Kubectl) GetPodNames ¶

func (k *Kubectl) GetPodNames(namespace string, selector string) ([]string, error)

GetPodNames returns the names of the pods matching the selector

func (*Kubectl) PodExists ¶

func (k *Kubectl) PodExists(namespace string, labelName string, podName string) (bool, error)

PodExists returns true if the pod by that label is present

func (*Kubectl) PodStatus ¶

func (k *Kubectl) PodStatus(namespace string, podName string) (*v1.PodStatus, error)

PodStatus returns the status if the pod by that label is present

func (*Kubectl) RunCommandWithCheckString ¶

func (k *Kubectl) RunCommandWithCheckString(namespace string, podName string, commandInPod string, result string) error

RunCommandWithCheckString runs the command specified helper in the container

func (*Kubectl) SecretExists ¶

func (k *Kubectl) SecretExists(namespace string, secretName string) (bool, error)

SecretExists returns true if the pod by that name is in state running

func (*Kubectl) Service ¶

func (k *Kubectl) Service(namespace string, serviceName string) (v1.Service, error)

Service returns the service if serviceName exists.

func (*Kubectl) ServiceExists ¶

func (k *Kubectl) ServiceExists(namespace string, serviceName string) (bool, error)

ServiceExists returns true if the pod by that name is in state running

func (*Kubectl) Wait ¶

func (k *Kubectl) Wait(namespace string, requiredStatus string, resourceName string, customTimeout time.Duration) error

Wait waits for the condition on the resource using kubectl command

func (*Kubectl) WaitForData ¶

func (k *Kubectl) WaitForData(namespace string, resourceName string, name string, template string, expectation string) error

WaitForData blocks until the specified data is available. It fails after the timeout.

func (*Kubectl) WaitForPVC ¶

func (k *Kubectl) WaitForPVC(namespace string, pvcName string) error

WaitForPVC blocks until the pvc is available. It fails after the timeout.

func (*Kubectl) WaitForPod ¶

func (k *Kubectl) WaitForPod(namespace string, labelName string, podName string) error

WaitForPod blocks until the pod is available. It fails after the timeout.

func (*Kubectl) WaitForPodDelete ¶

func (k *Kubectl) WaitForPodDelete(namespace string, podName string) error

WaitForPodDelete blocks until the pod is available. It fails after the timeout.

func (*Kubectl) WaitForSecret ¶

func (k *Kubectl) WaitForSecret(namespace string, secretName string) error

WaitForSecret blocks until the secret is available. It fails after the timeout.

func (*Kubectl) WaitForService ¶

func (k *Kubectl) WaitForService(namespace string, serviceName string) error

WaitForService blocks until the service is available. It fails after the timeout.

func (*Kubectl) WaitLabelFilter ¶

func (k *Kubectl) WaitLabelFilter(namespace string, requiredStatus string, resourceName string, labelName string) error

WaitLabelFilter waits for the condition on the resource based on label using kubectl command

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
e2ehelper
integration
machine
testhelper

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