[#255] add filter priority to get_filtered_logs method #255
3 changed files with 5 additions and 1 deletions
|
@ -240,6 +240,7 @@ class DockerHost(Host):
|
||||||
until: Optional[datetime] = None,
|
until: Optional[datetime] = None,
|
||||||
unit: Optional[str] = None,
|
unit: Optional[str] = None,
|
||||||
exclude_filter: Optional[str] = None,
|
exclude_filter: Optional[str] = None,
|
||||||
|
priority: Optional[str] = None
|
||||||
) -> str:
|
) -> str:
|
||||||
client = self._get_docker_client()
|
client = self._get_docker_client()
|
||||||
filtered_logs = ""
|
filtered_logs = ""
|
||||||
|
|
|
@ -297,6 +297,7 @@ class Host(ABC):
|
||||||
until: Optional[datetime] = None,
|
until: Optional[datetime] = None,
|
||||||
unit: Optional[str] = None,
|
unit: Optional[str] = None,
|
||||||
exclude_filter: Optional[str] = None,
|
exclude_filter: Optional[str] = None,
|
||||||
|
priority: Optional[str] = None
|
||||||
) -> str:
|
) -> str:
|
||||||
"""Get logs from host filtered by regex.
|
"""Get logs from host filtered by regex.
|
||||||
|
|
||||||
|
@ -305,6 +306,8 @@ class Host(ABC):
|
||||||
since: If set, limits the time from which logs should be collected. Must be in UTC.
|
since: If set, limits the time from which logs should be collected. Must be in UTC.
|
||||||
until: If set, limits the time until which logs should be collected. Must be in UTC.
|
until: If set, limits the time until which logs should be collected. Must be in UTC.
|
||||||
unit: required unit.
|
unit: required unit.
|
||||||
|
priority: logs level, 0 - emergency, 7 - debug. All messages with that code and higher.
|
||||||
|
For example, if we specify the -p 2 option, journalctl will show all messages with levels 2, 1 and 0.
|
||||||
|
|
||||||
Returns:
|
Returns:
|
||||||
Found entries as str if any found.
|
Found entries as str if any found.
|
||||||
|
|
|
@ -19,7 +19,7 @@ def check_metrics_counter(
|
||||||
counter_act += get_metrics_value(cluster_node, parse_from_command, **metrics_greps)
|
counter_act += get_metrics_value(cluster_node, parse_from_command, **metrics_greps)
|
||||||
assert eval(
|
assert eval(
|
||||||
f"{counter_act} {operator} {counter_exp}"
|
f"{counter_act} {operator} {counter_exp}"
|
||||||
), f"Expected: {counter_exp}, Actual: {counter_act} in node: {cluster_node}"
|
), f"Expected: {counter_exp} {operator} Actual: {counter_act} in node: {cluster_node}"
|
||||||
|
|
||||||
|
|
||||||
@reporter.step("Get metrics value from node: {node}")
|
@reporter.step("Get metrics value from node: {node}")
|
||||||
|
|
Loading…
Reference in a new issue