Struct Producer 

pub struct Producer { /* private fields */ }

Producer for enqueueing messages to a queue.

Implementations

impl Producer

pub fn new( store: AnyStore, queue_info: QueueRecord, worker_record: WorkerRecord, validation_config: ValidationConfig, ) -> Self

Create a producer bound to a queue and worker record.

pub fn with_time(self, time: DateTime<Utc>) -> Self

Set the current time used for enqueue timestamps.

pub fn current_time(&self) -> DateTime<Utc>

Return the current time used for enqueue timestamps.

pub fn worker_id(&self) -> i64

Return the worker id for this producer.

pub fn worker_record(&self) -> &WorkerRecord

Return the worker record for this producer.

pub async fn status(&self) -> Result<WorkerStatus>

Fetch the current worker status.

pub async fn suspend(&self) -> Result<()>

Suspend this worker.

pub async fn resume(&self) -> Result<()>

Resume this worker.

pub async fn shutdown(&self) -> Result<()>

Shut down this worker.

pub async fn heartbeat(&self) -> Result<()>

Record a heartbeat for this worker.

pub async fn is_healthy(&self, max_age: Duration) -> Result<bool>

Check if the worker heartbeat is within the given age.

pub async fn get_message_by_id(&self, msg_id: i64) -> Result<QueueMessage>

Fetch a message by id.

pub async fn enqueue(&self, payload: &Value) -> Result<QueueMessage>

Enqueue a message immediately.

pub async fn enqueue_delayed( &self, payload: &Value, delay_seconds: u32, ) -> Result<QueueMessage>

Enqueue a message with a delay in seconds.

pub async fn batch_enqueue( &self, payloads: &[Value], ) -> Result<Vec<QueueMessage>>

Enqueue multiple messages immediately.

pub async fn batch_enqueue_delayed( &self, payloads: &[Value], delay_seconds: u32, ) -> Result<Vec<QueueMessage>>

Enqueue multiple messages with a delay in seconds.

pub async fn enqueue_at( &self, payload: &Value, now: DateTime<Utc>, delay_seconds: u32, ) -> Result<QueueMessage>

Enqueue a message using an explicit time reference.

pub async fn batch_enqueue_at( &self, payloads: &[Value], now: DateTime<Utc>, delay_seconds: u32, ) -> Result<Vec<QueueMessage>>

Enqueue multiple messages using an explicit time reference.

pub async fn replay_dlq( &self, archived_msg_id: i64, ) -> Result<Option<QueueMessage>>

Replay an archived DLQ message back into the queue.

pub fn validation_config(&self) -> &ValidationConfig

Return the validation config for this producer.

pub fn rate_limit_status(&self) -> Option<RateLimitStatus>

Return the current rate limit status, if enabled.

Trait Implementations

impl Clone for Producer

fn clone(&self) -> Producer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Producer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.