- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for endpointSet (0.16 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)