Struct Outbox

pub struct Outbox {
    pub idempotent_key: Uuid,
    pub partition_key: Uuid,
    pub destinations: Json<Vec<OutboxDestination>>,
    pub headers: Option<Json<HashMap<String, String>>>,
    pub payload: String,
    pub attempts: i32,
    pub created_at: DateTime<Utc>,
    pub processing_until: Option<DateTime<Utc>>,
    pub processed_at: Option<DateTime<Utc>>,
}

Fields

idempotent_key: Uuid

partition_key: Uuid

destinations: Json<Vec<OutboxDestination>>

headers: Option<Json<HashMap<String, String>>>

payload: String

attempts: i32

created_at: DateTime<Utc>

processing_until: Option<DateTime<Utc>>

processed_at: Option<DateTime<Utc>>

Implementations

impl Outbox

pub fn start_delay(&self, process_after: DateTime<Utc>) -> Self

pub fn http_post_json( partition_key: Uuid, url: &str, headers: Option<HashMap<String, String>>, payload: &Value, ) -> Self

pub fn http_put_json( partition_key: Uuid, url: &str, headers: Option<HashMap<String, String>>, payload: &Value, ) -> Self

pub fn http_patch_json( partition_key: Uuid, url: &str, headers: Option<HashMap<String, String>>, payload: &Value, ) -> Self

pub fn sqs( partition_key: Uuid, queue_url: &str, headers: Option<HashMap<String, String>>, payload: &str, ) -> Self

pub fn sns( partition_key: Uuid, topic_arn: &str, headers: Option<HashMap<String, String>>, payload: &str, ) -> Self

pub fn http_and_sns( partition_key: Uuid, url: &str, topic_arn: &str, headers: Option<HashMap<String, String>>, payload: &Value, ) -> Self

pub fn http_and_sqs( partition_key: Uuid, url: &str, queue_url: &str, headers: Option<HashMap<String, String>>, payload: &Value, ) -> Self

pub fn new( partition_key: Uuid, destinations: Vec<OutboxDestination>, headers: Option<HashMap<String, String>>, payload: &str, ) -> Self

Trait Implementations

impl Clone for Outbox

fn clone(&self) -> Outbox

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Outbox

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

Formats the value using the given formatter.

impl<'a, R: Row> FromRow<'a, R> for Outbox

where &'a str: ColumnIndex<R>, Uuid: Decode<'a, R::Database> + Type<R::Database>, Json<Vec<OutboxDestination>>: Decode<'a, R::Database> + Type<R::Database>, Option<Json<HashMap<String, String>>>: Decode<'a, R::Database> + Type<R::Database>, String: Decode<'a, R::Database> + Type<R::Database>, i32: Decode<'a, R::Database> + Type<R::Database>, DateTime<Utc>: Decode<'a, R::Database> + Type<R::Database>, Option<DateTime<Utc>>: Decode<'a, R::Database> + Type<R::Database>,

fn from_row(__row: &'a R) -> Result<Self>

impl PartialEq for Outbox

fn eq(&self, other: &Outbox) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for Outbox