mysql_es

Function mysql_cqrs

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

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;