Add replicafrom tag.

This commit is contained in:
Oleksii Kliukin
2015-12-11 18:54:03 +01:00
parent 146d9a688e
commit a4af9f2a4c
2 changed files with 8 additions and 0 deletions
+4
View File
@@ -29,6 +29,10 @@ class Patroni:
def nofailover(self):
return self.tags.get('nofailover', False)
@property
def replicatefrom(self):
return self.tags.get('replicatefrom')
@staticmethod
def get_dcs(name, config):
if 'etcd' in config:
+4
View File
@@ -67,6 +67,10 @@ class Member(namedtuple('Member', 'index,name,session,data')):
def nofailover(self):
return self.data.get('tags', {}).get('nofailover', False)
@property
def replicatefrom(self):
return self.data.get('tags', {}).get('replicatefrom')
class Leader(namedtuple('Leader', 'index,session,member')):