pub struct GrpcEtcdConenctor { /* private fields */ }Implementations§
Source§impl GrpcEtcdConenctor
impl GrpcEtcdConenctor
pub fn new( watch_client: WatchClient, key: Vec<u8>, watch_options_prototype: WatchOptions, ) -> Self
Trait Implementations§
Source§impl EtcdConnector for GrpcEtcdConenctor
impl EtcdConnector for GrpcEtcdConenctor
type WatchStream = WatchStream
type ConnectFut = Pin<Box<dyn Future<Output = Result<<GrpcEtcdConenctor as EtcdConnector>::WatchStream, Error>> + Send>>
fn connect_watch(&mut self, last_revision: Option<Revision>) -> Self::ConnectFut
Auto Trait Implementations§
impl !Freeze for GrpcEtcdConenctor
impl !RefUnwindSafe for GrpcEtcdConenctor
impl !UnwindSafe for GrpcEtcdConenctor
impl Send for GrpcEtcdConenctor
impl Sync for GrpcEtcdConenctor
impl Unpin for GrpcEtcdConenctor
impl UnsafeUnpin for GrpcEtcdConenctor
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