Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 35 of 35 for index (0.34 sec)

  1. pilot/pkg/networking/core/route/route_test.go

    			"*.example.org":             exampleWildcardService,
    			"goodbye.hello.example.org": exampleNestedWildcardService,
    		}
    
    		// note that the VS containing *.google.com doesn't have an entry in the wildcard index
    		wildcardIndex := map[host.Name]types.NamespacedName{
    			"*.example.org":       virtualServiceWithWildcardHost.NamespacedName(),
    			"*.hello.example.org": virtualServiceWithNestedWildcardHost.NamespacedName(),
    		}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 14:12:39 UTC 2024
    - 88.1K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/serviceregistry_test.go

    func expectServiceEndpoints(t *testing.T, fx *xdsfake.Updater, svc *model.Service, port int, expected []EndpointResponse) {
    	t.Helper()
    	expectServiceEndpointsFromIndex(t, fx.Delegate.(*model.EndpointIndexUpdater).Index, svc, port, expected)
    }
    
    func setPodReady(pod *v1.Pod) {
    	pod.Status.Conditions = []v1.PodCondition{
    		{
    			Type:               v1.PodReady,
    			Status:             v1.ConditionTrue,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 51.2K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/route/route.go

    	serviceRegistry map[host.Name]*model.Service,
    	mostSpecificWildcardVsIndex map[host.Name]types.NamespacedName,
    ) ([]string, []*model.Service) {
    	// TODO: A further optimization would be to completely rely on the index and not do the loop below
    	// However, that requires assuming that serviceRegistry never got filtered after the
    	// egressListener was created.
    	rule := virtualService.Spec.(*networking.VirtualService)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 14:12:39 UTC 2024
    - 56.1K bytes
    - Viewed (0)
  4. pilot/pkg/config/kube/gateway/conversion.go

    	result.ReferencedNamespaceKeys = nsReferences
    	result.ResourceReferences = ctx.resourceReferences
    	return result
    }
    
    // convertReferencePolicies extracts all ReferencePolicy into an easily accessibly index.
    func convertReferencePolicies(r GatewayResources) AllowedReferences {
    	res := map[Reference]map[Reference]*Grants{}
    	type namespacedGrant struct {
    		Namespace string
    		Grant     *k8sbeta.ReferenceGrantSpec
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 84.7K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/serviceentry/controller_test.go

    	retry.UntilSuccessOrFail(t, func() error {
    		for i, svc := range svcs {
    			endpoints := GetEndpointsForPort(svc, sd.XdsUpdater.(*xdsfake.Updater).Delegate.(*model.EndpointIndexUpdater).Index, port)
    			if endpoints == nil {
    				endpoints = []*model.IstioEndpoint{} // To simplify tests a bit
    			}
    			sortEndpoints(endpoints)
    			sortEndpoints(expe[i])
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 92.9K bytes
    - Viewed (0)
Back to top