Method commit_catalog_changes

influxdb3_write/src/write_buffer/validator.rs:295–314

(
        self,
    )

impl WriteValidator<LinesParsed> {
    pub async fn commit_catalog_changes(
        self,
    ) -> Result<Prompt<WriteValidator<CatalogChangesCommitted>>> {
        let db_schema = self.state.txn.db_schema();
        let db_id = db_schema.id;
        let db_name = Arc::clone(&db_schema.name);
        match self.state.catalog.commit(self.state.txn).await? {
            Prompt::Success(catalog_sequence) => Ok(Prompt::Success(WriteValidator {
                state: CatalogChangesCommitted {
                    catalog_sequence,
                    db_id,
                    db_name,
                    lines: self.state.lines,
                    bytes: self.state.bytes,
                    errors: self.state.errors,
                },
            })),
            Prompt::Retry(_) => Ok(Prompt::Retry(())),
        }
    }

    pub fn ignore_catalog_changes_and_convert_lines_to_buffer(
        self,