re_redap_tests 0.27.2

Official test suite for the Rerun Data Protocol
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100

mod column_projection;
mod common;
#[cfg(feature = "lance")]
mod create_table;
#[cfg(not(feature = "lance"))]
mod create_table {
    // This is a stub test so that we do not have issues with setting
    // --no-default-options when running tests
    pub async fn create_table_entry(
        _service: impl re_protos::cloud::v1alpha1::rerun_cloud_service_server::RerunCloudService,
    ) {
    }
}
mod create_dataset;
mod dataset_schema;
mod entries_table;
mod fetch_chunks;
mod indexes;
mod query_dataset;
mod register_partition;
mod update_entry;
#[cfg(feature = "lance")]
mod write_table;

#[cfg(not(feature = "lance"))]
mod write_table {
    // This is a stub test so that we do not have issues with setting
    // --no-default-options when running tests
    pub async fn write_table(
        _service: impl re_protos::cloud::v1alpha1::rerun_cloud_service_server::RerunCloudService,
    ) {
    }
}

macro_rules! define_redap_tests {
    (
        $(
            $mod:ident :: $test:ident
        ),* $(,)?
    ) => {
        // Generate public wrapper functions
        //
        // The purpose of these wrappers is to allow the _actual_ tests to be not be exported by
        // this crate. As a result, the `dead_code` lint will kick in one forgets to add them to the
        // definition below.
        $(
            pub async fn $test<T>(service: T)
            where
                T: re_protos::cloud::v1alpha1::rerun_cloud_service_server::RerunCloudService,
            {
                $mod::$test(service).await;
            }
        )*

        // Generate the test instantiation macro
        //
        // This is the macro that must be used to actually instantiate the tests in implementing
        // crates/repos.
        #[macro_export]
        macro_rules! generate_redap_tests {
            ($builder:ident) => {
                $(
                    #[tokio::test]
                    async fn $test() {
                        $crate::$test($builder().await).await
                    }
                )*
            };
        }
    };
}

define_redap_tests! {
    column_projection::test_dataset_manifest_column_projections,
    column_projection::test_partition_table_column_projections,
    create_dataset::create_dataset_tests,
    create_table::create_table_entry,
    dataset_schema::empty_dataset_schema,
    dataset_schema::simple_dataset_schema,
    entries_table::entries_table_with_empty_dataset,
    entries_table::list_entries_table,
    fetch_chunks::multi_dataset_fetch_chunk_completeness,
    fetch_chunks::simple_dataset_fetch_chunk_snapshot,
    indexes::column_doesnt_exist,
    indexes::index_lifecycle,
    indexes::dataset_doesnt_exist,
    query_dataset::query_dataset_should_fail,
    query_dataset::query_empty_dataset,
    query_dataset::query_simple_dataset,
    query_dataset::query_simple_dataset_with_layers,
    register_partition::register_and_scan_blueprint_dataset,
    register_partition::register_and_scan_empty_dataset,
    register_partition::register_and_scan_simple_dataset,
    register_partition::register_and_scan_simple_dataset_with_layers,
    register_partition::register_and_scan_simple_dataset_with_properties,
    register_partition::register_and_scan_simple_dataset_with_properties_out_of_order,
    register_partition::register_with_prefix,
    update_entry::update_entry_tests,
    write_table::write_table
}