Sha256: 53cdf39589607971e231d65f140d56962e4d6815fe2295776ab7563bfae69267
Contents?: true
Size: 1.3 KB
Versions: 15
Compression:
Stored size: 1.3 KB
Contents
#!/usr/bin/env bash
set -u
instances=1
if [ ! -z ${INSTANCES+x} ]; then
instances=$INSTANCES
fi
uuid=$(echo $(uuidgen) | tr '[:upper:]' '[:lower:]')
stream_name="testStream-$uuid"
if [ ! -z ${STREAM_NAME+x} ]; then
stream_name=$STREAM_NAME
fi
title="Writing $instances Messages to Stream $stream_name"
if [ -z ${METADATA+x} ]; then
metadata="'{\"metaAttribute\": \"some meta value\"}'"
else
metadata="$METADATA"
title="$title with Metadata $metadata"
fi
metadata="$metadata::jsonb"
echo
echo $title
echo "= = ="
echo
default_name=message_store
if [ -z ${DATABASE_USER+x} ]; then
echo "(DATABASE_USER is not set)"
user=$default_name
else
user=$DATABASE_USER
fi
echo "Database user is: $user"
if [ -z ${DATABASE_NAME+x} ]; then
echo "(DATABASE_NAME is not set)"
database=$default_name
else
database=$DATABASE_NAME
fi
echo "Database name is: $database"
echo
for (( i=1; i<=instances; i++ )); do
uuid=$(echo $(uuidgen) | tr '[:upper:]' '[:lower:]')
echo "Instance: $i, Message ID: $uuid"
psql $database -U $user -c "SELECT write_message('$uuid'::varchar, '$stream_name'::varchar, 'SomeType'::varchar, '{\"attribute\": \"some value\"}'::jsonb, $metadata);" > /dev/null
done
echo
psql $database -U $user -P pager=off -x -c "SELECT * FROM messages WHERE stream_name = '$stream_name';"
echo
Version data entries
15 entries across 15 versions & 1 rubygems