- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for insertedClusters (0.19 sec)
-
pilot/pkg/networking/core/envoyfilter/cluster_patch.go
continue } if commonConditionMatch(pctx, cp) && clusterMatch(c, cp, hosts) { return false } } return true } // InsertedClusters collects all clusters that are added via ADD operation and match the patch context. func InsertedClusters(pctx networking.EnvoyFilter_PatchContext, efw *model.EnvoyFilterWrapper) []*cluster.Cluster { if efw == nil { return nil } var result []*cluster.Cluster
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 6.8K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
} for _, c := range clusters { if patched := p.doPatch(hosts, c); patched != nil { l = append(l, patched) } } return l } func (p clusterPatcher) insertedClusters() []*cluster.Cluster { return envoyfilter.InsertedClusters(p.pctx, p.efw) } func (p clusterPatcher) hasPatches() bool { return p.efw != nil && len(p.efw.Patches[networking.EnvoyFilter_CLUSTER]) > 0 }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0) -
pilot/pkg/networking/core/envoyfilter/cluster_patch_test.go
pc := ApplyClusterMerge(tc.patchContext, efw, c, []host.Name{host.Name(tc.host)}) output = append(output, pc) } } output = append(output, InsertedClusters(tc.patchContext, efw)...) if diff := cmp.Diff(tc.output, output, protocmp.Transform()); diff != "" { t.Errorf("%s mismatch (-want +got):\n%s", tc.name, diff) } }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 20.7K bytes - Viewed (0)