liminal-server 0.24.5

Standalone server for the liminal messaging bus
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
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103

//! Server-owned participant storage and transport bindings.
//!
//! The conversation event stream, opaque aggregate owner, and connection-
//! incarnation stream are production durability boundaries over protocol-owned
//! transitions. The older crash/cursor/detach repositories remain test-only
//! regression fixtures until their operations move behind the aggregate.

#[allow(
    dead_code,
    reason = "production aggregate boundary is wired before its participant runtime consumer"
)]
mod aggregate;
#[allow(
    dead_code,
    reason = "production aggregate registry is wired before participant handlers consume it"
)]
mod aggregate_registry;
mod conversation_stream;
#[cfg(test)]
mod crash_repository;
#[cfg(test)]
mod cursor_repository;
#[cfg(test)]
mod detach_repository;
mod dispatch;
pub mod dispatch_impact;
pub(super) mod incarnation_stream;
mod production;
pub(crate) mod publication;
mod transport;

#[cfg(test)]
mod aggregate_registry_tests;
#[cfg(test)]
mod aggregate_tests;
#[cfg(test)]
mod conversation_stream_tests;
#[cfg(test)]
mod crash_repository_tests;
#[cfg(test)]
mod cursor_repository_tests;
#[cfg(test)]
mod detach_repository_tests;
#[cfg(test)]
mod dispatch_impact_tests;
#[cfg(test)]
mod dispatch_tests;
#[cfg(test)]
mod incarnation_stream_bound_tests;
#[cfg(test)]
mod incarnation_stream_scale_tests;
#[cfg(test)]
mod incarnation_stream_tests;
#[cfg(test)]
mod transport_tests;

pub(crate) use dispatch::CandidateLaneListener;
pub use dispatch::{
    BootDrainRefusal, ConnectionFateClass, ConnectionFateWorkItem, InstalledParticipantService,
    MARKER_SETTLED_FOLLOWS_EVERY_SETTLEMENT_REFUSAL, ParticipantConnectionContext,
    ParticipantConnectionConversations, ParticipantConnectionFateOutcome, ParticipantDispatch,
    ParticipantDispatchError, ParticipantSemanticError, ParticipantSemanticHandler,
    ParticipantSemanticOutcome, ParticipantServiceFatal, dispatch_generic_frame,
};
pub(in crate::server) use production::ParticipantWarm;
pub(crate) use production::checkpoint_batches::checkpoint_census;
#[cfg(test)]
pub(crate) use production::checkpoint_batches::{CheckpointCensus, PublicationBound};
pub use production::log_migration::{
    ConversationLogMigration, ConversationLogOutcome, ParticipantLogMigration,
    ParticipantLogMigrationError, migrate_participant_logs,
};
pub use production::marker_source::{
    MarkerSourceRefusalReason, MarkerSourceRefused, ValidatedFencedMarkerInputs,
    validate_marker_source,
};
pub use production::prune::{
    DEFAULT_KEEP_ACKNOWLEDGED_BEHIND_CHECKPOINT, PruneLedgerError, PruneProofError, PruneReceipt,
    PrunedStream, RecipientAcknowledgement, effective_keep, prune_receipts,
};
pub(crate) use production::store_census::store_census;
#[cfg(test)]
pub(crate) use production::tests::test_participant_config;
pub use production::{
    COMMITTED_OPERATION_PAGE_MAX, CommittedOperation, CommittedOperationReadError,
    RoutedStreamRefusal, read_committed_operations,
};
pub(crate) use production::{ProductionParticipantHandler, constant_time_eq};
pub(crate) use publication::{
    MarkerSettledPublication, ObserverPublication, ParticipantPublicationError,
    ParticipantPublicationInbox, ParticipantPublicationRegistry,
};
pub use publication::{
    ObserverPublicationTarget, ParticipantOfferedProgress, ParticipantPublication,
};
pub use transport::{
    PARTICIPANT_CAPABILITY_BIT, ParticipantIngress, ParticipantSession, encode_server_push,
    encode_server_value, gate_generic_frame, normalize_configured_frame_limit,
    preflight_generic_bytes,
};

#[cfg(test)]
pub(crate) use production::tests_memory_store::MemoryStore as ParticipantMemoryStore;