Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for Conn (0.12 sec)

  1. cni/pkg/pluginlistener/listener_test.go

    	}
    	defer l.Close()
    	conn, err := connect(f)
    	if err != nil {
    		t.Fatalf("failed to connect %v", err)
    	}
    	conn.Close()
    }
    
    func connect(socket string) (*grpc.ClientConn, error) {
    	var opts []grpc.DialOption
    
    	opts = append(opts, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithContextDialer(func(ctx context.Context, addr string) (net.Conn, error) {
    		var d net.Dialer
    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)
  2. cni/pkg/plugin/cnieventclient.go

    	client *http.Client
    	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