mirror of
https://github.com/GreptimeTeam/greptimedb.git
synced 2026-01-05 21:02:58 +00:00
41656c8635
* refactor: replace TableMetadataManager with TableNameManager * refactor: allocate table id in the procedure * refactor: refactor client logical of handling retries * feat(test_util): add TestCreateTableExprBuilder * feat(test_util): add MockDatanodeManager * feat(test_util): add new_ddl_context * feat(test_util): add build_raw_table_info_from_expr * feat(test_util): add MockDatanodeManager::new * feat(procedure): add downcast_output_ref to Status * test(create_table): add tests for CreateTableProcedure on_prepare * refactor(ddl): rename handle_operate_region_error to add_peer_context_if_need * test(create_table): add tests for CreateTableProcedure on_datanode_create_regions * test(create_table): add tests for CreateTableProcedure on_create_metadata * refactor(meta): use CreateTableExprBuilder * feat(create_table): ensure number of partitions is greater than 0 * refactor: rename to add_peer_context_if_needed * feat: add context for panic * refactor: simplify the should_retry * refactor: use Option<&T> instead of &Option<T> * refactor: move downcast_output_ref under cfg(test) * chore: fmt toml
48 lines
1.2 KiB
Rust
48 lines
1.2 KiB
Rust
// Copyright 2023 Greptime Team
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
#![feature(assert_matches)]
|
|
#![feature(btree_extract_if)]
|
|
#![feature(async_closure)]
|
|
#![feature(let_chains)]
|
|
|
|
pub mod cache_invalidator;
|
|
pub mod datanode_manager;
|
|
pub mod ddl;
|
|
pub mod ddl_manager;
|
|
pub mod distributed_time_constants;
|
|
pub mod error;
|
|
pub mod heartbeat;
|
|
pub mod instruction;
|
|
pub mod key;
|
|
pub mod kv_backend;
|
|
pub mod lock_key;
|
|
pub mod metrics;
|
|
pub mod peer;
|
|
pub mod range_stream;
|
|
pub mod region_keeper;
|
|
pub mod rpc;
|
|
pub mod sequence;
|
|
pub mod state_store;
|
|
pub mod table_name;
|
|
#[cfg(any(test, feature = "testing"))]
|
|
pub mod test_util;
|
|
pub mod util;
|
|
pub mod wal_options_allocator;
|
|
|
|
pub type ClusterId = u64;
|
|
pub type DatanodeId = u64;
|
|
|
|
pub use instruction::RegionIdent;
|