Tool: PQ Discovery & Monitoring

[chipkent]

PQ Discovery & Monitoring:

• ControllerClient.subscribe() - Subscribe to PQ state updates
• ControllerClient.map() - Get current PQ state map (serial → info)
• ControllerClient.map_and_version() - Get PQ state map with version number
• ControllerClient.get(serial, timeout) - Get specific PQ info by serial
• ControllerClient.get_serial_for_name(name, timeout) - Resolve PQ name to serial
• ControllerClient.wait_for_change() - Wait for any PQ state change
• ControllerClient.wait_for_change_from_version(version, timeout) - Wait for specific version change
• ControllerClient.wait_for_state(state_function, timeout) - Wait for custom state condition

[chipkent]

Persistent Query Management (Critical for Enterprise)
Essential PQ Operations (Add these 8 tools)
pq_list - List all persistent queries with status

Maps to: ControllerClient.subscribe() + ControllerClient.map()
Returns: List of PQ serials, names, states, heap sizes, owners
pq_details - Get detailed PQ information

Maps to: ControllerClient.get(serial)
Returns: Full PQ configuration and state
pq_create - Create new persistent query

Maps to: ControllerClient.add_query(config)
Parameters: name, heap_size_gb, engine, jvm_args, env_vars, auto_delete_timeout, admin_groups, viewer_groups
pq_delete - Delete persistent query(s)

Maps to: ControllerClient.delete_query(serials)
pq_start - Start persistent query

Maps to: ControllerClient.start_and_wait(serial, timeout)
pq_stop - Stop persistent query

Maps to: ControllerClient.stop_and_wait(serial, timeout)
pq_restart - Restart persistent query

Maps to: ControllerClient.restart_query(serials)
pq_modify - Modify PQ configuration

Maps to: ControllerClient.modify_query(config, restart)
Parameters: serial, new config, whether to restart
Impact: Enables full PQ lifecycle management via MCP