common_meta/reconciliation/reconcile_logical_tables/
reconciliation_end.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::any::Any;
16
17use common_procedure::{Context as ProcedureContext, Status};
18use common_telemetry::info;
19use serde::{Deserialize, Serialize};
20
21use crate::error::Result;
22use crate::reconciliation::reconcile_logical_tables::{ReconcileLogicalTablesContext, State};
23
24#[derive(Debug, Serialize, Deserialize)]
25pub struct ReconciliationEnd;
26
27#[async_trait::async_trait]
28#[typetag::serde]
29impl State for ReconciliationEnd {
30    async fn next(
31        &mut self,
32        ctx: &mut ReconcileLogicalTablesContext,
33        procedure_ctx: &ProcedureContext,
34    ) -> Result<(Box<dyn State>, Status)> {
35        let table_id = ctx.table_id();
36        let table_name = ctx.table_name();
37        let metrics = ctx.metrics();
38
39        info!(
40            "Logical tables reconciliation completed. logical tables: {:?}, physical_table_id: {}, table_name: {}, procedure_id: {}, metrics: {}",
41            ctx.persistent_ctx.logical_table_ids,
42            table_id,
43            table_name,
44            procedure_ctx.procedure_id,
45            metrics
46        );
47        Ok((Box::new(ReconciliationEnd), Status::done()))
48    }
49
50    fn as_any(&self) -> &dyn Any {
51        self
52    }
53}