obix 0.16.0

Implementation of outbox backed by PG / sqlx
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

#![cfg_attr(feature = "fail-on-warnings", deny(warnings))]
#![cfg_attr(feature = "fail-on-warnings", deny(clippy::all))]
#![forbid(unsafe_code)]

pub mod prelude {
    pub use es_entity;
    pub use serde;
    pub use serde_json;
    pub use sqlx;
}

mod config;
mod error;
mod handle;
pub mod inbox;
pub mod out;
mod sequence;
mod tables;

#[cfg(feature = "test-utils")]
pub mod test_utils;

pub use config::{
    CommitLane, DEFAULT_BACKFILL_PAGE_SIZE, DEFAULT_COMMIT_CHECKPOINT_EVERY,
    DEFAULT_COMMIT_CHECKPOINT_INTERVAL, DEFAULT_GAP_FILL_GRACE, DEFAULT_IDLE_RESYNC_INTERVAL,
    DEFAULT_NOTIFY_DEBOUNCE, DEFAULT_PARTITION_MAINTAINER_INTERVAL, DEFAULT_PARTITION_PREMAKE,
    DEFAULT_PARTITION_WIDTH, DEFAULT_PERSIST_EVENTS_BATCH_SIZE, MailboxConfig,
};
pub use error::ObixFault;

pub use inbox::{
    Inbox, InboxAttempt, InboxConfig, InboxEvent, InboxEventId, InboxEventStatus, InboxHandler,
    InboxIdempotencyKey, InboxRejection, InboxResult,
};
pub use obix_macros::{EphemeralSelection, MailboxTables, OutboxEvent};
pub use out::{
    CommitLaneDisabled, CommitOrder, CouldNotDecodeStored, DecodeFailure, Delivery,
    EphemeralConfig, EphemeralEvent, EphemeralEventType, EphemeralOutbox, EphemeralOutboxEvent,
    EphemeralOutboxListener, EphemeralSelection, EphemeralSubscriber, EphemeralSubscriberConfig,
    EphemeralSubscription, EventCtx, EventDelivery, FlushError, FlushOp, Handled, InsertOrder,
    IsolatedOp, KeyedEventCtx, KeyedSubscriber, KeyedSubscriberConfig, Lane, LaneMismatch,
    Ordering, Outbox, OutboxEventJobConfig, PartitionMaintainerConfig, Partitions, PostPersistHook,
    RawPayload, SingletonSubscriber, StagedOp, StreamPosition, Subscription, SubscriptionDef,
    SubscriptionRejection, SubscriptionSnapshot, SubscriptionStreamStatus, Subscriptions,
    Suspended, UndecodableDelivery, UndecodableEventError, WakeKey, WakeKeys,
};
pub use sequence::{CommitGroupId, CommitSequence, EventSequence};
#[doc(hidden)]
pub use tables::CommitCheckpoint;
pub use tables::MailboxTables;
pub use tables::{PersistentEventRows, SubscriptionRow};
#[doc(hidden)]
pub use tables::{
    decode_persistent_event, record_ephemeral_event_type_undecodable,
    record_ephemeral_payload_undecodable, record_tracing_context_undecodable,
};