Method ExecByContainer

e2e/kube/kube.go:61–78

(labelSelector, containerName, namespace string, command []string)

}

func (k *KubeHelper) ExecByContainer(labelSelector, containerName, namespace string, command []string) (string, error) {
	targetOptions := targetselector.NewOptionsFromFlags(containerName, labelSelector, nil, namespace, "").
		WithTimeout(120).
		WithWaitingStrategy(targetselector.NewUntilNewestRunningWaitingStrategy(time.Second * 2))

	globalTargetSelector := targetselector.NewTargetSelector(targetOptions)
	container, err := globalTargetSelector.SelectSingleContainer(context.TODO(), k.client, log.Discard)
	if err != nil {
		return "", err
	}

	stdout, stderr, err := k.client.ExecBuffered(context.TODO(), container.Pod, container.Container.Name, command, nil)
	if err != nil {
		return "", fmt.Errorf("exec error: %v %s", err, string(stderr))
	}

	return string(stdout), nil
}

func (k *KubeHelper) CreateNamespace(name string) (string, error) {
	name = strings.ToLower(name + "-" + randutil.GenerateRandomString(5))