- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 375 for observ (0.19 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/metrics/metrics.go
m.policyCheck.WithContext(ctx).WithLabelValues(policy, binding, "allow", state).Inc() m.policyLatency.WithContext(ctx).WithLabelValues(policy, binding, "allow", state).Observe(elapsed.Seconds()) } // ObserveRejection observes a policy validation error that was at least one of the reasons for a deny.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 5.4K bytes - Viewed (0) -
src/internal/runtime/atomic/types_64bit.go
package atomic // LoadAcquire is a partially unsynchronized version // of Load that relaxes ordering constraints. Other threads // may observe operations that precede this operation to // occur after it, but no operation that occurs after it // on this thread can be observed to occur before it. // // WARNING: Use sparingly and with great care. // //go:nosplit func (u *Uint64) LoadAcquire() uint64 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 1.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/metrics/metrics_test.go
"apiserver_validating_admission_policy_check_total", "apiserver_validating_admission_policy_check_duration_seconds", } testCases := []struct { desc string want string observer metricsObserver }{ { desc: "observe policy admission", want: `
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 6.9K bytes - Viewed (0) -
doc/go_mem.html
<p> A read <i>r</i> of a memory location <i>x</i> holding a value that is not larger than a machine word must observe some write <i>w</i> such that <i>r</i> does not happen before <i>w</i> and there is no write <i>w'</i> such that <i>w</i> happens before <i>w'</i> and <i>w'</i> happens before <i>r</i>. That is, each read must observe a value written by a preceding or concurrent write. </p> <p>
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 15:54:42 UTC 2024 - 26.6K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector_test.go
}), // observe cluster-scoped parent processEvent(makeAddEvent(node1)), assertState(state{ graphNodes: []*node{makeNode(pod1ns1, withOwners(node1)), makeNode(node1)}, // node1 switched to observed, fixed namespace coordinate
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/configurations/ProjectComponentObservationListener.java
import org.gradle.util.Path; import javax.annotation.Nullable; /** * A listener that is notified when one project observes the local component metadata of another. */ @StatefulListener @EventScope(Scope.Build.class) public interface ProjectComponentObservationListener { /** * Called when one project observes the local component metadata of another project. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 1.5K bytes - Viewed (0) -
src/internal/runtime/atomic/types.go
return Load(&u.value) } // LoadAcquire is a partially unsynchronized version // of Load that relaxes ordering constraints. Other threads // may observe operations that precede this operation to // occur after it, but no operation that occurs after it // on this thread can be observed to occur before it. // // WARNING: Use sparingly and with great care. // //go:nosplit func (u *Uint32) LoadAcquire() uint32 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 14.2K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
if proxier.ipvsScheduler == "mh" { serv.Flags |= utilipvs.FlagSourceHash } // We need to bind ClusterIP to dummy interface, so set `bindAddr` parameter to `true` in syncService() if err := proxier.syncService(svcPortNameString, serv, true, alreadyBoundAddrs); err == nil { activeIPVSServices.Insert(serv.String()) activeBindAddrs.Insert(serv.Address.String())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0) -
platforms/core-configuration/input-tracking/src/main/java/org/gradle/internal/configuration/inputs/AccessTrackingProperties.java
* the caller. If the modifying method provides a way for the caller to observe a previous value of the key then * {@link #onAccess(Object, Object)} method is called prior to this method. * <p> * The state of the observed Properties object is undefined for the duration of the call: it may be already completely or partially
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 23 07:32:51 UTC 2024 - 20.7K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager.go
// track when a threshold was first observed now := m.clock.Now() thresholdsFirstObservedAt := thresholdsFirstObservedAt(thresholds, m.thresholdsFirstObservedAt, now) // the set of node conditions that are triggered by currently observed thresholds nodeConditions := nodeConditions(thresholds) if len(nodeConditions) > 0 { klog.V(3).InfoS("Eviction manager: node conditions - observed", "nodeCondition", nodeConditions) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 27 18:55:56 UTC 2024 - 24.6K bytes - Viewed (0)