- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 582 for observ (0.2 sec)
-
pkg/proxy/nftables/proxier.go
} // OnServiceAdd is called whenever creation of new service object // is observed. func (proxier *Proxier) OnServiceAdd(service *v1.Service) { proxier.OnServiceUpdate(nil, service) } // OnServiceUpdate is called whenever modification of an existing // service object is observed. func (proxier *Proxier) OnServiceUpdate(oldService, service *v1.Service) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackDecodeTestBase.kt
} /** * Checks if `expected` and `observed` are equal when viewed as a set and headers are * deduped. * * TODO: See if duped headers should be preserved on decode and verify. */ private fun assertSetEquals( message: String, expected: List<Header>, observed: List<Header>, ) { assertThat(LinkedHashSet(observed), message) .isEqualTo(LinkedHashSet(expected))
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/metrics/metrics.go
} dekCacheInterArrivals.WithLabelValues(transformationType).Observe(start.Sub(lastFromStorage).Seconds()) lastFromStorage = start case ToStorageLabel: lockLastToStorage.Lock() defer lockLastToStorage.Unlock() if lastToStorage.IsZero() { lastToStorage = start } dekCacheInterArrivals.WithLabelValues(transformationType).Observe(start.Sub(lastToStorage).Seconds()) lastToStorage = start } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 09 22:31:32 UTC 2023 - 12K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler.go
slices.toDelete = append(slices.toDelete, existingSlice) } } } metrics.EndpointsAddedPerSync.WithLabelValues().Observe(float64(totals.added)) metrics.EndpointsUpdatedPerSync.WithLabelValues().Observe(float64(totals.updated)) metrics.EndpointsRemovedPerSync.WithLabelValues().Observe(float64(totals.removed)) endpointsNN := types.NamespacedName{Name: endpoints.Name, Namespace: endpoints.Namespace}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 13.1K bytes - Viewed (0) -
samples/extauthz/README.md
< content-length: 0 < x-envoy-upstream-service-time: 19 < server: envoy < * Connection #0 to host ext-authz-server left intact ``` As you observe, the check request with header `x-ext-authz: allow` is allowed by the Ext Authz server. Send another check request with `x-ext-authz: blabla` to the Ext Authz server: ```console
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Sep 21 13:52:47 UTC 2023 - 4.1K bytes - Viewed (0) -
samples/tcp-echo/README.md
```console $ kubectl run -i --rm --restart=Never dummy --image=busybox -- sh -c "echo world | nc tcp-echo 9000" hello world pod "dummy" deleted ``` As you observe, sending _world_ on a TCP connection to the server results in the server prepending _hello_ and echoing back with _hello world_. 1. To clean up, execute the following command: ```console
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Oct 28 07:41:56 UTC 2022 - 1.2K bytes - Viewed (0) -
pkg/scheduler/metrics/profile_metrics.go
observeScheduleAttemptAndLatency(ErrorResult, profile, duration) } func observeScheduleAttemptAndLatency(result, profile string, duration float64) { schedulingLatency.WithLabelValues(result, profile).Observe(duration) scheduleAttempts.WithLabelValues(result, profile).Inc()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 07 13:18:13 UTC 2023 - 1.7K bytes - Viewed (0) -
cmd/tier_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "testing" "time" ) func TestTierMetrics(t *testing.T) { tier := "WARM-1" globalTierMetrics.Observe(tier, 200*time.Millisecond) expSuccess := 10 expFailure := 5 for i := 0; i < expSuccess; i++ { globalTierMetrics.logSuccess(tier) } for i := 0; i < expFailure; i++ { globalTierMetrics.logFailure(tier) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Dec 21 04:13:40 UTC 2023 - 1.5K bytes - Viewed (0) -
pkg/proxy/config/config.go
// OnServiceAdd is called whenever creation of new service object // is observed. OnServiceAdd(service *v1.Service) // OnServiceUpdate is called whenever modification of an existing // service object is observed. OnServiceUpdate(oldService, service *v1.Service) // OnServiceDelete is called whenever deletion of an existing service // object is observed. OnServiceDelete(service *v1.Service)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 15.1K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/execution/MojoExecutionListener.java
* under the License. */ package org.apache.maven.execution; import org.apache.maven.plugin.MojoExecutionException; /** * <p> * Extension point that allows build extensions observe and possibly veto mojo executions. * </p> * <strong>Note:</strong> This interface is part of work in progress and can be changed or removed without notice. * * @see org.apache.maven.execution.scope.WeakMojoExecutionListener
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Nov 22 13:26:01 UTC 2022 - 1.5K bytes - Viewed (0)