Function waitForCaughtUp

testing/go/replication_test.go:765–785

(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) >= 2*time.Second {
			return errors.New("Replication did not catch up")
		}
		time.Sleep(20 * time.Millisecond)
	}

	return nil
}