- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 35 for SelectedNode (0.19 sec)
-
pkg/volume/volume.go
// Provision creates the resource by allocating the underlying volume in a // storage system. This method should block until completion and returns // PersistentVolume representing the created storage resource. Provision(selectedNode *v1.Node, allowedTopologies []v1.TopologySelectorTerm) (*v1.PersistentVolume, error) } // Deleter removes the resource from the underlying storage provider. Calls
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 11.8K bytes - Viewed (0) -
pkg/apis/resource/v1alpha2/zz_generated.conversion.go
} func autoConvert_v1alpha2_PodSchedulingContextSpec_To_resource_PodSchedulingContextSpec(in *v1alpha2.PodSchedulingContextSpec, out *resource.PodSchedulingContextSpec, s conversion.Scope) error { out.SelectedNode = in.SelectedNode out.PotentialNodes = *(*[]string)(unsafe.Pointer(&in.PotentialNodes)) return nil } // Convert_v1alpha2_PodSchedulingContextSpec_To_resource_PodSchedulingContextSpec is an autogenerated conversion function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 14 17:07:36 UTC 2024 - 103.6K bytes - Viewed (0) -
pkg/volume/hostpath/host_path.go
// This Provisioner is meant for development and testing only and WILL NOT WORK in a multi-node cluster. func (r *hostPathProvisioner) Provision(selectedNode *v1.Node, allowedTopologies []v1.TopologySelectorTerm) (*v1.PersistentVolume, error) { if util.CheckPersistentVolumeClaimModeBlock(r.options.PVC) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 15.3K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller_test.go
Kind: "Pod", Name: testPodName, UID: testPodUID, Controller: pointer.Bool(true), }, }, }, Spec: resourcev1alpha2.PodSchedulingContextSpec{ SelectedNode: nodeName, }, } ) func init() { klog.InitFlags(nil) } func TestSyncHandler(t *testing.T) { tests := []struct { name string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 08:56:16 UTC 2024 - 28.2K bytes - Viewed (0) -
staging/src/k8s.io/api/resource/v1alpha2/generated.pb.go
i = encodeVarintGenerated(dAtA, i, uint64(len(m.PotentialNodes[iNdEx]))) i-- dAtA[i] = 0x12 } } i -= len(m.SelectedNode) copy(dAtA[i:], m.SelectedNode) i = encodeVarintGenerated(dAtA, i, uint64(len(m.SelectedNode))) i-- dAtA[i] = 0xa return len(dAtA) - i, nil } func (m *PodSchedulingContextStatus) Marshal() (dAtA []byte, err error) { size := m.Size()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 14 17:07:36 UTC 2024 - 261.9K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller.go
ctrl.eventRecorder.Event(claim, v1.EventTypeWarning, events.ProvisioningFailed, strerr) return pluginName, err } var selectedNode *v1.Node = nil if nodeName, ok := claim.Annotations[storagehelpers.AnnSelectedNode]; ok { selectedNode, err = ctrl.NodeLister.Get(nodeName) if err != nil { strerr := fmt.Sprintf("Failed to get target node: %v", err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 89.2K bytes - Viewed (0) -
pkg/printers/internalversion/printers.go
{Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, {Name: "SelectedNode", Type: "string", Description: resourcev1alpha2.PodSchedulingContextSpec{}.SwaggerDoc()["selectedNode"]}, {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 14:04:15 UTC 2024 - 128.3K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/framework_test.go
plugin.provisionOptions = options return plugin, nil } else { return nil, fmt.Errorf("Mock plugin error: no provisionCalls configured") } } func (plugin *mockVolumePlugin) Provision(selectedNode *v1.Node, allowedTopologies []v1.TopologySelectorTerm) (*v1.PersistentVolume, error) { if len(plugin.provisionCalls) <= plugin.provisionCallCounter {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 09:54:00 UTC 2023 - 38.3K bytes - Viewed (0) -
pkg/volume/testing/testing.go
} type FakeProvisioner struct { Options volume.VolumeOptions Host volume.VolumeHost ProvisionDelaySeconds int } func (fc *FakeProvisioner) Provision(selectedNode *v1.Node, allowedTopologies []v1.TopologySelectorTerm) (*v1.PersistentVolume, error) { // Add provision failure hook if fc.Options.Parameters != nil { if _, ok := fc.Options.Parameters[ExpectProvisionFailureKey]; ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 53.3K bytes - Viewed (0) -
api/openapi-spec/v3/apis__resource.k8s.io__v1alpha2_openapi.json
"default": "", "type": "string" }, "type": "array", "x-kubernetes-list-type": "atomic" }, "selectedNode": { "description": "SelectedNode is the node for which allocation of ResourceClaims that are referenced by the Pod and that use \"WaitForFirstConsumer\" allocation is to be attempted.", "type": "string" }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 12:18:45 UTC 2024 - 656.6K bytes - Viewed (0)