gador/nixpkgs
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

nixosTests: handleTest -> runTest, batch 1

Browse Source 
Reference: https://github.com/NixOS/nixpkgs/issues/386873
This commit is contained in:
Sizhe Zhao
2025-05-24 23:40:23 +08:00
parent 131462b962
commit f34483be5e
538 changed files with 35525 additions and 36600 deletions
Download Patch File Download Diff File Expand all files Collapse all files

98
nixos/tests/fluentd.nix
View File

@@ -1,58 +1,56 @@
import ./make-test-python.nix (
{ pkgs, lib, ... }:
{
name = "fluentd";
{ pkgs, lib, ... }:
{
name = "fluentd";
nodes.machine =
{ pkgs, ... }:
{
services.fluentd = {
enable = true;
config = ''
<source>
@type http
port 9880
</source>
nodes.machine =
{ pkgs, ... }:
{
services.fluentd = {
enable = true;
config = ''
<source>
@type http
port 9880
</source>
<match **>
type copy
<store>
@type file
format json
path /tmp/fluentd
symlink_path /tmp/current-log
</store>
<store>
@type stdout
</store>
</match>
'';
};
<match **>
type copy
<store>
@type file
format json
path /tmp/fluentd
symlink_path /tmp/current-log
</store>
<store>
@type stdout
</store>
</match>
'';
};
};
testScript =
let
testMessage = "an example log message";
testScript =
let
testMessage = "an example log message";
payload = pkgs.writeText "test-message.json" (
builtins.toJSON {
inherit testMessage;
}
);
in
''
machine.start()
machine.wait_for_unit("fluentd.service")
machine.wait_for_open_port(9880)
payload = pkgs.writeText "test-message.json" (
builtins.toJSON {
inherit testMessage;
}
);
in
''
machine.start()
machine.wait_for_unit("fluentd.service")
machine.wait_for_open_port(9880)
machine.succeed(
"curl -fsSL -X POST -H 'Content-type: application/json' -d @${payload} http://localhost:9880/test.tag"
)
machine.succeed(
"curl -fsSL -X POST -H 'Content-type: application/json' -d @${payload} http://localhost:9880/test.tag"
)
# blocking flush
machine.succeed("systemctl stop fluentd")
# blocking flush
machine.succeed("systemctl stop fluentd")
machine.succeed("grep '${testMessage}' /tmp/current-log")
'';
}
)
machine.succeed("grep '${testMessage}' /tmp/current-log")
'';
}