- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 47 for httpfilter (0.28 sec)
-
pilot/pkg/networking/core/envoyfilter/listener_patch.go
if !hasHTTPFilterMatch(lp) { httpconn.HttpFilters = append([]*hcm.HttpFilter{proto.Clone(lp.Value).(*hcm.HttpFilter)}, httpconn.HttpFilters...) continue } httpconn.HttpFilters, applied = insertBeforeFunc( httpconn.HttpFilters, func(e *hcm.HttpFilter) (bool, *hcm.HttpFilter) { if httpFilterMatch(e, lp) { return true, proto.Clone(lp.Value).(*hcm.HttpFilter) } return false, nil },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 15:39:29 UTC 2024 - 26.7K bytes - Viewed (0) -
pilot/pkg/xds/filters/filters.go
}, } Cors = &hcm.HttpFilter{ Name: wellknown.CORS, ConfigType: &hcm.HttpFilter_TypedConfig{ TypedConfig: protoconv.MessageToAny(&cors.Cors{}), }, } Fault = &hcm.HttpFilter{ Name: wellknown.Fault, ConfigType: &hcm.HttpFilter_TypedConfig{ TypedConfig: protoconv.MessageToAny(&fault.HTTPFault{}), }, } GrpcWeb = &hcm.HttpFilter{ Name: wellknown.GRPCWeb,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 09 09:24:25 UTC 2024 - 15.5K bytes - Viewed (0) -
pilot/pkg/security/authz/builder/builder.go
} func (b Builder) buildHTTP(rules *rbacpb.RBAC, shadowRules *rbacpb.RBAC, providers []string) []*hcm.HttpFilter { if !b.option.IsCustomBuilder { rbac := &rbachttp.RBAC{ Rules: rules, ShadowRules: shadowRules, ShadowRulesStatPrefix: shadowRuleStatPrefix(shadowRules), } return []*hcm.HttpFilter{ { Name: wellknown.HTTPRoleBasedAccessControl,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Nov 20 22:15:12 UTC 2023 - 12.6K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/lds.go
"istio.io/istio/pilot/pkg/util/protoconv" xdsfilters "istio.io/istio/pilot/pkg/xds/filters" "istio.io/istio/pkg/istio-agent/grpcxds" "istio.io/istio/pkg/util/sets" ) var supportedFilters = []*hcm.HttpFilter{ xdsfilters.Fault, xdsfilters.BuildRouterFilter(xdsfilters.RouterFilterContext{ StartChildSpan: false, SuppressDebugHeaders: false, // No need to set this to true, gRPC doesn't respect it anyways }), }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 14.6K bytes - Viewed (0) -
pilot/pkg/model/telemetry.go
ServerSpec: serverSpec, } return &cfg } // HTTPFilters computes the HttpFilter for a given proxy/class func (t *Telemetries) HTTPFilters(proxy *Proxy, class networking.ListenerClass, svc *Service) []*hcm.HttpFilter { if res := t.telemetryFilters(proxy, class, networking.ListenerProtocolHTTP, svc); res != nil { return res.([]*hcm.HttpFilter) } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 18:14:09 UTC 2024 - 35.2K bytes - Viewed (0) -
pilot/pkg/security/authn/policy_applier.go
} } func (a policyApplier) JwtFilter(useExtendedJwt, clearRouteCache bool) *hcm.HttpFilter { if len(a.processedJwtRules) == 0 { return nil } filterConfigProto := convertToEnvoyJwtConfig(a.processedJwtRules, a.push, useExtendedJwt, clearRouteCache) if filterConfigProto == nil { return nil } return &hcm.HttpFilter{ Name: authn_model.EnvoyJwtFilterName,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 19.2K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_builder.go
} } connectionManager.Proxy_100Continue = features.Enable100ContinueHeaders return connectionManager } func appendMxFilter(httpOpts *httpListenerOpts, filters []*hcm.HttpFilter) []*hcm.HttpFilter { if !features.MetadataExchange || httpOpts.hbone { return filters } if httpOpts.class == istionetworking.ListenerClassSidecarInbound { return append(filters, xdsfilters.SidecarInboundMetadataFilter)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 17.9K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_waypoint.go
} } h := lb.buildHTTPConnectionManager(httpOpts) // Last filter must be router. router := h.HttpFilters[len(h.HttpFilters)-1] h.HttpFilters = append(pre, h.HttpFilters[:len(h.HttpFilters)-1]...) h.HttpFilters = append(h.HttpFilters, post...) h.HttpFilters = append(h.HttpFilters, router) filters = append(filters, &listener.Filter{ Name: wellknown.HTTPConnectionManager,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 27.6K bytes - Viewed (0) -
pilot/pkg/security/authz/builder/builder_test.go
t.Fatalf("failed to parse YAML: %v", err) } return out } out := &hcm.HttpFilter{} if err := protomarshal.ApplyYAML(string(data), out); err != nil { t.Fatalf("failed to parse YAML: %v", err) } return out } func convertHTTP(in []*hcm.HttpFilter) []proto.Message { ret := make([]proto.Message, len(in)) for i := range in { ret[i] = in[i] } return ret
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 13.8K bytes - Viewed (0) -
pkg/config/validation/envoyfilter/envoyfilter_test.go
} } func TestRecurseMissingTypedConfig(t *testing.T) { good := &listener.Filter{ Name: wellknown.TCPProxy, ConfigType: &listener.Filter_TypedConfig{TypedConfig: nil}, } ecds := &hcm.HttpFilter{ Name: "something", ConfigType: &hcm.HttpFilter_ConfigDiscovery{}, } bad := &listener.Filter{ Name: wellknown.TCPProxy, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 00:31:03 UTC 2024 - 16.7K bytes - Viewed (0)