-
Notifications
You must be signed in to change notification settings - Fork 0
/
check.go
97 lines (86 loc) · 2.71 KB
/
check.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
85
86
87
88
89
90
91
92
93
94
95
96
97
// Copyright 2018 Istio Authors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package check
import (
"fmt"
"time"
multierror "github.com/hashicorp/go-multierror"
kubeMeta "istio.io/istio/galley/pkg/metadata/kube"
"istio.io/istio/galley/pkg/source/kube/client"
"istio.io/istio/galley/pkg/source/kube/log"
sourceSchema "istio.io/istio/galley/pkg/source/kube/schema"
"k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset"
"k8s.io/apimachinery/pkg/runtime/schema"
"k8s.io/apimachinery/pkg/util/wait"
)
var (
pollInterval = time.Second
pollTimeout = time.Minute
)
// ResourceTypesPresence verifies that all expected k8s resources types are
// present in the k8s apiserver.
func ResourceTypesPresence(k client.Interfaces) error {
cs, err := k.APIExtensionsClientset()
if err != nil {
return err
}
return resourceTypesPresence(cs, kubeMeta.Types.All())
}
func resourceTypesPresence(cs clientset.Interface, specs []sourceSchema.ResourceSpec) error {
search := make(map[string]*sourceSchema.ResourceSpec, len(specs))
for i, spec := range specs {
search[spec.Plural] = &specs[i]
}
err := wait.Poll(pollInterval, pollTimeout, func() (bool, error) {
var errs error
nextResource:
for plural, spec := range search {
gv := schema.GroupVersion{Group: spec.Group, Version: spec.Version}.String()
list, err := cs.Discovery().ServerResourcesForGroupVersion(gv)
if err != nil {
errs = multierror.Append(errs, fmt.Errorf("could not find %v: %v", gv, err))
continue nextResource
}
found := false
for _, r := range list.APIResources {
if r.Name == spec.Plural {
delete(search, plural)
found = true
break
}
}
if !found {
log.Scope.Infof("%s resource type not found", spec.CanonicalResourceName())
}
}
if len(search) == 0 {
return true, nil
}
// entire search failed
if errs != nil {
return true, errs
}
// check again next poll
return false, nil
})
if err != nil {
var notFound []string
for plural := range search {
notFound = append(notFound, plural)
}
return fmt.Errorf("%v: the following resource type(s) were not found: %v", err, notFound)
}
log.Scope.Infof("Discovered all supported resources (# = %v)", len(specs))
return nil
}