harmos-sidecar 0.1.13

Harmos sidecar transport and kit for out-of-process plugins.
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

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

/* === Modules === */

mod error;

#[cfg(feature = "transport")]
pub mod attach;

#[cfg(feature = "transport")]
pub mod transport;

#[cfg(feature = "kit")]
pub mod kit;

#[cfg(feature = "transport")]
mod wire;

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

pub use harmos_domain::model;
pub use harmos_operations as builtins;

#[cfg(feature = "transport")]
pub use attach::{Attach, Attached, Executable, ExecutableError};
pub use error::{Error, Result};
pub mod catalog {
    pub use harmos_domain::catalog::*;
}
pub use harmos_domain::inventory;
pub use harmos_domain::{
    ConfigError, Failure, RESERVED, Refusal, Registrar, Registration, RegistrationError, StreamSpec, UNKNOWN, UNREADABLE, encode_config,
    reserved, validate_config,
};
pub use harmos_domain::{failure, listeners};
pub use harmos_sdk::operations;
pub use harmos_sdk::operations::Host;
pub use harmos_sdk::operations::{Backoff, CacheKey, Jitter, OperationDeclaration, OperationPolicy, RestartPolicy, RetryPolicy};
pub use harmos_sdk::{Context, Dependent, ExecutionContext, Lifecycle, Operation, Plugin, Resource, Service, Setup};

pub use harmos_domain::StreamDeclaration;
#[cfg(feature = "kit")]
pub use kit::{
    Activation, ActivationId, Activity, CATALOG_EXPORT_FLAG, CATALOG_EXPORT_LIMIT, CallError, DemandKey, Instance, Observer,
    ObserverAttachment, ObserverCaller, ObserverContext, ObserverError, ObserverHost, ObserverPublisher, ObserverStreamPublisher,
    OperationInstance, PluginNative, PublicationError, PublishError, Publisher, Supervisor, Tick, run_plugin, serve_plugin_channels,
};

#[cfg(feature = "transport")]
pub use wire::{Frame, FramePayload, PluginCatalog, Publication};

#[cfg(feature = "derive")]
pub use harmos_domain::observer;
pub use harmos_domain::schema;
pub use harmos_domain::streams;
pub use harmos_domain::{Axial, Batched, Metadata, Prefix, StreamField, Track, Tracked};
pub use harmos_domain::{
    Digest, Fingerprint, MemorySize, Message, MessageError, OperationDefinition, Portable, QualifiedId, RowMetadata, ServicePolicy,
    Storable,
};
#[cfg(feature = "derive")]
pub use harmos_domain::{listener, message, stream};
#[cfg(feature = "derive")]
pub use harmos_macros::{sidecar_catalog as catalog, sidecar_operation as operation};
pub use harmos_sdk::plugin;

#[cfg(feature = "kit")]
pub use kit::__private;

/* === Imports === */

// Standard Library Imports

// Third Party Imports

// Local Imports

/* === Constants === */

/* === Macros === */

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

/* === Structs === */

/* === Enums === */

/* === Traits === */

/* === Implementations === */

#[cfg(feature = "kit")]
impl harmos_domain::__private::CarrierContext for Supervisor {
    const FACILITY: &'static str = "sidecar";
}

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

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

/* === Tests === */