admin/kubesphere
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

change application source location

Browse Source
This commit is contained in:
Jeff
2019-05-12 15:28:56 +08:00
committed by zryfish
parent ea5009d571
commit 692de802b3
14 changed files with 2659 additions and 486 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
vendor/github.com/kubernetes-sigs/application/pkg/genericreconciler/genericreconciler.go generated vendored
View File

@@ -52,6 +52,7 @@ func (gr *Reconciler) observe(observables ...resource.Observable) (*resource.Obj
if obs.Labels != nil {
opts := client.MatchingLabels(obs.Labels)
opts.Raw = &metav1.ListOptions{TypeMeta: obs.Type}
opts.Namespace = obs.Namespace
err = gr.List(context.TODO(), opts, obs.ObjList.(runtime.Object))
if err == nil {
items, err := meta.ExtractList(obs.ObjList.(runtime.Object))
@@ -62,7 +63,7 @@ func (gr *Reconciler) observe(observables ...resource.Observable) (*resource.Obj
}
}
} else {
var obj metav1.Object = obs.Obj.(metav1.Object)
var obj = obs.Obj.(metav1.Object)
name := obj.GetName()
namespace := obj.GetNamespace()
otype := reflect.TypeOf(obj).String()
@@ -200,6 +201,11 @@ func (gr *Reconciler) ObserveAndMutate(crname string, c component.Component, sta
// Get observables
observables := c.Observables(gr.Scheme, c.CR, c.Labels(), expected)
// constraint observables only in component's namespace
for i := range observables {
observables[i].Namespace = c.CR.GetNamespace()
}
// Observe observables
observed, err = gr.observe(observables...)
if err != nil {