- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 27 for labelServiceName (0.22 sec)
-
pkg/controlplane/reconcilers/helpers_test.go
slice := &discoveryv1.EndpointSlice{ ObjectMeta: metav1.ObjectMeta{ Namespace: metav1.NamespaceDefault, Name: name, Labels: map[string]string{ discoveryv1.LabelServiceName: name, }, }, AddressType: discoveryv1.AddressTypeIPv4, Endpoints: make([]discoveryv1.Endpoint, len(ips)), Ports: make([]discoveryv1.EndpointPort, len(ports)), } ready := true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 27 12:46:23 UTC 2022 - 4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice.go
type endpointSliceController struct { endpointCache *endpointSliceCache slices kclient.Client[*v1.EndpointSlice] c *Controller } var ( endpointSliceRequirement = labelRequirement(mcs.LabelServiceName, selection.DoesNotExist, nil) endpointSliceSelector = klabels.NewSelector().Add(*endpointSliceRequirement) ) func newEndpointSliceController(c *Controller) *endpointSliceController {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 16.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice_test.go
svc1Ips := []string{"128.0.0.1"} portNames := []string{"tcp-port"} createEndpoints(t, controller, svcName, ns, portNames, svc1Ips, nil, map[string]string{ mcs.LabelServiceName: svcName, }) fx.AssertEmpty(t, time.Millisecond*50) // Ensure that no endpoint is create endpoints := GetEndpoints(svc, controller.Endpoints) assert.Equal(t, len(endpoints), 0) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 4.5K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler_test.go
} serviceNameVal, ok := epSlice.Labels[discovery.LabelServiceName] if !ok { t.Errorf("Expected EndpointSlice to have %s label set", discovery.LabelServiceName) } if serviceNameVal != endpoints.Name { t.Errorf("Expected EndpointSlice to have %s label set to %s, got %s", discovery.LabelServiceName, endpoints.Name, serviceNameVal) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 42.7K bytes - Viewed (0) -
pkg/controlplane/reconcilers/endpointsadapter.go
endpointSlice := &discovery.EndpointSlice{} endpointSlice.Name = endpoints.Name endpointSlice.Namespace = endpoints.Namespace endpointSlice.Labels = map[string]string{discovery.LabelServiceName: endpoints.Name} // TODO: Add support for dual stack here (and in the rest of // EndpointsAdapter). endpointSlice.AddressType = discovery.AddressTypeIPv4 if len(endpoints.Subsets) > 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 27 12:46:23 UTC 2022 - 7.8K bytes - Viewed (0) -
pkg/proxy/nftables/proxier_test.go
eps := &discovery.EndpointSlice{ ObjectMeta: metav1.ObjectMeta{ Name: fmt.Sprintf("%s-%d", name, sliceNum), Namespace: namespace, Labels: map[string]string{discovery.LabelServiceName: name}, }, } epsFunc(eps) return eps } func makeNSN(namespace, name string) types.NamespacedName { return types.NamespacedName{Namespace: namespace, Name: name} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 173.5K bytes - Viewed (0) -
pkg/proxy/endpointslicecache_test.go
endpoint2 := discovery.Endpoint{Addresses: []string{"10.0.1.1"}} objMeta := metav1.ObjectMeta{ Name: "foo", Namespace: "bar", Labels: map[string]string{discovery.LabelServiceName: "svc1"}, } testCases := map[string]struct { cache *EndpointSliceCache initialSlice *discovery.EndpointSlice updatedSlice *discovery.EndpointSlice expectChanged bool }{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:07:21 UTC 2024 - 24.9K bytes - Viewed (0) -
pilot/pkg/xds/cds_test.go
}, } endpoint := &discoveryv1.EndpointSlice{ ObjectMeta: metav1.ObjectMeta{ Name: service.Name, Namespace: service.Namespace, Labels: map[string]string{ discoveryv1.LabelServiceName: service.Name, }, }, Endpoints: []discoveryv1.Endpoint{{ Addresses: []string{pod.Status.PodIP}, TargetRef: &v1.ObjectReference{ Kind: "Pod", Namespace: pod.Namespace,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 01 02:06:39 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier_test.go
endpointSlice := &discovery.EndpointSlice{ ObjectMeta: metav1.ObjectMeta{ Name: fmt.Sprintf("%s-1", svcPortName.Name), Namespace: svcPortName.Namespace, Labels: map[string]string{discovery.LabelServiceName: svcPortName.Name}, }, Ports: []discovery.EndpointPort{{ Name: &svcPortName.Port, Port: ptr.To[int32](80), Protocol: ptr.To(v1.ProtocolTCP), }},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 28 14:30:51 UTC 2024 - 30.2K bytes - Viewed (0) -
pkg/controlplane/reconcilers/endpointsadapter_test.go
epSlice := &discovery.EndpointSlice{ ObjectMeta: metav1.ObjectMeta{Name: name, Namespace: namespace}, AddressType: discovery.AddressTypeIPv4, } epSlice.Labels = map[string]string{discovery.LabelServiceName: name} subset := corev1.EndpointSubset{} for i, port := range ports { endpointPort := corev1.EndpointPort{ Name: fmt.Sprintf("port-%d", i), Port: int32(port),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 15.4K bytes - Viewed (0)