Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. pkg/proxy/ipvs/proxier.go

    				}
    			}
    		} else {
    			endpoints = clusterEndpoints
    		}
    	}
    
    	newEndpoints := sets.New[string]()
    	for _, epInfo := range endpoints {
    		newEndpoints.Insert(epInfo.String())
    	}
    
    	// Create new endpoints
    	for _, ep := range newEndpoints.UnsortedList() {
    		ip, port, err := net.SplitHostPort(ep)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
  2. cmd/test-utils_test.go

    		Endpoints:    endpoints,
    		CmdLine:      strings.Join(args, " "),
    	}}
    }
    
    func mustGetNewEndpoints(poolIdx int, drivesPerSet int, args ...string) (endpoints Endpoints) {
    	endpoints, err := NewEndpoints(args...)
    	if err != nil {
    		panic(err)
    	}
    	for i := range endpoints {
    		endpoints[i].SetPoolIndex(poolIdx)
    		endpoints[i].SetSetIndex(i / drivesPerSet)
    		endpoints[i].SetDiskIndex(i % drivesPerSet)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 76.9K bytes
    - Viewed (0)
Back to top