Struct ServiceBindings 

pub struct ServiceBindings { /* private fields */ }

Administrative effect seams and an optional address broker, bound once.

Implementations

impl ServiceBindings

pub fn new( http: &Arc<dyn LysHttp>, bearer: &str, machine: String, publisher: &Arc<dyn ServicePublisher>, ) -> Self

Binds every seam: Lys asked through http with bearer (this machine’s own pass), seats started on machine, messages published through publisher.

pub const fn watches_context(&self) -> bool

Whether the operator asked for the context watch to run.

pub fn services(&self) -> Services<'_>

The seams, lent for one serve.

pub fn context_reporter(&self) -> Arc<ContextReporter>

The reporter the context watch shares with the context-watch call.

pub const fn broker(&self) -> Option<&Broker>

The configured address broker, independent of administrative services.

pub fn echo_address(&self) -> Option<SocketAddr>

The address actually bound by the configured broker’s UDP echo.

pub const fn relay(&self) -> Option<&Arc<Relay>>

The configured blind relay, independent of administrative services.

pub fn relay_topology_local(&self) -> Option<&str>

The console’s canonical local endpoint for relay observations.

pub fn serve_broker( &self, session: Option<&dyn LysSession>, subject: &str, request: &ServiceRequest<'_>, now: u64, ) -> Result<Value, BrokerRefusal>

Serves a broker request on the connection’s admitted session.

Errors

The broker or admitted session is absent, or the broker refuses the call.

pub fn configure( lys: &LysConfig, services: Arc<LiminalConnectionServices>, handle: Handle, now: u64, ) -> Result<Option<Self>, ServiceEffectError>

Builds configured services when the boot machine pass is present. Ok(None) when no services are selected or a dial pass was refused. Lys is asked on handle’s runtime; messages are published through services as liminal.<host>.

Errors

[auth.lys.machine] is absent (the services would have no identity to ask Lys as), this machine’s pass or the issuer’s key set cannot be read or does not verify, or the issuer is not an HTTP origin.

Trait Implementations

impl BudgetSource for ServiceBindings

fn read(&self, name: &str) -> Result<Option<BudgetPolicy>, ServiceEffectError>

Errors

impl Debug for ServiceBindings

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl KeySender for ServiceBindings

fn send( &self, session: &str, keys: &[u8], operation: &str, ) -> Result<(), ServiceEffectError>

Sends keys to session under operation.

impl SeatStarter for ServiceBindings

fn start(&self, seat: &str, operation: &str) -> Result<(), ServiceEffectError>

Starts seat under operation.

impl ServiceAction for ServiceBindings

fn act( &self, service: ServiceKind, payload: &[u8], operation: &str, ) -> Result<(), ServiceEffectError>

Takes service’s act with the request’s payload under operation.