Skip to main content

save_journal_entry

cruster::storage::sql_workflow_journal

Function save_journal_entry 

Source 
pub async fn save_journal_entry(
    conn: &mut PgConnection,
    key: &str,
    value: &[u8],
) -> Result<(), ClusterError>
Expand description

Write a journal entry into an open SQL transaction.

This is used by the macro-generated activity dispatch code to write the journal entry atomically with activity SQL writes (self.tx). Both the journal entry and any user SQL execute in the same transaction.