Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for insertedClusters (0.43 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top