commit c999eab3e78484e75d44536f8e20229fc738d2ed · pyrox.dev/nixpkgs

+10 -7
nixos/tests/fluentd.nix
···

       1
       1
       -
       import ./make-test.nix ({ pkgs, lib, ... }: {

     

       1
       1
       +
       import ./make-test-python.nix ({ pkgs, lib, ... }: {

     

       2
       2
        
         name = "fluentd";

     

       3
       3
        
       

     

       4
       4
        
         machine = { pkgs, ... }: {

     
···

       33
       33
        
             inherit testMessage;

     

       34
       34
        
           });

     

       35
       35
        
         in ''

     

       36
       36
       -
           $machine->start;

     

       37
       37
       -
           $machine->waitForUnit('fluentd.service');

     

       38
       38
       -
           $machine->waitForOpenPort(9880);

     

       36
       36
       +
           machine.start()

     

       37
       37
       +
           machine.wait_for_unit("fluentd.service")

     

       38
       38
       +
           machine.wait_for_open_port(9880)

     

       39
       39
        
       

     

       40
       40
       -
           $machine->succeed("curl -fsSL -X POST -H 'Content-type: application/json' -d @${payload} http://localhost:9880/test.tag");

     

       40
       40
       +
           machine.succeed(

     

       41
       41
       +
               "curl -fsSL -X POST -H 'Content-type: application/json' -d @${payload} http://localhost:9880/test.tag"

     

       42
       42
       +
           )

     

       41
       43
        
       

     

       42
       42
       -
           $machine->succeed("systemctl stop fluentd"); # blocking flush

     

       44
       44
       +
           # blocking flush

     

       45
       45
       +
           machine.succeed("systemctl stop fluentd")

     

       43
       46
        
       

     

       44
       44
       -
           $machine->succeed("grep '${testMessage}' /tmp/current-log");

     

       47
       47
       +
           machine.succeed("grep '${testMessage}' /tmp/current-log")

     

       45
       48
        
         '';

     

       46
       49
        
       })