blob: 3c9a5554d360b3257533e60dd853eeb0a290dd0d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
|
#! /bin/sh
. ../env.sh
mkdir -p log pid
./zstop.sh
v=
v=-v
v=-q
cleardb() {
psql -q -d $db -c '
set client_min_messages=warning;
drop schema if exists londiste cascade;
drop schema if exists pgq_node cascade;
drop schema if exists pgq cascade;
drop table if exists mydata;
drop table if exists footable;
drop sequence if exists footable_id_seq;
'
}
run() {
echo "$ $*"
"$@"
}
for db in db1 db2 db3; do
pgqadm conf/ticker_$db.ini -k
cleardb $db
done
run ./plainconsumer.py -s conf/nop_consumer.ini
rm -f log/*.log
set -e
run cat conf/ticker_db1.ini
#echo " # pgqadm install # "
run pgqadm $v conf/ticker_db1.ini install
run pgqadm $v conf/ticker_db2.ini install
run pgqadm $v conf/ticker_db3.ini install
#echo " # pgqadm ticker # "
run pgqadm $v -d conf/ticker_db1.ini ticker
run pgqadm $v -d conf/ticker_db2.ini ticker
run pgqadm $v -d conf/ticker_db3.ini ticker
#echo " # setadm create-node # "
run setadm $v --worker=node1_worker conf/setadm.ini create-root node1 'dbname=db1'
run setadm $v --worker=node2_worker conf/setadm.ini create-branch node2 'dbname=db2' --provider='dbname=db1'
run setadm $v --worker=node3_worker conf/setadm.ini create-branch node3 'dbname=db3' --provider='dbname=db2'
#echo " # setadm status # "
run setadm $v conf/setadm.ini status
#echo " # plainconsumer # "
run ./plainconsumer.py $v conf/nop_consumer.ini --register --provider='dbname=db1'
run ./plainconsumer.py $v -d conf/nop_consumer.ini
#echo " # plainworker # "
run ./plainworker.py $v -d conf/worker_db1.ini
run ./plainworker.py $v -d conf/worker_db2.ini
run ./plainworker.py $v -d conf/worker_db3.ini
#echo " # insert_event() # "
run psql db1 -c "select pgq.insert_event('fooqueue', 'tmp', 'data')"
run sleep 10
grep -E 'ERR|WARN|CRIT' log/*.log || true
|
