- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 118 for Funnels (0.32 sec)
-
guava-tests/test/com/google/common/hash/BloomFilterTest.java
.addEqualityGroup(BloomFilter.create(Funnels.byteArrayFunnel(), 100, 0.01)) .addEqualityGroup(BloomFilter.create(Funnels.byteArrayFunnel(), 100, 0.02)) .addEqualityGroup(BloomFilter.create(Funnels.byteArrayFunnel(), 200, 0.01)) .addEqualityGroup(BloomFilter.create(Funnels.byteArrayFunnel(), 200, 0.02)) .addEqualityGroup(BloomFilter.create(Funnels.unencodedCharsFunnel(), 100, 0.01))
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 17 15:27:58 UTC 2024 - 21.2K bytes - Viewed (0) -
guava/src/com/google/common/hash/BloomFilter.java
Funnel<? super T> funnel, long expectedInsertions, double fpp) { return create(funnel, expectedInsertions, fpp, BloomFilterStrategies.MURMUR128_MITZ_64); } @VisibleForTesting static <T extends @Nullable Object> BloomFilter<T> create( Funnel<? super T> funnel, long expectedInsertions, double fpp, Strategy strategy) { checkNotNull(funnel); checkArgument(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 26.3K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/BloomFilter.java
Funnel<? super T> funnel, long expectedInsertions, double fpp) { return create(funnel, expectedInsertions, fpp, BloomFilterStrategies.MURMUR128_MITZ_64); } @VisibleForTesting static <T extends @Nullable Object> BloomFilter<T> create( Funnel<? super T> funnel, long expectedInsertions, double fpp, Strategy strategy) { checkNotNull(funnel); checkArgument(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 23.1K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector.go
) // ResourceResyncTime defines the resync period of the garbage collector's informers. const ResourceResyncTime time.Duration = 0 // GarbageCollector runs reflectors to watch for changes of managed API // objects, funnels the results to a single-threaded dependencyGraphBuilder, // which builds a graph caching the dependencies among objects. Triggered by the // graph changes, the dependencyGraphBuilder enqueues objects that can
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/doc.go
// the output streams of a WebSocket connection (e.g. STDIN, STDOUT, // STDERR, TTY resize, and error streams) to the input streams of a // SPDY connection. // // The stream tunnel proxy tunnels SPDY frames through a WebSocket // connection, and it is used for the PortForward subprotocol (e.g. // kubectl port-forward). This proxy implements tunneling by transparently
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 17:56:46 UTC 2024 - 1.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
// Make an SSL Tunnel on the first message pair of each SSL + proxy connection. val url = route.address.url val requestLine = "CONNECT ${url.toHostHeader(includeDefaultPort = true)} HTTP/1.1" while (true) { val source = this.source!! val sink = this.sink!! val tunnelCodec = Http1ExchangeCodec( // No client for CONNECT tunnels: client = null,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 18.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
connectionSpecIndex = -1, isTlsFallback = false, ) } /** * Returns a request that creates a TLS tunnel via an HTTP proxy. Everything in the tunnel request * is sent unencrypted to the proxy server, so tunnels include only the minimum set of headers. * This avoids sending potentially sensitive data like HTTP cookies to the proxy unencrypted. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 12K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel.go
"k8s.io/client-go/tools/portforward" "k8s.io/klog/v2" ) // TunnelingHandler is a handler which tunnels SPDY through WebSockets. type TunnelingHandler struct { // Used to communicate between upstream SPDY and downstream tunnel. upgradeHandler http.Handler } // NewTunnelingHandler is used to create the tunnel between an upstream // SPDY connection and a downstream tunneling connection through the stored // UpgradeAwareProxy.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.7K bytes - Viewed (0) -
tests/integration/pilot/testdata/tunneling/destination-rule.tmpl.yaml
apiVersion: networking.istio.io/v1alpha3 kind: DestinationRule metadata: name: tunnel-outbound-traffic-to-external-svc-via-external-forward-proxy spec: host: external-forward-proxy.{{ .externalNamespace }}.svc.cluster.local subsets: - name: external-svc-tcp trafficPolicy: tunnel: targetHost: external.{{ .externalNamespace }} targetPort: {{ .externalSvcTcpPort }} - name: external-svc-tls trafficPolicy:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Jan 20 19:37:50 UTC 2024 - 1K bytes - Viewed (0) -
pilot/pkg/networking/core/networkfilter_test.go
tunnelingEnabled := &networking.DestinationRule{ Host: "tunnel-proxy.com", TrafficPolicy: &networking.TrafficPolicy{ Tunnel: &networking.TrafficPolicy_TunnelSettings{ Protocol: "CONNECT", TargetHost: "example.com", TargetPort: 8443, }, }, } tunnelingEnabledWithoutProtocol := &networking.DestinationRule{ Host: "tunnel-proxy.com", TrafficPolicy: &networking.TrafficPolicy{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 25.8K bytes - Viewed (0)