def get_wal_receiver_status()

in postgresql_metrics/postgres_queries.py [0:0]

• 9 lines of code
• 2 McCabe index (conditional complexity)

def get_wal_receiver_status(conn):
    sql = ("SELECT conninfo, CASE WHEN status = 'streaming' THEN 1 ELSE 0 END "
           "FROM public.stat_incoming_replication")
    results = query(conn, sql)
    host_replication_status = []
    for conn_info, status in results:
        host = CONNINFO_HOST_RE.search(conn_info).groupdict().get('host', 'UNKNOWN')
        host_replication_status.append((host, status))
    return host_replication_status