- def find_one_of_log_entryies(searched_entries):
- print(type(searched_entries))
- client = docker.from_env()
- container = client.containers.get('prh')
- print("Check for log searches for pattern: ", searched_entries)
- for line in container.logs(stream=True):
- print("Check for log analysis line: ", line )
+ def get_current_utc_datetime():
+ return datetime.datetime.utcnow()
+
+ def get_docker_logs_since_test_start(self, container_id):
+ return self.get_docker_logs(container_id, self.test_start_time)
+
+ @staticmethod
+ def get_docker_logs(container_id, since=None):
+ container = PrhLibrary.__get_docker_container(container_id)
+ return container.logs(stream=False, since=since)
+
+ def wait_for_one_of_docker_log_entries(self, container_id, searched_entries):
+ print("Looking for: %s" % searched_entries)
+ container = PrhLibrary.__get_docker_container(container_id)
+ print("Log lines:")
+ for line in container.logs(stream=True, since=self.test_start_time):
+ print(line)