- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 231 for filter0 (0.12 sec)
-
pkg/kube/namespace/filter.go
namespaces.Start(stop) kube.WaitForCacheSync("discovery filter", stop, namespaces.HasSynced) f.selectorsChanged(mesh.Mesh().GetDiscoverySelectors(), false) return f } func (d *discoveryNamespacesFilter) notifyHandlersLocked(added sets.Set[string], removed sets.String) { for _, h := range d.handlers { h(added, removed) } } func (d *discoveryNamespacesFilter) Filter(obj any) bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 17:12:52 UTC 2024 - 9.3K bytes - Viewed (0) -
releasenotes/notes/ns-filter.yaml
apiVersion: release-notes/v2 kind: bug-fix area: traffic-management releaseNotes: - |
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 17:12:52 UTC 2024 - 186 bytes - Viewed (0) -
pilot/pkg/networking/core/listener_inbound.go
filters = extension.PopAppendNetwork(filters, wasm, extensions.PluginPhase_AUTHZ) filters = extension.PopAppendNetwork(filters, wasm, extensions.PluginPhase_STATS) filters = extension.PopAppendNetwork(filters, wasm, extensions.PluginPhase_UNSPECIFIED_PHASE) h := lb.buildHTTPConnectionManager(httpOpts) filters = append(filters, &listener.Filter{ Name: wellknown.HTTPConnectionManager,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 35.1K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client.go
// composedFilter offers a way to join multiple different object filters into a single one type composedFilter struct { // The primary filter, which has a handler. Optional filter kubetypes.DynamicObjectFilter // Secondary filters (no handler allowed) extra []func(obj any) bool } func (f composedFilter) Filter(obj any) bool { for _, filter := range f.extra { if !filter(obj) { return false } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
pilot/pkg/networking/core/listenertest/match.go
} // Check ListenerFilters if lt.Filters != nil { if lt.TotalMatch { assert.Equal(t, lt.Filters, haveFilters, l.Name+": listener filters should be equal") } else { if missing := sets.SortedList(sets.New(lt.Filters...).Difference(sets.New(haveFilters...))); len(missing) > 0 { t.Fatalf("%v: missing listener filters: %v", l.Name, missing) } } } // Check FilterChains
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 6.4K bytes - Viewed (0) -
tests/integration/ambient/testdata/wasm-filter.yaml
Adil Mohamed M P <******@****.***> 1717448525 +0530
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 21:02:05 UTC 2024 - 513 bytes - Viewed (0) -
platforms/jvm/testing-jvm/src/main/java/org/gradle/api/internal/tasks/testing/detection/ForkedTestClasspathFactory.java
); AdditionalClasspath filtered = filterAdditionalClasspath(classpath, modulepath, unfiltered); // The test's runtimeClasspath already includes the test framework's implementation modules. // No need to load anything extra ourselves. if (filtered.isEmpty()) { return new ForkedTestClasspath(
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 14:28:48 UTC 2024 - 19.4K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_waypoint.go
hbone: true, } tcpChain := &listener.FilterChain{ Filters: append([]*listener.Filter{ xdsfilters.ConnectAuthorityNetworkFilter, }, lb.buildInboundNetworkFilters(cc)...), Name: "direct-tcp", } // TODO: maintains undesirable persistent HTTP connections to "encap" httpChain := &listener.FilterChain{ Filters: append([]*listener.Filter{ xdsfilters.ConnectAuthorityNetworkFilter, },
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/networking/core/listener_test.go
} func verifyListenerFilters(t *testing.T, lfilters []*listener.ListenerFilter) { t.Helper() if len(lfilters) != 2 { t.Fatalf("expected %d listener filter, found %d", 2, len(lfilters)) } if lfilters[0].Name != wellknown.TLSInspector || lfilters[1].Name != wellknown.HTTPInspector { t.Fatalf("expected listener filters not found, got %v", lfilters) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 93.6K bytes - Viewed (0) -
pilot/pkg/networking/core/accesslog_test.go
} // Validate that access log filter uses the new format. for _, l := range listeners { if l.AccessLog[0].Filter == nil { t.Fatal("expected filter config in listener access log configuration") } // Verify listener access log. verify(t, tc.encoding, l.AccessLog[0], tc.wantFormat) for _, fc := range l.FilterChains { for _, filter := range fc.Filters { switch filter.Name {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 19.9K bytes - Viewed (0)