lenso-web-ingress-plugin 0.4.11

General-purpose linked Rust HTTP Ingress Plugin for Lenso backends.
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

//! HTTP Ingress Plugin with shared semantics for socket and event hosts.
mod config;
mod diagnostics;
mod event;
mod ingress;
mod manifest;
mod middleware;
#[cfg(feature = "native")]
mod native;
#[cfg(feature = "native")]
mod replication;
mod response_stream;
mod routing;
#[cfg(feature = "native")]
mod server;
mod session_cookie;

pub use config::{SessionCookieConfig, WebIngressConfig, WebSocketConfig};
pub use diagnostics::{WebIngressDiagnostics, WebIngressEndpointFailure};
pub use event::{WebIngressEventBody, WebIngressEventFactory};
use lenso_app_plan::{CapabilityRequirementPlan, authoring::PluginDescriptor};
use lenso_kernel::RuntimeFailure;
pub use manifest::{WebIngressReplicaMismatch, WebIngressRoute, WebIngressRouteManifest};
pub use middleware::{
    WebIngressMiddleware, WebIngressMiddlewareOutcome, WebIngressRequest, WebIngressResponse,
};
#[cfg(feature = "native")]
pub use native::WebIngressFactory;
#[cfg(feature = "native")]
pub use replication::WebIngressListenerCoordinator;
pub use response_stream::WebIngressResponseStream;

pub const PACKAGE_ID: &str = "lenso.web-ingress";
pub const PACKAGE_VERSION: &str = env!("CARGO_PKG_VERSION");
/// Package-owned configuration schema, shared by native and event ingress.
pub const CONFIGURATION_SCHEMA_JSON: &str = include_str!("../config.schema.json");
fn plugin_descriptor() -> PluginDescriptor {
    PluginDescriptor::new(PACKAGE_ID, PACKAGE_VERSION, "http-ingress")
        .with_requirement(CapabilityRequirementPlan::many(
            lenso_capability_http_endpoint::CAPABILITY_ID,
            lenso_capability_http_endpoint::DESCRIPTOR_VERSION,
        ))
        .with_requirement(CapabilityRequirementPlan::many(
            lenso_capability_http_stream_endpoint::CAPABILITY_ID,
            lenso_capability_http_stream_endpoint::DESCRIPTOR_VERSION,
        ))
        .with_requirement(CapabilityRequirementPlan::many(
            lenso_capability_websocket_endpoint::CAPABILITY_ID,
            lenso_capability_websocket_endpoint::DESCRIPTOR_VERSION,
        ))
        .with_configuration_schema(
            serde_json::from_str(CONFIGURATION_SCHEMA_JSON)
                .expect("the embedded Web Ingress configuration schema is valid"),
        )
}

fn plugin_failure(detail: impl Into<String>) -> RuntimeFailure {
    RuntimeFailure::PluginFailure {
        detail: detail.into(),
    }
}

mod websocket;
pub use websocket::WebSocketSession;

mod websocket_handshake;

#[cfg(feature = "native")]
mod websocket_native;