Struct Registry 

pub struct Registry { /* private fields */ }

Registry activation - backend discovery and registration service

Implementations

impl Registry

pub async fn new(config: RegistryStorageConfig) -> Result<Self, String>

Create a new Registry instance with the given configuration

pub async fn with_defaults() -> Result<Self, String>

Create with default configuration

pub fn set_local_backend(&self, _name: String, _description: Option<String>)

Set the local backend name (called by the host)

impl Registry

pub const NAMESPACE: &'static str = "registry"

pub const PLUGIN_ID: Uuid

Stable plugin instance ID for handle routing

pub fn plugin_id(&self) -> Uuid

Get the plugin’s stable instance ID

Trait Implementations

impl Activation for Registry

type Methods = RegistryMethod

fn namespace(&self) -> &str

fn version(&self) -> &str

fn description(&self) -> &str

Short description (max 15 words)

fn long_description(&self) -> Option<&str>

Long description (optional, for detailed documentation)

fn methods(&self) -> Vec<&str>

fn method_help(&self, method: &str) -> Option<String>

fn call<'life0, 'life1, 'async_trait>( &'life0 self, method: &'life1 str, params: Value, ) -> Pin<Box<dyn Future<Output = Result<PlexusStream, PlexusError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn into_rpc_methods(self) -> Methods

fn plugin_schema(&self) -> PluginSchema

Return this activation’s schema (methods + optional children)

fn plugin_id(&self) -> Uuid

Stable activation instance ID for handle routing By default generates a deterministic UUID from namespace+major_version Using major version only ensures handles survive minor/patch upgrades (semver)

fn resolve_handle<'life0, 'life1, 'async_trait>( &'life0 self, _handle: &'life1 Handle, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = PlexusStreamItem> + Send>>, PlexusError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

impl Clone for Registry

fn clone(&self) -> Registry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl RegistryRpcServer for Registry

fn register<'life0, 'async_trait>( &'life0 self, pending: PendingSubscriptionSink, name: String, host: String, port: u16, protocol: Option<String>, description: Option<String>, namespace: Option<String>, ) -> Pin<Box<dyn Future<Output = SubscriptionResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Register a new backend

fn list<'life0, 'async_trait>( &'life0 self, pending: PendingSubscriptionSink, active_only: Option<bool>, ) -> Pin<Box<dyn Future<Output = SubscriptionResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List all registered backends

fn get<'life0, 'async_trait>( &'life0 self, pending: PendingSubscriptionSink, name: String, ) -> Pin<Box<dyn Future<Output = SubscriptionResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get a specific backend by name

fn update<'life0, 'async_trait>( &'life0 self, pending: PendingSubscriptionSink, name: String, host: Option<String>, port: Option<u16>, protocol: Option<String>, description: Option<String>, namespace: Option<String>, ) -> Pin<Box<dyn Future<Output = SubscriptionResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Update an existing backend

fn delete<'life0, 'async_trait>( &'life0 self, pending: PendingSubscriptionSink, name: String, ) -> Pin<Box<dyn Future<Output = SubscriptionResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete a backend

fn ping<'life0, 'async_trait>( &'life0 self, pending: PendingSubscriptionSink, name: String, ) -> Pin<Box<dyn Future<Output = SubscriptionResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Ping a backend to update its last_seen timestamp

fn reload<'life0, 'async_trait>( &'life0 self, pending: PendingSubscriptionSink, ) -> Pin<Box<dyn Future<Output = SubscriptionResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Reload the configuration file

fn into_rpc(self) -> RpcModule<Self>

Collects all the methods and subscriptions defined in the trait and adds them into a single RpcModule.