Struct PgEventListener 

pub struct PgEventListener<E, S>
where
    E: Event + Clone,
    S: Serde<E> + Send + Sync,
{ /* private fields */ }

PostgreSQL event listener implementation.

Implementations

impl<E, S> PgEventListener<E, S>

where E: Event + Clone + Send + Sync + 'static, S: Serde<E> + Clone + Send + Sync + 'static,

pub fn builder(event_store: PgEventStore<E, S>) -> Self

Creates a new PgEventListener that listens to the events coming from the provided PgEventStore

Parameters

• event_store: An instance of PgEventStore representing the event store for the listener.

Returns

A new PgEventListener instance.

pub fn uninitialized(self) -> Self

Marks the event listener as uninitialized, indicating that the database setup is already done.

This method sets the initialize flag to false. When the flag is unset, the listener will not initialize the database. If you set initialize to false, you must ensure that the database is initialized before running the listener. Check the SQL files in the listener/sql folder to initialize the database.

Returns

The updated PgEventListener instance with the uninitialized flag set.

pub fn register_listener<QE>( self, event_listener: impl EventListener<PgEventId, QE> + 'static, config: PgEventListenerConfig, ) -> Self

where QE: TryFrom<E> + Into<E> + Event + Send + Sync + Clone + 'static, <QE as TryFrom<E>>::Error: StdError + Send + Sync,

Registers an event listener to the PgEventListener.

Parameters

• event_listner: An implementation of the EventListener trait for the specified event type QE.
• config: A PgEventListenerConfig instance representing the configuration for the event listener.

Returns

The updated PgEventListener instance with the registered event handler.

pub async fn start(self) -> Result<(), Error>

Starts the listener process for all registered event listeners.

Returns

A Result indicating the success or failure of the listener process.

pub async fn start_with_shutdown<F: Future<Output = ()> + Send + 'static>( self, shutdown: F, ) -> Result<(), Error>

Starts the listener process for all the registered event listeners with a shutdown signal.

Parameters

• shutdown: A future that represents the shutdown signal.

Returns

A Result indicating the success or failure of the listener process.