def get_stats_replication_delays()

in postgresql_metrics/metrics_gatherer.py [0:0]


def get_stats_replication_delays(_data_dir, db_connection):
    replication_delays = get_replication_delays(db_connection)
    metrics = []
    for client_addr, delay_in_bytes in replication_delays:
        metrics.append(metric_replication_delay_bytes(client_addr, delay_in_bytes))
    return metrics