rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-09-13 00:42:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

docs(meta): describe flow extension interfaces neutrally

Browse Source 
Signed-off-by: discord9 <discord9@163.com>
This commit is contained in:
discord9
2026-09-07 11:05:46 +08:00
parent 61c629c901
commit dd845cfbc9
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/common/meta/src/ddl/create_flow.rs
+1 -1
View File
@@ -785,7 +785,7 @@ pub enum FlowType {
pub const FLOW_EXPERIMENTAL_ENABLE_INCREMENTAL_READ_KEY: &str =
"experimental_enable_incremental_read";
/// Reserved internal value for Enterprise flows requiring exact sequence ranges.
/// Reserved internal value for flows requiring exact sequence ranges.
pub const FLOW_EXPERIMENTAL_ENABLE_INCREMENTAL_READ_SEQUENCE_RANGE: &str =
"__greptime_internal_exact_sequence_range";
src/common/meta/src/ddl_manager.rs
+4 -4
View File
@@ -148,7 +148,7 @@ pub trait TriggerDdlManager: Send + Sync {
#[cfg(feature = "enterprise")]
pub type TriggerDdlManagerRef = Arc<dyn TriggerDdlManager>;
/// This trait is responsible for handling enterprise CREATE FLOW tasks.
/// This trait is responsible for handling custom/extension CREATE FLOW tasks.
#[cfg(feature = "enterprise")]
#[async_trait::async_trait]
pub trait CreateFlowHandler: Send + Sync {
@@ -1959,7 +1959,7 @@ mod tests {
#[cfg(feature = "enterprise")]
#[tokio::test]
async fn test_reserved_sequence_range_is_rejected_before_enterprise_handler() {
async fn test_reserved_sequence_range_is_rejected_before_custom_handler() {
let handler = Arc::new(RecordingCreateFlowHandler::default());
let ddl_manager =
build_soft_drop_test_ddl_manager().with_create_flow_handler(handler.clone());
@@ -1987,7 +1987,7 @@ mod tests {
#[tokio::test]
async fn test_create_flow_handler_dispatches_without_procedure() {
let response = SubmitDdlTaskResponse {
key: b"enterprise".to_vec(),
key: b"custom-handler".to_vec(),
..Default::default()
};
let handler = Arc::new(RecordingCreateFlowHandler {
@@ -2018,7 +2018,7 @@ mod tests {
)
.await
.unwrap();
assert_eq!(actual.key, b"enterprise");
assert_eq!(actual.key, b"custom-handler");
assert_eq!(handler.tasks.lock().unwrap().len(), 1);
assert_eq!(
handler.contexts.lock().unwrap().as_slice(),