Skip to main content

SharedContext

Struct SharedContext 

Source
pub struct SharedContext {
Show 16 fields pub config: EnvoyConfig, pub envoy_key: String, pub envoy_tx: UnboundedSender<ToEnvoyMessage>, pub actors: Arc<Mutex<HashMap<String, HashMap<u32, SharedActorEntry>>>>, pub actors_notify: Arc<Notify>, pub live_tunnel_requests: Arc<Mutex<HashMap<[u8; 8], String>>>, pub pending_hibernation_restores: Arc<Mutex<HashMap<String, Vec<HibernatingWebSocketMetadata>>>>, pub ws_tx: Arc<Mutex<Option<UnboundedSender<WsTxMessage>>>>, pub http_ws_tx: Arc<Mutex<Option<HttpConnectionTx>>>, pub connection_session: AtomicU64, pub next_connection_session: AtomicU64, pub connection_session_tx: Sender<u64>, pub protocol_metadata: Arc<Mutex<Option<ProtocolMetadata>>>, pub shutting_down: AtomicBool, pub last_ping_ts: AtomicI64, pub stopped_tx: Sender<bool>,
}

Fields§

§config: EnvoyConfig§envoy_key: String§envoy_tx: UnboundedSender<ToEnvoyMessage>§actors: Arc<Mutex<HashMap<String, HashMap<u32, SharedActorEntry>>>>§actors_notify: Arc<Notify>§live_tunnel_requests: Arc<Mutex<HashMap<[u8; 8], String>>>§pending_hibernation_restores: Arc<Mutex<HashMap<String, Vec<HibernatingWebSocketMetadata>>>>§ws_tx: Arc<Mutex<Option<UnboundedSender<WsTxMessage>>>>§http_ws_tx: Arc<Mutex<Option<HttpConnectionTx>>>§connection_session: AtomicU64

The currently connected WebSocket session, or zero while disconnected.

Session IDs are actor-client-local and never cross the wire. Remote SQLite transactions use them to prevent a statement from being admitted on a replacement WebSocket after the server-side connection (and its SQLite handle) has already been torn down.

§next_connection_session: AtomicU64§connection_session_tx: Sender<u64>§protocol_metadata: Arc<Mutex<Option<ProtocolMetadata>>>§shutting_down: AtomicBool§last_ping_ts: AtomicI64

Epoch ms timestamp of the most recent ping packet received from the engine. Used by EnvoyHandle::is_ping_healthy to surface a dead engine link to upstream health checks. Zero means no ping has been received yet.

§stopped_tx: Sender<bool>

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> Same for T

Source§

type Output = T

Should always be Self
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<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

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