Struct K2KTypeRegistry 

pub struct K2KTypeRegistry {
    by_type_id: HashMap<u64, &'static K2KMessageRegistration>,
    by_type_name: HashMap<&'static str, &'static K2KMessageRegistration>,
    by_category: HashMap<&'static str, Vec<u64>>,
}

Registry for discovering K2K-routable message types at runtime.

The registry is built by scanning all K2KMessageRegistration entries submitted via the inventory crate. This enables runtime discovery of message types for routing, validation, and monitoring.

Example

let registry = K2KTypeRegistry::discover();

// Check if a type is routable
if registry.is_routable(501) {
    // Allow K2K routing
}

// Get all types in a category
let order_types = registry.get_category("orders");
for type_id in order_types {
    println!("Order message type: {}", type_id);
}

Fields

by_type_id: HashMap<u64, &'static K2KMessageRegistration>

by_type_name: HashMap<&'static str, &'static K2KMessageRegistration>

by_category: HashMap<&'static str, Vec<u64>>

Implementations

impl K2KTypeRegistry

pub fn discover() -> K2KTypeRegistry

Discover all registered K2K message types at runtime.

This scans all K2KMessageRegistration entries that were submitted via inventory::submit! during compilation.

pub fn is_routable(&self, type_id: u64) -> bool

Check if a message type ID is K2K routable.

pub fn get(&self, type_id: u64) -> Option<&'static K2KMessageRegistration>

Get registration by type ID.

pub fn get_by_name( &self, type_name: &str, ) -> Option<&'static K2KMessageRegistration>

Get registration by type name.

pub fn get_category(&self, category: &str) -> &[u64]

Get all type IDs in a category.

pub fn categories(&self) -> impl Iterator<Item = &'static str>

Get all registered categories.

pub fn iter(&self) -> impl Iterator<Item = &'static K2KMessageRegistration>

Iterate all registered message types.

pub fn routable_types(&self) -> Vec<u64>

Get all routable type IDs.

pub fn len(&self) -> usize

Get total number of registered message types.

pub fn is_empty(&self) -> bool

Check if the registry is empty.

Trait Implementations

impl Debug for K2KTypeRegistry

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for K2KTypeRegistry

fn default() -> K2KTypeRegistry

Returns the “default value” for a type.