Function waitForCaughtUp

pgserver/logrepl/replication_test.go:925–945

(r *logrepl.LogicalReplicator)

}

func waitForCaughtUp(r *logrepl.LogicalReplicator) error {
	log.Println("Waiting for replication to catch up")

	start := time.Now()
	for {
		if caughtUp, err := r.CaughtUp(150); caughtUp {
			log.Println("replication caught up")
			break
		} else if err != nil {
			return err
		}

		log.Println("replication not caught up, waiting")
		if time.Since(start) >= 30*time.Second {
			return errors.New("Replication did not catch up")
		}
		time.Sleep(1 * time.Second)
	}

	return nil
}