harmos_runtime/operations/
mod.rs

1/* ***
2 *
3 * Harmos
4 *
5 * SPDX-License-Identifier: Apache-2.0
6 *
7 * ***
8 */
9
10/* === Modules === */
11
12mod admission;
13mod authored;
14pub mod authorization;
15mod binding;
16mod caller;
17mod catalog;
18pub(crate) mod context;
19mod surface;
20
21#[cfg(any(feature = "plugin-sidecar", all(feature = "plugin-guest", not(target_arch = "wasm32"))))]
22pub(crate) mod children;
23
24#[cfg(all(feature = "plugin-guest", not(target_arch = "wasm32")))]
25mod component;
26mod execution;
27mod finalization;
28#[cfg(feature = "grpc")]
29mod grpc;
30mod handler;
31pub(crate) mod instances;
32pub(crate) mod lane;
33pub mod listing;
34mod manager;
35pub mod middleware;
36pub(crate) mod refusal;
37pub mod resident;
38pub(crate) mod scope;
39mod session;
40mod streaming;
41
42#[cfg(feature = "plugin-sidecar")]
43mod native;
44mod registration;
45#[cfg(any(feature = "plugin-sidecar", all(feature = "plugin-guest", not(target_arch = "wasm32"))))]
46mod remote;
47
48#[cfg(any(feature = "plugin-sidecar", all(feature = "plugin-guest", not(target_arch = "wasm32"))))]
49mod sdk;
50mod wire;
51
52/* === Re-Exports === */
53
54pub use crate::supervision::instance::{Outcome as OperationOutcome, Phase as OperationPhase, Status as OperationStatus};
55#[cfg(any(feature = "plugin", feature = "plugin-guest", feature = "plugin-sidecar"))]
56pub use caller::Caller;
57pub use catalog::{Binding, Implementations, WireImplementations};
58pub use context::ContextMut;
59#[cfg(feature = "grpc")]
60pub use grpc::GrpcBinding;
61#[cfg(feature = "grpc")]
62pub use grpc::GrpcMethod;
63pub use harmos_sdk::operations::{
64    AuthoredContracts, AuthoredDeclarations, Backoff, CHILD_METHOD, CacheKey, CacheKeyError, CallValue, Codec, ContextError, ContextValue,
65    Contract, ContractError, Contracts, Declarations, Declares, Definition, Direction, Entry, FailureKind, Grpc, Jitter,
66    MAX_CACHE_KEY_BYTES, NoStream, Operation, OperationDeclaration, OperationPolicy, PORTABLE_BYTES, PORTABLE_VALUES, PolicyError,
67    ReplaySafety, RestartPolicy, RetryPolicy, Serves, ServingError, Stream, Visibility, WIRE_METHOD, WireAnswer, WireBinding, WireChild,
68    WireChildAction, WireChildCall, WireChildControl, WireCodecError, WireCommand, WireDeclaration, WireEndpoints, WireStreamLimits,
69    WireStreams, WireTable, item_types,
70};
71pub use harmos_sdk::operations::{CallContext, Host, Instance, Response, instance};
72pub use lane::{Capacity, Lane, LaneSet};
73#[cfg(any(feature = "plugin-sidecar", all(feature = "plugin-guest", not(target_arch = "wasm32"))))]
74pub use remote::{RemoteStreamError, StreamEndpoints, StreamPeer};
75pub use scope::Scope;
76
77pub use crate::config::OperationSettings as Settings;
78#[cfg(all(feature = "plugin-guest", not(target_arch = "wasm32")))]
79pub use component::{Component, ComponentBindings, ComponentError, ComponentOperation};
80pub use handler::{Context, OperationGeneration, OperationInstance, OperationInstanceId};
81pub use harmos_domain::observers;
82pub use harmos_sdk::operations::{EndpointSet, InputEndpoint, OutputEndpoint, host, lifecycle, streams};
83pub use manager::OperationManager;
84pub use session::{Completion, Download, Exchange, Session, SessionInput, SessionOutput, Upload};
85pub use streaming::{StreamInput, StreamItem, StreamOutput, StreamPermit, StreamSettings, stream};
86
87#[cfg(any(feature = "plugin", feature = "plugin-guest", feature = "plugin-sidecar"))]
88pub(crate) use manager::Registry;
89
90#[cfg(feature = "plugin-sidecar")]
91pub use native::{Native, NativeBindings, NativeError, NativeOperation};
92pub use registration::Bindings;
93pub(crate) use registration::CatalogBinding;
94
95#[cfg(any(feature = "plugin", feature = "plugin-guest", feature = "plugin-sidecar"))]
96pub use registration::PluginRegistration;
97
98#[cfg(any(feature = "plugin-sidecar", all(feature = "plugin-guest", not(target_arch = "wasm32"))))]
99pub use sdk::PluginSdkRegistration;
100pub use wire::EncodedInvocation;
101
102#[cfg(any(feature = "plugin", feature = "plugin-guest", feature = "plugin-sidecar"))]
103pub use wire::PluginCallback;
104
105#[cfg(feature = "plugin-sidecar")]
106pub(crate) use wire::PluginControl;
107
108/* === Imports === */
109
110// Standard Library Imports
111
112// Third Party Imports
113
114// Local Imports
115
116/* === Constants === */
117
118/* === Macros === */
119
120/* === Type Aliases === */
121
122/* === Structs === */
123
124/* === Enums === */
125
126/* === Traits === */
127
128/* === Implementations === */
129
130/* === Public Functions === */
131
132/* === Private Functions === */
133
134/* === Tests === */
harmos_runtime/operations/mod.rs

harmos_runtime/operations/
mod.rs
