Function TestGetDelObjectCfgs

engine/clean_test.go:240–376

(t *testing.T)

}

func TestGetDelObjectCfgs(t *testing.T) {
	finishedJobs := map[string]struct{}{
		"app2": {},
	}
	cfg1 := specv1.Configuration{Name: "cfg1", Version: "v1"}
	cfg2 := specv1.Configuration{Name: "cfg2", Version: "v2"}
	cfg3 := specv1.Configuration{Name: "cfg3", Version: "v3"}
	objectCfgs := map[string]*specv1.Configuration{
		makeKey(specv1.KindConfiguration, "cfg1", "v1"): &cfg1,
		makeKey(specv1.KindConfiguration, "cfg2", "v2"): &cfg2,
		makeKey(specv1.KindConfiguration, "cfg3", "v3"): &cfg3,
	}
	occupiedApps := map[string]*specv1.Application{
		"app1": {
			Name:    "app1",
			Version: "v1",
			Volumes: []specv1.Volume{{
				Name: "vm1",
				VolumeSource: specv1.VolumeSource{
					Config: &specv1.ObjectReference{
						Name:    "cfg1",
						Version: "v1",
					},
				},
			}},
			Services: []specv1.Service{{
				Name: "svc1",
				VolumeMounts: []specv1.VolumeMount{{
					Name:      "vm1",
					AutoClean: false,
				}},
			}},
		},
		"app2": {
			Name:    "app2",
			Version: "v1",
			Volumes: []specv1.Volume{{
				Name: "vm2",
				VolumeSource: specv1.VolumeSource{
					Config: &specv1.ObjectReference{
						Name:    "cfg2",
						Version: "v2",
					},
				},
			}},
			Services: []specv1.Service{{
				Name: "svc2",
				VolumeMounts: []specv1.VolumeMount{{
					Name:      "vm2",
					AutoClean: true,
				}},
			}},
		},
	}
	obsoleteApps := map[string]*specv1.Application{
		"app3": {
			Name:     "app3",
			Version:  "v2",