datasources 0.1.5

Async datasource interfaces, middleware, registry, and test doubles
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

use crate::create_enrichment_strategy::CreateEnrichmentStrategy;
use crate::default_write_enrichment_strategy::DefaultWriteEnrichmentStrategy;
use crate::delete_enrichment_strategy::DeleteEnrichmentStrategy;
use crate::update_enrichment_strategy::UpdateEnrichmentStrategy;
use std::sync::Arc;

pub struct LazyWriteEnrichmentStrategy;

impl LazyWriteEnrichmentStrategy {
    pub fn new(
        delete: Option<Arc<dyn DeleteEnrichmentStrategy>>,
        update: Option<Arc<dyn UpdateEnrichmentStrategy>>,
        create: Option<Arc<dyn CreateEnrichmentStrategy>>,
        use_transaction: bool,
    ) -> DefaultWriteEnrichmentStrategy {
        DefaultWriteEnrichmentStrategy::lazy(delete, update, create, use_transaction)
    }
}