Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Conn (0.24 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 01 22:53:12 GMT 2024
    - Last Modified: Thu Feb 08 21:58:32 GMT 2024
    - 1.4K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/ztunnelserver.go

    	defer conn.Close()
    
    	context.AfterFunc(ctx, func() {
    		log.Debug("context cancelled - closing conn")
    		conn.Close()
    	})
    
    	// before doing anything, add the connection to the list of active connections
    	z.conns.addConn(conn)
    	defer z.conns.deleteConn(conn)
    
    	// get hello message from ztunnel
    	m, _, err := readProto[zdsapi.ZdsHello](conn.u, readWriteDeadline, nil)
    	if err != nil {
    		return err
    	}
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  3. 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 01 22:53:12 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 2.4K bytes
    - Viewed (0)
  4. manifests/charts/istiod-remote/templates/crd-all.gen.yaml

                                  description: |2-
    
    
                                    Valid Options: LEAST_CONN, RANDOM, PASSTHROUGH, ROUND_ROBIN, LEAST_REQUEST
                                  enum:
                                  - UNSPECIFIED
                                  - LEAST_CONN
                                  - RANDOM
                                  - PASSTHROUGH
                                  - ROUND_ROBIN
    Others
    - Registered: Wed Mar 20 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 18:46:49 GMT 2024
    - 570.3K bytes
    - Viewed (0)
  5. manifests/charts/base/crds/crd-all.gen.yaml

                                  description: |2-
    
    
                                    Valid Options: LEAST_CONN, RANDOM, PASSTHROUGH, ROUND_ROBIN, LEAST_REQUEST
                                  enum:
                                  - UNSPECIFIED
                                  - LEAST_CONN
                                  - RANDOM
                                  - PASSTHROUGH
                                  - ROUND_ROBIN
    Others
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Mon Apr 22 20:20:47 GMT 2024
    - 606.1K bytes
    - Viewed (0)
  6. operator/cmd/mesh/testdata/manifest-generate/data-snapshot.tar.gz

    string type: object type: array failoverPriority: description: failoverPriority is an ordered list of labels used to sort endpoints to do priority based load balancing. items: type: string type: array type: object simple: enum: - UNSPECIFIED - LEAST_CONN - RANDOM - PASSTHROUGH - ROUND_ROBIN - LEAST_REQUEST type: string warmupDurationSecs: description: Represents the warmup duration of Service. type: string type: object outlierDetection: properties: baseEjectionTime: description: Minimum ejection duration....
    Others
    - Registered: Wed Mar 20 22:53:08 GMT 2024
    - Last Modified: Wed Jan 10 05:10:03 GMT 2024
    - 198.1K bytes
    - Viewed (1)
Back to top