-
Notifications
You must be signed in to change notification settings - Fork 104
/
labeled_app.go
84 lines (65 loc) · 2.54 KB
/
labeled_app.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
// Copyright 2020 VMware, Inc.
// SPDX-License-Identifier: Apache-2.0
package app
import (
"fmt"
"strings"
"time"
ctlres "github.com/k14s/kapp/pkg/kapp/resources"
"k8s.io/apimachinery/pkg/labels"
"k8s.io/apimachinery/pkg/runtime/schema"
)
type LabeledApp struct {
labelSelector labels.Selector
identifiedResources ctlres.IdentifiedResources
}
var _ App = &LabeledApp{}
func (a *LabeledApp) Name() string {
str := a.labelSelector.String()
if len(str) == 0 {
return "?"
}
return str
}
func (a *LabeledApp) Namespace() string { return "" }
func (a *LabeledApp) CreationTimestamp() time.Time { return time.Time{} }
func (a *LabeledApp) Description() string {
return fmt.Sprintf("labeled app '%s'", a.Name())
}
func (a *LabeledApp) LabelSelector() (labels.Selector, error) {
return a.labelSelector, nil
}
func (a *LabeledApp) UsedGVs() ([]schema.GroupVersion, error) { return nil, nil }
func (a *LabeledApp) UsedGKs() (*[]schema.GroupKind, error) { return nil, nil }
func (a *LabeledApp) UpdateUsedGVsAndGKs([]schema.GroupVersion, []schema.GroupKind) error { return nil }
func (a *LabeledApp) CreateOrUpdate(labels map[string]string, isDiffRun bool) error { return nil }
func (a *LabeledApp) Exists() (bool, string, error) { return true, "", nil }
func (a *LabeledApp) Delete() error {
labelSelector, err := a.LabelSelector()
if err != nil {
return err
}
rs, err := a.identifiedResources.List(labelSelector, nil, ctlres.IdentifiedResourcesListOpts{IgnoreCachedResTypes: true})
if err != nil {
return fmt.Errorf("Relisting app resources: %w", err)
}
if len(rs) > 0 {
var resourceNames []string
for _, res := range rs {
resourceNames = append(resourceNames, res.Description())
}
return fmt.Errorf("Expected all resources to be gone, but found: %s", strings.Join(resourceNames, ", "))
}
return nil
}
func (a *LabeledApp) Rename(_ string, _ string) error { return fmt.Errorf("Not supported") }
func (a *LabeledApp) RenamePrevApp(_ string, _ map[string]string, _ bool) error {
return fmt.Errorf("Not supported")
}
func (a *LabeledApp) Meta() (Meta, error) { return Meta{}, nil }
func (a *LabeledApp) Changes() ([]Change, error) { return nil, nil }
func (a *LabeledApp) LastChange() (Change, error) { return nil, nil }
func (a *LabeledApp) BeginChange(ChangeMeta) (Change, error) { return NoopChange{}, nil }
func (a *LabeledApp) GCChanges(max int, reviewFunc func(changesToDelete []Change) error) (int, int, error) {
return 0, 0, nil
}