Skip to main content

nnrp_core/
lib.rs

1pub mod cache;
2pub mod codes;
3pub mod control;
4pub mod data;
5pub mod enums;
6pub mod error;
7pub mod flow;
8pub mod header;
9pub mod lifecycle;
10pub mod operation;
11pub mod recovery;
12pub mod schema;
13pub mod session;
14pub mod version;
15
16pub use cache::{
17    validate_cache_dependencies, CacheAckMetadata, CacheAckStatus, CacheDependency,
18    CacheDependencyState, CacheInvalidateMetadata, CacheInvalidateScope, CacheLease,
19    CacheLeaseOwnerScope, CacheObjectId, CacheObjectKind, CachePutMetadata, CacheValidationFailure,
20    CACHE_ACK_METADATA_LEN, CACHE_INVALIDATE_METADATA_LEN, CACHE_PUT_FLAGS_KNOWN_MASK,
21    CACHE_PUT_METADATA_LEN,
22};
23pub use codes::{
24    CACHE_ERROR_DEPENDENCY_INVALID, CACHE_ERROR_LEASE_EXPIRED, CACHE_ERROR_MISS, CACHE_ERROR_NONE,
25    CACHE_ERROR_SCHEMA_MISMATCH, CACHE_ERROR_VERSION_MISMATCH, SCHEMA_ERROR_DEPENDENCY_MISSING,
26    SCHEMA_ERROR_HASH_CONFLICT, SCHEMA_ERROR_INCOMPATIBLE, SCHEMA_ERROR_NONE, SCHEMA_ERROR_UNKNOWN,
27    SCHEMA_ERROR_UPDATE_REJECTED, SCHEMA_ERROR_VERSION_UNKNOWN, SESSION_ERROR_AUTH_FAILED,
28    SESSION_ERROR_LEASE_POLICY_REJECTED, SESSION_ERROR_LIMIT_REACHED, SESSION_ERROR_NONE,
29    SESSION_ERROR_PRIORITY_REJECTED, SESSION_ERROR_PROFILE_UNSUPPORTED,
30    SESSION_ERROR_RESUME_REJECTED, SESSION_ERROR_SCHEMA_UNSUPPORTED,
31};
32pub use control::{
33    validate_close_header, validate_empty_control_header, ClientHelloMetadata, ErrorMetadata,
34    ErrorScope, ResultHintBudgetPolicy, ResultHintCongestionState, ResultHintMetadata,
35    ResultHintReason, ServerHelloAckMetadata, SessionMigrateAckMetadata, SessionMigrateMetadata,
36    SessionPatchAckMetadata, SessionPatchAckStatus, SessionPatchMetadata, SessionPatchRejectReason,
37    TransportId, TransportProbeAckMetadata, TransportProbeMetadata, CLIENT_HELLO_METADATA_LEN,
38    ERROR_METADATA_LEN, RESULT_HINT_METADATA_LEN, SERVER_HELLO_ACK_FLAGS_KNOWN_MASK,
39    SERVER_HELLO_ACK_METADATA_LEN, SESSION_MIGRATE_ACK_METADATA_LEN, SESSION_MIGRATE_METADATA_LEN,
40    SESSION_PATCH_ACK_METADATA_LEN, SESSION_PATCH_FIELD_KNOWN_MASK, SESSION_PATCH_METADATA_LEN,
41    TRANSPORT_PROBE_ACK_METADATA_LEN, TRANSPORT_PROBE_METADATA_LEN,
42};
43pub use data::{
44    validate_result_drop_header, validate_submit_object_ref_mask, BodyRegionPrelude,
45    FrameSubmitMetadata, InputProfile, ObjectReferenceBlock, ObjectReferenceRegion, PayloadFamily,
46    PayloadKindBitmap, ResultClass, ResultPushMetadata, SubmitMode, TileIndexMode,
47    TypedPayloadFrameView, TypedPayloadRegion, BODY_REGION_PRELUDE_LEN, BUDGET_POLICY_KNOWN_MASK,
48    FRAME_SUBMIT_METADATA_LEN, OBJECT_REFERENCE_BLOCK_LEN, PAYLOAD_KIND_KNOWN_MASK,
49    RESULT_FLAGS_KNOWN_MASK, RESULT_PUSH_METADATA_LEN, STANDARD_PROFILE_TENSOR,
50    STANDARD_PROFILE_TOKEN, STANDARD_PROFILE_UNSPECIFIED, SUBMIT_OBJECT_REF_MASK_KNOWN_BITS,
51};
52pub use enums::{
53    BackpressureLevel, CancelScope, FlowScopeKind, FlowUpdateReason, HeaderFlags, InFlightPolicy,
54    MessageType, OperationState, SessionCloseReason, SessionCloseStatus, SessionPriorityClass,
55    SessionStatus,
56};
57pub use error::NnrpError;
58pub use flow::{
59    FlowUpdateMetadata, FLOW_UPDATE_FLAGS_KNOWN_MASK, FLOW_UPDATE_FLAG_BACKGROUND_ONLY,
60    FLOW_UPDATE_FLAG_CREDIT_VALID, FLOW_UPDATE_FLAG_DRAIN_IN_FLIGHT_ONLY,
61    FLOW_UPDATE_FLAG_RETRY_AFTER_VALID, FLOW_UPDATE_METADATA_LEN,
62};
63pub use header::{CommonHeader, ALPN, COMMON_HEADER_LEN, CURRENT_VERSION_MAJOR};
64pub use lifecycle::{
65    ConnectionLifecycle, ConnectionLifecycleState, SessionLifecycle, SessionLifecycleState,
66};
67pub use operation::{
68    OperationCancelRequest, OperationDescriptor, OperationRecord, OperationRegistry,
69};
70pub use recovery::{
71    should_replay_frame_after_migration, validate_migration_recovery,
72    validate_session_recovery_ack, validate_session_recovery_request, SessionRecoveryIntent,
73    SessionRecoveryOutcome, SESSION_ACK_FLAG_RESUME_ENABLED, SESSION_FLAG_ALLOW_RESUME,
74};
75pub use schema::{
76    token_delta_schema_descriptor, validate_profile_assignment, SchemaDescriptorHeader,
77    SchemaRegistry, SchemaRegistryAction, SchemaRegistryFailure, TypedPayloadDescriptor,
78    DESCRIPTOR_FLAGS_KNOWN_MASK, PROFILE_TENSOR, PROFILE_TOKEN, PROFILE_UNSPECIFIED,
79    SCHEMA_DESCRIPTOR_HEADER_LEN, SCHEMA_FLAGS_KNOWN_MASK, STREAM_SEMANTICS_TOKEN_DELTA,
80    TOKEN_DELTA_SCHEMA_ID, TOKEN_DELTA_SCHEMA_VERSION, TYPED_PAYLOAD_DESCRIPTOR_LEN,
81};
82pub use session::{
83    SessionCloseAckMetadata, SessionCloseMetadata, SessionOpenAckMetadata, SessionOpenMetadata,
84    SESSION_CLOSE_ACK_METADATA_LEN, SESSION_CLOSE_METADATA_LEN, SESSION_OPEN_ACK_METADATA_LEN,
85    SESSION_OPEN_METADATA_LEN,
86};
87pub use version::{ProtocolVersion, CURRENT_WIRE_FORMAT};