pub struct BridgeSlot {
pub name: String,
pub broker_url: String,
pub broker_type: BrokerType,
pub credentials: Option<(String, String)>,
pub state_rx: Receiver<BridgeState>,
pub process: Arc<Mutex<Option<BridgeProcess>>>,
/* private fields */
}Fields§
§name: String§broker_url: String§broker_type: BrokerType§credentials: Option<(String, String)>§state_rx: Receiver<BridgeState>§process: Arc<Mutex<Option<BridgeProcess>>>BridgeProcess::stop(mut self) takes ownership — Mutex<Option<>> is required.
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for BridgeSlot
impl !UnwindSafe for BridgeSlot
impl Freeze for BridgeSlot
impl Send for BridgeSlot
impl Sync for BridgeSlot
impl Unpin for BridgeSlot
impl UnsafeUnpin for BridgeSlot
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
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
impl<T> ErasedDestructor for Twhere
T: 'static,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request