Struct OnlineNodeRegistration 

pub struct OnlineNodeRegistration { /* private fields */ }

Online-node registry task.

Implementations

impl OnlineNodeRegistration

pub fn new( heartbeat_interval: Duration, ttl: Duration, node_type: OnlineNodeType, endpoint_hint: Option<String>, additional_capabilities: Vec<String>, ) -> Self

Create an online-node registration task.

pub fn validate_enabled_schedule(&self) -> Result<()>

Validate this registration’s periodic schedule when it is enabled.

pub fn default_capabilities() -> Vec<String>

Return capability labels advertised by online-node descriptors.

pub fn add_capabilities<I>(&self, capabilities: I) -> Result<()>

where I: IntoIterator<Item = &'static str>,

Add extension-declared capability labels.

pub fn capabilities(&self) -> Result<Vec<String>>

Return capability labels advertised by this registration.

pub fn descriptor_at( &self, context: &RegistrationContext<'_>, now_ms: u128, ) -> Result<OnlineNodeDescriptor>

Build this node’s signed descriptor at now_ms.

pub async fn publish_descriptor( &self, context: &RegistrationContext<'_>, ) -> Result<OnlineNodeDescriptor>

Publish this node’s signed online descriptor.

pub fn descriptors_from_entry(entry: &Entry) -> Vec<OnlineNodeDescriptor>

Decode online-node descriptors from a DHT entry.

Trait Implementations

impl Clone for OnlineNodeRegistration

fn clone(&self) -> OnlineNodeRegistration

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OnlineNodeRegistration

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

Formats the value using the given formatter.

impl RegistrationTask for OnlineNodeRegistration

fn name(&self) -> &'static str

Stable name used in logs.

fn interval(&self) -> Duration

Time between registration attempts.

fn register_once<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, context: &'life1 RegistrationContext<'life2>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Publish one registration heartbeat.