code: def ReadFlowOutputPluginLogEntries(self,
                                       client_id,
                                       flow_id,
                                       output_plugin_id,
                                       offset,
                                       count,
                                       with_type=None):
      
      entries = sorted(
          self.flow_output_plugin_log_entries.get((client_id, flow_id), []),
          key=lambda e: e.timestamp)
  
      entries = [e for e in entries if e.output_plugin_id == output_plugin_id]
  
      if with_type is not None:
        entries = [e for e in entries if e.log_entry_type == with_type]
  
      return entries[offset:offset + count]
docs: Reads flow output plugin log entries.