Add helpers

README.md

@@ -67,6 +67,7 @@ This API offers methods for creating, retrieving, listing and deleting resources
 |                | namespace |
 | list         | kind| returns a collection of resources of a given kind
 |                | namespace |
+| update         | spec object | updates an existing resource
 
 
 The kinds of resources currently supported are:
@@ -154,6 +155,68 @@ export default function () {
 }
 ```
 
+## Helpers
+
+The `xk6-kubernetes` extension offers helpers to facilitate common tasks when setting up a tests. All helper functions work in a namespace to facilitate the development of tests segregated by namespace. The helpers are accessed using the following method:
+
+|  Method      | Parameters|   Description |
+| -------------| ---| ------ |
+| helpers      | namespace | returns helpers that operate in the given namespace. If none is specified, "default" is used |
+
+The methods above return an object that implements the following helper functions:
+
+|  Method     | Parameters|   Description |
+| ------------ | --------| ------ |
+| getExternalIP        | service        | returns the external IP of a service if any is assigned before timeout expires|
+|                      | timeout in seconds | |
+| waitPodRunning | pod name | waits until the pod is in 'Running' state or the timeout expires. Returns a boolean indicating of the pod was ready or not. Throws an error if the pod is Failed. |
+|                | timeout in seconds | |
+| waitServiceReady         | service name | waits until the given service has at least one endpoint ready or the timeout expires |
+|                | timeout in seconds | |
+
+
+
+### Examples
+
+### Creating a pod in a random namespace and wait until it is running
+
+```javascript
+import { Kubernetes } from 'k6/x/kubernetes';
+
+let podSpec = {
+    apiVersion: "v1",
+    kind:       "Pod",
+    metadata: {
+        name:      "busybox",
+        namespace:  "default"
+    },
+    spec: {
+        containers: [
+            {
+                name:    "busybox",
+                image:   "busybox",
+                command: ["sh", "-c", "sleep 30"]
+            }
+        ]
+    }
+}
+
+export default function () {
+  const kubernetes = new Kubernetes();
+
+  // create pod
+  kubernetes.create(pod)
+
+  // get helpers for test namespace
+  const helpers = kubernetes.helpers()
+
+  // wait for pod to be running
+  const timeout = 10
+  if (!helpers.waitPodRunning(pod.metadata.name, timeout)) {
+      console.log(`"pod ${pod.metadata.name} not ready after ${timeout} seconds`)
+  }
+}
+
 ## Resource kind helpers
 
 This API offers a helper for each kind of Kubernetes resources supported (Pods, Deployments, Secrets, et cetera). For each one, an interface for creating, getting, listing and deleting objects is offered. 

examples/wait_pod_running.js

@@ -0,0 +1,40 @@
+import { Kubernetes } from 'k6/x/kubernetes';
+
+let pod = {
+    apiVersion: "v1",
+    kind:       "Pod",
+    metadata: {
+        name:      "busybox",
+        namespace:  "default"
+    },
+    spec: {
+        containers: [
+            {
+                name:    "busybox",
+                image:   "busybox",
+                command: ["sh", "-c", "sleep 30"]
+            }
+        ]
+    }
+}
+
+export default function () {
+  const kubernetes = new Kubernetes();
+
+  // create namespace with random name with prefix 'test-'
+  const ns = kubernetes.helpers().createRandomNamespace("test-")
+  //const ns = "default"
+
+  // create pod in test namespace
+  pod.metadata.namespace = ns
+  kubernetes.create(pod)
+
+  // get helpers for test namespace
+  const helpers = kubernetes.namespacedHelpers(ns)
+
+  // wait for pod to be running
+  const timeout = 10
+  if (!helpers.waitPodRunning(pod.metadata.name, timeout)) {
+      console.log(`"pod ${pod.metadata.name} not ready after ${timeout} seconds`)
+  }
+}

internal/testutils/fake.go

@@ -7,11 +7,12 @@ import (
 )
 
 // NewFakeDynamic creates a new instance of a fake dynamic client with a default scheme
-func NewFakeDynamic() (*dynamicfake.FakeDynamicClient, error) {
+func NewFakeDynamic(objs ...runtime.Object) (*dynamicfake.FakeDynamicClient, error) {
 	scheme := runtime.NewScheme()
 	err := fake.AddToScheme(scheme)
 	if err != nil {
 		return nil, err
 	}
-	return dynamicfake.NewSimpleDynamicClient(scheme), nil
+
+	return dynamicfake.NewSimpleDynamicClient(scheme, objs...), nil
 }

kubernetes_test.go

@@ -505,3 +505,47 @@ if (k8s.list(podSpec.kind, podSpec.metadata.namespace).length != 0) {
 `)
 	require.NoError(t, err)
 }
+
+// TestHelpersAreScriptable runs helpers
+func TestHelpersAreScriptable(t *testing.T) {
+	t.Parallel()
+
+	rt := setupTestEnv(t)
+
+	_, err := rt.RunString(`
+const k8s = new Kubernetes()
+
+let pod = {
+	apiVersion: "v1",
+	kind:       "Pod",
+	metadata: {
+	    name:      "busybox",
+	    namespace:  "default"
+	},
+	spec: {
+	    containers: [
+		{
+		    name:    "busybox",
+		    image:   "busybox",
+		    command: ["sh", "-c", "sleep 30"]
+		}
+	    ]
+	},
+	status: {
+		phase: "Running"
+	}
+}
+
+// create pod in test namespace
+k8s.create(pod)
+
+// get helpers for test namespace
+const helpers = k8s.helpers()
+
+// wait for pod to be running
+if (!helpers.waitPodRunning(pod.metadata.name, 5)) {
+	throw new Error("should not timeout")
+}
+`)
+	require.NoError(t, err)
+}