- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,208 for endpointv3 (0.18 sec)
-
pilot/test/xdstest/endpoints.go
func CompareEndpointsOrFail(t *testing.T, cluster string, got []*endpointv3.LocalityLbEndpoints, want []LocLbEpInfo) { if err := CompareEndpoints(cluster, got, want); err != nil { t.Error(err) } } func CompareEndpoints(cluster string, got []*endpointv3.LocalityLbEndpoints, want []LocLbEpInfo) error { if len(got) != len(want) { return fmt.Errorf("unexpected number of filtered endpoints for %s: got %v, want %v", cluster, len(got), len(want)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 01:17:58 UTC 2024 - 2.8K bytes - Viewed (0) -
pkg/controlplane/reconcilers/endpointsadapter_test.go
initialState: []runtime.Object{}, namespaceParam: endpoints2.Namespace, endpointsParam: endpoints2, }, "single-endpoint-full-ipv6": { expectedError: nil, expectedResult: endpoints3, expectCreate: []runtime.Object{endpoints3, epSlice3}, initialState: []runtime.Object{}, namespaceParam: endpoints3.Namespace, endpointsParam: endpoints3, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 15.4K bytes - Viewed (0) -
pkg/proxy/config/config_test.go
}}, Ports: []discoveryv1.EndpointPort{{Port: ptr.To[int32](80)}}, } fakeWatch.Add(endpoints3) endpoints = []*discoveryv1.EndpointSlice{endpoints2, endpoints1, endpoints3} handler.ValidateEndpointSlices(t, endpoints) handler2.ValidateEndpointSlices(t, endpoints) // Update the "foo" service with new endpoints endpoints1v2 := &discoveryv1.EndpointSlice{ ObjectMeta: metav1.ObjectMeta{Namespace: "testnamespace", Name: "foo"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 14.3K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/endpoint.go
if epCount != 0 { endpoints = append(endpoints, cla) } } for _, e := range dump.GetStaticEndpointConfigs() { cla, epCount := retrieveEndpoint(e.EndpointConfig, filter) if epCount != 0 { endpoints = append(endpoints, cla) } } sort.Slice(endpoints, func(i, j int) bool { iDirection, iSubset, iName, iPort := safelyParseSubsetKey(endpoints[i].ClusterName)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 5.6K bytes - Viewed (0) -
cmd/endpoint.go
GridHost string } // Endpoint - any type of endpoint. type Endpoint struct { *url.URL IsLocal bool PoolIdx, SetIdx, DiskIdx int } // Equal returns true if endpoint == ep func (endpoint Endpoint) Equal(ep Endpoint) bool { if endpoint.IsLocal == ep.IsLocal && endpoint.PoolIdx == ep.PoolIdx && endpoint.SetIdx == ep.SetIdx && endpoint.DiskIdx == ep.DiskIdx { if endpoint.Path == ep.Path && endpoint.Host == ep.Host {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 34.1K bytes - Viewed (0) -
pkg/registry/registrytest/endpoint.go
for ix := range e.Endpoints.Items { if e.Endpoints.Items[ix].Name == endpoints.Name { e.Endpoints.Items[ix] = *endpoints } } e.Endpoints.Items = append(e.Endpoints.Items, *endpoints) return endpoints, false, nil } func (e *EndpointRegistry) Delete(ctx context.Context, name string, deleteValidation rest.ValidateObjectFunc, options *metav1.DeleteOptions) (runtime.Object, bool, error) { // TODO: support namespaces in this mock
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 16:50:16 UTC 2019 - 4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/queue/MultiEndPointQueueTest.groovy
def endpoint1 = queue.newEndpoint() def endpoint2 = queue.newEndpoint() and: queue.empty(endpoint1) queue.empty(endpoint2) when: queue.dispatch(message) queue.dispatch(message2) def messages1 = [] endpoint1.take(messages1) def messages2 = [] endpoint2.take(messages2) then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/proxy/endpointslicecache_test.go
Endpoints: []discovery.Endpoint{endpoint1, endpoint2}, }, expectChanged: false, }, "identical with endpoints out of order": { cache: NewEndpointSliceCache("", v1.IPv4Protocol, nil, nil), initialSlice: &discovery.EndpointSlice{ ObjectMeta: objMeta, Ports: []discovery.EndpointPort{port443}, Endpoints: []discovery.Endpoint{endpoint1, endpoint2}, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:07:21 UTC 2024 - 24.9K bytes - Viewed (0) -
pkg/proxy/config/api_test.go
// Delete endpoints1 fakeWatch.Delete(endpoints1v2) handler.ValidateEndpointSlices(t, []*discoveryv1.EndpointSlice{endpoints2}) // Delete endpoints2 fakeWatch.Delete(endpoints2) handler.ValidateEndpointSlices(t, []*discoveryv1.EndpointSlice{}) } func TestInitialSync(t *testing.T) { _, ctx := klogtesting.NewTestContext(t) svc1 := &v1.Service{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 8.2K bytes - Viewed (0) -
cmd/endpoint-ellipses.go
} // Returns all the expanded endpoints, each argument is expanded separately. func (s *endpointSet) getEndpoints() (endpoints []string) { if len(s.endpoints) != 0 { return s.endpoints } for _, argPattern := range s.argPatterns { for _, lbls := range argPattern.Expand() { endpoints = append(endpoints, strings.Join(lbls, "")) } } s.endpoints = endpoints return endpoints }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.7K bytes - Viewed (0)