async def METHOD_NAME(
    self, request: web.Request, identifier: str | None = None, follow: bool = False
) -> web.StreamResponse:
    """Return systemd-journald logs."""
    params = {}
    if identifier:
        params[PARAM_SYSLOG_IDENTIFIER] = identifier
    elif IDENTIFIER in request.match_info:
        params[PARAM_SYSLOG_IDENTIFIER] = request.match_info.get(IDENTIFIER)
    else:
        params[PARAM_SYSLOG_IDENTIFIER] = self.sys_host.logs.default_identifiers
    if BOOTID in request.match_info:
        params[PARAM_BOOT_ID] = await self._get_boot_id(
            request.match_info.get(BOOTID)
        )
    if follow:
        params[PARAM_FOLLOW] = ""
    if ACCEPT in request.headers and request.headers[ACCEPT] not in [
        CONTENT_TYPE_TEXT,
        "*/*",
    ]:
        raise APIError(
            "Invalid content type requested. Only text/plain supported for now."
        )
    if RANGE in request.headers:
        range_header = request.headers.get(RANGE)
    else:
        range_header = f"entries=:-{DEFAULT_RANGE}:"
    async with self.sys_host.logs.journald_logs(
        params=params, range_header=range_header
    ) as resp:
        try:
            response = web.StreamResponse()
            response.content_type = CONTENT_TYPE_TEXT
            await response.prepare(request)
            async for data in resp.content:
                await response.write(data)
        except ConnectionResetError as ex:
            raise APIError(
                "Connection reset when trying to fetch data from systemd-journald."
            ) from ex
        return response