- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 1,172 for attacher (0.15 sec)
-
pkg/kubelet/container/runtime.go
// GetImageSize returns the size of the image GetImageSize(ctx context.Context, image ImageSpec) (uint64, error) } // Attacher interface allows to attach a container. type Attacher interface { AttachContainer(ctx context.Context, id ContainerID, stdin io.Reader, stdout, stderr io.WriteCloser, tty bool, resize <-chan remotecommand.TerminalSize) (err error) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 27.8K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/util/util.go
} attachableVolumePlugin, err := volumePluginMgr.FindAttachablePluginBySpec(volumeSpec) if err != nil || attachableVolumePlugin == nil { logger.V(10).Info("Skipping volume for pod, it does not implement attacher interface", "pod", klog.KObj(pod), "volumeName", podVolume.Name, "err", err) continue } uniquePodName := util.GetUniquePodName(pod) if addVolumes { // Add volume to desired state of world
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 12K bytes - Viewed (0) -
staging/src/k8s.io/api/storage/v1beta1/generated.pb.go
if err != nil { return 0, err } i -= size i = encodeVarintGenerated(dAtA, i, uint64(size)) } i-- dAtA[i] = 0x12 i -= len(m.Attacher) copy(dAtA[i:], m.Attacher) i = encodeVarintGenerated(dAtA, i, uint64(len(m.Attacher))) i-- dAtA[i] = 0xa return len(dAtA) - i, nil } func (m *VolumeAttachmentStatus) Marshal() (dAtA []byte, err error) { size := m.Size()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:37 UTC 2024 - 133.9K bytes - Viewed (0) -
staging/src/k8s.io/api/storage/v1/generated.pb.go
if err != nil { return 0, err } i -= size i = encodeVarintGenerated(dAtA, i, uint64(size)) } i-- dAtA[i] = 0x12 i -= len(m.Attacher) copy(dAtA[i:], m.Attacher) i = encodeVarintGenerated(dAtA, i, uint64(len(m.Attacher))) i-- dAtA[i] = 0xa return len(dAtA) - i, nil } func (m *VolumeAttachmentStatus) Marshal() (dAtA []byte, err error) { size := m.Size()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:37 UTC 2024 - 133.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
// GetVolumesInUse returns a list of all volumes that implement the volume.Attacher // interface and are currently in use according to the actual and desired // state of the world caches. A volume is considered "in use" as soon as it // is added to the desired state of world, indicating it *should* be // attached to this node and remains "in use" until it is removed from both
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/volume/iscsi/iscsi.go
return true } var _ volume.BlockVolumeUnmapper = &iscsiDiskUnmapper{} var _ volume.CustomBlockVolumeUnmapper = &iscsiDiskUnmapper{} // Even though iSCSI plugin has attacher/detacher implementation, iSCSI plugin // needs volume detach operation during TearDownDevice(). This method is only // chance that operations are done on kubelet node during volume teardown sequences.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 23.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/desired_state_of_world.go
// attached volumes, this is a no-op. // If after deleting the pod, the specified volume contains no other child // pods, the volume is also deleted. DeletePodFromVolume(podName types.UniquePodName, volumeName v1.UniqueVolumeName) // VolumeExists returns true if the given volume exists in the list of // volumes that should be attached to this node.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 27.1K bytes - Viewed (0) -
pkg/kubelet/container/testing/runtime_mock.go
mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RemoveImage", reflect.TypeOf((*MockImageService)(nil).RemoveImage), ctx, image) } // MockAttacher is a mock of Attacher interface. type MockAttacher struct { ctrl *gomock.Controller recorder *MockAttacherMockRecorder } // MockAttacherMockRecorder is the mock recorder for MockAttacher.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 27K bytes - Viewed (0) -
api/openapi-spec/v3/apis__storage.k8s.io__v1_openapi.json
}, "attached": { "default": false, "description": "attached indicates the volume is successfully attached. This field must only be set by the entity completing the attach operation, i.e. the external-attacher.",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 481.9K bytes - Viewed (0) -
pkg/volume/csi/csi_mounter_test.go
csiMounter.csiClient = setupClient(t, true) attachID := getAttachmentName(csiMounter.volumeID, string(csiMounter.driverName), string(plug.host.GetNodeName())) attachment := &storage.VolumeAttachment{ ObjectMeta: meta.ObjectMeta{ Name: attachID, }, Spec: storage.VolumeAttachmentSpec{ NodeName: "test-node", Attacher: CSIPluginName, Source: storage.VolumeAttachmentSource{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 50.1K bytes - Viewed (0)