Struct OutboxProcessorResources

pub struct OutboxProcessorResources {
    pub postgres_pool: Pool<Postgres>,
    pub sqs_client: Option<SqsClient>,
    pub sns_client: Option<SnsClient>,
    pub http_timeout_in_millis: Option<u64>,
    pub outbox_query_limit: Option<u32>,
    pub outbox_execution_interval_in_seconds: Option<u64>,
    pub delete_after_process_successfully: Option<bool>,
    pub max_in_flight_interval_in_seconds: Option<u64>,
    pub outbox_failure_limit: Option<u32>,
    pub scheduled_clear_locked_partition: Option<bool>,
    pub outbox_cleaner_execution_interval_in_seconds: Option<u64>,
    pub delay_for_failure_attempt_in_seconds: Option<u64>,
}

Fields

postgres_pool: Pool<Postgres>

sqs_client: Option<SqsClient>

sns_client: Option<SnsClient>

http_timeout_in_millis: Option<u64>

outbox_query_limit: Option<u32>

outbox_execution_interval_in_seconds: Option<u64>

delete_after_process_successfully: Option<bool>

max_in_flight_interval_in_seconds: Option<u64>

outbox_failure_limit: Option<u32>

scheduled_clear_locked_partition: Option<bool>

outbox_cleaner_execution_interval_in_seconds: Option<u64>

delay_for_failure_attempt_in_seconds: Option<u64>

Implementations

impl OutboxProcessorResources

pub fn new( postgres_pool: Pool<Postgres>, sqs_client: Option<SqsClient>, sns_client: Option<SnsClient>, ) -> Self

pub fn with_http_timeout_in_millis(self, http_timeout: u64) -> Self

pub fn with_outbox_query_limit(self, outbox_query_limit: u32) -> Self

pub fn with_outbox_execution_interval_in_seconds( self, outbox_execution_interval_in_seconds: u64, ) -> Self

pub fn with_delete_after_process_successfully( self, delete_after_process_successfully: bool, ) -> Self

pub fn with_max_in_flight_interval_in_seconds( self, max_in_flight_interval_in_seconds: u64, ) -> Self

pub fn with_outbox_failure_limit(self, outbox_failure_limit: u32) -> Self

pub fn with_scheduled_clear_locked_partition( self, scheduled_clear_locked_partition: bool, ) -> Self

pub fn with_outbox_cleaner_execution_interval_in_seconds( self, outbox_cleaner_execution_interval_in_seconds: u64, ) -> Self

pub fn with_delay_for_failure_attempt_in_seconds( self, delay_for_failure_attempt_in_seconds: u64, ) -> Self

Trait Implementations

impl Clone for OutboxProcessorResources

fn clone(&self) -> OutboxProcessorResources

Returns a duplicate of the value.

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

Performs copy-assignment from source.