/
list.go
51 lines (41 loc) · 1.07 KB
/
list.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
package manifest
import (
"context"
"k8s.io/apimachinery/pkg/api/meta"
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
"k8s.io/client-go/dynamic"
)
type List interface {
Delete(ctx context.Context) error
Apply(ctx context.Context) error
Filter(funcs ...Filter) List
Transform(funcs ...Transformer) (List, error)
Resources() []*unstructured.Unstructured
Size() int
Append(mfs ...List) List
}
type list struct {
resources []*unstructured.Unstructured
client dynamic.Interface
mapper meta.RESTMapper
}
func (l *list) Resources() []*unstructured.Unstructured {
return l.resources
}
func (l *list) Size() int {
return len(l.resources)
}
func (l *list) Append(mfs ...List) List {
resources := make([]*unstructured.Unstructured, 0, l.Size())
for _, v := range l.Resources() {
resource := v.DeepCopy()
resources = append(resources, resource)
}
for _, mf := range mfs {
for _, v := range mf.Resources() {
resource := v.DeepCopy()
resources = append(resources, resource)
}
}
return &list{resources: resources, client: l.client, mapper: l.mapper}
}