Function collect_logs 

pub async fn collect_logs<S>(
    query: &LogsQuery,
    source: &S,
) -> Result<ExecutionResult, EventsError>
where
    S: LogSource + ?Sized + Sync,

Collect log lines into an ExecutionResult (batch mode).