- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for buffcon (0.09 sec)
-
pkg/istio-agent/xds_proxy_test.go
if err != nil { t.Fatalf("Failed to initialize xds proxy %v", err) } ia.xdsProxy = proxy return proxy } func setDialOptions(p *XdsProxy, l *bufconn.Listener) { // Override dialOptions so that the test can connect with plain text and with buffcon listener. p.dialOptions = []grpc.DialOption{ grpc.WithBlock(), grpc.WithTransportCredentials(insecure.NewCredentials()),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 04:48:02 UTC 2024 - 18.6K bytes - Viewed (0) -
pilot/test/xds/fake.go
} // ConnectADS starts an ADS connection to the server. It will automatically be cleaned up when the test ends func (f *FakeDiscoveryServer) ConnectADS() *xds.AdsTest { conn, err := grpc.Dial("buffcon", grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithBlock(), grpc.WithContextDialer(func(context.Context, string) (net.Conn, error) { return f.BufListener.Dial() })) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0)