nodedb 0.4.0

Local-first, real-time, edge-to-cloud hybrid database for multi-modal workloads
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

// SPDX-License-Identifier: BUSL-1.1

//! Shared dispatch utilities used by both the pgwire and native endpoints.

mod change_events;
mod collect;
mod dispatch;
mod submit_write;
mod types;

pub(crate) use change_events::{
    WriteChangeSet, extract_write_change_set, publish_change_set_with_lsn,
    publish_cluster_array_change_events, publish_origin_change_events,
};
pub(crate) use collect::{DispatchCollectError, collect_bounded_response};
pub(crate) use dispatch::{dispatch_autocommit_write, dispatch_write_to_data_plane};
pub use dispatch::{
    dispatch_to_data_plane, dispatch_to_data_plane_with_source, dispatch_to_data_plane_with_txn,
};
pub(crate) use submit_write::{
    ChangeFeedOwner, SubmitOutcome, SubmitWrite, WalDurability, WriteOrdering, submit_write,
};
pub(crate) use types::{AutocommitWrite, WriteDispatch};