From dcc721a95bef6f0d8e6d8775b8efe33e5aecd562 Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Mon, 15 Apr 2024 18:28:20 +0200 Subject: Adding upstream version 8.2402.0. Signed-off-by: Daniel Baumann --- tests/imhiredis-stream-from-beginning.sh | 60 ++++++++++++++++++++++++++++++++ 1 file changed, 60 insertions(+) create mode 100755 tests/imhiredis-stream-from-beginning.sh (limited to 'tests/imhiredis-stream-from-beginning.sh') diff --git a/tests/imhiredis-stream-from-beginning.sh b/tests/imhiredis-stream-from-beginning.sh new file mode 100755 index 0000000..f007d3a --- /dev/null +++ b/tests/imhiredis-stream-from-beginning.sh @@ -0,0 +1,60 @@ +#!/usr/bin/env bash +# added 2023-04-20 by Théo Bertin, released under ASL 2.0 +## Uncomment for debugging +#export RS_REDIR=-d + +. ${srcdir:=.}/diag.sh init + +start_redis + +# WILL be logged by Rsyslog +redis_command "XADD mystream * msg message1" +redis_command "XADD mystream * msg message2" +redis_command "XADD mystream * msg message3" + +generate_conf +add_conf ' +global(localhostname="server") +module(load="../contrib/imhiredis/.libs/imhiredis") +template(name="outfmt" type="string" string="%$/num% %$!msg%\n") + + +input(type="imhiredis" + server="127.0.0.1" + port="'$REDIS_RANDOM_PORT'" + key="mystream" + mode="stream" + stream.readFrom="0-0" + ruleset="redis") + +ruleset(name="redis") { + set $/num = cnum($/num + 1); + action(type="omfile" + file="'$RSYSLOG_OUT_LOG'" + template="outfmt") +} + +action(type="omfile" file="'$RSYSLOG_OUT_LOG'" template="outfmt") +' +startup + +redis_command "XADD mystream * msg message4" +redis_command "XADD mystream * msg message5" +redis_command "XADD mystream * msg message6" + +shutdown_when_empty +wait_shutdown + +stop_redis + +content_check '1 message1' +content_check '2 message2' +content_check '3 message3' +content_check '4 message4' +content_check '5 message5' +content_check '6 message6' + +# Removes generated configuration file, log and pid files +cleanup_redis + +exit_test -- cgit v1.2.3