diff --git a/patroni/__init__.py b/patroni/__init__.py index 045d0d59..028142e9 100644 --- a/patroni/__init__.py +++ b/patroni/__init__.py @@ -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: diff --git a/patroni/dcs.py b/patroni/dcs.py index f640787c..85fda68c 100644 --- a/patroni/dcs.py +++ b/patroni/dcs.py @@ -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')):