kubernetes/pkg/controller/volume/attachdetach/cache/desired_state_of_world.go

type DesiredStateOfWorld …

type VolumeToAttach …

type PodToAdd …

// NewDesiredStateOfWorld returns a new instance of DesiredStateOfWorld.
func NewDesiredStateOfWorld(volumePluginMgr *volume.VolumePluginMgr) DesiredStateOfWorld { … }

type desiredStateOfWorld …

type nodeManaged …

type volumeToAttach …

type pod …

func (dsw *desiredStateOfWorld) AddNode(nodeName k8stypes.NodeName) { … }

func (dsw *desiredStateOfWorld) AddPod(
	podName types.UniquePodName,
	podToAdd *v1.Pod,
	volumeSpec *volume.Spec,
	nodeName k8stypes.NodeName) (v1.UniqueVolumeName, error) { … }

func (dsw *desiredStateOfWorld) DeleteNode(nodeName k8stypes.NodeName) error { … }

func (dsw *desiredStateOfWorld) DeletePod(
	podName types.UniquePodName,
	volumeName v1.UniqueVolumeName,
	nodeName k8stypes.NodeName) { … }

func (dsw *desiredStateOfWorld) NodeExists(nodeName k8stypes.NodeName) bool { … }

func (dsw *desiredStateOfWorld) VolumeExists(
	volumeName v1.UniqueVolumeName, nodeName k8stypes.NodeName) bool { … }

func (dsw *desiredStateOfWorld) SetMultiAttachError(
	volumeName v1.UniqueVolumeName,
	nodeName k8stypes.NodeName) { … }

func (dsw *desiredStateOfWorld) GetVolumesToAttach() []VolumeToAttach { … }

// Construct a list of v1.Pod objects from the given pod map
func getPodsFromMap(podMap map[types.UniquePodName]pod) []*v1.Pod { … }

func (dsw *desiredStateOfWorld) GetPodToAdd() map[types.UniquePodName]PodToAdd { … }

func (dsw *desiredStateOfWorld) GetVolumePodsOnNodes(nodes []k8stypes.NodeName, volumeName v1.UniqueVolumeName) []*v1.Pod { … }