Struct Endpoint 

pub struct Endpoint { /* private fields */ }

Implementations

impl Endpoint

pub async fn unregister_endpoint_instance(&self) -> Result<()>

Unregister this endpoint instance from discovery.

This removes the endpoint from the instances bucket, preventing the router from sending requests to this worker. Use this when a worker is sleeping and should not receive any requests.

pub async fn register_endpoint_instance(&self) -> Result<()>

Re-register this endpoint instance to discovery.

This adds the endpoint back to the instances bucket, allowing the router to send requests to this worker again. Use this when a worker wakes up and should start receiving requests.

impl Endpoint

pub fn id(&self) -> EndpointId

pub fn name(&self) -> &str

pub fn component(&self) -> &Component

pub async fn client(&self) -> Result<Client>

pub fn endpoint_builder(&self) -> EndpointConfigBuilder

Trait Implementations

impl Clone for Endpoint

fn clone(&self) -> Endpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Endpoint

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

Formats the value using the given formatter.

impl DistributedRuntimeProvider for Endpoint

fn drt(&self) -> &DistributedRuntime

impl Hash for Endpoint

fn hash<H: Hasher>(&self, state: &mut H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl MetricsHierarchy for Endpoint

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 PartialEq for Endpoint

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl RuntimeProvider for Endpoint

fn rt(&self) -> &Runtime

impl Eq for Endpoint