pub struct ReplicationStream<'a, F: ConnectionFactory> { /* private fields */ }Implementations§
Source§impl<'a, F: ConnectionFactory> ReplicationStream<'a, F>
impl<'a, F: ConnectionFactory> ReplicationStream<'a, F>
Sourcepub async fn next_message(
&mut self,
) -> Result<Option<ReplicationMessage<'_>>, ElefantClientError>
pub async fn next_message( &mut self, ) -> Result<Option<ReplicationMessage<'_>>, ElefantClientError>
Reads the next replication message from the stream.
Returns Ok(None) when the server ends the replication stream
(sends CopyDone). Automatically replies to keepalive messages
that have reply_requested set, so callers never see those.
pub async fn send_status_update( &mut self, write_lsn: Lsn, flush_lsn: Lsn, apply_lsn: Lsn, ) -> Result<(), ElefantClientError>
Auto Trait Implementations§
impl<'a, F> !UnwindSafe for ReplicationStream<'a, F>
impl<'a, F> Freeze for ReplicationStream<'a, F>where
&'a mut PostgresClient<F>: Freeze,
impl<'a, F> RefUnwindSafe for ReplicationStream<'a, F>where
&'a mut PostgresClient<F>: RefUnwindSafe,
impl<'a, F> Send for ReplicationStream<'a, F>where
&'a mut PostgresClient<F>: Send,
impl<'a, F> Sync for ReplicationStream<'a, F>where
&'a mut PostgresClient<F>: Sync,
impl<'a, F> Unpin for ReplicationStream<'a, F>where
&'a mut PostgresClient<F>: Unpin,
impl<'a, F> UnsafeUnpin for ReplicationStream<'a, F>where
&'a mut PostgresClient<F>: UnsafeUnpin,
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