Function main

examples/batch_insert_mysql.rs:5–63

()

#[tokio::main]
async fn main() {

    let producer_factory = || Prod;
    let producer_concurrency = 3;
    let producer_router = RouterType::RoundRobin;
    let producer_buffer_pool = 100;


    let proc_factory = || Layer1Process;
    let proc_concurrency = 3;
    let proc_router = RouterType::Partition;
    let proc_buffer_size = 10;


    // Mysql Config
    let database_url = "...";
    let pool = mysql_async::Pool::new(database_url);


    let batcher_factory =  || MysqlBatcher::new(pool);
    let batcher_concurrency = 2;
    let batcher_buffer_size = 10;
    let batcher_batch_size = 10;
    let batcher_batch_timeout: BATCH_TIMEOUT;
    
    //               /    processor-1  \                                    
    //              /                   \
    //  producer-1 /                     -----> MysqlBatcher[fullname] 
    //  producer-2 ----   processor-2    
    //  producer-3 \                     -----> MysqlBatcher[fullname]
    //              \                    /
    //               \    processor-3   / 


    let safe_shutdown = 
                run_topology_1_with_batcher(
                   producer_factory,
                   producer_concurrency,
                   producer_router,
                   producer_buffer_pool,
                
                   proc_factory,
                   proc_concurrency,
                   proc_router,
                   proc_buffer_size,

                   batcher_factory,
                   batcher_concurrency,
                   batcher_buffer_size,
                   batcher_batch_size,
                   batcher_batch_timeout
                );


    // Safe Shutdown from (Producer) to (Layer_X_Processor)
    safe_shutdown.send(());