Struct DistributedRuntime 

pub struct DistributedRuntime { /* private fields */ }

Distributed Runtime which provides access to shared resources across the cluster, this includes communication protocols and transports.

Implementations

impl DistributedRuntime

pub async fn new(runtime: Runtime, config: DistributedConfig) -> Result<Self>

pub async fn from_settings(runtime: Runtime) -> Result<Self>

pub async fn from_settings_without_discovery(runtime: Runtime) -> Result<Self>

pub fn runtime(&self) -> &Runtime

pub fn primary_token(&self) -> CancellationToken

pub fn component_registry(&self) -> &Registry

pub fn system_health(&self) -> Arc<Mutex<SystemHealth>>

pub fn connection_id(&self) -> u64

pub fn shutdown(&self)

pub fn namespace(&self, name: impl Into<String>) -> Result<Namespace>

Create a Namespace

pub fn discovery(&self) -> Arc<dyn Discovery>

Returns the discovery interface for service registration and discovery

pub async fn tcp_server(&self) -> Result<Arc<TcpStreamServer>>

pub async fn network_manager(&self) -> Result<Arc<NetworkManager>>

Get the network manager (lazy initialization)

The network manager consolidates all network configuration and provides unified access to request plane servers and clients.

pub async fn request_plane_server(&self) -> Result<Arc<dyn RequestPlaneServer>>

Get the request plane server (convenience method)

This is a shortcut for network_manager().await?.server().await.

pub async fn http_server(&self) -> Result<Arc<SharedHttpServer>>

👎Deprecated: Use request_plane_server() or network_manager().server() instead

DEPRECATED: Use network_manager().server() instead

pub async fn shared_tcp_server(&self) -> Result<Arc<SharedTcpServer>>

👎Deprecated: Use request_plane_server() or network_manager().server() instead

DEPRECATED: Use network_manager().server() instead

pub fn nats_client(&self) -> Option<&Client>

pub fn system_status_server_info(&self) -> Option<Arc<SystemStatusServerInfo>>

Get system status server information if available

pub fn etcd_client(&self) -> Option<Client>

pub fn store(&self) -> &KeyValueStoreManager

An interface to store things. Will eventually replace etcd_client. Currently does key-value, but will grow to include whatever we need to store.

pub fn child_token(&self) -> CancellationToken

pub fn instance_sources( &self, ) -> Arc<Mutex<HashMap<Endpoint, Weak<InstanceSource>>>>

Trait Implementations

impl Clone for DistributedRuntime

fn clone(&self) -> DistributedRuntime

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DistributedRuntime

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

Formats the value using the given formatter.

impl DistributedRuntimeProvider for DistributedRuntime

fn drt(&self) -> &DistributedRuntime

impl MetricsHierarchy for DistributedRuntime

fn basename(&self) -> String

Get the name of this hierarchy (without any hierarchy prefix)

fn parent_hierarchies(&self) -> Vec<&dyn MetricsHierarchy>

Get the parent hierarchies as actual objects (not strings) Returns a vector of hierarchy references, ordered from root to immediate parent. For example, an Endpoint would return [DRT, Namespace, Component].

fn get_metrics_registry(&self) -> &MetricsRegistry

Get a reference to this hierarchy’s metrics registry

fn metrics(&self) -> Metrics<&Self>

where Self: Sized,

Access the metrics interface for this hierarchy This is a provided method that works for any type implementing MetricsHierarchy

impl RuntimeProvider for DistributedRuntime

fn rt(&self) -> &Runtime