- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 234 for Healthy (0.12 sec)
-
samples/addons/prometheus.yaml
periodSeconds: 5 timeoutSeconds: 4 failureThreshold: 3 successThreshold: 1 livenessProbe: httpGet: path: /-/healthy port: 9090 scheme: HTTP initialDelaySeconds: 30 periodSeconds: 15 timeoutSeconds: 10 failureThreshold: 3
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:57:35 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/topology_hints.go
return true } } return false } func (m *ManagerImpl) getAvailableDevices(resource string) sets.Set[string] { // Strip all devices in use from the list of healthy ones. return m.healthyDevices[resource].Difference(m.allocatedDevices[resource]) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 9.9K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
func (s *DiscoveryServer) handleWorkloadHealthcheck(proxy *model.Proxy, req *discovery.DiscoveryRequest) { if features.WorkloadEntryHealthChecks { event := autoregistration.HealthEvent{} event.Healthy = req.ErrorDetail == nil if !event.Healthy { event.Message = req.ErrorDetail.Message } s.WorkloadEntryController.QueueWorkloadEntryHealth(proxy, event) } } // DeltaAggregatedResources is not implemented.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
m.With(resultLabel.Value(resultSuccess)).Increment() return nil } func (c *Controller) labelBrokenPod(pod *corev1.Pod) error { // Added for safety, to make sure no healthy pods get labeled. m := podsRepaired.With(typeLabel.Value(labelType)) repairLog.Infof("Pod detected as broken, adding label: %s/%s", pod.Namespace, pod.Name) labels := pod.GetLabels()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 10 00:31:55 UTC 2024 - 10.4K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/upgrade/plan.go
func runPlan(flagSet *pflag.FlagSet, flags *planFlags, args []string, printer output.Printer) error { // Start with the basics, verify that the cluster is healthy, build a client and a versionGetter. Never dry-run when planning. klog.V(1).Infoln("[upgrade/plan] verifying health of cluster") klog.V(1).Infoln("[upgrade/plan] retrieving configuration from cluster")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Mar 03 03:03:29 UTC 2024 - 14.9K bytes - Viewed (0) -
cmd/kubeadm/app/phases/etcd/local.go
etcdClient, err := etcdutil.NewFromCluster(client, certificatesDir) if err != nil { return err } // Checking health state err = etcdClient.CheckClusterHealth() if err != nil { return errors.Wrap(err, "etcd cluster is not healthy") } return nil } // RemoveStackedEtcdMemberFromCluster will remove a local etcd member from etcd cluster, // when reset the control plane node.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 14:07:27 UTC 2024 - 13.8K bytes - Viewed (1) -
pilot/pkg/serviceregistry/kube/controller/pod.go
if len(pc.c.handlers.GetWorkloadHandlers()) == 0 { return } // fire instance handles for workload ep := pc.c.NewEndpointBuilder(pod).buildIstioEndpoint(pod.Status.PodIP, 0, "", model.AlwaysDiscoverable, model.Healthy) workloadInstance := &model.WorkloadInstance{ Name: pod.Name, Namespace: pod.Namespace, Kind: model.PodKind, Endpoint: ep, PortMap: getPortMap(pod), }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 10.8K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/staticpods.go
return false, errors.New("external etcd detected, won't try to change any etcd state") } // Checking health state of etcd before proceeding with the upgrade err := oldEtcdClient.CheckClusterHealth() if err != nil { return true, errors.Wrap(err, "etcd cluster is not healthy") } // Backing up etcd data store backupEtcdDir := pathMgr.BackupEtcdDir() runningEtcdDir := cfg.Etcd.Local.DataDir
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 10:07:41 UTC 2024 - 30.7K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy.go
} }() go proxy.healthChecker.PerformApplicationHealthCheck(func(healthEvent *health.ProbeEvent) { // Store the same response as Delta and SotW. Depending on how Envoy connects we will use one or the other. req := &discovery.DiscoveryRequest{TypeUrl: model.HealthInfoType} if !healthEvent.Healthy { req.ErrorDetail = &google_rpc.Status{ Code: int32(codes.Internal),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0) -
samples/bookinfo/src/productpage/productpage.py
table_attributes="class=\"table table-condensed table-bordered table-hover\"") return render_template('index.html', serviceTable=table) @app.route('/health') def health(): return 'Product page is healthy' @app.route('/login', methods=['POST']) def login(): user = request.values.get('username') response = app.make_response(redirect(request.referrer))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 14:35:54 UTC 2024 - 14.6K bytes - Viewed (0)