mirror of
https://github.com/rsyslog/rsyslog.git
synced 2025-12-13 04:50:41 +01:00
3ac9fa5267
- [IMHIREDIS] Add support for simple XREADs from Redis Streams (Redis >= 5.0 required) - [IMHIREDIS] Add support for XREADGROUP from Redis Streams, allowing for user to define workers to dequeue logs in a stream - [IMHIREDIS] stream mode can select fields to extract and insert in custom keys - [IMHIREDIS] Add tests for the new 'stream' modes
61 lines
1.3 KiB
Bash
Executable File
61 lines
1.3 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
|
|
|
|
# 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
|