eventcore-postgres 2.1.0

PostgreSQL event store adapter for EventCore event sourcing library
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

//! Transactional projection delivery support for PostgreSQL.

pub use eventcore_types::{
    DeliveryIdentityError, DeliveryPosition, DeliverySourceId, DeliveryUpperBound, EventTypeName,
    PersistedEventEnvelope, PersistedEventId, ProjectionSelection, ProjectionSelectionError,
    ProjectionSelectionId, ProjectionSource, ProjectionStreamFilter, ProjectorName,
};
pub use sqlx::{Postgres, Transaction};

mod config;
mod error;
mod migration;
mod projector;
mod reset;
mod runner;
mod source;
mod store;

pub use config::{
    PostgresProjectionConfig, PostgresProjectionMode, ProjectionConfigurationError,
    ProjectionPollSleeper, ProjectionRetryPolicy, ProjectionRetrySleeper,
    TokioProjectionPollSleeper, TokioProjectionRetrySleeper,
};
pub use error::{
    BoxedProjectionError, ProjectionResetAndReplayError, ProjectionResetError,
    TransactionalProjectionError,
};
pub use projector::{
    AfterCommit, NoopAfterCommit, PostgresProjectionReset, PostgresProjector,
    ProjectionFailureContext, ProjectionFailureDecision,
};
pub use reset::{reset_and_replay_transactional_projection, reset_transactional_projection};
pub use runner::{ProjectionRunOutcome, run_transactional_projection};
pub use source::{PostgresProjectionSource, PostgresProjectionSourceError};
pub(crate) use store::ProjectionLeader;
pub use store::{PostgresProjectionStore, ProjectionProgress};