Skip to main content

SingBoxProcess

Struct SingBoxProcess 

Source
pub struct SingBoxProcess { /* private fields */ }
Expand description

The owner-local sing-box process adapter.

Implementations§

Source§

impl SingBoxProcess

Source

pub fn with_tokio( binary_path: PathBuf, config_path: PathBuf, instance_id: CoreInstanceId, controller_address: SocketAddr, ) -> Result<Self, PortError>

Creates the process adapter that launches the binary through tokio.

Fails with a Failed port error when the controller address is not a fixed loopback address.

Source

pub fn new( binary_path: PathBuf, config_path: PathBuf, instance_id: CoreInstanceId, controller_address: SocketAddr, command: Arc<dyn SingBoxCommandPort>, ) -> Result<Self, PortError>

Creates the process adapter with an injected command boundary.

Source

pub fn new_with_operation_gate( binary_path: PathBuf, config_path: PathBuf, instance_id: CoreInstanceId, controller_address: SocketAddr, command: Arc<dyn SingBoxCommandPort>, operation_gate: Arc<SingBoxCoreOperationGate>, ) -> Result<Self, PortError>

Creates the process adapter that shares one operation gate.

Source

pub fn binary_path(&self) -> &PathBuf

Returns the path of the sing-box binary the adapter launches.

Source

pub fn config_path(&self) -> &PathBuf

Returns the path of the configuration file the core reads.

Source

pub fn operation_gate(&self) -> Arc<SingBoxCoreOperationGate> ⓘ

Returns the gate that serializes process activation with file commits.

Trait Implementations§

Source§

impl CoreProcess for SingBoxProcess

Source§

fn core_identity(&self) -> Option<CoreIdentity>

Stable engine/configured-instance identity. Missing identity disables scoped core commands instead of guessing which backend owns the process.
Source§

fn start<'life0, 'async_trait>( &'life0 self, context: CoreProcessStartContext, ) -> Pin<Box<dyn Future<Output = Result<(), PortError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Starts the owned core process for the supplied ownership context. Read more
Source§

fn stop<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), PortError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Stop the exact configured process instance and confirm its exit before returning success. A command acknowledgement or disappearance of a tracked PID record is not terminal evidence; identity mismatches and stop deadlines fail. With no owned or recorded instance, stop is an idempotent no-op.
Source§

fn status<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<CoreLifecycle, PortError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Observes the lifecycle state of the owned process.
Source§

fn controller_endpoint(&self) -> Option<String>

Returns the controller endpoint of the owned process, when it has one.
Source§

fn pid<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Option<u32>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Returns the process id of the owned process, when the host can read it.
Source§

fn prepare_start<'life0, 'life1, 'async_trait>( &'life0 self, _context: &'life1 CoreProcessStartContext, ) -> Pin<Box<dyn Future<Output = Result<CoreProcessStartAdmission, PortError>> + Send + 'async_trait>>
where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Observe the host process slot before the application persists its managed session proof. Android overrides this to refuse stale or ambiguous children before a new session can replace their proof.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more