common_meta/
node_manager.rs

1// Copyright 2023 Greptime Team
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7//     http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15use std::sync::Arc;
16
17use api::region::RegionResponse;
18use api::v1::flow::{DirtyWindowRequest, FlowRequest, FlowResponse};
19use api::v1::region::{InsertRequests, RegionRequest};
20pub use common_base::AffectedRows;
21use common_query::request::QueryRequest;
22use common_recordbatch::SendableRecordBatchStream;
23
24use crate::error::Result;
25use crate::peer::Peer;
26
27/// The trait for handling requests to datanode.
28#[async_trait::async_trait]
29pub trait Datanode: Send + Sync {
30    /// Handles DML, and DDL requests.
31    async fn handle(&self, request: RegionRequest) -> Result<RegionResponse>;
32
33    /// Handles query requests
34    async fn handle_query(&self, request: QueryRequest) -> Result<SendableRecordBatchStream>;
35}
36
37pub type DatanodeRef = Arc<dyn Datanode>;
38
39/// The trait for handling requests to flownode
40#[async_trait::async_trait]
41pub trait Flownode: Send + Sync {
42    async fn handle(&self, request: FlowRequest) -> Result<FlowResponse>;
43
44    async fn handle_inserts(&self, request: InsertRequests) -> Result<FlowResponse>;
45
46    /// Handles requests to mark time window as dirty.
47    async fn handle_mark_window_dirty(&self, req: DirtyWindowRequest) -> Result<FlowResponse>;
48}
49
50pub type FlownodeRef = Arc<dyn Flownode>;
51
52/// Datanode manager
53#[async_trait::async_trait]
54pub trait NodeManager: Send + Sync {
55    /// Retrieves a target `datanode`.
56    async fn datanode(&self, node: &Peer) -> DatanodeRef;
57
58    /// Retrieves a target `flownode`.
59    async fn flownode(&self, node: &Peer) -> FlownodeRef;
60}
61
62pub type NodeManagerRef = Arc<dyn NodeManager>;
common_meta/node_manager.rs

common_meta/
node_manager.rs
