lenso-kernel 0.1.0

Portable Kernel runtime for Lenso vNext applications.
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

//! Portable Lenso vNext Kernel and Runtime Driver seam.

use std::{
    any::Any,
    cell::{Cell, RefCell},
    collections::{BTreeMap, BTreeSet, VecDeque},
    future::Future,
    panic::AssertUnwindSafe,
    pin::Pin,
    rc::{Rc, Weak},
    task::{Context, Poll},
    time::Duration,
};

use futures::{
    channel::oneshot,
    executor::{LocalPool, LocalSpawner},
    future::{AbortHandle, Abortable, Either, FutureExt, LocalBoxFuture, pending, select},
    task::{LocalSpawnExt, SpawnError},
};
use lenso_app_plan::{
    EventAdmissionPlan, ExecutionClassId, ModuleCriticality, PlanResolutionError,
    RequestAdmissionPlan, ResolvedAppPlan, RestartMode, RestartPolicy,
};

mod deterministic;
mod diagnostics;
mod driver;
mod event;
mod invocation;
mod kernel;
mod lifecycle;
mod prepared;
mod request;
mod request_handle;
mod runtime;
mod stream;
mod supervision;

pub use diagnostics::{
    DiagnosticAdmission, DiagnosticEvent, DiagnosticFilter, DiagnosticObserver, DiagnosticOutcome,
    DiagnosticRecord, DiagnosticShutdownOutcome, DiagnosticSource, DiagnosticSubscribeError,
    RuntimeDiagnostics, RuntimeFailureKind,
};
pub use event::{
    EventAdmission, EventCapability, EventPublishResult, EventPublishStatus,
    ModuleEventDependencyHandle, NativeEventEndpoint, NativeEventHandle,
};
pub use invocation::*;
pub use stream::{
    NativeStream, NativeStreamEndpoint, NativeStreamHandle, NativeStreamItem, NativeStreamSession,
    StreamCapability, StreamEvent, StreamSession,
};

type ErasedValue = Box<dyn Any>;
type ErasedDomainResult = Result<ErasedValue, ErasedValue>;
type NativeBindingTable = BTreeMap<(String, &'static str), Vec<NativeEndpointBinding>>;
type NativeEndpointStateTable = BTreeMap<(String, String), Rc<NativeEndpointState>>;
type NativeStreamBindingTable = BTreeMap<(String, &'static str), Vec<NativeStreamEndpointBinding>>;
type NativeStreamEndpointStateTable = BTreeMap<(String, String), Rc<NativeStreamEndpointState>>;
type NativeEventBindingTable =
    BTreeMap<(String, &'static str), Vec<event::NativeEventEndpointBinding>>;
type NativeEventEndpointStateTable =
    BTreeMap<(String, String), Rc<event::NativeEventEndpointState>>;

/// Static identity and Rust value types generated for one request Capability.
pub use deterministic::*;
pub use driver::*;
pub use kernel::*;
pub use lifecycle::*;
pub use prepared::*;
pub use request::*;
pub use request_handle::*;
pub use runtime::*;
use supervision::{
    begin_module_supervision, deactivate_in_reverse, module_supervision,
    schedule_module_supervision, shutdown_native_modules, validate_native_endpoint_set,
};