pub struct MockForwardProxy {
pub proxy_address: SocketAddr,
pub stubbed_get_config_spec_response: Mutex<ConfigSpecResponse>,
/* private fields */
}Fields§
§proxy_address: SocketAddr§stubbed_get_config_spec_response: Mutex<ConfigSpecResponse>Implementations§
Source§impl MockForwardProxy
impl MockForwardProxy
pub async fn spawn() -> Arc<MockForwardProxy>
pub async fn send_stream_update( &self, update: Result<ConfigSpecResponse, Status>, )
pub async fn stop(&self)
pub async fn restart(self: Arc<Self>)
Auto Trait Implementations§
impl !Freeze for MockForwardProxy
impl !RefUnwindSafe for MockForwardProxy
impl Send for MockForwardProxy
impl Sync for MockForwardProxy
impl Unpin for MockForwardProxy
impl UnsafeUnpin for MockForwardProxy
impl UnwindSafe for MockForwardProxy
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
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