- Sort Score
- Result 10 results
- Languages All
Results 11 - 18 of 18 for DiscoveryV1 (0.38 sec)
-
pkg/config/schema/kubeclient/resources.gen.go
} case gvr.EndpointSlice: l = func(options metav1.ListOptions) (runtime.Object, error) { return c.Kube().DiscoveryV1().EndpointSlices(opts.Namespace).List(context.Background(), options) } w = func(options metav1.ListOptions) (watch.Interface, error) { return c.Kube().DiscoveryV1().EndpointSlices(opts.Namespace).Watch(context.Background(), options) } case gvr.Endpoints:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 13:57:51 UTC 2024 - 31.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
// delete slice 1, it should still exist _ = s.KubeClient().Kube().DiscoveryV1().EndpointSlices(namespace).Delete(context.TODO(), "slice1", metav1.DeleteOptions{}) fx.WaitOrFail(t, "eds") expectEndpoints(t, s, "outbound|80||service.namespace.svc.cluster.local", []string{"1.2.3.4:80"}, nil) _ = s.KubeClient().Kube().DiscoveryV1().EndpointSlices(namespace).Delete(context.TODO(), "slice2", metav1.DeleteOptions{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
assert.NoError(t, err) err = esController.syncService(logger, fmt.Sprintf("%s/%s", namespace, serviceName)) assert.NoError(t, err) assert.Len(t, client.Actions(), 0) sliceList, err := client.DiscoveryV1().EndpointSlices(namespace).List(context.TODO(), metav1.ListOptions{}) assert.NoError(t, err) assert.Len(t, sliceList.Items, 0, "Expected 0 endpoint slices") }) } }
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/controlplane/instance.go
batchapiv1 "k8s.io/api/batch/v1" certificatesapiv1 "k8s.io/api/certificates/v1" certificatesv1alpha1 "k8s.io/api/certificates/v1alpha1" coordinationapiv1 "k8s.io/api/coordination/v1" apiv1 "k8s.io/api/core/v1" discoveryv1 "k8s.io/api/discovery/v1" eventsv1 "k8s.io/api/events/v1" networkingapiv1 "k8s.io/api/networking/v1" networkingapiv1alpha1 "k8s.io/api/networking/v1alpha1" nodev1 "k8s.io/api/node/v1" policyapiv1 "k8s.io/api/policy/v1"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:50:04 UTC 2024 - 21.2K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller_test.go
esController.serviceStore.Add(tc.service) } for _, epSlice := range tc.endpointSlices { epSlice.Namespace = namespace esController.endpointSliceStore.Add(epSlice) _, err := client.DiscoveryV1().EndpointSlices(namespace).Create(context.TODO(), epSlice, metav1.CreateOptions{}) if err != nil { t.Fatalf("Expected no error creating EndpointSlice, got %v", err) } }
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/reconciler_test.go
epSlice.Labels = map[string]string{ discovery.LabelServiceName: endpoints.Name, discovery.LabelManagedBy: controllerName, } _, err := client.DiscoveryV1().EndpointSlices(namespace).Create(context.TODO(), epSlice, metav1.CreateOptions{}) if err != nil { t.Fatalf("Expected no error creating EndpointSlice, got %v", err) } numInitialActions++ }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 42.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
discovery.LabelServiceName: name, }, }, Endpoints: []discovery.Endpoint{ { Addresses: ips, }, }, Ports: esps, } if _, err := controller.client.Kube().DiscoveryV1().EndpointSlices(namespace).Update(context.TODO(), endpointSlice, metav1.UpdateOptions{}); err != nil { t.Errorf("failed to create endpoint slice %s in namespace %s (error %v)", name, namespace, err) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller_test.go
} } func buildMockController() *Controller { discovery1 := memory.NewServiceDiscovery(mock.ReplicatedFooServiceV1.DeepCopy(), mock.HelloService.DeepCopy(), mock.ExtHTTPService.DeepCopy(), ) for _, port := range mock.HelloService.Ports { discovery1.AddInstance(mock.MakeServiceInstance(mock.HelloService, port, 0, model.Locality{})) discovery1.AddInstance(mock.MakeServiceInstance(mock.HelloService, port, 1, model.Locality{}))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 14.5K bytes - Viewed (0)