Struct NetpolNetworksService 

pub struct NetpolNetworksService { /* private fields */ }

Implementations

impl NetpolNetworksService

pub fn with_operations_inspect( self, parent: &Node, name: impl AsRef<str>, ) -> Result<Self, AttachError>

pub fn with_network_registry_inspect( self, parent: &Node, name: impl AsRef<str>, ) -> Self

pub fn with_inspect( self, telemetry_parent: &Node, operations_name: impl AsRef<str>, networks_parent: &Node, networks_name: impl AsRef<str>, ) -> Result<Self, AttachError>

pub fn synthesize_reachability_snapshot(&self) -> Snapshot

pub fn set_telemetry(&mut self, telemetry: TelemetrySender)

pub fn add_stream<S: Into<NetworkRequestStream>>(&mut self, s: S)

pub async fn handle_event( &mut self, event: NetworkRequest, ) -> Result<DelegatedNetworkUpdateResult, Error>

pub fn consolidated_dns_servers(&self) -> Vec<DnsServer_>

Returns the consolidated DNS servers from the Network Registry.

pub async fn handle_network_attributes_request( &mut self, id: NetworksConnectionId, req: Option<Result<NetworksRequest, Error>>, ) -> Result<(), Error>

Handles a single item produced by a client’s [NetworksRequestStream].

Panics

Panics if id does not correspond to a currently registered client. A client is removed only when its stream yields the terminal None item, and the stream is fused, so every item from the stream belongs to a live client.

pub async fn handle_property_watcher_request( &mut self, id: PropertyWatcherConnectionId, req: Option<Result<PropertyWatcherRequest, Error>>, ) -> Result<(), Error>

Handles a single item produced by a client’s [PropertyWatcherRequestStream].

Panics

Panics if id does not correspond to a currently registered client. A client is removed only when its stream yields the terminal None item, and the stream is fused, so every item from the stream belongs to a live client.

pub async fn handle_delegated_networks_update( &mut self, update: Option<Result<NetworkRegistryRequest, Error>>, ) -> DelegatedNetworkUpdateResult

Handles delegated network updates coming from Starnix.

Resolves network events requested through the NetworkRegistry interface, applies the corresponding properties changes, and yields the computed DNS configuration targets for output updates.

TODO(https://fxbug.dev/428712735): Stop returning DnsServer list once dns-resolver learns about DNS via NetworkProperties.

Panics

Panics if there is no currently active delegated networks client. A client is removed only when its stream yields the terminal None item, and the stream is fused, so every item from the stream belongs to a live client.

pub async fn update(&mut self, update: NetworkRegistryUpdate)

Trait Implementations

impl Default for NetpolNetworksService

fn default() -> NetpolNetworksService

Returns the “default value” for a type.

impl FusedStream for NetpolNetworksService

fn is_terminated(&self) -> bool

Returns true if the stream should no longer be polled.

impl Stream for NetpolNetworksService

type Item = NetworkRequest

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.