Function mysql_es::mysql_cqrs

pub fn mysql_cqrs<A>(
    pool: Pool<MySql>, 
    query_processor: Vec<Box<dyn Query<A>>>
) -> MysqlCqrs<A> where
    A: Aggregate, 

A convenience method for building a simple connection pool for MySql. A connection pool is needed for both the event and view repositories.

use sqlx::{MySql, Pool};
use mysql_es::default_mysql_pool;

let connection_string = "mysql://test_user:test_pass@localhost:3306/test";
let pool: Pool<MySql> = default_mysql_pool(connection_string).await;