- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 103 for httpfilter (0.14 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_test.go
) func TestBuildRouterFilter(t *testing.T) { tests := []struct { name string ctx RouterFilterContext expected *hcm.HttpFilter }{ { name: "test for build router filter", ctx: RouterFilterContext{StartChildSpan: true}, expected: &hcm.HttpFilter{ Name: wellknown.Router, ConfigType: &hcm.HttpFilter_TypedConfig{ TypedConfig: protoconv.MessageToAny(&router.Router{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Sep 11 15:29:30 UTC 2023 - 2.3K 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/networking/plugin/authz/authorization.go
func (b *Builder) BuildHTTP(class networking.ListenerClass) []*hcm.HttpFilter { if b == nil || b.builder == nil { return nil } if class == networking.ListenerClassSidecarOutbound { // Only applies to inbound and gateways return nil } if b.httpBuilt { return b.httpFilters } b.httpBuilt = true b.httpFilters = b.builder.BuildHTTP() return b.httpFilters
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 2.7K bytes - Viewed (0) -
pilot/pkg/networking/core/extension/wasmplugin_test.go
WasmPlugin: &extensions.WasmPlugin{ Priority: &wrapperspb.Int32Value{Value: 1000}, Type: extensions.PluginType_NETWORK, }, } ) func TestInsertedExtensionConfigurations(t *testing.T) { httpFilter := protoconv.MessageToAny(&httpwasm.Wasm{ Config: &wasmextension.PluginConfig{ Name: "istio-system.someAuthNFilter", Configuration: &anypb.Any{}, Vm: &wasmextension.PluginConfig_VmConfig{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 5.6K bytes - Viewed (0) -
pilot/pkg/networking/plugin/authn/authentication.go
func (b *Builder) BuildHTTP(class networking.ListenerClass) []*hcm.HttpFilter { if b == nil { return nil } if class == networking.ListenerClassSidecarOutbound { // Only applies to inbound and gateways return nil } if b.proxy.SupportsEnvoyExtendedJwt() { filter := b.applier.JwtFilter(true, b.proxy.Type != model.SidecarProxy) if filter != nil { return []*hcm.HttpFilter{filter} } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 4.4K bytes - Viewed (0) -
pilot/pkg/security/authn/policy_applier_test.go
} jwksURI := ms.URL + "/oauth2/v3/certs" cases := []struct { name string in []*config.Config jwksFetchMode jwt.JwksFetchMode expected *hcm.HttpFilter }{ { name: "No policy", in: []*config.Config{}, expected: nil, }, { name: "Empty policy", in: []*config.Config{ { Spec: &v1beta1.RequestAuthentication{},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 01 07:32:22 UTC 2023 - 60.2K bytes - Viewed (0) -
pilot/pkg/networking/core/extension/wasmplugin.go
// plugins of a provided phase from the WASM plugin set and append them to the list of filters func PopAppendHTTP(list []*hcm.HttpFilter, filterMap map[extensions.PluginPhase][]*model.WasmPluginWrapper, phase extensions.PluginPhase, ) []*hcm.HttpFilter { for _, ext := range filterMap[phase] { list = append(list, toEnvoyHTTPFilter(ext)) } delete(filterMap, phase) return list }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 5.4K 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) -
istioctl/pkg/authz/listener.go
if cm := getHTTPConnectionManager(filter); cm != nil { for _, httpFilter := range cm.GetHttpFilters() { switch httpFilter.GetName() { case wellknown.HTTPRoleBasedAccessControl: rbacHTTP := &rbachttp.RBAC{} if err := getHTTPFilterConfig(httpFilter, rbacHTTP); err != nil { log.Errorf("found RBAC HTTP filter but failed to parse: %s", err) } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Sep 11 15:29:30 UTC 2023 - 6K bytes - Viewed (0)