- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 582 for observ (0.2 sec)
-
staging/src/k8s.io/apiserver/pkg/cel/metrics/metrics.go
func (m *CelMetrics) ObserveCompilation(elapsed time.Duration) { seconds := elapsed.Seconds() m.compilationTime.Observe(seconds) } // ObserveEvaluation records a CEL evaluation with the time the evaluation took. func (m *CelMetrics) ObserveEvaluation(elapsed time.Duration) { seconds := elapsed.Seconds() m.evaluationTime.Observe(seconds)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 09 23:50:48 UTC 2022 - 2.1K bytes - Viewed (0) -
src/text/tabwriter/example_test.go
fmt.Fprintln(w) w.Flush() // output: // a b c d . // 123 12345 1234567 123456789 . // // a b c d. // 123 12345 1234567 123456789. } func Example_elastic() { // Observe how the b's and the d's, despite appearing in the // second cell of each line, belong to different columns. w := tabwriter.NewWriter(os.Stdout, 0, 0, 1, '.', tabwriter.AlignRight|tabwriter.Debug) fmt.Fprintln(w, "a\tb\tc")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 23 22:09:32 UTC 2016 - 2K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection.go
OnStartedLeading func(context.Context) // OnStoppedLeading is called when a LeaderElector client stops leading OnStoppedLeading func() // OnNewLeader is called when the client observes a leader that is // not the previously observed leader. This includes the first observed // leader when the client starts. OnNewLeader func(identity string) } // LeaderElector is a leader election client. type LeaderElector struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 24 04:04:42 UTC 2023 - 16.3K bytes - Viewed (0) -
src/runtime/chan.go
// and not ready for sending. We behave as if we observed the channel at that moment, // and report that the send cannot proceed. // // It is okay if the reads are reordered here: if we observe that the channel is not // ready for sending and then observe that it is not closed, that implies that the // channel wasn't closed during the first observation. However, nothing here
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0) -
pkg/volume/util/metrics.go
status = statusFailUnknown } migrated := false if c.Migrated != nil { migrated = *c.Migrated } StorageOperationMetric.WithLabelValues(plugin, operationName, status, strconv.FormatBool(migrated)).Observe(timeTaken) } return opComplete } // FSGroupCompleteHook returns a hook to call when volume recursive permission is changed
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 23 23:05:31 UTC 2022 - 5.8K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
// Keep track of how long syncs take. start := time.Now() defer func() { metrics.SyncProxyRulesLatency.Observe(metrics.SinceInSeconds(start)) if tryPartialSync { metrics.SyncPartialProxyRulesLatency.Observe(metrics.SinceInSeconds(start)) } else { metrics.SyncFullProxyRulesLatency.Observe(metrics.SinceInSeconds(start)) } proxier.logger.V(2).Info("SyncProxyRules complete", "elapsed", time.Since(start)) }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/graph.go
// secret -> pod // configmap -> pod // pvc -> pod // svcacct -> pod func (g *Graph) AddPod(pod *corev1.Pod) { start := time.Now() defer func() { graphActionsDuration.WithLabelValues("AddPod").Observe(time.Since(start).Seconds()) }() g.lock.Lock() defer g.lock.Unlock() g.deleteVertex_locked(podVertexType, pod.Namespace, pod.Name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 17.5K bytes - Viewed (0) -
pkg/controller/namespace/namespace_controller.go
// This allows time for the following to occur: // * lifecycle admission plugins on HA apiservers to also observe a namespace // deletion and prevent new objects from being created in the terminating namespace // * non-leader etcd servers to observe last-minute object creations in a namespace // so this controller's cleanup can actually clean up all objects namespaceDeletionGracePeriod = 5 * time.Second
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.6K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/go/analysis/passes/loopclosure/doc.go
// iteration variable of an enclosing loop, and the loop calls the function // in such a way (e.g. with go or defer) that it may outlive the loop // iteration and possibly observe the wrong value of the variable. // // Note: An iteration variable can only outlive a loop iteration in Go versions <=1.21. // In Go 1.22 and later, the loop variable lifetimes changed to create a new
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Nov 20 21:52:54 UTC 2023 - 2.6K bytes - Viewed (0) -
releasenotes/notes/29427.yaml
upgradeNotes: - title: Connectivity issues among your proxies when updating from 1.7.x to 1.7.5 or newer. content: | When upgrading your Istio data plane from 1.7.x (where x < 5) to 1.7.5 or newer, you may observe connectivity issues between your gateway and your sidecars or among your sidecars with 503 errors in the log. This happens when 1.7.5+ proxies send HTTP 1xx or 204 response
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 08 21:29:31 UTC 2020 - 653 bytes - Viewed (0)