Struct DieselEventHandler 

pub struct DieselEventHandler {
    pool: Arc<DbPool>,
    db_handler: DatabaseHandler,
}

Fields

pool: Arc<DbPool>

db_handler: DatabaseHandler

Delegate for event handling / batch cancel / fill persistence.

Implementations

impl DieselEventHandler

pub fn new(database_url: &str) -> Result<Self>

pub fn new_with_pool_size(database_url: &str, pool_max: u32) -> Result<Self>

pub fn new_with_auth(auth: DbAuthConfig, pool_max: u32) -> Result<Self>

pub fn new_readonly(database_url: &str, pool_max: u32) -> Result<Self>

Create a DieselEventHandler with a connection pool but skip migrations.

pub fn new_readonly_auth(auth: DbAuthConfig, pool_max: u32) -> Result<Self>

fn new_pool_only(auth: &DbAuthConfig, pool_max: u32) -> Result<Self>

Internal: create the pool without running migrations.

pub async fn get_connection( &self, ) -> Result<PooledConnection<DynConnectionManager>>

Get a connection from the pool

pub fn pool(&self) -> Arc<DbPool>

Get the connection pool.

pub fn get_pool(&self) -> DbPool

Get a clone of the connection pool (not the Arc).

pub fn with_pool(pool: Arc<DbPool>) -> Result<Self>

Create DieselEventHandler with an existing pool

pub fn with_pool_no_migrations(pool: Arc<DbPool>) -> Self

Create DieselEventHandler with an existing pool, skipping migrations.

pub fn db_handler(&self) -> &DatabaseHandler

Get a reference to the underlying DatabaseHandler.

pub fn run_migrations(&self) -> Result<()>

pub async fn handle_event(&self, event: &EngineMessage) -> Result<()>

pub fn handle_event_with_conn( &self, conn: &mut PgConnection, event: &EngineMessage, ) -> Result<()>

pub async fn handle_event_batch(&self, events: Vec<EngineMessage>) -> Result<()>

pub(crate) fn batch_cancel_expired_orders_sync( &self, cancels: &[StartupExpiredOrderCancel], reason: &str, ) -> Result<usize>

Batch-insert CANCELED rows into order_updates for orders on expired instruments discovered during replay. Delegates to DatabaseHandler::batch_cancel_expired_orders_sync.

pub(crate) fn persist_fill_with_side_effects_in_tx( conn: &mut PgConnection, fill: &Fill, side_effects: &JournalFillSideEffect, ) -> Result<(bool, bool)>

Trait Implementations

impl EngineEventPersistence for DieselEventHandler

fn handle_event<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 EngineMessage, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,