Struct SharedResourceRegistry 

pub struct SharedResourceRegistry { /* private fields */ }

Thread-safe registry for resource types.

This is a concurrent version of ResourceRegistry that can be safely shared across threads without external synchronization.

Uses DashMap internally for lock-free reads and efficient concurrent writes.

Example

use xds_core::{SharedResourceRegistry, TypeUrl};
use std::sync::Arc;

let registry = Arc::new(SharedResourceRegistry::with_envoy_types());

// Can be shared across threads safely
assert!(registry.contains(TypeUrl::CLUSTER));
assert!(registry.contains(TypeUrl::LISTENER));

Implementations

impl SharedResourceRegistry

pub fn new() -> Self

Create a new empty thread-safe registry.

pub fn with_envoy_types() -> Self

Create a thread-safe registry pre-populated with standard Envoy types.

pub fn register(&self, info: ResourceTypeInfo)

Register a new resource type.

This is safe to call from multiple threads concurrently.

pub fn get(&self, type_url: &str) -> Option<ResourceTypeInfo>

Get information about a resource type by type URL.

Returns None if the type is not registered.

pub fn contains(&self, type_url: &str) -> bool

Check if a type URL is registered.

pub fn type_urls(&self) -> Vec<String>

Get all registered type URLs.

pub fn len(&self) -> usize

Get the number of registered types.

pub fn is_empty(&self) -> bool

Check if the registry is empty.

pub fn validate(&self, type_url: &str) -> Result<(), String>

Validate that a type URL is registered.

Returns Ok(()) if registered, or an error with available types if not.

Trait Implementations

impl Debug for SharedResourceRegistry

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

Formats the value using the given formatter.

impl Default for SharedResourceRegistry

fn default() -> Self

Returns the “default value” for a type.