async def METHOD_NAME(
    self,
    cluster_name: Optional[str] = None,
    org_name: Union[Optional[str], OrgNameSentinel] = ORG_NAME_SENTINEL,
    project_name: Optional[str] = None,
) -> AsyncIterator[Disk]:
    url = self._get_disks_url(cluster_name)
    params = {}
    if not isinstance(org_name, OrgNameSentinel):
        params["org_name"] = org_name or "NO_ORG"
    if project_name:
        params["project_name"] = project_name
    auth = await self._config._api_auth()
    async with self._core.request("GET", url, auth=auth, params=params) as resp:
        ret = await resp.json()
        for disk_payload in ret:
            yield self._parse_disk_payload(disk_payload)