rust_bus 3.0.6

bus — Lightweight CQRS Library for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77

use crate::contracts::bus_event::IBusEvent;

#[cfg(all(not(feature = "context"), feature = "_db_any"))]
pub trait IEventHandler<'a, TEvent>: Default + Send + Sync
where
    TEvent: IBusEvent,
{
    const HANDLER_IDENTITY: &'static str;

    #[cfg(feature = "sqlx-postgres")]
    fn handle(
        &self,
        txn: &mut sqlx::Transaction<'a, sqlx::Postgres>,
        event: &TEvent,
        metadata: &crate::contracts::meta::BusMetadata,
    ) -> impl Future<Output = Result<(), Box<dyn std::error::Error + Send + Sync>>> + Send;

    #[cfg(feature = "sqlx-mysql")]
    fn handle(
        &self,
        txn: &mut sqlx::Transaction<'a, sqlx::MySql>,
        event: &TEvent,
        metadata: &crate::contracts::meta::BusMetadata,
    ) -> impl Future<Output = Result<(), Box<dyn std::error::Error + Send + Sync>>> + Send;

    #[cfg(feature = "_db_sea_orm")]
    fn handle(
        &self,
        txn: &'a sea_orm::DatabaseTransaction,
        event: &TEvent,
        metadata: &crate::contracts::meta::BusMetadata,
    ) -> impl Future<Output = Result<(), Box<dyn std::error::Error + Send + Sync>>> + Send;
}

#[cfg(all(not(feature = "context"), not(feature = "_db_any")))]
pub trait IEventHandler<TEvent>: Default + Send + Sync
where
    TEvent: IBusEvent,
{
    const HANDLER_IDENTITY: &'static str;

    fn handle(
        &self,
        event: &TEvent,
        metadata: &crate::contracts::meta::BusMetadata,
    ) -> impl Future<Output = Result<(), Box<dyn std::error::Error + Send + Sync>>> + Send;
}

#[cfg(all(feature = "context", feature = "_db_any"))]
pub trait IEventHandler<'a, TContext, TEvent>: Default + Send + Sync
where
    TEvent: IBusEvent,
    TContext: crate::contracts::ctx::IBusContext<'a> + ?Sized,
{
    const HANDLER_IDENTITY: &'static str;

    fn handle(
        &self,
        ctx: TContext,
        event: &TEvent,
    ) -> impl Future<Output = Result<(), Box<dyn std::error::Error + Send + Sync>>> + Send;
}

#[cfg(all(feature = "context", not(feature = "_db_any")))]
pub trait IEventHandler<TContext, TEvent>: Default + Send + Sync
where
    TEvent: IBusEvent,
    TContext: crate::contracts::ctx::IBusContext + ?Sized,
{
    const HANDLER_IDENTITY: &'static str;

    fn handle(
        &self,
        ctx: TContext,
        event: &TEvent,
    ) -> impl Future<Output = Result<(), Box<dyn std::error::Error + Send + Sync>>> + Send;
}