Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for endpointSet (0.16 sec)

  1. cmd/endpoint-ellipses_test.go

    	testCases := []struct {
    		arg     string
    		es      endpointSet
    		success bool
    	}{
    		// Tests invalid inputs.
    		{
    			"...",
    			endpointSet{},
    			false,
    		},
    		// No range specified.
    		{
    			"{...}",
    			endpointSet{},
    			false,
    		},
    		// Invalid range.
    		{
    			"http://minio{2...3}/export/set{1...0}",
    			endpointSet{},
    			false,
    		},
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  2. pkg/proxy/endpointslicecache.go

    func (cache *EndpointSliceCache) addEndpoints(svcPortName *ServicePortName, portNum int, endpointSet map[string]Endpoint, endpoints []discovery.Endpoint) map[string]Endpoint {
    	if endpointSet == nil {
    		endpointSet = map[string]Endpoint{}
    	}
    
    	// iterate through endpoints to add them to endpointSet.
    	for _, endpoint := range endpoints {
    		if len(endpoint.Addresses) == 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:07:21 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  3. pkg/controller/endpointslicemirroring/reconciler_helpers.go

    		endpointsByKey:      map[addrTypePortMapKey]endpointsliceutil.EndpointSet{},
    		numDesiredEndpoints: 0,
    	}
    }
    
    // desiredCalc helps calculate desired endpoints and ports.
    type desiredCalc struct {
    	portsByKey          map[addrTypePortMapKey][]discovery.EndpointPort
    	endpointsByKey      map[addrTypePortMapKey]endpointsliceutil.EndpointSet
    	numDesiredEndpoints int
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 11 18:08:12 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  4. cmd/endpoint-ellipses.go

    	}
    	return totalSizes
    }
    
    // Parses all arguments and returns an endpointSet which is a collection
    // of endpoints following the ellipses pattern, this is what is used
    // by the object layer for initializing itself.
    func parseEndpointSet(setDriveCount uint64, args ...string) (ep endpointSet, err error) {
    	argPatterns := make([]ellipses.ArgPattern, len(args))
    	for i, arg := range args {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  5. pkg/controller/endpointslicemirroring/reconciler.go

    // and delete.
    func (r *reconciler) reconcileByPortMapping(
    	endpoints *corev1.Endpoints,
    	existingSlices []*discovery.EndpointSlice,
    	desiredSet endpointsliceutil.EndpointSet,
    	endpointPorts []discovery.EndpointPort,
    	addressType discovery.AddressType,
    ) (slicesByAction, totalsByAction) {
    	slices := slicesByAction{}
    	totals := totalsByAction{}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 11 18:08:12 UTC 2023
    - 13.1K bytes
    - Viewed (0)
  6. samples/bookinfo/src/reviews/reviews-wlpcfg/src/test/java/it/EndpointTest.java

    import javax.ws.rs.client.Client;
    import javax.ws.rs.client.ClientBuilder;
    import javax.ws.rs.client.Invocation;
    import javax.ws.rs.client.WebTarget;
    import javax.ws.rs.core.Response;
    
    public class EndpointTest {
    
        public void testEndpoint(String endpoint, String expectedOutput) {
            String port = System.getProperty("liberty.test.port");
            String war = System.getProperty("war.name");
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Sep 21 17:00:23 UTC 2017
    - 2.1K bytes
    - Viewed (0)
  7. samples/bookinfo/src/reviews/reviews-wlpcfg/src/test/java/it/rest/LibertyRestEndpointTest.java

     * limitations under the License.
     *******************************************************************************/ 
    package it.rest;
    
    import it.EndpointTest;
    
    import org.junit.Test;
    
    public class LibertyRestEndpointTest extends EndpointTest {
    
        @Test
        public void testDeployment() {
            testEndpoint("/rest", "Hello from the REST endpoint!");
        }
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Sep 21 17:00:23 UTC 2017
    - 1002 bytes
    - Viewed (0)
  8. pilot/pkg/serviceregistry/kube/controller/endpointslice_test.go

    }
    
    func testEndpointsEqual(a, b []*model.IstioEndpoint) bool {
    	if len(a) != len(b) {
    		return false
    	}
    	m1 := make(map[endpointKey]int)
    	m2 := make(map[endpointKey]int)
    	for _, i := range a {
    		m1[endpointKey{i.Address, i.ServicePortName}]++
    	}
    	for _, i := range b {
    		m2[endpointKey{i.Address, i.ServicePortName}]++
    	}
    	return reflect.DeepEqual(m1, m2)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Aug 14 18:50:38 UTC 2023
    - 4.5K bytes
    - Viewed (0)
  9. samples/bookinfo/src/reviews/reviews-wlpcfg/src/test/java/it/TestApplication.java

     * limitations under the License.
     *******************************************************************************/ 
    package it;
    
    import org.junit.Test;
    
    public class TestApplication extends EndpointTest {
    
        @Test
        public void testDeployment() {
            testEndpoint("/index.html", "<h1>Welcome to your Liberty Application</h1>");
        }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Sep 21 17:00:23 UTC 2017
    - 986 bytes
    - Viewed (0)
  10. pilot/pkg/xds/debug_test.go

    				}
    				if (ss.RouteAcked != "") != wantAcked {
    					errorHandler("wanted RouteAcked set %v got %v for %v", wantAcked, ss.RouteAcked, nodeID)
    				}
    				if (ss.EndpointSent != "") != wantSent {
    					errorHandler("wanted EndpointSent set %v got %v for %v", wantSent, ss.EndpointSent, nodeID)
    				}
    				if (ss.EndpointAcked != "") != wantAcked {
    					errorHandler("wanted EndpointAcked set %v got %v for %v", wantAcked, ss.EndpointAcked, nodeID)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 12 18:20:36 UTC 2024
    - 7.8K bytes
    - Viewed (0)
Back to top