Struct ProcessManager 

pub struct ProcessManager {
    peer_addr: String,
    next_id: AtomicU32,
    catalogs: RwLock<HashMap<String, HashMap<ProcessId, CancellableProcess>>>,
    frontend_selector: Option<MetaClientSelector>,
}

Query process manager.

Fields

peer_addr: String

Address this frontend advertises to the cluster.

It is the heartbeat peer address, which is also the only address other frontends use to reach this node’s process management service. The same value identifies processes owned by this frontend and routes kill requests, so discovery addresses and process addresses share one namespace.

next_id: AtomicU32

Next process id for local queries.

catalogs: RwLock<HashMap<String, HashMap<ProcessId, CancellableProcess>>>

Running process per catalog.

frontend_selector: Option<MetaClientSelector>

Frontend selector to locate frontend nodes.

Implementations

impl ProcessManager

pub fn new(peer_addr: String, meta_client: Option<MetaClientRef>) -> Self

Creates a ProcessManager for the frontend identified by peer_addr.

peer_addr must be the address the frontend advertises to metasrv, not its public gRPC address: discovered peers are matched by that address to exclude this node from remote listings and to route kill requests.

impl ProcessManager

pub fn register_query( self: &Arc<Self>, catalog: String, schemas: Vec<String>, query: String, client: String, query_id: Option<ProcessId>, _slow_query_timer: Option<SlowQueryTimer>, ) -> Ticket

Registers a submitted query. Use the provided id if present.

pub fn next_id(&self) -> u32

Generates the next process id.

pub fn deregister_query(&self, catalog: String, id: ProcessId)

De-register a query from process list.

pub fn local_processes(&self, catalog: Option<&str>) -> Result<Vec<ProcessInfo>>

List local running processes in given catalog.

pub async fn list_all_processes( &self, catalog: Option<&str>, ) -> Result<Vec<ProcessInfo>>

Lists running processes from every selected frontend and the local registry.

The local frontend is excluded from the remote selection by its advertised peer address, which is what [MetaClientSelector] discovers. Its processes are appended from the local registry exactly once.

Returns an error if a remote frontend cannot provide its process list.

pub async fn kill_process( &self, peer_addr: String, catalog: String, id: ProcessId, ) -> Result<bool>

Kills query with provided catalog and id.

peer_addr is the frontend address from the process id, which is the advertised peer address of the frontend that owns the process.

pub async fn kill_local_process( &self, catalog: String, id: ProcessId, ) -> Result<bool>

Kills local query with provided catalog and id.