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 {}