- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 54 for current1_ (0.54 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)