Commit8c23f1d

committed

add replicate() method to PostgresNode

1 parent259c27c commit8c23f1dCopy full SHA for 8c23f1d

File tree

+21

-0

lines changed

+21

-0

lines changed

Lines changed: 13 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -872,6 +872,19 @@ def backup(self, username=None, xlog_method=DEFAULT_XLOG_METHOD):`
`872`	`872`	`username=username,`
`873`	`873`	`xlog_method=xlog_method)`
`874`	`874`
	`875`	`+defreplicate(self,name,username=None,xlog_method=DEFAULT_XLOG_METHOD):`
	`876`	`+"""`
	`877`	`+ Create a replica of this node.`
	`878`	`+`
	`879`	`+ Args:`
	`880`	`+ name: replica's name (str).`
	`881`	`+ username: database user name (str).`
	`882`	`+ xlog_method: a method for collecting the logs ('fetch' \| 'stream').`
	`883`	`+ """`
	`884`	`+`
	`885`	`+returnself.backup(username=username,`
	`886`	`+xlog_method=xlog_method).spawn_replica(name)`
	`887`	`+`
`875`	`888`	`defpgbench_init(self,dbname='postgres',scale=1,options=[]):`
`876`	`889`	`"""`
`877`	`890`	`Prepare database for pgbench (create tables etc).`

Lines changed: 8 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -246,6 +246,14 @@ def test_backup_and_replication(self):`
`246`	`246`	`res=replica.execute('postgres','select * from abc')`
`247`	`247`	`self.assertListEqual(res, [(1,2), (3,4)])`
`248`	`248`
	`249`	`+deftest_replicate(self):`
	`250`	`+withget_new_node('node')asnode:`
	`251`	`+node.init(allow_streaming=True).start()`
	`252`	`+`
	`253`	`+withnode.replicate(name='replica')asreplica:`
	`254`	`+res=replica.start().execute('postgres','select 1')`
	`255`	`+self.assertListEqual(res, [(1, )])`
	`256`	`+`
`249`	`257`	`deftest_dump(self):`
`250`	`258`	`withget_new_node('node1')asnode1:`
`251`	`259`	`node1.init().start()`

Comments

(0)