my ($node_publisher, $node_subscriber, $publisher_connstr, $result, $offset);
$offset = 0;
-sub publish_insert($$)
+sub publish_insert
{
my ($tbl, $new_i) = @_;
$node_publisher->safe_psql('postgres', qq(
));
}
-sub publish_update($$$)
+sub publish_update
{
my ($tbl, $old_i, $new_i) = @_;
$node_publisher->safe_psql('postgres', qq(
));
}
-sub publish_delete($$)
+sub publish_delete
{
my ($tbl, $old_i) = @_;
$node_publisher->safe_psql('postgres', qq(
));
}
-sub expect_replication($$$$$)
+sub expect_replication
{
my ($tbl, $cnt, $min, $max, $testname) = @_;
$node_publisher->wait_for_catchup('admin_sub');
is ($result, "$cnt|$min|$max", $testname);
}
-sub expect_failure($$$$$$)
+sub expect_failure
{
my ($tbl, $cnt, $min, $max, $re, $testname) = @_;
$offset = $node_subscriber->wait_for_log($re, $offset);
is ($result, "$cnt|$min|$max", $testname);
}
-sub revoke_superuser($)
+sub revoke_superuser
{
my ($role) = @_;
$node_subscriber->safe_psql('postgres', qq(
ALTER ROLE $role NOSUPERUSER));
}
-sub grant_superuser($)
+sub grant_superuser
{
my ($role) = @_;
$node_subscriber->safe_psql('postgres', qq(
ALTER ROLE $role SUPERUSER));
}
-sub revoke_bypassrls($)
+sub revoke_bypassrls
{
my ($role) = @_;
$node_subscriber->safe_psql('postgres', qq(
ALTER ROLE $role NOBYPASSRLS));
}
-sub grant_bypassrls($)
+sub grant_bypassrls
{
my ($role) = @_;
$node_subscriber->safe_psql('postgres', qq(