in client/src/client/pull_logs.rs [218:244]
fn try_from(body: bytes::Bytes, http_headers: &http::HeaderMap) -> ResponseResult<Self> {
let request_id = http_headers.get_str(LOG_REQUEST_ID);
let log_group_list: LogGroupList = LogGroupList::decode(body.as_ref())
.map_err(|source| ResponseErrorKind::ProtobufDeserialize { source, request_id })
.map_err(ResponseError::from)?;
let log_group_count = http_headers.get_i32_or_default("x-log-count", 0);
let read_last_cursor = http_headers.get_str("x-log-read-last-cursor");
let raw_size_before_query = http_headers.get_i32("x-log-rawdatasize");
let data_count_before_query = http_headers.get_i32("x-log-rawdatacount");
let result_lines = http_headers.get_i32("x-log-resultlines");
let lines_before_query = http_headers.get_i32("x-log-rawdatalines");
let failed_lines = http_headers.get_i32("x-log-failedlines");
let next_cursor = http_headers.get_str_or_default("x-log-cursor", "");
Ok(PullLogsResponse {
log_group_list: log_group_list.into(),
next_cursor,
log_group_count,
read_last_cursor,
data_count_before_query,
result_lines,
lines_before_query,
failed_lines,
raw_size_before_query,
})
}