DogStreams

datadog.py

    def check(self, agentConfig, move_end=True):
        if not self.dogstreams:
            return {}
        
        output = {}
        for dogstream in self.dogstreams:
            try:
                result = dogstream.check(agentConfig, move_end)
                # result contains {"dogstream": [...]}
                if "dogstream" in result and "dogstream" in output:
                    output["dogstream"].extend(result["dogstream"])
                else:
                    output.update(result)
            except Exception, e:
                self.logger.exception(traceback.format_exc())
                self.logger.error("Error in parsing %s" % (dogstream.log_path))
        return output