f10a16aed7
* Rename VK to chewong for development purpose * Rename basic_test.go to basic.go * Add e2e.go and suite.go * Disable tests in node.go * End to end tests are now importable as a testing suite * Remove 'test' from test files * Add documentations * Rename chewong back to virtual-kubelet * Change 'Testing Suite' to 'Test Suite' * Add the ability to skip certain testss * Add unit tests for suite.go * Add README.md for importable e2e test suite * VK implementation has to be based on VK v1.0.0 * Stricter checks on validating test functions * Move certain files back to internal folder * Add WatchTimeout as a config field * Add slight modifications
62 lines
1.6 KiB
Go
62 lines
1.6 KiB
Go
package e2e
|
|
|
|
import (
|
|
"context"
|
|
"testing"
|
|
"time"
|
|
|
|
"gotest.tools/assert"
|
|
is "gotest.tools/assert/cmp"
|
|
v1 "k8s.io/api/core/v1"
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
"k8s.io/apimachinery/pkg/fields"
|
|
watchapi "k8s.io/apimachinery/pkg/watch"
|
|
)
|
|
|
|
// TestNodeCreateAfterDelete makes sure that a node is automatically recreated
|
|
// if it is deleted while VK is running.
|
|
func (ts *EndToEndTestSuite) TestNodeCreateAfterDelete(t *testing.T) {
|
|
ctx, cancel := context.WithCancel(context.Background())
|
|
defer cancel()
|
|
|
|
podList, err := f.KubeClient.CoreV1().Pods(f.Namespace).List(metav1.ListOptions{
|
|
FieldSelector: fields.OneTermEqualSelector("spec.nodeName", f.NodeName).String(),
|
|
})
|
|
|
|
assert.NilError(t, err)
|
|
assert.Assert(t, is.Len(podList.Items, 0), "Kubernetes does not allow node deletion with dependent objects (pods) in existence: %v")
|
|
|
|
chErr := make(chan error, 1)
|
|
|
|
originalNode, err := f.GetNode()
|
|
assert.NilError(t, err)
|
|
|
|
ctx, cancel = context.WithTimeout(ctx, time.Minute)
|
|
defer cancel()
|
|
|
|
go func() {
|
|
wait := func(e watchapi.Event) (bool, error) {
|
|
err = ctx.Err()
|
|
// Our timeout has expired
|
|
if err != nil {
|
|
return true, err
|
|
}
|
|
if e.Type == watchapi.Deleted || e.Type == watchapi.Error {
|
|
return false, nil
|
|
}
|
|
|
|
return originalNode.ObjectMeta.UID != e.Object.(*v1.Node).ObjectMeta.UID, nil
|
|
}
|
|
chErr <- f.WaitUntilNodeCondition(wait)
|
|
}()
|
|
|
|
assert.NilError(t, f.DeleteNode())
|
|
|
|
select {
|
|
case result := <-chErr:
|
|
assert.NilError(t, result, "Did not observe new node object created after deletion")
|
|
case <-ctx.Done():
|
|
t.Fatal("Test timed out while waiting for node object to be deleted / recreated")
|
|
}
|
|
}
|