Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 35 for blackholed (0.37 sec)

  1. src/runtime/slice_test.go

    			}
    		})
    	}
    }
    
    var (
    	blackhole []byte
    )
    
    func BenchmarkAppendSliceLarge(b *testing.B) {
    	for _, length := range []int{1 << 10, 4 << 10, 16 << 10, 64 << 10, 256 << 10, 1024 << 10} {
    		y := make([]byte, length)
    		b.Run(fmt.Sprint(length, "Bytes"), func(b *testing.B) {
    			for i := 0; i < b.N; i++ {
    				blackhole = nil
    				blackhole = append(blackhole, y...)
    			}
    		})
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Aug 17 09:45:44 UTC 2020
    - 10.3K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/listener_waypoint.go

    		port = service.Ports[0].Port
    
    		// Do not return blackhole cluster for service==nil case as there is a legitimate use case for
    		// calling this function with nil service: to route to a pre-defined statically configured cluster
    		// declared as part of the bootstrap.
    		// If blackhole cluster is needed, do the check on the caller side. See gateway and tls.go for examples.
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 27.6K bytes
    - Viewed (0)
  3. tests/integration/telemetry/policy/helper_test.go

    func RunExternalRequest(t *testing.T, cases []*TestCase, prometheus prometheus.Instance, mode TrafficPolicy) {
    	t.Helper()
    	// Testing of Blackhole and Passthrough clusters:
    	// Setup of environment:
    	// 1. client and destination are deployed to app-1-XXXX namespace
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 02 21:29:40 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/tls.go

    		// has multiple ports, then route to a cluster with the listener port (i.e. sidecar defined port) - the
    		// traffic will most likely blackhole.
    		port := listenPort.Port
    		if len(service.Ports) == 1 {
    			port = service.Ports[0].Port
    		}
    
    		clusterName := model.BuildSubsetKey(model.TrafficDirectionOutbound, "", service.Hostname, port)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/gateway_simulation_test.go

    					},
    					Result: simulation.Result{
    						Error:              simulation.ErrNoRoute,
    						ListenerMatched:    "0.0.0.0_80",
    						RouteConfigMatched: "http.80",
    						VirtualHostMatched: "blackhole:80",
    					},
    				},
    				{
    					// There will be no listener
    					Name: "undefined port",
    					Call: simulation.Call{
    						Port:       81,
    						HostHeader: "foo.bar",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 10 18:27:40 UTC 2024
    - 46.5K bytes
    - Viewed (0)
  6. pilot/pkg/networking/core/sidecar_simulation_test.go

    							ClusterMatched: expectedCluster,
    						},
    					}
    					// For blackhole, we will 502 where possible instead of blackhole cluster
    					// This only works for HTTP on HTTP
    					if expectedCluster == util.BlackHoleCluster && call.IsHTTP() && isHTTPPort(call.Port) {
    						e.Result.ClusterMatched = ""
    						e.Result.VirtualHostMatched = util.BlackHole
    					}
    					testCalls = append(testCalls, e)
    				}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 84.7K bytes
    - Viewed (0)
  7. pilot/pkg/networking/util/util.go

    )
    
    const (
    	// BlackHoleCluster to catch traffic from routes with unresolved clusters. Traffic arriving here goes nowhere.
    	BlackHoleCluster = "BlackHoleCluster"
    	// BlackHole is the name of the virtual host and route name used to block all traffic
    	BlackHole = "block_all"
    	// PassthroughCluster to forward traffic to the original destination requested. This cluster is used when
    	// traffic does not match any listener in envoy.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  8. pilot/pkg/networking/core/route/route.go

    		port = service.Ports[0].Port
    
    		// Do not return blackhole cluster for service==nil case as there is a legitimate use case for
    		// calling this function with nil service: to route to a pre-defined statically configured cluster
    		// declared as part of the bootstrap.
    		// If blackhole cluster is needed, do the check on the caller side. See gateway and tls.go for examples.
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 14:12:39 UTC 2024
    - 56.1K bytes
    - Viewed (0)
  9. pilot/pkg/networking/core/httproute.go

    					},
    				},
    			},
    			IncludeRequestAttemptCount: includeRequestAttemptCount,
    		}
    	}
    
    	return &route.VirtualHost{
    		Name:    util.BlackHole,
    		Domains: []string{"*"},
    		Routes: []*route.Route{
    			{
    				Name: util.BlackHole,
    				Match: &route.RouteMatch{
    					PathSpecifier: &route.RouteMatch_Prefix{Prefix: "/"},
    				},
    				Action: &route.Route_DirectResponse{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 32.7K bytes
    - Viewed (1)
  10. pilot/pkg/xds/lds_test.go

    	}
    
    	// Expect 9 CDS clusters:
    	// 2 inbound(http, inbound passthroughipv4) notes: no passthroughipv6
    	// 9 outbound (2 http services, 1 tcp service,
    	//   and 2 subsets of http1, 1 blackhole, 1 passthrough)
    	if (len(adsc.GetClusters()) + len(adsc.GetEdsClusters())) != 9 {
    		t.Fatalf("Expected 9 clusters in CDS output. Got %d", len(adsc.GetClusters())+len(adsc.GetEdsClusters()))
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 12 18:20:36 UTC 2024
    - 13.1K bytes
    - Viewed (0)
Back to top