Struct RequestResponseService 

pub struct RequestResponseService { /* private fields */ }

Service for request-response pattern using PostgreSQL. Uses queue for requests and LISTEN/NOTIFY for responses.

Implementations

impl RequestResponseService

pub fn new(pool: PgPool, queue: QueueRepository) -> Self

pub async fn push_and_wait<Req, Resp>( &self, queue: &QueueName, request: &Req, timeout_duration: Duration, ) -> Result<Resp>

where Req: Serialize, Resp: DeserializeOwned,

Push a request to a queue and wait for a response.

Sets up a LISTEN channel before pushing to avoid race conditions. The processor must call store_response() with the matching request_id.

pub async fn store_response<T: Serialize>( &self, request_id: &Uuid, response: &T, ) -> Result<()>

Store a response for a request (called by the processor)

pub async fn cleanup_old_responses(&self, older_than: Duration) -> Result<u64>

Clean up old responses (housekeeping)

Trait Implementations

impl Clone for RequestResponseService

fn clone(&self) -> RequestResponseService

Returns a duplicate of the value.

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

Performs copy-assignment from source.