- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 582 for observ (0.1 sec)
-
guava/src/com/google/common/collect/MapMaker.java
* be performed atomically on the returned map. Additionally, {@code size} and {@code * containsValue} are implemented as bulk read operations, and thus may fail to observe concurrent * writes. * * @return a serializable concurrent map having the requested features */ public <K, V> ConcurrentMap<K, V> makeMap() { if (!useCustomMap) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Mar 13 14:30:51 UTC 2023 - 12.8K bytes - Viewed (0) -
pkg/kubelet/eviction/helpers.go
threshold := thresholds[i] observed, found := observations[threshold.Signal] if found { quantity := evictionapi.GetThresholdQuantity(threshold.Value, observed.capacity) klogV.InfoS("Eviction manager: threshold observed resource", "log", logPrefix, "signal", threshold.Signal, "resourceName", signalToResource[threshold.Signal], "quantity", quantity, "available", observed.available) } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 53.6K bytes - Viewed (0) -
docs/features/interceptors.md
**Application interceptors** * Don't need to worry about intermediate responses like redirects and retries. * Are always invoked once, even if the HTTP response is served from the cache. * Observe the application's original intent. Unconcerned with OkHttp-injected headers like `If-None-Match`. * Permitted to short-circuit and not call `Chain.proceed()`. * Permitted to retry and make multiple calls to `Chain.proceed()`.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 8.1K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/internal/component/local/model/LocalComponentGraphResolveState.java
/** * We currently allow a configuration that has been partially observed for resolution to be modified * in a beforeResolve callback. * * To reduce the number of instances of root component metadata we create, we mark all configurations
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 22 16:00:57 UTC 2024 - 3.2K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/verification/ChecksumAndSignatureVerificationOverride.java
@Override public void run(BuildOperationContext context) { verifier.verify(checksumService, signatureVerificationService, ve.kind, ve.artifact, observed(ve.mainFile), observed(ve.signatureFile.create()), f -> { synchronized (failuresLock) { failures.put(ve.artifact, new RepositoryAwareVerificationFailure(f, ve.repositoryName));
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun Jan 21 03:12:15 UTC 2024 - 14.2K bytes - Viewed (0) -
pkg/proxy/ipvs/util/testing/fake.go
func (f *FakeIPVS) UpdateVirtualServer(serv *utilipvs.VirtualServer) error { if serv == nil { return fmt.Errorf("failed to update service, service can't be nil") } key := toServiceKey(serv) f.Services[key] = serv return nil } // DeleteVirtualServer is a fake implementation, it simply deletes the VirtualServer from the cache store. func (f *FakeIPVS) DeleteVirtualServer(serv *utilipvs.VirtualServer) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 7K bytes - Viewed (0) -
pkg/monitoring/monitoring_test.go
kind = monitoring.CreateLabel("kind") testSum = monitoring.NewSum( "events_total", "Number of events observed, by name and kind", ) goofySum = testSum.With(kind.Value("goofy")) hookSum = monitoring.NewSum( "hook_total", "Number of hook events observed", ) testDistribution = monitoring.NewDistribution( "test_buckets", "Testing distribution functionality",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Sep 13 16:04:48 UTC 2023 - 8.4K bytes - Viewed (0) -
pkg/kubelet/server/metrics/metrics.go
} // CollectVolumeStatCalDuration collects the duration in seconds to calculate volume stats. func CollectVolumeStatCalDuration(metricSource string, start time.Time) { VolumeStatCalDuration.WithLabelValues(metricSource).Observe(SinceInSeconds(start))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 19 14:33:37 UTC 2022 - 3.5K bytes - Viewed (0) -
src/runtime/debug/example_monitor_test.go
func ExampleSetCrashOutput_monitor() { appmain() // This Example doesn't actually run as a test because its // purpose is to crash, so it has no "Output:" comment // within the function body. // // To observe the monitor in action, replace the entire text // of this comment with "Output:" and run this command: // // $ go test -run=ExampleSetCrashOutput_monitor runtime/debug // panic: oops // ...stack...
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 15:19:04 UTC 2024 - 2.7K bytes - Viewed (0) -
pkg/kubelet/lifecycle/interfaces.go
// AddPodAdmitHandler adds the specified observer. func (handlers *PodAdmitHandlers) AddPodAdmitHandler(a PodAdmitHandler) { *handlers = append(*handlers, a) } // PodSyncLoopHandlers maintains a list of handlers to pod sync loop. type PodSyncLoopHandlers []PodSyncLoopHandler // AddPodSyncLoopHandler adds the specified observer.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 22 17:25:57 UTC 2017 - 4K bytes - Viewed (0)