- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 1,299 for endpoints2 (0.15 sec)
-
prow/config/calico.yaml
traffic that goes from a workload endpoint to the host itself (after the traffic hits the endpoint egress policy). By default Calico blocks traffic from workload endpoints to the host itself with an iptables "DROP" action. If you want to allow some or all traffic from endpoint to host, set this parameter to RETURN or ACCEPT. Use
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:01 UTC 2024 - 246.5K bytes - Viewed (0) -
pkg/controlplane/reconcilers/endpointsadapter.go
// returned. func (adapter *EndpointsAdapter) Create(namespace string, endpoints *corev1.Endpoints) (*corev1.Endpoints, error) { endpoints, err := adapter.endpointClient.Endpoints(namespace).Create(context.TODO(), endpoints, metav1.CreateOptions{}) if err == nil { err = adapter.EnsureEndpointSliceFromEndpoints(namespace, endpoints) } return endpoints, err }
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/controller/endpointslicemirroring/reconciler.go
endpointsNN := types.NamespacedName{Name: endpoints.Name, Namespace: endpoints.Namespace} r.metricsCache.UpdateEndpointPortCache(endpointsNN, epMetrics) return r.finalize(endpoints, slices) } // reconcileByPortMapping compares the endpoints found in existing slices with // the list of desired endpoints and returns lists of slices to create, update, // and delete.
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/controller/endpointslicemirroring/utils_test.go
Namespace: endpoints.Namespace, OwnerReferences: []metav1.OwnerReference{*ownerRef}, }, Ports: ports, AddressType: addrType, Endpoints: []discovery.Endpoint{}, }, }, { name: "create slice from endpoints with annotations", tweakEndpoint: func(ep *v1.Endpoints) { annotations := map[string]string{"foo": "bar"} ep.Annotations = annotations },
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
testName: "Endpoints with skip-mirror=true", endpoints: &v1.Endpoints{ ObjectMeta: metav1.ObjectMeta{ Name: "test-endpoints", Labels: map[string]string{ discovery.LabelSkipMirror: "true", }, }, }, shouldMirror: false, }, { testName: "Endpoints with skip-mirror=invalid", endpoints: &v1.Endpoints{ ObjectMeta: metav1.ObjectMeta{ Name: "test-endpoints",
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/endpoint/endpoints_controller_test.go
}, } endpoints.serviceStore.Add(service) endpoints.onServiceUpdate(service) endpoints.podsSynced = test.podsSynced endpoints.servicesSynced = test.servicesSynced endpoints.endpointsSynced = test.endpointsSynced endpoints.workerLoopPeriod = 10 * time.Millisecond go endpoints.Run(tCtx, 1)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0) -
pkg/proxy/healthcheck/healthcheck_test.go
} if hcs.services[nsn1].endpoints != 0 { t.Errorf("expected 0 endpoints, got %d", hcs.services[nsn1].endpoints) } if hcs.services[nsn2].endpoints != 0 { t.Errorf("expected 0 endpoints, got %d", hcs.services[nsn2].endpoints) } if hcs.services[nsn3].endpoints != 0 { t.Errorf("expected 0 endpoints, got %d", hcs.services[nsn3].endpoints) } if len(listener.openPorts) != 3 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 21.4K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
// onEndpointsAdd queues a sync for the relevant Endpoints resource. func (c *Controller) onEndpointsAdd(logger klog.Logger, obj interface{}) { endpoints := obj.(*v1.Endpoints) if endpoints == nil { utilruntime.HandleError(fmt.Errorf("onEndpointsAdd() expected type v1.Endpoints, got %T", obj)) return } if !c.shouldMirror(endpoints) { logger.V(5).Info("Skipping mirroring", "endpoints", klog.KObj(endpoints)) return }
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/proxy/topology_test.go
serviceInfo: &BaseServicePortInfo{}, endpoints: []Endpoint{ &BaseEndpointInfo{endpoint: "10.0.0.0:80", ready: false}, &BaseEndpointInfo{endpoint: "10.0.0.1:80", ready: false}, }, clusterEndpoints: sets.New[string](), localEndpoints: nil, }, { name: "Cluster traffic policy, some endpoints are Ready", serviceInfo: &BaseServicePortInfo{}, endpoints: []Endpoint{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 26.6K bytes - Viewed (0) -
pkg/apis/discovery/validation/validation_test.go
}) } return ports } func generateEndpoints(n int) []discovery.Endpoint { endpoints := []discovery.Endpoint{} for i := 0; i < n; i++ { endpoints = append(endpoints, discovery.Endpoint{ Addresses: []string{fmt.Sprintf("10.1.2.%d", i%255)}, }) } return endpoints } func generateIPAddresses(n int) []string { addresses := []string{} for i := 0; i < n; i++ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 05 10:48:05 UTC 2023 - 23.9K bytes - Viewed (0)