- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 582 for observ (0.1 sec)
-
pkg/proxy/metaproxier/meta_proxier.go
} // OnServiceAdd is called whenever creation of new service object is observed. func (proxier *metaProxier) OnServiceAdd(service *v1.Service) { proxier.ipv4Proxier.OnServiceAdd(service) proxier.ipv6Proxier.OnServiceAdd(service) } // OnServiceUpdate is called whenever modification of an existing // service object is observed. func (proxier *metaProxier) OnServiceUpdate(oldService, service *v1.Service) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 21 14:28:37 UTC 2024 - 5.9K bytes - Viewed (0) -
test/fixedbugs/issue19182.go
i, val := 0, atomic.LoadUint64(&a) for ; val == 0 && i < 100; val, i = atomic.LoadUint64(&a), i+1 { time.Sleep(100 * time.Millisecond) } if val == 0 { fmt.Printf("Failed to observe atomic increment after %d tries\n", i) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:25 UTC 2023 - 737 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/responsewriters/errors_test.go
{"InternalError", "/<script>", "Internal Server Error: \"/<script>\": ARGH\n"}, } for _, test := range cases { observer := httptest.NewRecorder() fns[test.fn](observer, &http.Request{RequestURI: test.uri}) result := observer.Body.String() if result != test.expected { t.Errorf("%s(..., %q) != %q, got %q", test.fn, test.uri, test.expected, result) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 29 07:45:20 UTC 2022 - 4.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filters/metrics.go
resultLabel = noOpinionLabel } authorizationAttemptsCounter.WithContext(ctx).WithLabelValues(resultLabel).Inc() authorizationLatency.WithContext(ctx).WithLabelValues(resultLabel).Observe(authFinish.Sub(authStart).Seconds()) } func recordAuthenticationMetrics(ctx context.Context, resp *authenticator.Response, ok bool, err error, apiAudiences authenticator.Audiences, authStart time.Time, authFinish time.Time) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 20 13:35:55 UTC 2023 - 5.3K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/projectresult/ResolvedLocalComponentsResultGraphVisitor.java
* so that we instantly mark configurations as observed as their metadata is constructed. That would be an improvement * over this visitor, since here we only mark a configuration observed if its metadata is present in the final graph. * There are likely scenarios that this visitor does not cover, where a configuration's metadata is observed but * its component is not present in the final graph. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 14:19:34 UTC 2024 - 5K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/artifacts/dsl/DependencyCollectorIntegrationTest.groovy
*/ class DependencyCollectorIntegrationTest extends AbstractIntegrationSpec { def "cannot add dependencies after dependency set has been observed"() { given: buildFile << """ ${createDependenciesAndConfiguration()} dependencies.implementation 'com:foo:1.0' assert conf.dependencies*.name == ["foo"]
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 22 00:10:09 UTC 2024 - 4.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
* worker runs and exhausts the queue, another thread enqueues a task and fails to schedule the * worker, and then the first thread's call to delegate.execute() returns. Without this counter, * it would observe the QUEUING state and set it to QUEUED, and the worker would never be * scheduled again for future submissions. */ @GuardedBy("queue") private long workerRunCount = 0;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 10.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/SequentialExecutor.java
* worker runs and exhausts the queue, another thread enqueues a task and fails to schedule the * worker, and then the first thread's call to delegate.execute() returns. Without this counter, * it would observe the QUEUING state and set it to QUEUED, and the worker would never be * scheduled again for future submissions. */ @GuardedBy("queue") private long workerRunCount = 0;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 10.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/metrics.go
transformerOperationsTotal.WithLabelValues(transformationType, transformerPrefix, getErrorCode(err)).Inc() if err == nil { transformerLatencies.WithLabelValues(transformationType, transformerPrefix).Observe(elapsed.Seconds()) } } // RecordCacheMiss records a miss on Key Encryption Key(KEK) - call to KMS was required to decrypt KEK. func RecordCacheMiss() { envelopeTransformationCacheMissTotal.Inc() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 22:44:02 UTC 2023 - 5.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/metrics/metrics.go
}) } func RecordRequestBodySize(ctx context.Context, resource string, verb RequestBodyVerb, size int) { RequestBodySizes.WithContext(ctx).WithLabelValues(resource, string(verb)).Observe(float64(size))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 16 02:06:01 UTC 2023 - 1.8K bytes - Viewed (0)