pub struct DcbServer { /* private fields */ }Implementations§
Trait Implementations§
Source§impl Dcb for DcbServer
impl Dcb for DcbServer
Source§type ReadStream = Pin<Box<dyn Stream<Item = Result<ReadResponse, Status>> + Send>>
type ReadStream = Pin<Box<dyn Stream<Item = Result<ReadResponse, Status>> + Send>>
Server streaming response type for the Read method.
Source§type SubscribeStream = Pin<Box<dyn Stream<Item = Result<SubscribeResponse, Status>> + Send>>
type SubscribeStream = Pin<Box<dyn Stream<Item = Result<SubscribeResponse, Status>> + Send>>
Server streaming response type for the Subscribe method.
Source§fn read<'life0, 'async_trait>(
&'life0 self,
request: Request<ReadRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::ReadStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn read<'life0, 'async_trait>(
&'life0 self,
request: Request<ReadRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::ReadStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Provides a stream of batches of already-recorded events, up to a captured head position.
Source§fn subscribe<'life0, 'async_trait>(
&'life0 self,
request: Request<SubscribeRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::SubscribeStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn subscribe<'life0, 'async_trait>(
&'life0 self,
request: Request<SubscribeRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::SubscribeStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Provides a stream of batches of already-recorded events, then continues as new events are recorded.
Source§fn append<'life0, 'async_trait>(
&'life0 self,
request: Request<AppendRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<AppendResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn append<'life0, 'async_trait>(
&'life0 self,
request: Request<AppendRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<AppendResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Appends new events to the store.
Source§fn head<'life0, 'async_trait>(
&'life0 self,
request: Request<HeadRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<HeadResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn head<'life0, 'async_trait>(
&'life0 self,
request: Request<HeadRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<HeadResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Gets the position of the last recorded event in the store.
Source§fn get_tracking_info<'life0, 'async_trait>(
&'life0 self,
request: Request<TrackingRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<TrackingResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_tracking_info<'life0, 'async_trait>(
&'life0 self,
request: Request<TrackingRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<TrackingResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Gets the last record position for a named source.
Auto Trait Implementations§
impl !RefUnwindSafe for DcbServer
impl !UnwindSafe for DcbServer
impl Freeze for DcbServer
impl Send for DcbServer
impl Sync for DcbServer
impl Unpin for DcbServer
impl UnsafeUnpin for DcbServer
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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§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