Struct ProviderConnection

pub struct ProviderConnection {
    pub source_links: Arc<RwLock<HashMap<LatticeTarget, InterfaceLinkDefinition>>>,
    pub target_links: Arc<RwLock<HashMap<String, InterfaceLinkDefinition>>>,
    pub nats: Arc<Client>,
    pub lattice: Arc<str>,
    pub host_id: String,
    pub provider_id: Arc<str>,
    pub provider_xkey: Arc<XKey>,
    pub host_xkey: Arc<XKey>,
    pub config: HashMap<String, String>,
}

Fields

source_links: Arc<RwLock<HashMap<LatticeTarget, InterfaceLinkDefinition>>>

Links from the provider to other components, aka where the provider is the source of the link. Indexed by the component ID of the target

target_links: Arc<RwLock<HashMap<String, InterfaceLinkDefinition>>>

Links from other components to the provider, aka where the provider is the target of the link. Indexed by the component ID of the source

nats: Arc<Client>

NATS client used for performing RPCs

lattice: Arc<str>

Lattice name

host_id: String

provider_id: Arc<str>

provider_xkey: Arc<XKey>

Secrets XKeys

host_xkey: Arc<XKey>

config: HashMap<String, String>

Implementations

impl ProviderConnection

pub fn new( nats: impl Into<Arc<Client>>, provider_id: impl Into<Arc<str>>, lattice: impl Into<Arc<str>>, host_id: String, config: HashMap<String, String>, provider_private_xkey: impl Into<Arc<XKey>>, host_public_xkey: impl Into<Arc<XKey>>, ) -> ProviderInitResult<ProviderConnection>

pub async fn get_wrpc_client(&self, target: &str) -> Result<WrpcClient>

Retrieve a wRPC client that can be used based on the NATS client of this connection

Arguments

• target - Target ID to which invocations will be sent

pub async fn get_wrpc_client_custom( &self, target: &str, timeout: Option<Duration>, ) -> Result<WrpcClient>

Retrieve a wRPC client that can be used based on the NATS client of this connection, customized with invocation timeout

Arguments

• target - Target ID to which invocations will be sent
• timeout - Timeout to be set on the client (by default if this is unset it will be 10 seconds)

pub fn provider_key(&self) -> &str

Get the provider key that was assigned to this host at startup

pub async fn put_link(&self, ld: InterfaceLinkDefinition)

Stores link in the ProviderConnection, either as a source link or target link depending on if the provider is the source or target of the link

pub async fn delete_link(&self, source_id: &str, target: &str)

Deletes link from the ProviderConnection, either a source link or target link based on if the provider is the source or target of the link

pub async fn is_linked( &self, source_id: &str, target_id: &str, wit_namespace: &str, wit_package: &str, link_name: &str, ) -> bool

Returns true if the source is linked to this provider or if the provider is linked to the target on the given interface and link name

Trait Implementations

impl Clone for ProviderConnection

fn clone(&self) -> ProviderConnection

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ProviderConnection

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

Formats the value using the given formatter.