sui_indexer::store

Function transaction_with_retry

Source 
pub async fn transaction_with_retry<'a, Q, T>(
    pool: &ConnectionPool,
    timeout: Duration,
    query: Q,
) -> Result<T, IndexerError>
where
    Q: for<'r> FnOnce(&'r mut AsyncPgConnection) -> ScopedBoxFuture<'a, 'r, Result<T, IndexerError>> + Send + Clone,
    T: 'a,