gitops/patroni
1
0
Fork 0
mirror of https://github.com/outbackdingo/patroni.git synced 2026-08-26 23:50:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

Show tags for member via patronictl (#1383)

Browse Source 
Add one more field to patronictl output to check tags defined for a member.
Closes #1375
This commit is contained in:
Kostiantyn Nemchenko
2020-02-13 15:07:05 +01:00
committed by GitHub
parent f419d73465
commit bc948ce551
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
patroni/ctl.py
+4 -3
View File
@@ -726,7 +726,7 @@ def output_members(cluster, name, extended=False, fmt='pretty'):
cluster = cluster_as_json(cluster)
columns = ['Cluster', 'Member', 'Host', 'Role', 'State', 'TL', 'Lag in MB']
for c in ('Pending restart', 'Scheduled restart'):
for c in ('Pending restart', 'Scheduled restart', 'Tags'):
if extended or any(m.get(c.lower().replace(' ', '_')) for m in cluster['members']):
columns.append(c)
@@ -741,7 +741,8 @@ def output_members(cluster, name, extended=False, fmt='pretty'):
m.update(cluster=name, member=m['name'], tl=m.get('timeline', ''),
role='' if m['role'] == 'replica' else m['role'].replace('_', ' ').title(),
lag_in_mb=round(lag/1024/1024) if isinstance(lag, six.integer_types) else lag,
pending_restart='*' if m.get('pending_restart') else '')
pending_restart='*' if m.get('pending_restart') else '',
tags=json.dumps(m['tags']) if m.get('tags') else '')
if append_port:
m['host'] = ':'.join([m['host'], str(m['port'])])
@@ -754,7 +755,7 @@ def output_members(cluster, name, extended=False, fmt='pretty'):
rows.append([m.get(n.lower().replace(' ', '_'), '') for n in columns])
print_output(columns, rows, {'Lag in MB': 'r', 'TL': 'r'}, fmt)
print_output(columns, rows, {'Lag in MB': 'r', 'TL': 'r', 'Tags': 'l'}, fmt)
if fmt != 'pretty': # Omit service info when using machine-readable formats
return