Struct TailscaleProvider 

pub struct TailscaleProvider { /* private fields */ }

Tailscale network provider implementing NetworkProvider.

Wraps the Go sidecar (tsnet) and local TCP bridge to provide:

• Peer discovery via WatchIPNBus events
• Raw TCP dial/listen over encrypted Tailscale tunnels
• Network-level ping and health monitoring

All bridge internals (pending_dials, session tokens, binary headers) are completely hidden. Callers interact only with plain TcpStreams and high-level types.

Implementations

impl TailscaleProvider

pub fn new(config: TailscaleConfig) -> Self

Create a new TailscaleProvider with the given configuration.

Does not start the provider — call start() to begin.

impl TailscaleProvider

pub async fn local_identity_async(&self) -> NodeIdentity

Get the local identity (convenience alias — same as the trait method).

Retained for backwards compatibility with existing callers that used the old async version.

pub async fn local_addr_async(&self) -> PeerAddr

Get the local address (convenience alias — same as the trait method).

Retained for backwards compatibility with existing callers that used the old async version.

Trait Implementations

impl NetworkProvider for TailscaleProvider

async fn start(&mut self) -> Result<(), NetworkError>

Start the network provider.

async fn stop(&self) -> Result<(), NetworkError>

Stop the network provider and clean up all resources.

fn local_identity(&self) -> NodeIdentity

Local node’s identity (stable ID, hostname, display name).

fn local_addr(&self) -> PeerAddr

Local node’s network address.

fn peer_events(&self) -> Receiver<NetworkPeerEvent>

Subscribe to peer events. Fires immediately when peers join/leave/update.

async fn peers(&self) -> Vec<NetworkPeer>

Snapshot of all currently known peers.

async fn dial_tcp( &self, addr: &str, port: u16, ) -> Result<TcpStream, NetworkError>

Dial a TCP connection to a peer via the encrypted Tailscale tunnel.

async fn dial_tcp_opts( &self, addr: &str, port: u16, opts: DialOpts, ) -> Result<TcpStream, NetworkError>

Dial a TCP connection with explicit options (e.g. a TLS override).

async fn listen_tcp( &self, port: u16, ) -> Result<NetworkTcpListener, NetworkError>

Listen for incoming TCP connections on a port via the Tailscale tunnel.

async fn listen_tcp_opts( &self, port: u16, opts: ListenOpts, ) -> Result<NetworkTcpListener, NetworkError>

As listen_tcp, with options (RFC 023 §7.1).

async fn unlisten_tcp(&self, port: u16) -> Result<(), NetworkError>

Stop listening on a previously opened port.

async fn ping(&self, addr: &str) -> Result<PingResult, NetworkError>

Ping a peer via the network layer (Tailscale TSMP).

async fn bind_udp(&self, port: u16) -> Result<NetworkUdpSocket, NetworkError>

Bind a UDP socket on a port via the network tunnel.

async fn health(&self) -> HealthInfo

Node health info (key expiry, connection quality, warnings).

fn proxy_runtime_errors(&self) -> Option<Receiver<ProxyRuntimeError>>

Subscribe to runtime proxy-engine errors (RFC 023 G5). None for providers without a proxy engine — the caller then skips spawning a forwarding task.

async fn proxy_add( &self, config: ProxyAddParams, ) -> Result<ProxyAddResult, NetworkError>

Start a reverse proxy. Only supported by providers with sidecar integration.

async fn proxy_remove(&self, id: &str) -> Result<(), NetworkError>

Stop a reverse proxy.

async fn proxy_list(&self) -> Result<Vec<ProxyListEntry>, NetworkError>

List active reverse proxies.