Skip to main content

PgStreamFactory

pgsync_postgres::replication::stream

Struct PgStreamFactory

pub struct PgStreamFactory {
    pub info: ConnectionInfo,
    pub safety: SafetyConfig,
    pub timeout: Duration,
    pub slot: String,
    pub publication: String,
    pub max_message_bytes: usize,
}

Expand description

Opens replication streams for run, verifying source identity and slot continuity.

Fields§

§info: ConnectionInfo§safety: SafetyConfig§timeout: Duration§slot: String§publication: String§max_message_bytes: usize

Trait Implementations§

impl StreamFactory for PgStreamFactory

type Stream = PgEventStream

async fn connect(&mut self, cp: &Checkpoint) -> Result<(PgEventStream, Lsn)>

Open a stream resuming from cp.committed_lsn (the server may start later, at its confirmed flush position). Implementations verify source identity and slot continuity against cp and fail with ResyncRequired when continuity cannot be proven. Returns the stream and the server’s current WAL end.

Auto Trait Implementations§

impl Freeze for PgStreamFactory

impl RefUnwindSafe for PgStreamFactory

impl Send for PgStreamFactory

impl Sync for PgStreamFactory

impl Unpin for PgStreamFactory

impl UnsafeUnpin for PgStreamFactory

impl UnwindSafe for PgStreamFactory

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> Same for T

type Output = T

Should always be Self

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = !

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, !>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more