Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 54 for current1_ (0.15 sec)

  1. cmd/kubelet/app/server.go

    	}
    
    	nodeName, err := instances.CurrentNodeName(context.TODO(), hostname)
    	if err != nil {
    		return "", fmt.Errorf("error fetching current node name from cloud provider: %w", err)
    	}
    
    	klog.V(2).InfoS("Cloud provider determined current node", "nodeName", klog.KRef("", string(nodeName)))
    
    	return nodeName, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:34 UTC 2024
    - 53.9K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/route/route.go

    type DestinationHashMap map[*networking.HTTPRouteDestination]*networking.LoadBalancerSettings_ConsistentHashLB
    
    // VirtualHostWrapper is a context-dependent virtual host entry with guarded routes.
    // Note: Currently we are not fully utilizing this structure. We could invoke this logic
    // once for all sidecars in the cluster to compute all RDS for inside the mesh and arrange
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 14:12:39 UTC 2024
    - 56.1K bytes
    - Viewed (0)
  3. cmd/xl-storage.go

    	defer xioutil.SafeClose(updates)
    	var lc *lifecycle.Lifecycle
    
    	// Check if the current bucket has a configured lifecycle policy
    	if globalLifecycleSys != nil {
    		lc, err = globalLifecycleSys.Get(cache.Info.Name)
    		if err == nil && lc.HasActiveRules("") {
    			cache.Info.lifeCycle = lc
    		}
    	}
    
    	// Check if the current bucket has replication configuration
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (2)
  4. src/cmd/go/internal/modload/init.go

    	// a go.mod file in the current directory or any parent. If none is found,
    	// modules may be disabled (GO111MODULE=auto) or commands may run in a
    	// limited module mode.
    	AutoRoot Root = iota
    
    	// NoRoot is used for commands that run in module mode and ignore any go.mod
    	// file the current directory or in parent directories.
    	NoRoot
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 18:36:30 UTC 2024
    - 69.8K bytes
    - Viewed (0)
  5. pkg/kubelet/kuberuntime/kuberuntime_manager.go

    	// typeName is a description used to describe this type of container in log messages,
    	// currently: "container", "init container" or "ephemeral container"
    	// metricLabel is the label used to describe this type of container in monitoring metrics.
    	// currently: "container", "init_container" or "ephemeral_container"
    	start := func(ctx context.Context, typeName, metricLabel string, spec *startSpec) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 02:01:31 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  6. hack/local-up-cluster.sh

    ENABLE_HOSTPATH_PROVISIONER=${ENABLE_HOSTPATH_PROVISIONER:-"false"}
    CLAIM_BINDER_SYNC_PERIOD=${CLAIM_BINDER_SYNC_PERIOD:-"15s"} # current k8s default
    ENABLE_CONTROLLER_ATTACH_DETACH=${ENABLE_CONTROLLER_ATTACH_DETACH:-"true"} # current default
    LOCAL_STORAGE_CAPACITY_ISOLATION=${LOCAL_STORAGE_CAPACITY_ISOLATION:-"true"} # current default
    # This is the default dir and filename where the apiserver will generate a self-signed cert
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 25 02:33:52 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    			if err != nil {
    				t.Errorf("unexpected parsing error: %v", err)
    			} else {
    				if rv < currentRV {
    					t.Errorf("watcher going back in time")
    				}
    				currentRV = rv
    			}
    		case <-time.After(time.Second):
    			w2.Stop()
    		}
    	}
    }
    
    func TestCacherDontAcceptRequestsStopped(t *testing.T) {
    	backingStorage := &dummyStorage{}
    	cacher, _, err := newTestCacher(backingStorage)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
  8. tests/integration/ambient/baseline_test.go

    		}
    
    		// Non-HBONE clients will attempt to bypass the waypoint
    		if !src.Config().WaypointClient() && dst.Config().HasAnyWaypointProxy() && !src.Config().HasSidecar() {
    			// TODO currently leads to no L7 processing, in the future it might be denied
    			// opt.Check = check.Error()
    			opt.Check = tcpValidator
    		}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 00:07:28 UTC 2024
    - 78.4K bytes
    - Viewed (0)
  9. pilot/pkg/config/kube/gateway/conversion.go

    			Weight:      int32(weights[i]),
    		})
    	}
    	return res, invalidBackendErr, nil
    }
    
    func buildTLSMatch(hostnames []k8s.Hostname) []*istio.TLSMatchAttributes {
    	// Currently, the spec only supports extensions beyond hostname, which are not currently implemented by Istio.
    	return []*istio.TLSMatchAttributes{{
    		SniHosts: hostnamesToStringListWithWildcard(hostnames),
    	}}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 84.7K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    	timer *time.Timer
    
    	// dispatching determines whether there is currently dispatching of
    	// any event in flight.
    	dispatching bool
    	// watchersBuffer is a list of watchers potentially interested in currently
    	// dispatched event.
    	watchersBuffer []*cacheWatcher
    	// blockedWatchers is a list of watchers whose buffer is currently full.
    	blockedWatchers []*cacheWatcher
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
Back to top