- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 46 for lives (0.15 sec)
-
pkg/proxy/serviceport.go
// prior to dual stack services, this was considered an error, but with dual stack // services, this is actually expected. Hence we downgraded from reporting by events // to just log lines with high verbosity ipFamilyMap := proxyutil.MapIPsByIPFamily(service.Spec.ExternalIPs) info.externalIPs = ipFamilyMap[ipFamily] // Log the IPs not matching the ipFamily
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 09 08:17:56 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller.go
// Look for a Pod using pvc in the Informer's cache. If one is found the // correct decision to keep pvc is taken without doing an expensive live // list. logger := klog.FromContext(ctx) if inUse, err := c.askInformer(logger, pvc); err != nil { // No need to return because a live list will follow. logger.Error(err, "") } else if inUse { return true, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 14K bytes - Viewed (0) -
pkg/kubelet/certificate/kubelet.go
&compbasemetrics.HistogramOpts{ Subsystem: metrics.KubeletSubsystem, Name: "certificate_manager_server_rotation_seconds", Help: "Histogram of the number of seconds the previous certificate lived before being rotated.", Buckets: []float64{ 60, // 1 minute 3600, // 1 hour 14400, // 4 hours 86400, // 1 day 604800, // 1 week 2592000, // 1 month
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 03:07:16 UTC 2024 - 10.3K bytes - Viewed (0) -
pkg/proxy/healthcheck/healthcheck_test.go
hs.SyncNode(makeNode(tweakDeleted())) testHTTPHandler(hsTest, http.StatusOK, t) } type url string var ( healthzURL url = "/healthz" livezURL url = "/livez" ) func testProxierHealthUpdater(hs *ProxierHealthServer, hsTest *serverTest, fakeClock *testingclock.FakeClock, t *testing.T) { // Should return 200 "OK" by default. testHTTPHandler(hsTest, http.StatusOK, t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 21.4K bytes - Viewed (0) -
pkg/api/testing/defaulting_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 20.3K bytes - Viewed (0) -
cluster/gce/config-test.sh
exit 1 fi fi # Enable GCE Alpha features. if [[ -n "${GCE_ALPHA_FEATURES:-}" ]]; then PROVIDER_VARS="${PROVIDER_VARS:-} GCE_ALPHA_FEATURES" fi # Disable Docker live-restore. if [[ -n "${DISABLE_DOCKER_LIVE_RESTORE:-}" ]]; then PROVIDER_VARS="${PROVIDER_VARS:-} DISABLE_DOCKER_LIVE_RESTORE" fi # Override default GLBC image if [[ -n "${GCE_GLBC_IMAGE:-}" ]]; then
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 17:20:24 UTC 2024 - 29.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go
// the compactor is stopped. func startCompactorOnce(c storagebackend.TransportConfig, interval time.Duration) (func(), error) { compactorsMu.Lock() defer compactorsMu.Unlock() key := fmt.Sprintf("%v", c) // gives: {[server1 server2] keyFile certFile caFile} if compactor, foundBefore := compactors[key]; !foundBefore || compactor.interval > interval { compactorClient, err := newETCD3Client(c) if err != nil { return nil, err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 07:56:39 UTC 2024 - 15.1K bytes - Viewed (0) -
cluster/gce/windows/smoke-test.sh
# curl-ing the metrics-server service results in a ServerProtocolViolation # ("The server committed a protocol violation. Section=ResponseStatusLine") # exception. Since we don't care about what the metrics-server actually gives # back to us, just that we can reach it, we check that we get the expected # exception code and not some other exception code. # TODO: it might be less fragile to check that we don't get the "Unable to
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 07:02:51 UTC 2024 - 20.6K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/graph.go
// A node must never be able to create a pod that grants them permissions on other API objects. // The NodeRestriction admission plugin prevents creation of such pods, but short-circuiting here gives us defense in depth. if _, isMirrorPod := pod.Annotations[corev1.MirrorPodAnnotationKey]; isMirrorPod { return } // TODO(mikedanese): If the pod doesn't mount the service account secrets,
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/features/kube_features.go
// To add a new feature, define a key for it above and add it here. The features will be // available throughout Kubernetes binaries. // // Entries are separated from each other with blank lines to avoid sweeping gofmt changes // when adding or removing one entry. var defaultKubernetesFeatureGates = map[featuregate.Feature]featuregate.FeatureSpec{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 22:51:23 UTC 2024 - 45.2K bytes - Viewed (0)