- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for DiscoveryV1 (0.27 sec)
-
pkg/proxy/config/config_test.go
state map[types.NamespacedName]*discoveryv1.EndpointSlice synced bool updated chan []*discoveryv1.EndpointSlice process func([]*discoveryv1.EndpointSlice) } func NewEndpointSliceHandlerMock() *EndpointSliceHandlerMock { ehm := &EndpointSliceHandlerMock{ state: make(map[types.NamespacedName]*discoveryv1.EndpointSlice), updated: make(chan []*discoveryv1.EndpointSlice, 5), }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/proxy/config/config.go
// object is observed. OnEndpointSliceAdd(endpointSlice *discoveryv1.EndpointSlice) // OnEndpointSliceUpdate is called whenever modification of an existing // endpoint slice object is observed. OnEndpointSliceUpdate(oldEndpointSlice, newEndpointSlice *discoveryv1.EndpointSlice) // OnEndpointSliceDelete is called whenever deletion of an existing // endpoint slice object is observed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 15.1K bytes - Viewed (0) -
pkg/controlplane/reconcilers/endpointsadapter_test.go
epAdapter := NewEndpointsAdapter(client.CoreV1(), client.DiscoveryV1()) err := epAdapter.EnsureEndpointSliceFromEndpoints(testCase.namespaceParam, testCase.endpointsParam) if !apiequality.Semantic.DeepEqual(testCase.expectedError, err) { t.Errorf("Expected error: %v, got: %v", testCase.expectedError, err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 15.4K bytes - Viewed (0) -
pilot/pkg/xds/mesh_network_test.go
Port: w.port, Name: "http", Protocol: corev1.ProtocolTCP, }}, }, }, &discoveryv1.EndpointSlice{ ObjectMeta: baseMeta, Endpoints: []discoveryv1.Endpoint{{ Addresses: []string{w.ip}, Conditions: discoveryv1.EndpointConditions{}, Hostname: nil, TargetRef: &corev1.ObjectReference{ APIVersion: "v1", Kind: "Pod",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 24.6K bytes - Viewed (0) -
pkg/controlplane/reconcilers/instancecount_test.go
} for _, test := range reconcileTests { t.Run(test.testName, func(t *testing.T) { fakeClient := fake.NewSimpleClientset(test.initialState...) epAdapter := NewEndpointsAdapter(fakeClient.CoreV1(), fakeClient.DiscoveryV1()) reconciler := NewMasterCountEndpointReconciler(test.additionalMasters+1, epAdapter) err := reconciler.ReconcileEndpoints(test.serviceName, netutils.ParseIPSloppy(test.ip), test.endpointPorts, true) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 27 12:46:24 UTC 2022 - 14K bytes - Viewed (0) -
pkg/controlplane/reconcilers/lease_test.go
if err != nil { t.Errorf("unexpected error creating keys: %v", err) } clientset := fake.NewSimpleClientset(test.initialState...) epAdapter := NewEndpointsAdapter(clientset.CoreV1(), clientset.DiscoveryV1()) r := NewLeaseEndpointReconciler(epAdapter, fakeLeases) err = r.ReconcileEndpoints(test.serviceName, netutils.ParseIPSloppy(test.ip), test.endpointPorts, true) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 28.7K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler.go
// If there are slices to create and delete, recycle the slices marked for // deletion by replacing creates with updates of slices that would otherwise // be deleted. recycleSlices(&slices) epsClient := r.client.DiscoveryV1().EndpointSlices(endpoints.Namespace) // Don't create more EndpointSlices if corresponding Endpoints resource is // being deleted. if endpoints.DeletionTimestamp == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 13.1K bytes - Viewed (0) -
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) -
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)