Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for Dial (0.29 sec)

  1. istioctl/pkg/xds/client.go

    	if err != nil {
    		return nil, fmt.Errorf("could not dial: %w", err)
    	}
    	err = adscConn.Run()
    	if err != nil {
    		return nil, fmt.Errorf("ADSC: failed running %v", err)
    	}
    
    	err = adscConn.Send(dr)
    	if err != nil {
    		return nil, err
    	}
    	response, err := adscConn.WaitVersion(opts.Timeout, dr.TypeUrl, "")
    	return response, err
    }
    
    // DialOptions constructs gRPC dial options from command line configuration
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Dec 19 22:42:42 GMT 2023
    - 3.7K bytes
    - Viewed (0)
  2. cni/pkg/pluginlistener/listener_test.go

    		var d net.Dialer
    		return d.DialContext(ctx, "unix", socket)
    	}))
    
    	conn, err := grpc.Dial(socket, opts...)
    	if err != nil {
    		return nil, err
    	}
    
    	return conn, nil
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Feb 08 21:58:32 GMT 2024
    - 1.4K bytes
    - Viewed (0)
  3. cni/pkg/plugin/cnieventclient.go

    	url    string
    }
    
    func buildClient(address, path string) CNIEventClient {
    	c := &http.Client{
    		Transport: &http.Transport{
    			DialContext: func(_ context.Context, _, _ string) (net.Conn, error) {
    				return net.Dial("unix", address)
    			},
    		},
    		Timeout: 1000 * time.Millisecond,
    	}
    	eventC := CNIEventClient{
    		client: c,
    		url:    "http://unix" + path,
    	}
    	return eventC
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 2.4K bytes
    - Viewed (0)
Back to top