Function test_debug

src/catalog/tests/debug.rs:179–354

(state_builder: TestCatalogStateBuilder)

}

async fn test_debug(state_builder: TestCatalogStateBuilder) {
    let state_builder = state_builder.with_default_deploy_generation();
    let mut openable_state1 = state_builder.clone().unwrap_build().await;
    // Check initial empty trace.
    let err = openable_state1.trace_unconsolidated().await.unwrap_err();
    assert_eq!(
        err.to_string(),
        CatalogError::Durable(DurableCatalogError::Uninitialized).to_string()
    );

    // Check initial epoch.
    let err = openable_state1.epoch().await.unwrap_err();
    assert_eq!(
        err.to_string(),
        CatalogError::Durable(DurableCatalogError::Uninitialized).to_string()
    );

    // Use `NOW_ZERO` for consistent timestamps in the snapshots.
    let _ = openable_state1
        .open(NOW_ZERO().into(), &test_bootstrap_args())
        .await
        .unwrap()
        .0;

    // Check epoch
    let mut openable_state2 = state_builder.clone().unwrap_build().await;
    let epoch = openable_state2.epoch().await.unwrap();
    assert_eq!(Epoch::new(2).unwrap(), epoch);

    // Check opened trace.
    let mut unconsolidated_trace = openable_state2.trace_unconsolidated().await.unwrap();
    unconsolidated_trace.sort();
    {
        let test_trace = StableTrace(&unconsolidated_trace);
        let expected_ts = Timestamp::new(2);

        let ((user_version_key, user_version_value), user_version_ts, user_version_diff) =
            test_trace.user_version().unwrap();
        assert_eq!(user_version_key.key, USER_VERSION_KEY);
        assert_eq!(user_version_value.value, CATALOG_VERSION);
        assert_eq!(user_version_ts, &expected_ts);
        assert_eq!(*user_version_diff, Diff::ONE);

        let (
            (builtin_migration_shard_key, builtin_migration_shard_value),
            builtin_migration_shard_ts,
            builtin_migration_shard_diff,
        ) = test_trace.builtin_migration_shard().unwrap();
        assert_eq!(
            builtin_migration_shard_key.name,
            BUILTIN_MIGRATION_SHARD_KEY
        );
        let _shard_id: ShardId = builtin_migration_shard_value.value.parse().unwrap();
        assert_eq!(builtin_migration_shard_ts, &expected_ts);
        assert_eq!(*builtin_migration_shard_diff, Diff::ONE);

        let (
            (expression_cache_shard_key, expression_cache_shard_value),