distributed 4.0.2

CQRS/ES framework for Rust using Plain Old Rust Structs — append-only events, replay, snapshots, outbox, service bus, and pluggable infrastructure
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
109
110
111
112

//! Auto-generated read-only GraphQL over relational read models.
//!
//! `naming` and `sdl` always compile (zero deps beyond the rest of the crate)
//! so `distributed schema --format graphql` works without enabling the `graphql`
//! feature. Execution, the dynamic schema, and the axum router sit behind
//! `feature = "graphql"`.

pub mod client_manifest;
pub(crate) mod command_contract;
pub mod naming;
pub mod projection_delta;
pub mod sdl;
pub mod surface;

// These modules are structural GraphQL metadata and deliberately remain
// pool/server independent. `distributed` and the runtime engine must compile the same
// surface without pulling in async-graphql or a database adapter.
mod commands;
mod complexity_contract;
mod filter;
mod permissions;
mod types;

pub use client_manifest::*;
#[doc(hidden)]
pub use command_contract::{
    __command_input_defaults, __effect_key, __effect_key_assignment, __effect_key_field,
    __effect_relationship, __input_default_ulid, __input_default_uuid_v7, CombineEffectNullability,
    CompiledEffectKeyField, CompiledInputDefault, EffectInputDescendableKind,
    EffectInputFieldMarker, EffectInputObjectKind, EffectInputPath, EffectInputPathKind,
    EffectInputTerminalKind, EffectModelFieldMarker, EffectNullable, EffectPathNullability,
    EffectRelationshipMarker, EffectRequired, EffectWireBigInt, EffectWireBoolean, EffectWireBytea,
    EffectWireChecked, EffectWireCompatible, EffectWireFloat, EffectWireJson, EffectWireList,
    EffectWireLiteral, EffectWireObject, EffectWireString, EffectWireTimestamp,
    EffectWireUnsupported,
};
pub use command_contract::{
    __command_projection_event_descriptor, __command_projection_event_preview,
    __command_projection_events, __command_projection_preview_constant,
    __command_projection_state_known_values, __command_projection_state_preview,
    command_transition, typed_command, Atomic, CommandConsistency, CommandEventSet, CommandOutcome,
    CommandProjectionEventSet, CommandProjectionPreview, CommandProjectionPreviewSource,
    CommandProjectionPureArg, CommandProjectionPureReduce, CompiledDirectProjectionTarget,
    CompiledInputDefaults, Eventual, PrepareCommandError, PreparedCommand, Succeeded, TypedCommand,
    TypedEffectExpression, TypedEffectKey, TypedEffectRelationship,
};
pub use naming::{
    aggregate_field, by_pk_field, comparison_op_fields, include_postgres_json_comparison_ops,
    is_valid_graphql_name, object_type_name, root_list_field, scalar_type_name,
    PORTABLE_COMPARISON_OPS, POSTGRES_JSON_COMPARISON_OPS, STRING_COMPARISON_OPS,
};
pub use sdl::{
    graphql_sdl_for_role, graphql_sdl_for_tables, graphql_sdl_for_tables_with_options,
    graphql_sdl_from_surface, SdlOptions,
};
pub use surface::{
    build_surface, role_grants_for_role, surface_for_application, surface_for_application_contract,
    surface_for_role, RoleGrant, RootField, RootKind, Surface, SurfaceArgument,
    SurfaceArgumentKind, SurfaceCommand, SurfaceCommandShape, SurfaceDialect,
    SurfaceDirectProjection, SurfaceModel, SurfaceModeledProjection, SurfaceOptions,
    SurfaceProjectionOwner, SurfaceProjector, SurfaceRelationshipAggregate,
    SurfaceRelationshipKeys, SurfaceRowPolicy, SurfaceTypeDef, SurfaceTypeField,
};

pub use filter::{claim, col, lit, rel, ClaimRef, ColRef, FilterExpr, LitValue, Operand};
pub use permissions::{
    read, role_grant_from_read_permission, role_grants_from_model_role_perms, ModelPermissions,
    ReadPermission,
};
pub use types::{GraphqlInputType, GraphqlOutputType, GraphqlTypeDef, GraphqlTypeField};

#[cfg(feature = "graphql")]
pub(crate) mod command_input;
#[cfg(feature = "graphql")]
mod compile;
#[cfg(feature = "graphql")]
mod complexity;
#[cfg(feature = "graphql")]
mod engine;
#[cfg(feature = "graphql")]
mod execute;
#[cfg(feature = "graphql")]
pub mod http;
#[cfg(feature = "graphql")]
pub mod identity;
#[cfg(feature = "graphql")]
pub(crate) mod protocol;
#[cfg(feature = "graphql")]
pub(crate) mod query_protocol;
#[cfg(feature = "graphql")]
mod schema;
#[cfg(feature = "graphql")]
pub mod subscribe;
#[cfg(feature = "graphql")]
pub use engine::{
    graphiql_enabled_from_env, graphiql_enabled_from_env_vars, GraphqlBuildError, GraphqlEngine,
    GraphqlEngineBuilder, GraphqlPool, GraphqlPoolSource,
};
#[cfg(feature = "graphql")]
pub use http::{
    graphiql_page, graphql_router, graphql_router_with_dispatcher, graphql_router_with_service,
};
#[cfg(feature = "graphql")]
pub use identity::{
    extract_bearer, map_claims_to_session, public_oidc_identity_from_env,
    public_oidc_identity_from_env_vars, resolve_session, resolve_session_sync,
    strip_identity_headers, AuthError, ClaimMapConfig, IdentityConfig, IdentityMode,
    IdentityResolver, OidcConfig, OidcValidator, TrustedProxyConfig, ValidationError,
    DEFAULT_IDENTITY_STRIP_HEADERS, UNSET_OIDC_AUDIENCE, UNSET_OIDC_ISSUER,
};
#[cfg(feature = "graphql")]
pub use subscribe::ChangeHub;