harmos-domain 0.1.5

Harmos domain model: identifiers, contracts, catalogs and storage identities.
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
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118

/* ***
 *
 * Harmos
 *
 * SPDX-License-Identifier: Apache-2.0
 *
 * ***
 */

/* === Modules === */

mod aggregate;
mod answer;
pub mod artifacts;
pub mod catalog;
pub mod config;
mod error;
pub mod failure;
mod identity;
pub mod inventory;
pub mod journal;
pub mod listeners;
pub mod message;
mod metadata;
pub mod model;
pub mod observers;
pub mod operations;
pub mod plugin;
mod presentation;
mod refusal;
mod registration;
pub mod schema;
pub mod state;
pub mod streams;
mod value;

pub mod __private {
    pub use crate::config::SchemaSettings;
    pub use crate::plugin::schema_markers as PluginSchemaMarkers;
    pub use crate::{declare, postcard_product};
    pub extern crate serde;
    pub extern crate serde_json;
    pub use crate::streams::{BatchDefinition, StreamCatalog, StreamRow};

    pub fn stream_definition<S: StreamRow>(id: &'static str, version: u32, window: usize) -> crate::streams::Definition {
        crate::streams::Definition::declared::<S>(id, version, window)
            .batching(S::batch_definition())
            .presentation(S::metadata(), S::row_metadata())
    }

    pub use crate::inventory as PluginInventory;
    pub use crate::plugin::{
        Contribution as PluginContribution, Declared as PluginDeclared, Grant as PluginGrant, Requirement as PluginRequirement,
        Requirements as PluginRequirements,
    };
    pub use crate::{Registrar as PluginRegistrar, RegistrationError as PluginRegistrationError};

    pub trait CarrierContext {
        const FACILITY: &'static str;
    }

    pub use crate::answer::Answer;
    pub use crate::message::MessageError;
    pub use crate::message::allocation::{add as decoding_add, multiply as decoding_multiply, vector as decoding_vector};
    pub use crate::message::postcard::{Reader as PostcardReader, Value as PostcardValue};
    pub use crate::state::{Catalogued, Mutual};
}

/* === Re-Exports === */

pub use aggregate::Aggregate;
pub use artifacts::{FRAGMENT_LIMIT, KINDS, PREFIX, ScanError, fragments};
pub use config::{ConfigError, decode_config, encode_config, validate_config};
pub use error::{Error, Result};
pub use failure::Failure;
pub use identity::{DefinitionId, Identified, Requirement, artifact_subset, qualified, qualified_len, qualify, stream_subset};
pub use inventory::StreamDeclaration;
pub use inventory::publications::StreamSpec;
pub use metadata::{Identifier, IdentifierError, Metadata};
pub use refusal::{FAILED, RESERVED, Refusal, UNKNOWN, UNREADABLE, reserved};
pub use registration::{Registrar, Registration, RegistrationError};
pub use value::{VALUE_DEPTH, Value, ValueError};

#[cfg(feature = "derive")]
pub use harmos_macros::{
    catalog, listener, message, observer, operation, plugin, record, records, stream, streams, transaction, transactions,
};
pub use message::{MemorySize, Message, MessageError, Portable, Storable, btree_map_memory};
pub use presentation::{RowMetadata, StreamField};
pub use streams::{Axial, Batched, Definition, Prefix, Track, Tracked};

/* === Imports === */

// Standard Library Imports

// Third Party Imports

// Local Imports

/* === Constants === */

/* === Macros === */

/* === Type Aliases === */

/* === Structs === */

/* === Enums === */

/* === Traits === */

/* === Implementations === */

/* === Public Functions === */

/* === Private Functions === */

/* === Tests === */