harmos_domain/
lib.rs

1/* ***
2 *
3 * Harmos
4 *
5 * SPDX-License-Identifier: Apache-2.0
6 *
7 * ***
8 */
9
10/* === Modules === */
11
12mod aggregate;
13mod answer;
14pub mod artifacts;
15pub mod catalog;
16pub mod config;
17mod error;
18pub mod failure;
19pub mod identity;
20pub mod inventory;
21pub mod journal;
22pub mod listeners;
23pub mod message;
24mod metadata;
25pub mod model;
26pub mod observers;
27pub mod operations;
28pub mod plugin;
29mod presentation;
30mod refusal;
31mod registration;
32pub mod schema;
33pub mod state;
34pub mod streams;
35mod value;
36
37pub mod __private {
38    pub use crate::config::SchemaSettings;
39    pub use crate::plugin::schema_markers as PluginSchemaMarkers;
40    pub use crate::postcard_product;
41    pub extern crate serde;
42    pub extern crate serde_json;
43    pub use crate::streams::{BatchDefinition, StreamCatalog, StreamRow};
44
45    pub fn stream_definition<S: StreamRow>(id: &'static str, version: u32, window: usize) -> crate::streams::Definition {
46        crate::streams::Definition::declared::<S>(id, version, window)
47            .batching(S::batch_definition())
48            .presentation(S::metadata(), S::row_metadata())
49    }
50
51    pub use crate::inventory as PluginInventory;
52    pub use crate::plugin::{
53        Contribution as PluginContribution, Declared as PluginDeclared, Grant as PluginGrant, Requirement as PluginRequirement,
54        Requirements as PluginRequirements,
55    };
56    pub use crate::{Registrar as PluginRegistrar, RegistrationError as PluginRegistrationError};
57
58    pub trait CarrierContext {
59        const FACILITY: &'static str;
60    }
61
62    pub use crate::answer::Answer;
63    pub use crate::message::MessageError;
64    pub use crate::message::allocation::{add as decoding_add, multiply as decoding_multiply, vector as decoding_vector};
65    pub use crate::message::postcard::{Reader as PostcardReader, Value as PostcardValue};
66    pub use crate::state::{Catalogued, Mutual};
67}
68
69/* === Re-Exports === */
70
71pub use aggregate::Aggregate;
72pub use artifacts::{FRAGMENT_LIMIT, KINDS, PREFIX, ScanError, fragments};
73pub use config::{ConfigError, decode_config, encode_config, validate_config};
74pub use error::{Error, Result};
75pub use failure::Failure;
76pub use identity::{
77    DefinitionId, Identified, IdentityError, QualifiedId, Requirement, artifact_subset, qualified, qualified_len, qualify, stream_subset,
78};
79pub use inventory::StreamDeclaration;
80pub use inventory::publications::StreamSpec;
81pub use metadata::{Identifier, IdentifierError, Metadata};
82pub use refusal::{FAILED, RESERVED, Refusal, UNKNOWN, UNREADABLE, reserved};
83pub use registration::{Registrar, Registration, RegistrationError};
84pub use value::{VALUE_DEPTH, Value, ValueError};
85
86#[cfg(feature = "derive")]
87pub use harmos_macros::{
88    catalog, listener, message, observer, operation, plugin, record, records, stream, streams, transaction, transactions,
89};
90pub use message::{Digest, Fingerprint, MemorySize, Message, MessageError, Portable, Storable, btree_map_memory};
91pub use model::operations::policy::{Backoff, Jitter, OperationPolicy, RetryPolicy};
92pub use model::services::policy::{RestartPolicy, ServicePolicy};
93pub use operations::{Invokes, OperationDeclaration, OperationDefinition, Requires};
94pub use presentation::{RowMetadata, StreamField};
95pub use streams::{Axial, Batched, Definition, Prefix, Track, Tracked};
96
97/* === Imports === */
98
99// Standard Library Imports
100
101// Third Party Imports
102
103// Local Imports
104
105/* === Constants === */
106
107/* === Macros === */
108
109/* === Type Aliases === */
110
111/* === Structs === */
112
113/* === Enums === */
114
115/* === Traits === */
116
117/* === Implementations === */
118
119/* === Public Functions === */
120
121/* === Private Functions === */
122
123/* === Tests === */
harmos_domain/lib.rs

harmos_domain/
lib.rs
