mirror of
https://github.com/rsyslog/rsyslog.git
synced 2025-12-11 05:00:41 +01:00
4ef42fde7a
- changed diag.sh to be able to start/stop/clean a redis server - added helper functions in diag.sh to be able to query a redis server instance - added new tests for imhiredis module to check - that the queue mode works, with both lpop and rpop - that the module is capable of handling a redis server going down - that the module is capable of handling a redis server that appears afterwards - that the subscribe mode works
56 lines
1.1 KiB
Bash
Executable File
56 lines
1.1 KiB
Bash
Executable File
#!/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 once to be able to generate configuration
|
|
start_redis
|
|
stop_redis
|
|
|
|
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="mykey"
|
|
mode="queue"
|
|
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
|
|
|
|
start_redis
|
|
redis_command "RPUSH mykey message1"
|
|
redis_command "RPUSH mykey message2"
|
|
redis_command "RPUSH mykey message3"
|
|
|
|
wait_content '1 message3'
|
|
|
|
shutdown_when_empty
|
|
wait_shutdown
|
|
|
|
stop_redis
|
|
|
|
content_check '1 message3'
|
|
content_check '2 message2'
|
|
content_check '3 message1'
|
|
|
|
# Removes generated configuration file, log and pid files
|
|
cleanup_redis
|
|
|
|
exit_test
|