kubernetes/test/e2e/storage/csimock/csi_node_volume_health.go

var _ …

func findVolumeConditionMetrics(pvcNamespace, pvcName string, kubeMetrics e2emetrics.KubeletMetrics, nodeAbnormalVolumeCondition bool) bool { … }

func createGetVolumeStatsHook(abnormalVolumeCondition bool) *drivers.Hooks { … }