Struct Endpoint 

pub struct Endpoint { /* private fields */ }

Handle to a running mDNS endpoint.

Cloneable; every clone shares the same underlying driver task. The driver task is spawned at Self::server time and exits when the last clone (and every derived Service / Query handle) is dropped — detected via Rc::strong_count(&inner) == 1 inside the driver loop.

Implementations

impl Endpoint

pub async fn server(opts: ServerOptions) -> Result<Self, ServerError>

Bind the multicast sockets configured in opts and spawn the driver task on the current compio runtime.

pub fn stats(&self) -> StatsSnapshot

Available on crate feature stats only.

Return a point-in-time snapshot of the I/O + protocol counters for this endpoint.

Delegates to the shared stats::Stats instance owned by the proto endpoint (and shared with the driver I/O paths), so the snapshot covers wire-level rx/tx as well as protocol-level events.

pub async fn register_service( &self, spec: ServiceSpec, ) -> Result<Service, RegisterError>

Register a new service.

Returns a Service handle for receiving ServiceUpdate events; dropping the handle implicitly unregisters the service. Drop encodes the RFC 6762 §10.1 goodbye records and tears down the proto state synchronously; the driver task then multicasts the queued TTL=0 datagrams a few times for loss resilience.

pub async fn start_query( &self, spec: QuerySpec, ) -> Result<Query, StartQueryError>

Start a query against the endpoint.

Returns a Query handle for receiving QueryEvent events; dropping the handle implicitly cancels the query (the driver removes the proto state machine on its next loop iteration).

pub async fn browse(&self, param: QueryParam) -> Result<Lookup, StartQueryError>

Browse for instances of a DNS-SD service type, resolving each into a ServiceEntry. See Lookup and QueryParam.

pub async fn lookup( &self, service: Name, timeout: Duration, ) -> Result<Lookup, StartQueryError>

Convenience for Self::browse with default parameters and the given browse timeout.

pub async fn resolve_host( &self, host: Name, timeout: Duration, ) -> Result<Vec<IpAddr>, StartQueryError>

Resolve a host name to its addresses via mDNS A / AAAA queries (RFC 6762), without the DNS-SD browse/resolve chain.

Issues both queries and collects every advertised address for the timeout window (the answer window for multicast responses), returning them IPv4 first then IPv6, deduplicated and capped per family. The result is empty if nothing answers. Unlike Self::resolve_instance this does not require — or interpret — DNS-SD records; it is the multicast analogue of resolving a hostname.

pub async fn resolve_instance( &self, instance: Name, timeout: Duration, ) -> Result<Option<ServiceEntry>, StartQueryError>

Resolve a known DNS-SD service instance directly into a ServiceEntry, skipping the PTR browse step (e.g. Name::try_from_str("Office._ipp._tcp.local.")).

Issues SRV + TXT for the instance and A / AAAA for the SRV target host, and returns the first complete resolution — host + port, TXT, and at least one address — or None if it does not complete within timeout. Use Self::browse instead when the instance names are not known in advance.

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

Wake the driver when an Endpoint clone is dropped so it can promptly observe Rc::strong_count(&inner) == 1 and exit (per the exit-condition contract). Without this notify, the driver would only notice the dropped handle the next time it woke for a recv / timer event.

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.