Crate appcore_gateway 

Multi-tenant Gateway capability for the AppCore Runtime.

Re-exports

pub use authorization::client_connection_hash;

pub use authorization::gateway_token_claims;

pub use authorization::worker_connection_hash;

pub use authorization::GATEWAY_CONNECTION_TOKEN_TTL_MS;

pub use capability::gateway_capability_descriptor;

pub use capability::GatewayCapability;

pub use capability::GATEWAY_RUNTIME_CAPABILITY;

pub use config::GatewayConfig;

pub use config::GATEWAY_ADAPTER_NAME;

pub use config::GATEWAY_PROVIDER_ID;

pub use connection::ClientConnection;

pub use connection::WorkerConnection;

pub use connection::WorkerConnectionKey;

pub use error::GatewayError;

pub use error::GatewayResult;

pub use heartbeat::spawn_heartbeat_pruner;

pub use mesh::MeshPeerRequest;

pub use mesh::MeshPeerResponse;

pub use mesh::MeshPeerTransport;

pub use mesh::MESH_HTTP_SCHEMA_V1;

pub use mesh::MESH_PEER_RELAY_PATH;

pub use metrics::GatewayMetrics;

pub use registry::CapabilityRegistry;

pub use resolver::CapabilityResolver;

pub use router::EnvelopeRouter;

pub use runtime::GatewayRuntime;

pub use runtime::GatewayRuntimeSnapshot;

pub use runtime::GatewayRuntimeState;

pub use service::make_gateway_router;

pub use session::GatewaySession;

pub use state::GatewayState;

pub use tenant::TenantState;

Modules

authorization

Gateway connection authorization bindings.

capability

Capability definitions inside the Gateway context.

config

Gateway configuration definitions.

connection

Connection descriptors for workers and clients.

error

Gateway-scoped error types.

heartbeat

Heartbeat monitoring and worker pruning.

mesh

Mesh relay transport for Peer RPC over the Gateway.

metrics

Lightweight observability metrics for Gateway health and throughput.

registry

Capability advertisement registry.

resolver

Capability resolver to locate appropriate workers.

router

Multiplexing router for Peer RPC envelopes.

runtime

Owned listener, task, health, and shutdown lifecycle for one Gateway.

service

Axum HTTP and WebSocket routing service implementation.

session

Session management and token context tracking.

socket

Bounded Gateway worker and client WebSocket loops.

state

Shared central Gateway state.

tenant

Tenant-isolated state partition.

Structs

OpaqueContentEnvelopeV1

Gateway/sync transport metadata for an opaque encrypted content envelope.

OpaqueEnvelopeDeduplicator

Bounded in-memory deduplicator keyed by opaque message ID.

OpaqueEnvelopePolicy

Transport policy for opaque content envelopes.

Enums

OpaqueEnvelopeDecision

Result of opaque transport validation.

Constants

OPAQUE_CONTENT_ENVELOPE_SCHEMA_V1

Schema label for the first opaque content-envelope transport contract.