Struct PgEventListenerConfig 

pub struct PgEventListenerConfig<R> { /* private fields */ }

PostgreSQL listener Configuration.

Properties:

• poll: The poll property represents the interval at which the listener should poll for new events from the event store. This determines how frequently the event handler will handles new events.
• notifier_enabled: The notifier_enabled indicates if the listener is configured to handle events in “real time”.

Implementations

impl PgEventListenerConfig<AbortRetry>

pub fn poller(poll: Duration) -> PgEventListenerConfig<AbortRetry>

Creates a new PgEventListenerConfig with the specified poll interval.

Parameters

• poll: The poll interval.

Returns

A new PgEventListenerConfig instance.

impl<R> PgEventListenerConfig<R>

pub fn fetch_size(self, fetch_size: usize) -> Self

Sets the fetch size for the event listener. The fetch size determines the number of events to fetch from the event store at a time.

Parameters

• fetch_size: The number of events to fetch from the event store at a time.

Returns

A new PgEventListenerConfig instance.

pub fn with_notifier(self) -> Self

Sets the db notifier.

Returns

The updated PgEventListenerConfig instance with the db notifier set. When the db notifier is enabled, the event listener will handle events in “real time”.

pub fn with_retry<R1>(self, retry: R1) -> PgEventListenerConfig<R1>

Sets the retry policy for the event listener.

Parameters

• retry: The retry policy to use.

Returns

The updated PgEventListenerConfig instance with the retry policy set.

Trait Implementations

impl<R> Clone for PgEventListenerConfig<R>

where R: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.