- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 873 for NodeName (0.17 sec)
-
cmd/kubeadm/app/cmd/upgrade/plan.go
func newComponentUpgradePlan(name, currentVersion, newVersion, nodeName string) outputapiv1alpha3.ComponentUpgradePlan { return outputapiv1alpha3.ComponentUpgradePlan{ Name: name, CurrentVersion: currentVersion, NewVersion: newVersion, NodeName: nodeName, } } // runPlan takes care of outputting available versions to upgrade to for the user
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Mar 03 03:03:29 UTC 2024 - 14.9K bytes - Viewed (0) -
pkg/kubelet/config/apiserver.go
func NewSourceApiserver(c clientset.Interface, nodeName types.NodeName, nodeHasSynced func() bool, updates chan<- interface{}) { lw := cache.NewListWatchFromClient(c.CoreV1().RESTClient(), "pods", metav1.NamespaceAll, fields.OneTermEqualSelector("spec.nodeName", string(nodeName))) // The Reflector responsible for watching pods at the apiserver should be run only after
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 21 19:46:27 UTC 2021 - 2.4K bytes - Viewed (0) -
pkg/volume/csi/csi_attacher_test.go
wg.Add(1) go func(spec *volume.Spec, nodename string, fail bool) { defer wg.Done() attachID, err := csiAttacher.Attach(spec, types.NodeName(nodename)) if fail != (err != nil) { t.Errorf("expecting no failure, but got err: %v", err) } if attachID != "" { t.Errorf("expecting empty attachID, got %v", attachID) } }(tc.spec, tc.nodeName, tc.shouldFail)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 58.1K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler_test.go
// waitForAttachTimeout is the maximum amount of time a // operationexecutor.Mount call will wait for a volume to be attached. waitForAttachTimeout = 1 * time.Second nodeName = k8stypes.NodeName("mynodename") kubeletPodsDir = "fake-dir" testOperationBackOffDuration = 100 * time.Millisecond reconcilerSyncWaitDuration = 10 * time.Second )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpoint_builder.go
ClusterID: c.Cluster(), }, tlsMode: model.GetTLSModeFromEndpointLabels(proxy.Labels), nodeName: proxy.GetNodeName(), } var networkID network.ID if len(proxy.IPAddresses) > 0 { networkID = out.endpointNetwork(proxy.IPAddresses[0]) } out.labels = labelutil.AugmentLabels(proxy.Labels, c.Cluster(), locality, out.nodeName, networkID) return out } func (b *EndpointBuilder) buildIstioEndpoint(
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 4.8K bytes - Viewed (0) -
staging/src/k8s.io/client-go/applyconfigurations/core/v1/endpointaddress.go
return b } // WithNodeName sets the NodeName field in the declarative configuration to the given value // and returns the receiver, so that objects can be built by chaining "With" function invocations. // If called multiple times, the NodeName field is set to the value of the last call. func (b *EndpointAddressApplyConfiguration) WithNodeName(value string) *EndpointAddressApplyConfiguration { b.NodeName = &value return b }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 04 18:31:34 UTC 2021 - 2.9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/util/util_test.go
migratedVolume = "migrated-volume-name" nonMigratedVolume = "non-migrated-volume-name" testNodeName = "test-node-name" ) var ( dirOrCreate = v1.HostPathType(v1.HostPathDirectoryOrCreate) nodeName = kubetypes.NodeName(testNodeName) hostPath = &v1.HostPathVolumeSource{ Path: socketPath, Type: &dirOrCreate, } migratedObjectReference = v1.ObjectReference{Namespace: "default", Name: "migrated-pvc"}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 12 05:42:38 UTC 2023 - 10.4K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/sync/sync.go
mode: mode, nodeName: nodeName, opChan: make(chan syncOp, 1), set: set, } } // Loop runs the sync loop for a given node. done is an optional channel that // is closed when the Loop() returns. func (sync *NodeSync) Loop(logger klog.Logger, done chan struct{}) { logger.V(2).Info("Starting sync loop", "node", klog.KRef("", sync.nodeName)) defer func() { if done != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 07:50:01 UTC 2023 - 12.6K bytes - Viewed (0) -
pkg/kubelet/util/nodelease.go
if len(lease.OwnerReferences) == 0 { if node, err := c.CoreV1().Nodes().Get(context.TODO(), nodeName, metav1.GetOptions{}); err == nil { lease.OwnerReferences = []metav1.OwnerReference{ { APIVersion: corev1.SchemeGroupVersion.WithKind("Node").Version, Kind: corev1.SchemeGroupVersion.WithKind("Node").Kind, Name: nodeName, UID: node.UID, }, } } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Mar 07 15:47:46 UTC 2021 - 1.9K bytes - Viewed (0) -
pkg/apis/resource/validation/validation_resourceslice_test.go
"k8s.io/kubernetes/pkg/apis/resource" "k8s.io/utils/ptr" ) func testResourceSlice(name, nodeName, driverName string) *resource.ResourceSlice { return &resource.ResourceSlice{ ObjectMeta: metav1.ObjectMeta{ Name: name, }, NodeName: nodeName, DriverName: driverName, ResourceModel: resource.ResourceModel{ NamedResources: &resource.NamedResourcesResources{}, }, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 14 17:07:36 UTC 2024 - 8.9K bytes - Viewed (0)