harmos_domain/operations/streams/mod.rs
1/* ***
2 *
3 * Harmos
4 *
5 * SPDX-License-Identifier: Apache-2.0
6 *
7 * ***
8 */
9
10/* === Modules === */
11
12mod payloads;
13
14/* === Re-Exports === */
15
16pub use payloads::{FollowingRow, Publish};
17
18/* === Imports === */
19
20// Standard Library Imports
21
22// Third Party Imports
23
24// Local Imports
25use crate::operations::Visibility;
26
27/* === Constants === */
28
29/* === Macros === */
30
31// A Sidecar Publishing One Ordered Batch Of Stream Rows To Its Host.
32crate::declare!(Publish {
33 id: "host.publish",
34 version: 1,
35 policy: crate::operations::host::POLICY,
36 response: (),
37 visibility: Visibility::Shared,
38});
39
40/* === Type Aliases === */
41
42/* === Structs === */
43
44/* === Enums === */
45
46/* === Traits === */
47
48/* === Implementations === */
49
50/* === Public Functions === */
51
52/* === Private Functions === */
53
54/* === Tests === */