- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 873 for NodeName (0.12 sec)
-
pkg/scheduler/framework/plugins/examples/stateful/stateful.go
// point. In this trivial example, the Reserve method allocates an array of // strings. func (mp *MultipointExample) Reserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) *framework.Status { // Reserve is not called concurrently, and so we don't need to lock. mp.executionPoints = append(mp.executionPoints, "reserve") return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 09 03:43:17 UTC 2023 - 3.3K bytes - Viewed (0) -
pkg/volume/csi/nodeinfomanager/nodeinfomanager.go
UninstallCSIDriver(driverName string) error } // NewNodeInfoManager initializes nodeInfoManager func NewNodeInfoManager( nodeName types.NodeName, volumeHost volume.VolumeHost, migratedPlugins map[string](func() bool)) Interface { return &nodeInfoManager{ nodeName: nodeName, volumeHost: volumeHost, migratedPlugins: migratedPlugins, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 20.1K bytes - Viewed (0) -
pkg/volume/csi/csi_attacher.go
return nil } // getAttachmentName returns csi-<sha256(volName,csiDriverName,NodeName)> func getAttachmentName(volName, csiDriverName, nodeName string) string { result := sha256.Sum256([]byte(fmt.Sprintf("%s%s%s", volName, csiDriverName, nodeName))) return fmt.Sprintf("csi-%x", result) } func makeDeviceMountPath(plugin *csiPlugin, spec *volume.Spec) (string, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 03 07:38:14 UTC 2023 - 25.9K bytes - Viewed (0) -
pkg/kubelet/client/kubelet_client.go
}, nil } // GetConnectionInfo retrieves connection info from the status of a Node API object. func (k *NodeConnectionInfoGetter) GetConnectionInfo(ctx context.Context, nodeName types.NodeName) (*ConnectionInfo, error) { node, err := k.nodes.Get(ctx, string(nodeName), metav1.GetOptions{}) if err != nil { return nil, err } // Find a kubelet-reported address, using preferred address type
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 07 01:34:49 UTC 2023 - 7.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/examples/multipoint/multipoint.go
data: s.data, } return copy } // Reserve is the function invoked by the framework at "reserve" extension point. func (mc CommunicatingPlugin) Reserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) *framework.Status { if pod == nil { return framework.NewStatus(framework.Error, "pod cannot be nil") } if pod.Name == "my-test-pod" { state.Write(framework.StateKey(pod.Name), &stateData{data: "never bind"})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 09 03:43:17 UTC 2023 - 3K bytes - Viewed (0) -
src/os/sys_linux.go
var un syscall.Utsname err = syscall.Uname(&un) var buf [512]byte // Enough for a DNS name. for i, b := range un.Nodename[:] { buf[i] = uint8(b) if b == 0 { name = string(buf[:i]) break } } // If we got a name and it's not potentially truncated // (Nodename is 65 bytes), return it. if err == nil && len(name) > 0 && len(name) < 64 { return name, nil } if runtime.GOOS == "android" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 02 14:41:57 UTC 2018 - 1K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
if err := nc.reconcileNodeLabels(ctx, nodeName); err != nil { logger.Error(err, "Failed to reconcile labels for node, requeue it", "node", klog.KRef("", nodeName)) // TODO(yujuhong): Add nodeName back to the queue } nc.nodeUpdateQueue.Done(nodeName) } } func (nc *Controller) doNoScheduleTaintingPass(ctx context.Context, nodeName string) error { node, err := nc.nodeLister.Get(nodeName) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
Spec: example.PodSpec{NodeName: "machine"}, } podB := &example.Pod{ ObjectMeta: metav1.ObjectMeta{Name: "foo", Namespace: "test"}, Spec: example.PodSpec{NodeName: "machine2"}, } podAWithResourceVersion := &example.Pod{ ObjectMeta: metav1.ObjectMeta{Name: "foo", Namespace: "test", ResourceVersion: "7"}, Spec: example.PodSpec{NodeName: "machine"}, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeaffinity/node_affinity_test.go
} var gotList framework.NodeScoreList for _, n := range test.nodes { nodeName := n.ObjectMeta.Name score, status := p.(framework.ScorePlugin).Score(ctx, state, test.pod, nodeName) if !status.IsSuccess() { t.Errorf("unexpected error: %v", status) } gotList = append(gotList, framework.NodeScore{Name: nodeName, Score: score}) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Dec 18 12:00:10 UTC 2023 - 38.7K bytes - Viewed (0) -
pkg/controller/controller_utils.go
func (s ByLogging) Swap(i, j int) { s[i], s[j] = s[j], s[i] } func (s ByLogging) Less(i, j int) bool { // 1. assigned < unassigned if s[i].Spec.NodeName != s[j].Spec.NodeName && (len(s[i].Spec.NodeName) == 0 || len(s[j].Spec.NodeName) == 0) { return len(s[i].Spec.NodeName) > 0 } // 2. PodRunning < PodUnknown < PodPending if s[i].Status.Phase != s[j].Status.Phase {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 12 15:34:44 UTC 2024 - 47.6K bytes - Viewed (0)