iter_get_log_events ¶

def iter_get_log_events(
    self,
    log_stream_name: "capo_cloudwatch_logs.types.log_stream_name.LogStreamName",
    *,
    config_overrides: Optional[CloudWatchLogsClientConfig] = None,
    log_group_name: Optional[
        "capo_cloudwatch_logs.types.log_group_name.LogGroupName"
    ] = None,
    log_group_identifier: Optional[
        "capo_cloudwatch_logs.types.log_group_identifier.LogGroupIdentifier"
    ] = None,
    start_time: Optional["capo_cloudwatch_logs.types.timestamp.Timestamp"] = None,
    end_time: Optional["capo_cloudwatch_logs.types.timestamp.Timestamp"] = None,
    next_token: Optional["capo_cloudwatch_logs.types.next_token.NextToken"] = None,
    limit: Optional["capo_cloudwatch_logs.types.events_limit.EventsLimit"] = None,
    start_from_head: Optional[
        "capo_cloudwatch_logs.types.start_from_head.StartFromHead"
    ] = None,
    unmask: Optional["capo_cloudwatch_logs.types.unmask.Unmask"] = None,
) -> "Iterator[capo_cloudwatch_logs.types.output_log_event.OutputLogEvent]":
    _token = next_token
    while True:
        _response = self.get_log_events(
            log_stream_name,
            config_overrides=config_overrides,
            log_group_name=log_group_name,
            log_group_identifier=log_group_identifier,
            start_time=start_time,
            end_time=end_time,
            next_token=_token,
            limit=limit,
            start_from_head=start_from_head,
            unmask=unmask,
        )
        _page = _resolve_path(_response, ("events",))
        for _item in _page or []:
            yield _item
        _token = _resolve_path(_response, ("next_forward_token",))
        if not _token:
            break