Function full_lifecycle

nodedb-cluster/src/migration.rs:237–273

()

    #[test]
    fn full_lifecycle() {
        let mut m = test_migration();
        assert!(!m.is_active());

        // Phase 1.
        m.start_base_copy(1_000_000);
        assert!(m.is_active());
        m.update_base_copy(500_000);
        if let MigrationPhase::BaseCopy {
            bytes_transferred, ..
        } = m.phase
        {
            assert_eq!(bytes_transferred, 500_000);
        } else {
            panic!("expected BaseCopy");
        }

        // Phase 2.
        m.start_wal_catchup(100, 200);
        assert!(!m.is_catchup_ready());
        m.update_wal_catchup(195, 200);
        assert!(m.is_catchup_ready());

        // Phase 3.
        m.start_cutover(500).unwrap();
        assert!(matches!(m.phase, MigrationPhase::AtomicCutOver { .. }));

        // Complete.
        m.complete(450);
        assert!(!m.is_active());
        if let MigrationPhase::Completed {
            pause_duration_us, ..
        } = m.phase
        {
            assert_eq!(pause_duration_us, 450);
        }
    }

    #[test]
    fn pause_budget_exceeded() {