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 primary_lease(&self) -> Option<Lease>

The etcd lease all our components will be attached to. Not available for static workers.

pub fn shutdown(&self)

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

Create a Namespace

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

pub fn nats_client(&self) -> 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 child_token(&self) -> CancellationToken

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

pub fn add_prometheus_metric( &self, hierarchy: &str, prometheus_metric: Box<dyn Collector>, ) -> Result<()>

Add a Prometheus metric to a specific hierarchy’s registry. Note that it is possible to register the same metric name multiple times, as long as the labels are different.

pub fn register_metrics_callback( &self, hierarchies: Vec<String>, callback: Arc<dyn Fn() -> Result<()> + Send + Sync + 'static>, )

Add a callback function to metrics registries for the given hierarchies

pub fn execute_metrics_callbacks(&self, hierarchy: &str) -> Vec<Result<()>>

Execute all callbacks for a given hierarchy key and return their results

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 MetricsRegistry for DistributedRuntime

fn basename(&self) -> String

fn parent_hierarchy(&self) -> Vec<String>

fn hierarchy(&self) -> String

Retrieve the complete hierarchy and basename for this registry. Currently, the hierarchy for drt is an empty string, so we must account for the leading underscore. The existing code remains unchanged to accommodate any future scenarios where drt’s prefix might be assigned a value.

fn create_counter( &self, name: &str, description: &str, labels: &[(&str, &str)], ) -> Result<Counter>

Create a Counter metric

fn create_countervec( &self, name: &str, description: &str, const_labels: &[&str], const_label_values: &[(&str, &str)], ) -> Result<CounterVec>

Create a CounterVec metric with label names (for dynamic labels)

fn create_gauge( &self, name: &str, description: &str, labels: &[(&str, &str)], ) -> Result<Gauge>

Create a Gauge metric

fn create_histogram( &self, name: &str, description: &str, labels: &[(&str, &str)], buckets: Option<Vec<f64>>, ) -> Result<Histogram>

Create a Histogram metric with custom buckets

fn create_intcounter( &self, name: &str, description: &str, labels: &[(&str, &str)], ) -> Result<IntCounter>

Create an IntCounter metric

fn create_intcountervec( &self, name: &str, description: &str, const_labels: &[&str], const_label_values: &[(&str, &str)], ) -> Result<IntCounterVec>

Create an IntCounterVec metric with label names (for dynamic labels)

fn create_intgauge( &self, name: &str, description: &str, labels: &[(&str, &str)], ) -> Result<IntGauge>

Create an IntGauge metric

fn create_intgaugevec( &self, name: &str, description: &str, const_labels: &[&str], const_label_values: &[(&str, &str)], ) -> Result<IntGaugeVec>

Create an IntGaugeVec metric with label names (for dynamic labels)

fn prometheus_metrics_fmt(&self) -> Result<String>

Get metrics in Prometheus text format

impl RuntimeProvider for DistributedRuntime

fn rt(&self) -> &Runtime