func (pl *CSILimits) Filter(ctx context.Context, _ *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status {
	// If the new pod doesn't have any volume attached to it, the predicate will always be true
	if len(pod.Spec.Volumes) == 0 {
		return nil
	}

	node := nodeInfo.Node()

	logger := klog.FromContext(ctx)

			for i, nodeInfo := range tc.nodes {
				node := &v1.Node{
					ObjectMeta: metav1.ObjectMeta{Name: fmt.Sprintf("node-%d", i)},
					Status:     v1.NodeStatus{},
				}
				if nodeInfo.zoneLabel != nil {
					node.Labels = map[string]string{v1.LabelTopologyZone: *nodeInfo.zoneLabel}
				}
				if nodeInfo.ready != nil {
					status := v1.ConditionFalse

	return framework.NewStatus(framework.Code(pl.inj.PreFilterAddPodStatus), injectReason)
}
func (pl *TestPlugin) RemovePod(ctx context.Context, state *framework.CycleState, podToSchedule *v1.Pod, podInfoToRemove *framework.PodInfo, nodeInfo *framework.NodeInfo) *framework.Status {

        resourceVersion: resourceVersionValue
        uid: uidValue
  daemonEndpoints:
    kubeletEndpoint:
      Port: 1
  images:
  - names:
    - namesValue
    sizeBytes: 2
  nodeInfo:
    architecture: architectureValue
    bootID: bootIDValue
    containerRuntimeVersion: containerRuntimeVersionValue
    kernelVersion: kernelVersionValue
    kubeProxyVersion: kubeProxyVersionValue

        resourceVersion: resourceVersionValue
        uid: uidValue
  daemonEndpoints:
    kubeletEndpoint:
      Port: 1
  images:
  - names:
    - namesValue
    sizeBytes: 2
  nodeInfo:
    architecture: architectureValue
    bootID: bootIDValue
    containerRuntimeVersion: containerRuntimeVersionValue
    kernelVersion: kernelVersionValue
    kubeProxyVersion: kubeProxyVersionValue

    "addresses": [
      {
        "type": "typeValue",
        "address": "addressValue"
      }
    ],
    "daemonEndpoints": {
      "kubeletEndpoint": {
        "Port": 1
      }
    },
    "nodeInfo": {
      "machineID": "machineIDValue",
      "systemUUID": "systemUUIDValue",
      "bootID": "bootIDValue",
      "kernelVersion": "kernelVersionValue",
      "osImage": "osImageValue",

    "addresses": [
      {
        "type": "typeValue",
        "address": "addressValue"
      }
    ],
    "daemonEndpoints": {
      "kubeletEndpoint": {
        "Port": 1
      }
    },
    "nodeInfo": {
      "machineID": "machineIDValue",
      "systemUUID": "systemUUIDValue",
      "bootID": "bootIDValue",
      "kernelVersion": "kernelVersionValue",
      "osImage": "osImageValue",

// require calling out to the cloud provider.  It seems that we are moving away
// from inline volume declarations anyway.
func (pl *VolumeZone) Filter(ctx context.Context, cs *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status {
	logger := klog.FromContext(ctx)
	// If a pod doesn't have any volume attached to it, the predicate will always be true.

// PVCs can be matched with an available and node-compatible PV.
func (pl *VolumeBinding) Filter(ctx context.Context, cs *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status {
	logger := klog.FromContext(ctx)
	node := nodeInfo.Node()

	state, err := getStateData(cs)
	if err != nil {
		return framework.AsStatus(err)
	}

	} else {
		tok := strings.Split(mpa, ",")
		mpaSet = sets.New(tok...)
	}

	return mpaSet.Has(pluginName)
}

// volumeLimits returns volume limits associated with the node.
func volumeLimits(n *framework.NodeInfo) map[v1.ResourceName]int64 {
	volumeLimits := map[v1.ResourceName]int64{}
	for k, v := range n.Allocatable.ScalarResources {
		if v1helper.IsAttachableVolumeResourceName(k) {
			volumeLimits[k] = v
		}
	}