Add test for helmfile-destroy with selector (#1785)
* Add test for helmfile-destroy with selector I was curious if destroy with a selector is working at all while reading https://github.com/roboll/helmfile/issues/1750#issuecomment-823521572. So I added this test for verification. From the test result, it is working, though. * Add one more test case for destroying disabled but installed release
This commit is contained in:
Yusuke Kuoka
GitHub
parent
5d43b30a7c
commit
5617b593c8
|
|
@ -3,15 +3,16 @@ package app
|
||||||
import (
|
import (
|
||||||
"bufio"
|
"bufio"
|
||||||
"bytes"
|
"bytes"
|
||||||
|
"io"
|
||||||
|
"path/filepath"
|
||||||
|
"sync"
|
||||||
|
"testing"
|
||||||
|
|
||||||
"github.com/roboll/helmfile/pkg/exectest"
|
"github.com/roboll/helmfile/pkg/exectest"
|
||||||
"github.com/roboll/helmfile/pkg/helmexec"
|
"github.com/roboll/helmfile/pkg/helmexec"
|
||||||
"github.com/roboll/helmfile/pkg/testhelper"
|
"github.com/roboll/helmfile/pkg/testhelper"
|
||||||
"github.com/variantdev/vals"
|
"github.com/variantdev/vals"
|
||||||
"go.uber.org/zap"
|
"go.uber.org/zap"
|
||||||
"io"
|
|
||||||
"path/filepath"
|
|
||||||
"sync"
|
|
||||||
"testing"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
type destroyConfig struct {
|
type destroyConfig struct {
|
||||||
|
|
@ -38,9 +39,7 @@ func (d destroyConfig) Concurrency() int {
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestDestroy(t *testing.T) {
|
func TestDestroy(t *testing.T) {
|
||||||
testcases := []struct {
|
type testcase struct {
|
||||||
name string
|
|
||||||
loc string
|
|
||||||
ns string
|
ns string
|
||||||
concurrency int
|
concurrency int
|
||||||
error string
|
error string
|
||||||
|
|
@ -51,14 +50,135 @@ func TestDestroy(t *testing.T) {
|
||||||
upgraded []exectest.Release
|
upgraded []exectest.Release
|
||||||
deleted []exectest.Release
|
deleted []exectest.Release
|
||||||
log string
|
log string
|
||||||
}{
|
}
|
||||||
//
|
|
||||||
// complex test cases for smoke testing
|
check := func(t *testing.T, tc testcase) {
|
||||||
//
|
t.Helper()
|
||||||
{
|
|
||||||
name: "smoke",
|
wantUpgrades := tc.upgraded
|
||||||
loc: location(),
|
wantDeletes := tc.deleted
|
||||||
files: map[string]string{
|
|
||||||
|
var helm = &exectest.Helm{
|
||||||
|
FailOnUnexpectedList: true,
|
||||||
|
FailOnUnexpectedDiff: true,
|
||||||
|
Lists: tc.lists,
|
||||||
|
Diffs: tc.diffs,
|
||||||
|
DiffMutex: &sync.Mutex{},
|
||||||
|
ChartsMutex: &sync.Mutex{},
|
||||||
|
ReleasesMutex: &sync.Mutex{},
|
||||||
|
}
|
||||||
|
|
||||||
|
bs := &bytes.Buffer{}
|
||||||
|
|
||||||
|
func() {
|
||||||
|
t.Helper()
|
||||||
|
|
||||||
|
logReader, logWriter := io.Pipe()
|
||||||
|
|
||||||
|
logFlushed := &sync.WaitGroup{}
|
||||||
|
// Ensure all the log is consumed into `bs` by calling `logWriter.Close()` followed by `logFlushed.Wait()`
|
||||||
|
logFlushed.Add(1)
|
||||||
|
go func() {
|
||||||
|
scanner := bufio.NewScanner(logReader)
|
||||||
|
for scanner.Scan() {
|
||||||
|
bs.Write(scanner.Bytes())
|
||||||
|
bs.WriteString("\n")
|
||||||
|
}
|
||||||
|
logFlushed.Done()
|
||||||
|
}()
|
||||||
|
|
||||||
|
defer func() {
|
||||||
|
// This is here to avoid data-trace on bytes buffer `bs` to capture logs
|
||||||
|
if err := logWriter.Close(); err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
logFlushed.Wait()
|
||||||
|
}()
|
||||||
|
|
||||||
|
logger := helmexec.NewLogger(logWriter, "debug")
|
||||||
|
|
||||||
|
valsRuntime, err := vals.New(vals.Options{CacheSize: 32})
|
||||||
|
if err != nil {
|
||||||
|
t.Errorf("unexpected error creating vals runtime: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
app := appWithFs(&App{
|
||||||
|
OverrideHelmBinary: DefaultHelmBinary,
|
||||||
|
glob: filepath.Glob,
|
||||||
|
abs: filepath.Abs,
|
||||||
|
OverrideKubeContext: "default",
|
||||||
|
Env: "default",
|
||||||
|
Logger: logger,
|
||||||
|
helms: map[helmKey]helmexec.Interface{
|
||||||
|
createHelmKey("helm", "default"): helm,
|
||||||
|
},
|
||||||
|
valsRuntime: valsRuntime,
|
||||||
|
}, tc.files)
|
||||||
|
|
||||||
|
if tc.ns != "" {
|
||||||
|
app.Namespace = tc.ns
|
||||||
|
}
|
||||||
|
|
||||||
|
if tc.selectors != nil {
|
||||||
|
app.Selectors = tc.selectors
|
||||||
|
}
|
||||||
|
|
||||||
|
destroyErr := app.Destroy(destroyConfig{
|
||||||
|
// if we check log output, concurrency must be 1. otherwise the test becomes non-deterministic.
|
||||||
|
concurrency: tc.concurrency,
|
||||||
|
logger: logger,
|
||||||
|
})
|
||||||
|
|
||||||
|
if tc.error == "" && destroyErr != nil {
|
||||||
|
t.Fatalf("unexpected error: %v", destroyErr)
|
||||||
|
} else if tc.error != "" && destroyErr == nil {
|
||||||
|
t.Fatal("expected error did not occur")
|
||||||
|
} else if tc.error != "" && destroyErr != nil && tc.error != destroyErr.Error() {
|
||||||
|
t.Fatalf("invalid error: expected %q, got %q", tc.error, destroyErr.Error())
|
||||||
|
}
|
||||||
|
|
||||||
|
if len(wantUpgrades) > len(helm.Releases) {
|
||||||
|
t.Fatalf("insufficient number of upgrades: got %d, want %d", len(helm.Releases), len(wantUpgrades))
|
||||||
|
}
|
||||||
|
|
||||||
|
for relIdx := range wantUpgrades {
|
||||||
|
if wantUpgrades[relIdx].Name != helm.Releases[relIdx].Name {
|
||||||
|
t.Errorf("releases[%d].name: got %q, want %q", relIdx, helm.Releases[relIdx].Name, wantUpgrades[relIdx].Name)
|
||||||
|
}
|
||||||
|
for flagIdx := range wantUpgrades[relIdx].Flags {
|
||||||
|
if wantUpgrades[relIdx].Flags[flagIdx] != helm.Releases[relIdx].Flags[flagIdx] {
|
||||||
|
t.Errorf("releaes[%d].flags[%d]: got %v, want %v", relIdx, flagIdx, helm.Releases[relIdx].Flags[flagIdx], wantUpgrades[relIdx].Flags[flagIdx])
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if len(wantDeletes) > len(helm.Deleted) {
|
||||||
|
t.Fatalf("insufficient number of deletes: got %d, want %d", len(helm.Deleted), len(wantDeletes))
|
||||||
|
}
|
||||||
|
|
||||||
|
for relIdx := range wantDeletes {
|
||||||
|
if wantDeletes[relIdx].Name != helm.Deleted[relIdx].Name {
|
||||||
|
t.Errorf("releases[%d].name: got %q, want %q", relIdx, helm.Deleted[relIdx].Name, wantDeletes[relIdx].Name)
|
||||||
|
}
|
||||||
|
for flagIdx := range wantDeletes[relIdx].Flags {
|
||||||
|
if wantDeletes[relIdx].Flags[flagIdx] != helm.Deleted[relIdx].Flags[flagIdx] {
|
||||||
|
t.Errorf("releaes[%d].flags[%d]: got %v, want %v", relIdx, flagIdx, helm.Deleted[relIdx].Flags[flagIdx], wantDeletes[relIdx].Flags[flagIdx])
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}()
|
||||||
|
|
||||||
|
if tc.log != "" {
|
||||||
|
actual := bs.String()
|
||||||
|
|
||||||
|
diff, exists := testhelper.Diff(tc.log, actual, 3)
|
||||||
|
if exists {
|
||||||
|
t.Errorf("unexpected log:\nDIFF\n%s\nEOD", diff)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
files := map[string]string{
|
||||||
"/path/to/helmfile.yaml": `
|
"/path/to/helmfile.yaml": `
|
||||||
releases:
|
releases:
|
||||||
- name: database
|
- name: database
|
||||||
|
|
@ -114,7 +234,27 @@ releases:
|
||||||
- name: front-proxy
|
- name: front-proxy
|
||||||
chart: stable/envoy
|
chart: stable/envoy
|
||||||
`,
|
`,
|
||||||
},
|
}
|
||||||
|
|
||||||
|
filesForTwoReleases := map[string]string{
|
||||||
|
"/path/to/helmfile.yaml": `
|
||||||
|
releases:
|
||||||
|
- name: backend-v1
|
||||||
|
chart: charts/backend
|
||||||
|
installed: false
|
||||||
|
- name: frontend-v1
|
||||||
|
chart: charts/frontend
|
||||||
|
needs:
|
||||||
|
- backend-v1
|
||||||
|
`,
|
||||||
|
}
|
||||||
|
|
||||||
|
t.Run("smoke", func(t *testing.T) {
|
||||||
|
//
|
||||||
|
// complex test cases for smoke testing
|
||||||
|
//
|
||||||
|
check(t, testcase{
|
||||||
|
files: files,
|
||||||
diffs: map[exectest.DiffKey]error{},
|
diffs: map[exectest.DiffKey]error{},
|
||||||
lists: map[exectest.ListKey]string{
|
lists: map[exectest.ListKey]string{
|
||||||
exectest.ListKey{Filter: "^frontend-v1$", Flags: "--kube-contextdefault--deployed--failed--pending"}: `NAME REVISION UPDATED STATUS CHART APP VERSION NAMESPACE
|
exectest.ListKey{Filter: "^frontend-v1$", Flags: "--kube-contextdefault--deployed--failed--pending"}: `NAME REVISION UPDATED STATUS CHART APP VERSION NAMESPACE
|
||||||
|
|
@ -323,131 +463,256 @@ database
|
||||||
front-proxy
|
front-proxy
|
||||||
logging
|
logging
|
||||||
`,
|
`,
|
||||||
},
|
})
|
||||||
}
|
|
||||||
|
|
||||||
for i := range testcases {
|
|
||||||
tc := testcases[i]
|
|
||||||
t.Run(tc.name, func(t *testing.T) {
|
|
||||||
wantUpgrades := tc.upgraded
|
|
||||||
wantDeletes := tc.deleted
|
|
||||||
|
|
||||||
var helm = &exectest.Helm{
|
|
||||||
FailOnUnexpectedList: true,
|
|
||||||
FailOnUnexpectedDiff: true,
|
|
||||||
Lists: tc.lists,
|
|
||||||
Diffs: tc.diffs,
|
|
||||||
DiffMutex: &sync.Mutex{},
|
|
||||||
ChartsMutex: &sync.Mutex{},
|
|
||||||
ReleasesMutex: &sync.Mutex{},
|
|
||||||
}
|
|
||||||
|
|
||||||
bs := &bytes.Buffer{}
|
|
||||||
|
|
||||||
func() {
|
|
||||||
logReader, logWriter := io.Pipe()
|
|
||||||
|
|
||||||
logFlushed := &sync.WaitGroup{}
|
|
||||||
// Ensure all the log is consumed into `bs` by calling `logWriter.Close()` followed by `logFlushed.Wait()`
|
|
||||||
logFlushed.Add(1)
|
|
||||||
go func() {
|
|
||||||
scanner := bufio.NewScanner(logReader)
|
|
||||||
for scanner.Scan() {
|
|
||||||
bs.Write(scanner.Bytes())
|
|
||||||
bs.WriteString("\n")
|
|
||||||
}
|
|
||||||
logFlushed.Done()
|
|
||||||
}()
|
|
||||||
|
|
||||||
defer func() {
|
|
||||||
// This is here to avoid data-trace on bytes buffer `bs` to capture logs
|
|
||||||
if err := logWriter.Close(); err != nil {
|
|
||||||
panic(err)
|
|
||||||
}
|
|
||||||
logFlushed.Wait()
|
|
||||||
}()
|
|
||||||
|
|
||||||
logger := helmexec.NewLogger(logWriter, "debug")
|
|
||||||
|
|
||||||
valsRuntime, err := vals.New(vals.Options{CacheSize: 32})
|
|
||||||
if err != nil {
|
|
||||||
t.Errorf("unexpected error creating vals runtime: %v", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
app := appWithFs(&App{
|
|
||||||
OverrideHelmBinary: DefaultHelmBinary,
|
|
||||||
glob: filepath.Glob,
|
|
||||||
abs: filepath.Abs,
|
|
||||||
OverrideKubeContext: "default",
|
|
||||||
Env: "default",
|
|
||||||
Logger: logger,
|
|
||||||
helms: map[helmKey]helmexec.Interface{
|
|
||||||
createHelmKey("helm", "default"): helm,
|
|
||||||
},
|
|
||||||
valsRuntime: valsRuntime,
|
|
||||||
}, tc.files)
|
|
||||||
|
|
||||||
if tc.ns != "" {
|
|
||||||
app.Namespace = tc.ns
|
|
||||||
}
|
|
||||||
|
|
||||||
if tc.selectors != nil {
|
|
||||||
app.Selectors = tc.selectors
|
|
||||||
}
|
|
||||||
|
|
||||||
destroyErr := app.Destroy(destroyConfig{
|
|
||||||
// if we check log output, concurrency must be 1. otherwise the test becomes non-deterministic.
|
|
||||||
concurrency: tc.concurrency,
|
|
||||||
logger: logger,
|
|
||||||
})
|
})
|
||||||
|
|
||||||
if tc.error == "" && destroyErr != nil {
|
t.Run("destroy only one release with selector", func(t *testing.T) {
|
||||||
t.Fatalf("unexpected error for data defined at %s: %v", tc.loc, destroyErr)
|
check(t, testcase{
|
||||||
} else if tc.error != "" && destroyErr == nil {
|
files: files,
|
||||||
t.Fatalf("expected error did not occur for data defined at %s", tc.loc)
|
selectors: []string{"name=logging"},
|
||||||
} else if tc.error != "" && destroyErr != nil && tc.error != destroyErr.Error() {
|
diffs: map[exectest.DiffKey]error{},
|
||||||
t.Fatalf("invalid error: expected %q, got %q", tc.error, destroyErr.Error())
|
lists: map[exectest.ListKey]string{
|
||||||
}
|
exectest.ListKey{Filter: "^frontend-v1$", Flags: "--kube-contextdefault--deployed--failed--pending"}: `NAME REVISION UPDATED STATUS CHART APP VERSION NAMESPACE
|
||||||
|
`,
|
||||||
|
exectest.ListKey{Filter: "^frontend-v2$", Flags: "--kube-contextdefault--deployed--failed--pending"}: `NAME REVISION UPDATED STATUS CHART APP VERSION NAMESPACE
|
||||||
|
frontend-v2 4 Fri Nov 1 08:40:07 2019 DEPLOYED frontend-3.1.0 3.1.0 default
|
||||||
|
`,
|
||||||
|
exectest.ListKey{Filter: "^frontend-v3$", Flags: "--kube-contextdefault--deployed--failed--pending"}: `NAME REVISION UPDATED STATUS CHART APP VERSION NAMESPACE
|
||||||
|
frontend-v3 4 Fri Nov 1 08:40:07 2019 DEPLOYED frontend-3.1.0 3.1.0 default
|
||||||
|
`,
|
||||||
|
exectest.ListKey{Filter: "^backend-v1$", Flags: "--kube-contextdefault--deployed--failed--pending"}: `NAME REVISION UPDATED STATUS CHART APP VERSION NAMESPACE
|
||||||
|
`,
|
||||||
|
exectest.ListKey{Filter: "^backend-v2$", Flags: "--kube-contextdefault--deployed--failed--pending"}: `NAME REVISION UPDATED STATUS CHART APP VERSION NAMESPACE
|
||||||
|
backend-v2 4 Fri Nov 1 08:40:07 2019 DEPLOYED backend-3.1.0 3.1.0 default
|
||||||
|
`,
|
||||||
|
exectest.ListKey{Filter: "^logging$", Flags: "--kube-contextdefault--deployed--failed--pending"}: `NAME REVISION UPDATED STATUS CHART APP VERSION NAMESPACE
|
||||||
|
logging 4 Fri Nov 1 08:40:07 2019 DEPLOYED fluent-bit-3.1.0 3.1.0 default
|
||||||
|
`,
|
||||||
|
exectest.ListKey{Filter: "^front-proxy$", Flags: "--kube-contextdefault--deployed--failed--pending"}: `NAME REVISION UPDATED STATUS CHART APP VERSION NAMESPACE
|
||||||
|
front-proxy 4 Fri Nov 1 08:40:07 2019 DEPLOYED envoy-3.1.0 3.1.0 default
|
||||||
|
`,
|
||||||
|
exectest.ListKey{Filter: "^servicemesh$", Flags: "--kube-contextdefault--deployed--failed--pending"}: `NAME REVISION UPDATED STATUS CHART APP VERSION NAMESPACE
|
||||||
|
servicemesh 4 Fri Nov 1 08:40:07 2019 DEPLOYED istio-3.1.0 3.1.0 default
|
||||||
|
`,
|
||||||
|
exectest.ListKey{Filter: "^database$", Flags: "--kube-contextdefault--deployed--failed--pending"}: `NAME REVISION UPDATED STATUS CHART APP VERSION NAMESPACE
|
||||||
|
database 4 Fri Nov 1 08:40:07 2019 DEPLOYED mysql-3.1.0 3.1.0 default
|
||||||
|
`,
|
||||||
|
exectest.ListKey{Filter: "^anotherbackend$", Flags: "--kube-contextdefault--deployed--failed--pending"}: `NAME REVISION UPDATED STATUS CHART APP VERSION NAMESPACE
|
||||||
|
anotherbackend 4 Fri Nov 1 08:40:07 2019 DEPLOYED anotherbackend-3.1.0 3.1.0 default
|
||||||
|
`,
|
||||||
|
},
|
||||||
|
// Disable concurrency to avoid in-deterministic result
|
||||||
|
concurrency: 1,
|
||||||
|
upgraded: []exectest.Release{},
|
||||||
|
deleted: []exectest.Release{
|
||||||
|
{Name: "logging", Flags: []string{}},
|
||||||
|
},
|
||||||
|
log: `processing file "helmfile.yaml" in directory "."
|
||||||
|
first-pass rendering starting for "helmfile.yaml.part.0": inherited=&{default map[] map[]}, overrode=<nil>
|
||||||
|
first-pass uses: &{default map[] map[]}
|
||||||
|
first-pass rendering output of "helmfile.yaml.part.0":
|
||||||
|
0:
|
||||||
|
1: releases:
|
||||||
|
2: - name: database
|
||||||
|
3: chart: charts/mysql
|
||||||
|
4: needs:
|
||||||
|
5: - logging
|
||||||
|
6: - name: frontend-v1
|
||||||
|
7: chart: charts/frontend
|
||||||
|
8: installed: false
|
||||||
|
9: needs:
|
||||||
|
10: - servicemesh
|
||||||
|
11: - logging
|
||||||
|
12: - backend-v1
|
||||||
|
13: - name: frontend-v2
|
||||||
|
14: chart: charts/frontend
|
||||||
|
15: needs:
|
||||||
|
16: - servicemesh
|
||||||
|
17: - logging
|
||||||
|
18: - backend-v2
|
||||||
|
19: - name: frontend-v3
|
||||||
|
20: chart: charts/frontend
|
||||||
|
21: needs:
|
||||||
|
22: - servicemesh
|
||||||
|
23: - logging
|
||||||
|
24: - backend-v2
|
||||||
|
25: - name: backend-v1
|
||||||
|
26: chart: charts/backend
|
||||||
|
27: installed: false
|
||||||
|
28: needs:
|
||||||
|
29: - servicemesh
|
||||||
|
30: - logging
|
||||||
|
31: - database
|
||||||
|
32: - anotherbackend
|
||||||
|
33: - name: backend-v2
|
||||||
|
34: chart: charts/backend
|
||||||
|
35: needs:
|
||||||
|
36: - servicemesh
|
||||||
|
37: - logging
|
||||||
|
38: - database
|
||||||
|
39: - anotherbackend
|
||||||
|
40: - name: anotherbackend
|
||||||
|
41: chart: charts/anotherbackend
|
||||||
|
42: needs:
|
||||||
|
43: - servicemesh
|
||||||
|
44: - logging
|
||||||
|
45: - database
|
||||||
|
46: - name: servicemesh
|
||||||
|
47: chart: charts/istio
|
||||||
|
48: needs:
|
||||||
|
49: - logging
|
||||||
|
50: - name: logging
|
||||||
|
51: chart: charts/fluent-bit
|
||||||
|
52: - name: front-proxy
|
||||||
|
53: chart: stable/envoy
|
||||||
|
54:
|
||||||
|
|
||||||
if len(wantUpgrades) > len(helm.Releases) {
|
first-pass produced: &{default map[] map[]}
|
||||||
t.Fatalf("insufficient number of upgrades: got %d, want %d", len(helm.Releases), len(wantUpgrades))
|
first-pass rendering result of "helmfile.yaml.part.0": {default map[] map[]}
|
||||||
}
|
vals:
|
||||||
|
map[]
|
||||||
|
defaultVals:[]
|
||||||
|
second-pass rendering result of "helmfile.yaml.part.0":
|
||||||
|
0:
|
||||||
|
1: releases:
|
||||||
|
2: - name: database
|
||||||
|
3: chart: charts/mysql
|
||||||
|
4: needs:
|
||||||
|
5: - logging
|
||||||
|
6: - name: frontend-v1
|
||||||
|
7: chart: charts/frontend
|
||||||
|
8: installed: false
|
||||||
|
9: needs:
|
||||||
|
10: - servicemesh
|
||||||
|
11: - logging
|
||||||
|
12: - backend-v1
|
||||||
|
13: - name: frontend-v2
|
||||||
|
14: chart: charts/frontend
|
||||||
|
15: needs:
|
||||||
|
16: - servicemesh
|
||||||
|
17: - logging
|
||||||
|
18: - backend-v2
|
||||||
|
19: - name: frontend-v3
|
||||||
|
20: chart: charts/frontend
|
||||||
|
21: needs:
|
||||||
|
22: - servicemesh
|
||||||
|
23: - logging
|
||||||
|
24: - backend-v2
|
||||||
|
25: - name: backend-v1
|
||||||
|
26: chart: charts/backend
|
||||||
|
27: installed: false
|
||||||
|
28: needs:
|
||||||
|
29: - servicemesh
|
||||||
|
30: - logging
|
||||||
|
31: - database
|
||||||
|
32: - anotherbackend
|
||||||
|
33: - name: backend-v2
|
||||||
|
34: chart: charts/backend
|
||||||
|
35: needs:
|
||||||
|
36: - servicemesh
|
||||||
|
37: - logging
|
||||||
|
38: - database
|
||||||
|
39: - anotherbackend
|
||||||
|
40: - name: anotherbackend
|
||||||
|
41: chart: charts/anotherbackend
|
||||||
|
42: needs:
|
||||||
|
43: - servicemesh
|
||||||
|
44: - logging
|
||||||
|
45: - database
|
||||||
|
46: - name: servicemesh
|
||||||
|
47: chart: charts/istio
|
||||||
|
48: needs:
|
||||||
|
49: - logging
|
||||||
|
50: - name: logging
|
||||||
|
51: chart: charts/fluent-bit
|
||||||
|
52: - name: front-proxy
|
||||||
|
53: chart: stable/envoy
|
||||||
|
54:
|
||||||
|
|
||||||
for relIdx := range wantUpgrades {
|
merged environment: &{default map[] map[]}
|
||||||
if wantUpgrades[relIdx].Name != helm.Releases[relIdx].Name {
|
1 release(s) matching name=logging found in helmfile.yaml
|
||||||
t.Errorf("releases[%d].name: got %q, want %q", relIdx, helm.Releases[relIdx].Name, wantUpgrades[relIdx].Name)
|
|
||||||
}
|
|
||||||
for flagIdx := range wantUpgrades[relIdx].Flags {
|
|
||||||
if wantUpgrades[relIdx].Flags[flagIdx] != helm.Releases[relIdx].Flags[flagIdx] {
|
|
||||||
t.Errorf("releaes[%d].flags[%d]: got %v, want %v", relIdx, flagIdx, helm.Releases[relIdx].Flags[flagIdx], wantUpgrades[relIdx].Flags[flagIdx])
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if len(wantDeletes) > len(helm.Deleted) {
|
processing 1 groups of releases in this order:
|
||||||
t.Fatalf("insufficient number of deletes: got %d, want %d", len(helm.Deleted), len(wantDeletes))
|
GROUP RELEASES
|
||||||
}
|
1 logging
|
||||||
|
|
||||||
for relIdx := range wantDeletes {
|
processing releases in group 1/1: logging
|
||||||
if wantDeletes[relIdx].Name != helm.Deleted[relIdx].Name {
|
release "logging" processed
|
||||||
t.Errorf("releases[%d].name: got %q, want %q", relIdx, helm.Deleted[relIdx].Name, wantDeletes[relIdx].Name)
|
|
||||||
}
|
|
||||||
for flagIdx := range wantDeletes[relIdx].Flags {
|
|
||||||
if wantDeletes[relIdx].Flags[flagIdx] != helm.Deleted[relIdx].Flags[flagIdx] {
|
|
||||||
t.Errorf("releaes[%d].flags[%d]: got %v, want %v", relIdx, flagIdx, helm.Deleted[relIdx].Flags[flagIdx], wantDeletes[relIdx].Flags[flagIdx])
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}()
|
|
||||||
|
|
||||||
if tc.log != "" {
|
DELETED RELEASES:
|
||||||
actual := bs.String()
|
NAME
|
||||||
|
logging
|
||||||
diff, exists := testhelper.Diff(tc.log, actual, 3)
|
`,
|
||||||
if exists {
|
|
||||||
t.Errorf("unexpected log for data defined %s:\nDIFF\n%s\nEOD", tc.loc, diff)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
})
|
})
|
||||||
}
|
})
|
||||||
|
|
||||||
|
t.Run("destroy installed but disabled release", func(t *testing.T) {
|
||||||
|
check(t, testcase{
|
||||||
|
files: filesForTwoReleases,
|
||||||
|
diffs: map[exectest.DiffKey]error{},
|
||||||
|
lists: map[exectest.ListKey]string{
|
||||||
|
exectest.ListKey{Filter: "^frontend-v1$", Flags: "--kube-contextdefault--deployed--failed--pending"}: `NAME REVISION UPDATED STATUS CHART APP VERSION NAMESPACE
|
||||||
|
`,
|
||||||
|
exectest.ListKey{Filter: "^backend-v1$", Flags: "--kube-contextdefault--deployed--failed--pending"}: `NAME REVISION UPDATED STATUS CHART APP VERSION NAMESPACE
|
||||||
|
`,
|
||||||
|
},
|
||||||
|
// Disable concurrency to avoid in-deterministic result
|
||||||
|
concurrency: 1,
|
||||||
|
upgraded: []exectest.Release{},
|
||||||
|
deleted: []exectest.Release{
|
||||||
|
{Name: "frontend-v1", Flags: []string{}},
|
||||||
|
},
|
||||||
|
log: `processing file "helmfile.yaml" in directory "."
|
||||||
|
first-pass rendering starting for "helmfile.yaml.part.0": inherited=&{default map[] map[]}, overrode=<nil>
|
||||||
|
first-pass uses: &{default map[] map[]}
|
||||||
|
first-pass rendering output of "helmfile.yaml.part.0":
|
||||||
|
0:
|
||||||
|
1: releases:
|
||||||
|
2: - name: backend-v1
|
||||||
|
3: chart: charts/backend
|
||||||
|
4: installed: false
|
||||||
|
5: - name: frontend-v1
|
||||||
|
6: chart: charts/frontend
|
||||||
|
7: needs:
|
||||||
|
8: - backend-v1
|
||||||
|
9:
|
||||||
|
|
||||||
|
first-pass produced: &{default map[] map[]}
|
||||||
|
first-pass rendering result of "helmfile.yaml.part.0": {default map[] map[]}
|
||||||
|
vals:
|
||||||
|
map[]
|
||||||
|
defaultVals:[]
|
||||||
|
second-pass rendering result of "helmfile.yaml.part.0":
|
||||||
|
0:
|
||||||
|
1: releases:
|
||||||
|
2: - name: backend-v1
|
||||||
|
3: chart: charts/backend
|
||||||
|
4: installed: false
|
||||||
|
5: - name: frontend-v1
|
||||||
|
6: chart: charts/frontend
|
||||||
|
7: needs:
|
||||||
|
8: - backend-v1
|
||||||
|
9:
|
||||||
|
|
||||||
|
merged environment: &{default map[] map[]}
|
||||||
|
2 release(s) found in helmfile.yaml
|
||||||
|
|
||||||
|
processing 2 groups of releases in this order:
|
||||||
|
GROUP RELEASES
|
||||||
|
1 frontend-v1
|
||||||
|
2 backend-v1
|
||||||
|
|
||||||
|
processing releases in group 1/2: frontend-v1
|
||||||
|
release "frontend-v1" processed
|
||||||
|
processing releases in group 2/2: backend-v1
|
||||||
|
release "backend-v1" processed
|
||||||
|
|
||||||
|
DELETED RELEASES:
|
||||||
|
NAME
|
||||||
|
frontend-v1
|
||||||
|
backend-v1
|
||||||
|
`,
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue