Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 373 for filterFn (0.13 sec)

  1. pkg/kube/krt/filter.go

    	}
    }
    
    func FilterGeneric(f func(any) bool) FetchOption {
    	return func(h *dependency) {
    		h.filter.generic = f
    	}
    }
    
    func (f *filter) Matches(object any, forList bool) bool {
    	// Check each of our defined filters to see if the object matches
    	// This function is called very often and is important to keep fast
    	// Cheaper checks should come earlier to avoid additional work and short circuit early
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 10 23:33:56 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/gateway.go

    			filter := &listener.Filter{
    				Name:       wellknown.HTTPConnectionManager,
    				ConfigType: &listener.Filter_TypedConfig{TypedConfig: protoconv.MessageToAny(httpConnectionManagers[i])},
    			}
    			filterChain.Filters = append(filterChain.Filters, filter)
    			log.Debugf("attached HTTP filter with %d http_filter options to listener %q filter chain %d",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 46.4K bytes
    - Viewed (0)
  3. pom.xml

    							<filters>
    								<filter>${project.basedir}/src/packaging/common/packaging.properties</filter>
    								<filter>${project.basedir}/src/packaging/deb/packaging.properties</filter>
    							</filters>
    							<resources>
    								<resource>
    									<directory>src/packaging/common/</directory>
    									<filtering>true</filtering>
    									<includes>
    										<include>**/*</include>
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu May 30 06:49:02 UTC 2024
    - 48.7K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/networkfilter.go

    	// Stats
    	filters = extension.PopAppendNetwork(filters, wasm, extensions.PluginPhase_STATS)
    	filters = extension.PopAppendNetwork(filters, wasm, extensions.PluginPhase_UNSPECIFIED_PHASE)
    	filters = append(filters, buildMetricsNetworkFilters(lb.push, lb.node, class, policySvc)...)
    
    	// Terminal filters
    	filters = append(filters, networkFilterStack...)
    	return filters
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/listener_builder.go

    		filters = appendMxFilter(httpOpts, filters)
    		// TODO: how to deal with ext-authz? It will be in the ordering twice
    		filters = append(filters, lb.authzCustomBuilder.BuildHTTP(httpOpts.class)...)
    		filters = extension.PopAppendHTTP(filters, wasm, extensions.PluginPhase_AUTHN)
    		filters = append(filters, lb.authnBuilder.BuildHTTP(httpOpts.class)...)
    		filters = extension.PopAppendHTTP(filters, wasm, extensions.PluginPhase_AUTHZ)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  6. 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)
  7. pkg/scheduler/framework/interface.go

    	// When PreFilterResult filters out some Nodes, the framework considers Nodes that are filtered out as getting "UnschedulableAndUnresolvable".
    	// i.e., those Nodes will be out of the candidates of the preemption.
    	//
    	// When it returns Skip status, returned PreFilterResult and other fields in status are just ignored,
    	// and coupled Filter plugin/PreFilterExtensions() will be skipped in this scheduling cycle.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  8. 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)
  9. pilot/pkg/networking/core/listener.go

    			chain.Filters = append(chain.Filters, opt.networkFilters...)
    			chain.Filters = append(chain.Filters, filter)
    		}
    
    		// Set a default filter chain. This allows us to avoid issues where
    		// traffic starts to match a filter chain but then doesn't match latter criteria, leading to
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  10. 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)
Back to top