mirror of
https://github.com/rsyslog/rsyslog.git
synced 2025-12-12 19:30:42 +01:00
697f7d8378
kafkacat has been renamed to kcat, as it looks for trademark issues. Kafka module tests depend on that utility and are skipped if command is not available. This was now always the case for newer development containers. Name was now adjusted in all tests.
119 lines
3.7 KiB
Bash
Executable File
119 lines
3.7 KiB
Bash
Executable File
#!/bin/bash
|
|
# This file is part of the rsyslog project, released under ASL 2.0
|
|
. ${srcdir:=.}/diag.sh init
|
|
|
|
export NUMMESSAGES=100
|
|
export NUMMESSAGESFULL=$NUMMESSAGES
|
|
export WAITTIMEOUT=20
|
|
|
|
# REQUIRES EXTERNAL ENVIRONMENT VARIABLES
|
|
if [[ -z "${AZURE_HOST}" ]]; then
|
|
echo "SKIP: AZURE_HOST environment variable not SET! Example: <yourname>.servicebus.windows.net - SKIPPING"
|
|
exit 77
|
|
fi
|
|
if [[ -z "${AZURE_PORT}" ]]; then
|
|
echo "SKIP: AZURE_PORT environment variable not SET! Example: 5671 - SKIPPING"
|
|
exit 77
|
|
fi
|
|
if [[ -z "${AZURE_KEY_NAME}" ]]; then
|
|
echo "SKIP: AZURE_KEY_NAME environment variable not SET! Example: <yourkeyname> - SKIPPING"
|
|
exit 77
|
|
fi
|
|
if [[ -z "${AZURE_KEY}" ]]; then
|
|
echo "SKIP: AZURE_KEY environment variable not SET! Example: <yourlongkey> - SKIPPING"
|
|
exit 77
|
|
fi
|
|
if [[ -z "${AZURE_CONTAINER}" ]]; then
|
|
echo "SKIP: AZURE_CONTAINER environment variable not SET! Example: <youreventhubsname> - SKIPPING"
|
|
exit 77
|
|
fi
|
|
|
|
export AMQPS_ADRESS="amqps://$AZURE_KEY_NAME:$AZURE_KEY@$AZURE_HOST:$AZURE_PORT/$AZURE_NAME"
|
|
export AZURE_ENDPOINT="Endpoint=sb://$AZURE_HOST/;SharedAccessKeyName=$AZURE_KEY_NAME;SharedAccessKey=$AZURE_KEY;EntityPath=$AZURE_NAME"
|
|
|
|
# --- Create/Start omazureeventhubs sender config
|
|
|
|
generate_conf
|
|
add_conf '
|
|
global(
|
|
debug.whitelist="on"
|
|
debug.files=["omazureeventhubs.c", "modules.c", "errmsg.c", "action.c"]
|
|
)
|
|
|
|
# impstats in order to gain insight into error cases
|
|
module(load="../plugins/impstats/.libs/impstats"
|
|
log.file="'$RSYSLOG_DYNNAME.pstats'"
|
|
interval="1" log.syslog="off")
|
|
$imdiagInjectDelayMode full
|
|
|
|
# Load mods
|
|
module(load="../plugins/omazureeventhubs/.libs/omazureeventhubs")
|
|
|
|
# templates
|
|
template(name="outfmt" type="string" string="%msg:F,58:2%\n")
|
|
|
|
local4.* {
|
|
action( name="omazureeventhubs"
|
|
type="omazureeventhubs"
|
|
amqp_address="amqps://'$AZURE_KEY_NAME':'$AZURE_KEY'@'$AZURE_HOST'/'$AZURE_CONTAINER'"
|
|
template="outfmt"
|
|
action.resumeInterval="1"
|
|
action.resumeRetryCount="2"
|
|
)
|
|
|
|
action( type="omfile" file="'$RSYSLOG_OUT_LOG'")
|
|
stop
|
|
}
|
|
|
|
action( type="omfile" file="'$RSYSLOG_DYNNAME.othermsg'")
|
|
'
|
|
echo Starting sender instance [omazureeventhubs]
|
|
startup
|
|
|
|
echo Inject messages into rsyslog sender instance
|
|
injectmsg 1 $NUMMESSAGES
|
|
|
|
wait_file_lines $RSYSLOG_OUT_LOG $NUMMESSAGESFULL 100
|
|
|
|
# experimental: wait until kcat receives everything
|
|
timeoutend=$WAITTIMEOUT
|
|
timecounter=0
|
|
|
|
echo "CHECK $RSYSLOG_DYNNAME.pstats"
|
|
while [ $timecounter -lt $timeoutend ]; do
|
|
(( timecounter++ ))
|
|
|
|
if [ -f "$RSYSLOG_DYNNAME.pstats" ] ; then
|
|
# Read IMPSTATS for verification
|
|
IMPSTATSLINE=$(cat $RSYSLOG_DYNNAME.pstats | grep "origin\=omazureeventhubs" | tail -1 | cut -d: -f5)
|
|
SUBMITTED_MSG=$(echo $IMPSTATSLINE | grep "submitted" | cut -d" " -f2 | cut -d"=" -f2)
|
|
FAILED_MSG=$(echo $IMPSTATSLINE | grep "failures" | cut -d" " -f3 | cut -d"=" -f2)
|
|
ACCEPTED_MSG=$(echo $IMPSTATSLINE | grep "accepted" | cut -d" " -f4 | cut -d"=" -f2)
|
|
|
|
if ! [[ $SUBMITTED_MSG =~ $re ]] ; then
|
|
echo "**** omazureeventhubs WAITING FOR IMPSTATS"
|
|
else
|
|
if [ "$SUBMITTED_MSG" -ge "$NUMMESSAGESFULL" ]; then
|
|
if [ "$ACCEPTED_MSG" -eq "$NUMMESSAGESFULL" ]; then
|
|
echo "**** omazureeventhubs SUCCESS: NUMMESSAGESFULL: $NUMMESSAGESFULL, SUBMITTED_MSG:$SUBMITTED_MSG, ACCEPTED_MSG: $ACCEPTED_MSG, FAILED_MSG: $FAILED_MSG"
|
|
shutdown_when_empty
|
|
wait_shutdown
|
|
#cp $RSYSLOG_DEBUGLOG DEBUGDEBUG.log
|
|
exit_test
|
|
else
|
|
echo "**** omazureeventhubs FAIL: NUMMESSAGESFULL: $NUMMESSAGESFULL, SUBMITTED/WAITING: SUBMITTED_MSG:$SUBMITTED_MSG, ACCEPTED_MSG: $ACCEPTED_MSG, FAILED_MSG: $FAILED_MSG"
|
|
fi
|
|
else
|
|
echo "**** omazureeventhubs WAITING: SUBMITTED_MSG:$SUBMITTED_MSG, ACCEPTED_MSG: $ACCEPTED_MSG, FAILED_MSG: $FAILED_MSG"
|
|
fi
|
|
fi
|
|
fi
|
|
|
|
$TESTTOOL_DIR/msleep 1000
|
|
done
|
|
unset count
|
|
|
|
shutdown_when_empty
|
|
wait_shutdown
|
|
error_exit 1
|