allsource-core 0.19.1

High-performance event store core built in 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

// Copyright 2024-2025 AllSource Team
// Licensed under the Business Source License 1.1 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     See LICENSE-BSL in the repository root
//
// Change Date: 2029-03-01
// Change License: Apache License, Version 2.0

//! Leader-follower replication via WAL shipping.
//!
//! When `ALLSOURCE_REPLICATION_ENABLED=true` on a leader node, the WAL shipper
//! opens a TCP listener on `ALLSOURCE_REPLICATION_PORT` (default 3910) and
//! streams WAL entries to connected followers using newline-delimited JSON.
//!
//! Followers use the WAL receiver to connect, subscribe, validate, and replay
//! entries into their local EventStore.

pub mod protocol;
pub mod wal_receiver;
pub mod wal_shipper;

pub use wal_receiver::{FollowerReplicationStatus, WalReceiver};
pub use wal_shipper::{ReplicationMode, ReplicationStatus, WalShipper};