- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for labelServiceName (0.35 sec)
-
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.1K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/utils_test.go
name: "create slice from endpoints", tweakEndpoint: func(ep *v1.Endpoints) { }, expectedSlice: discovery.EndpointSlice{ ObjectMeta: metav1.ObjectMeta{ Labels: map[string]string{ discovery.LabelServiceName: endpoints.Name, discovery.LabelManagedBy: controllerName, }, Annotations: map[string]string{}, GenerateName: fmt.Sprintf("%s-", endpoints.Name), Namespace: endpoints.Namespace,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 23 15:40:23 UTC 2022 - 7.5K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller_test.go
}}, }, endpointSlices: []*discovery.EndpointSlice{{ ObjectMeta: metav1.ObjectMeta{ Name: endpointsName + "-1", Labels: map[string]string{ discovery.LabelServiceName: endpointsName, discovery.LabelManagedBy: controllerName, }, }, }}, expectedNumActions: 1, expectedNumSlices: 0, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 12:57:29 UTC 2023 - 13.9K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/utils.go
if endpointSlice == nil { return "", fmt.Errorf("nil EndpointSlice passed to serviceControllerKey()") } serviceName, ok := endpointSlice.Labels[discovery.LabelServiceName] if !ok || serviceName == "" { return "", fmt.Errorf("EndpointSlice missing %s label", discovery.LabelServiceName) } return fmt.Sprintf("%s/%s", endpointSlice.Namespace, serviceName), nil } // skipMirror return true if the LabelSkipMirror label has been set to
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 8.8K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/proxy/iptables/number_generated_rules_test.go
t.Fatalf("expected Service Type %s, got %s", test.svcType, svcs[i].Spec.Type) } if eps[i].ObjectMeta.Labels[discovery.LabelServiceName] != svcs[i].Name { t.Fatalf("endpoint slice reference %s instead of Service %s", eps[i].ObjectMeta.Labels[discovery.LabelServiceName], svcs[i].Name) } if len(eps[i].Endpoints) != test.epPerService {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 13.1K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
Labels: map[string]string{ discovery.LabelServiceName: serviceName, discovery.LabelManagedBy: controllerName, }, }, AddressType: discovery.AddressTypeIPv4, }, { ObjectMeta: metav1.ObjectMeta{ Name: "matching-2", Namespace: ns, OwnerReferences: []metav1.OwnerReference{*ownerRef}, Labels: map[string]string{ discovery.LabelServiceName: serviceName,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pkg/proxy/endpointslicecache.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:07:21 UTC 2024 - 11.7K bytes - Viewed (1) -
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)