pub struct ServeManager { /* private fields */ }Expand description
Owns the stored Serve config and the live per-port accept loops (tsnet serving runtime).
Built once from the application netstack Channel and the device’s overlay IPv4, held by the
crate::Runtime. set replaces the whole config (full-replace reconcile);
dropping the manager (with the runtime / device) aborts every accept loop.
Implementations§
Source§impl ServeManager
impl ServeManager
Sourcepub fn new(channel: Channel, self_ipv4: Ipv4Addr) -> Self
pub fn new(channel: Channel, self_ipv4: Ipv4Addr) -> Self
Build a manager bound to the application netstack channel and the device’s own tailnet
self_ipv4 (the overlay address every serve listener binds on). No accept loop runs until the
first set.
Sourcepub fn get(&self) -> ServeState
pub fn get(&self) -> ServeState
The currently-stored config (Go GetServeConfig); empty default if none was ever set.
Sourcepub fn set(
&self,
state: ServeState,
resolved: BTreeMap<u16, ResolvedPort>,
) -> ServeAcceptedReceiver
pub fn set( &self, state: ServeState, resolved: BTreeMap<u16, ResolvedPort>, ) -> ServeAcceptedReceiver
Replace the whole Serve config (Go SetServeConfig, REPLACE semantics), full-replace
reconcile.
state is the new config; resolved carries the per-port target + (for TLS ports) the
pre-built acceptor, keyed identically to state.ports. Aborts every existing accept loop and
spawns one per port in resolved. Returns a fresh ServeAcceptedReceiver delivering
connections for every ServeTarget::Accept port (empty if there are none).
The caller is responsible for state.validate() and for obtaining the acceptors (failing the
whole call closed if a cert can’t be issued) before calling this; the manager only binds and
dispatches.
Auto Trait Implementations§
impl Freeze for ServeManager
impl RefUnwindSafe for ServeManager
impl Send for ServeManager
impl Sync for ServeManager
impl Unpin for ServeManager
impl UnsafeUnpin for ServeManager
impl UnwindSafe for ServeManager
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
Source§fn into_any(self: Box<T>) -> Box<dyn Any>
fn into_any(self: Box<T>) -> Box<dyn Any>
Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>, which can then be
downcast into Box<dyn ConcreteType> where ConcreteType implements Trait.Source§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
Rc<Trait> (where Trait: Downcast) to Rc<Any>, which can then be further
downcast into Rc<ConcreteType> where ConcreteType implements Trait.Source§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
&Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &Any’s vtable from &Trait’s.Source§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
&mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &mut Any’s vtable from &mut Trait’s.Source§impl<T> DowncastSend for T
impl<T> DowncastSend for T
Source§impl<T> DowncastSync for T
impl<T> DowncastSync for T
Source§impl<A, T> DynMessage<A> for T
impl<A, T> DynMessage<A> for T
Source§fn handle_dyn<'a>(
self: Box<T>,
state: &'a mut A,
actor_ref: ActorRef<A>,
tx: Option<Sender<Result<Box<dyn Any + Send>, SendError<Box<dyn Any + Send>, Box<dyn Any + Send>>>>>,
stop: &'a mut bool,
) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn ReplyError>>> + Send + 'a>>
fn handle_dyn<'a>( self: Box<T>, state: &'a mut A, actor_ref: ActorRef<A>, tx: Option<Sender<Result<Box<dyn Any + Send>, SendError<Box<dyn Any + Send>, Box<dyn Any + Send>>>>>, stop: &'a mut bool, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn ReplyError>>> + Send + 'a>>
impl<T> ErasedDestructor for Twhere
T: 'static,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more