Function dispatch

nodedb/src/control/server/pgwire/ddl/router/admin.rs:9–496

(
    state: &SharedState,
    identity: &AuthenticatedIdentity,
    sql: &str,
    upper: &str,
    parts: &[&str],
)

use crate::control::state::SharedState;

pub(super) async fn dispatch(
    state: &SharedState,
    identity: &AuthenticatedIdentity,
    sql: &str,
    upper: &str,
    parts: &[&str],
) -> Option<PgWireResult<Vec<Response>>> {
    // BACKUP/RESTORE TENANT are fully dispatched via typed AST (ast.rs).

    // Schedules: CREATE/DROP/ALTER/SHOW SCHEDULE
    // CREATE SCHEDULE is fully dispatched via typed AST (ast.rs).
    if upper.starts_with("DROP SCHEDULE ") {
        return Some(super::super::schedule::drop_schedule(
            state, identity, parts,
        ));
    }
    // ALTER SCHEDULE is fully dispatched via typed AST (ast.rs).
    if upper.starts_with("SHOW SCHEDULE HISTORY ") {
        let name = parts.get(3).unwrap_or(&"");
        return Some(super::super::schedule::show_schedule_history(
            state, identity, name,
        ));
    }
    if upper.starts_with("SHOW SCHEDULE") {
        return Some(super::super::schedule::show_schedules(state, identity));
    }

    // Sequences: CREATE/DROP/ALTER/SHOW SEQUENCE
    // CREATE SEQUENCE is fully dispatched via typed AST (ast.rs).
    if upper.starts_with("DROP SEQUENCE ") {
        return Some(super::super::sequence::drop_sequence(
            state, identity, parts,
        ));
    }
    // ALTER SEQUENCE is fully dispatched via typed AST (ast.rs).
    if upper == "SHOW SEQUENCES" || upper.starts_with("SHOW SEQUENCES ") {
        return Some(super::super::sequence::show_sequences(state, identity));
    }

    // Maintenance: ANALYZE, COMPACT, REINDEX, SHOW STORAGE, SHOW COMPACTION
    if upper.starts_with("ANALYZE ") {
        return Some(super::super::maintenance::handle_analyze(state, identity, sql).await);
    }
    if upper.starts_with("COMPACT ") {
        return Some(super::super::maintenance::handle_compact(
            state, identity, parts,
        ));
    }
    // REINDEX is fully dispatched via typed AST (ast.rs).
    if upper.starts_with("SHOW STORAGE ") {
        return Some(super::super::maintenance::handle_show_storage(
            state, identity, parts,
        ));
    }
    if upper == "SHOW COMPACTION STATUS" || upper.starts_with("SHOW COMPACTION STATUS ") {
        return Some(super::super::maintenance::handle_show_compaction_status(
            state, identity,
        ));