- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 44 for Nodes (0.06 sec)
-
pkg/kubelet/kubelet_node_status_test.go
kubeClient.AddReactor("create", "nodes", func(action core.Action) (bool, runtime.Object, error) { return true, nil, tc.createError }) kubeClient.AddReactor("get", "nodes", func(action core.Action) (bool, runtime.Object, error) { // Return an existing (matching) node on get. return true, tc.existingNode, tc.getError })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 19:23:19 UTC 2024 - 115.8K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework_test.go
} return podInfo } // BuildNodeInfos build NodeInfo slice from a v1.Node slice func BuildNodeInfos(nodes []*v1.Node) []*framework.NodeInfo { res := make([]*framework.NodeInfo, len(nodes)) for i := 0; i < len(nodes); i++ { res[i] = framework.NewNodeInfo() res[i].SetNode(nodes[i]) } return res
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 103K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector_test.go
clientActions: []string{ "get /v1, Resource=nodes name=nodename", // lookup of node pre-delete }, graphNodes: []*node{makeNode(node1, withOwners(pod1nonamespace)), makeNode(pod1ns1)}, }), }, }, { name: "bad cluster-scoped child -> owner in ns1 (owner first)", steps: []step{ // setup createObjectInClient("", "v1", "nodes", "", makeMetadataObj(node1, pod1ns1)),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0) -
cluster/gce/gci/configure-helper.sh
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 22:07:47 UTC 2024 - 141.1K bytes - Viewed (0) -
cmd/admin-handlers.go
// // This newer API now returns back status per remote peer and local regarding // if a "restart/stop" was successful or not. Service signal now supports // a dry-run that helps skip the nodes that may have hung drives. By default // restart/stop will ignore the servers that are hung on drives. You can use // 'force' param to force restart even with hung drives if needed.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/LocalCache.java
* be read without locking. Next fields of nodes are immutable (final). All list additions are * performed at the front of each bin. This makes it easy to check changes, and also fast to * traverse. When nodes would otherwise be changed, new nodes are created to replace them. This
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat May 18 03:24:34 UTC 2024 - 143.6K bytes - Viewed (0) -
guava/src/com/google/common/cache/LocalCache.java
* be read without locking. Next fields of nodes are immutable (final). All list additions are * performed at the front of each bin. This makes it easy to check changes, and also fast to * traverse. When nodes would otherwise be changed, new nodes are created to replace them. This
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat May 18 03:24:34 UTC 2024 - 149.2K bytes - Viewed (0) -
cmd/metrics-v2.go
Help: "Total number of bytes sent to the other peer nodes", Type: counterMetric, } } func getInterNodeReceivedBytesMD() MetricDescription { return MetricDescription{ Namespace: interNodeMetricNamespace, Subsystem: trafficSubsystem, Name: receivedBytes, Help: "Total number of bytes received from other peer nodes", Type: counterMetric, } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:54 UTC 2024 - 131.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/testdata/swagger.json
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 20 15:45:02 UTC 2024 - 229.4K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
options.FieldSelector = fields.Set{metav1.ObjectNameField: string(nodeName)}.String() })) nodeLister = kubeInformers.Core().V1().Nodes().Lister() nodeHasSynced = func() bool { return kubeInformers.Core().V1().Nodes().Informer().HasSynced() } kubeInformers.Start(wait.NeverStop) klog.InfoS("Attempting to sync node with API server") } else { // we don't have a client to sync!
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0)