Struct ResourceManager 

pub struct ResourceManager { /* private fields */ }

Resource manager for managing available resources with retry logic

Implementations

impl ResourceManager

pub fn new() -> Self

Create new resource manager

pub fn with_notifications( notification_tx: UnboundedSender<JsonRpcNotification>, ) -> Self

Create resource manager with notification channel

pub fn set_notification_tx(&mut self, tx: UnboundedSender<JsonRpcNotification>)

Set notification channel

pub fn set_retry_config(&self, config: ResourceRetryConfig)

Configure retry behavior

pub fn register<R: Resource + 'static>(&self, resource: R)

Register a resource

pub fn register_boxed(&self, resource: Arc<dyn Resource>)

Register a boxed resource

pub fn register_template<T: ResourceTemplate + 'static>(&self, template: T)

Register a resource template

pub fn register_template_boxed(&self, template: Arc<dyn ResourceTemplate>)

Register a boxed resource template

pub fn get_template(&self, name: &str) -> Option<Arc<dyn ResourceTemplate>>

Get a template by name

pub fn get(&self, uri: &str) -> Option<Arc<dyn Resource>>

Get a resource by URI

pub fn list(&self) -> Vec<ResourceInfo>

List all registered resources

pub fn list_templates(&self) -> Vec<ResourceTemplateInfo>

List all resource templates

pub fn list_templates_for_session( &self, _session: &Session, ctx: &VisibilityContext<'_>, ) -> Vec<ResourceTemplateInfo>

List templates visible in the given session/context

pub async fn read( &self, uri: &str, params: HashMap<String, String>, session: &Session, ) -> Result<Vec<ResourceContent>, ResourceError>

Read a resource by URI with parameters and retry logic

pub fn list_for_session( &self, session: &Session, ctx: &VisibilityContext<'_>, ) -> Vec<ResourceInfo>

List resources visible to a specific session

Resolution order:

1. Session overrides (replace global resources with session-specific implementations)
2. Session extras (additional resources added to session)
3. Global resources (filtered by hidden list and visibility predicate)

pub async fn read_for_session( &self, uri: &str, params: HashMap<String, String>, session: &Session, visibility_ctx: &VisibilityContext<'_>, ) -> Result<Vec<ResourceContent>, ResourceError>

Read a resource with session context

Resolution order:

1. Check session overrides
2. Check session extras
3. Check session hidden
4. Check visibility predicate
5. Fall back to global registry with retry logic

pub fn len(&self) -> usize

Get number of registered resources

pub fn is_empty(&self) -> bool

Check if manager is empty

Trait Implementations

impl Clone for ResourceManager

fn clone(&self) -> ResourceManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for ResourceManager

fn default() -> Self

Returns the “default value” for a type.