Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for GetMatch (0.16 sec)

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

    		g.Expect(len(routes)).To(Equal(1))
    		g.Expect(len(routes[0].GetMatch().GetHeaders())).To(Equal(0))
    		g.Expect(routes[0].GetMatch().GetDynamicMetadata()[0].GetFilter()).To(Equal("istio_authn"))
    		g.Expect(routes[0].GetMatch().GetDynamicMetadata()[0].GetInvert()).To(BeFalse())
    		g.Expect(routes[0].GetMatch().GetDynamicMetadata()[1].GetFilter()).To(Equal("istio_authn"))
    		g.Expect(routes[0].GetMatch().GetDynamicMetadata()[1].GetInvert()).To(BeTrue())
    	})
    
    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. pkg/config/analysis/analyzers/envoyfilter/envoyfilter.go

    	ef := r.Message.(*network.EnvoyFilter)
    	for index, patch := range ef.ConfigPatches {
    		// validate that the patch and match sections are populated
    		if patch.GetPatch() == nil {
    			break
    		}
    
    		// collect filter names to figure out if there is more than one envoyFilter with the same filter name where one
    		// of the envoy filters has the proxy version set
    		instanceName := ""
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Aug 08 16:43:05 UTC 2023
    - 6.8K bytes
    - Viewed (0)
  3. pkg/config/analysis/analyzers/virtualservice/jwtclaimroute.go

    			}
    			return true
    		})
    	}
    }
    
    func routeBasedOnJWTClaimKey(vs *v1alpha3.VirtualService) string {
    	for _, httpRoute := range vs.GetHttp() {
    		for _, match := range httpRoute.GetMatch() {
    			for key := range match.GetHeaders() {
    				if jwt.ToRoutingClaim(key).Match {
    					return key
    				}
    			}
    			for key := range match.GetWithoutHeaders() {
    				if jwt.ToRoutingClaim(key).Match {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 11 16:38:57 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  4. pilot/pkg/model/telemetry.go

    				// if we disable all metrics, we should drop the entire filter
    				if isAllMetrics(o.GetMatch()) && o.Disabled.GetValue() {
    					for _, mode := range getModes(o.GetMatch().GetMode()) {
    						key := metricProviderModeKey(provider, mode)
    						disabledAllMetricsProviders.Insert(key)
    					}
    
    					continue
    				}
    
    				metricsNames := getMatches(o.GetMatch())
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 18:14:09 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  5. istioctl/pkg/writer/envoy/configdump/listener.go

    		return ""
    	}
    	vh := er.GetVirtualHosts()[0]
    	if !reflect.DeepEqual(vh.Domains, []string{"*"}) {
    		return ""
    	}
    	if len(vh.GetRoutes()) != 1 {
    		return ""
    	}
    	r := vh.GetRoutes()[0]
    	if r.GetMatch().GetPrefix() != "/" {
    		return ""
    	}
    	a, ok := r.GetAction().(*route.Route_Route)
    	if !ok {
    		return ""
    	}
    	cl, ok := a.Route.ClusterSpecifier.(*route.RouteAction_Cluster)
    	if !ok {
    		return ""
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Nov 29 12:37:14 UTC 2023
    - 18.1K bytes
    - Viewed (0)
  6. istioctl/pkg/writer/envoy/configdump/route.go

    						if !isPassthrough(r.GetAction()) {
    							fmt.Fprintf(w, "%v\t%s\t%s\t%s\t%s\n",
    								route.Name,
    								vhosts.Name,
    								describeRouteDomains(vhosts.GetDomains()),
    								describeMatch(r.GetMatch()),
    								describeManagement(r.GetMetadata()))
    						}
    					}
    					if len(vhosts.Routes) == 0 {
    						fmt.Fprintf(w, "%v\t%s\t%s\t%s\t%s\n",
    							route.Name,
    							vhosts.Name,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 11 05:38:17 UTC 2023
    - 7.2K bytes
    - Viewed (0)
  7. pilot/pkg/networking/core/route/route.go

    	}
    	return &out
    }
    
    // GetRouteOperation returns readable route description for trace.
    func GetRouteOperation(in *route.Route, vsName string, port int) string {
    	path := "/*"
    	m := in.GetMatch()
    	ps := m.GetPathSpecifier()
    	if ps != nil {
    		switch ps.(type) {
    		case *route.RouteMatch_Prefix:
    			path = m.GetPrefix() + "*"
    		case *route.RouteMatch_Path:
    			path = m.GetPath()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 14:12:39 UTC 2024
    - 56.1K bytes
    - Viewed (0)
  8. pkg/config/validation/validation.go

    						errs = AppendValidation(errs, errors.New(msg))
    					}
    				}
    			}
    			for _, http := range virtualService.GetHttp() {
    				for _, m := range http.GetMatch() {
    					validateJWTClaimRoute(m.GetHeaders())
    					validateJWTClaimRoute(m.GetWithoutHeaders())
    				}
    			}
    		}
    
    		allHostsValid := true
    		for _, virtualHost := range virtualService.Hosts {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 04:03:33 UTC 2024
    - 107.2K bytes
    - Viewed (0)
  9. staging/src/k8s.io/cli-runtime/pkg/resource/query_param_verifier.go

    	}
    
    	for _, path := range doc.GetPaths().GetPath() {
    		// Is this describing the gvk we're looking for?
    		if !hasGVKExtension(path.GetValue().GetPatch().GetVendorExtension(), gvk) {
    			continue
    		}
    		for _, param := range path.GetValue().GetPatch().GetParameters() {
    			if param.GetParameter().GetNonBodyParameter().GetQueryParameterSubSchema().GetName() == string(queryParam) {
    				return true, nil
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 01:23:27 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  10. pkg/kubelet/kubelet_node_status_test.go

    			require.True(t, actions[1].Matches("patch", "nodes"))
    			require.Equal(t, actions[1].GetSubresource(), "status")
    
    			updatedNode, err := applyNodeStatusPatch(&existingNode, actions[1].(core.PatchActionImpl).GetPatch())
    			assert.NoError(t, err)
    			for i, cond := range updatedNode.Status.Conditions {
    				assert.False(t, cond.LastHeartbeatTime.IsZero(), "LastHeartbeatTime for %v condition is zero", cond.Type)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
Back to top