- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for GetMatch (0.16 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)