laser_wire/
lib.rs

1#![forbid(unsafe_code)]
2
3pub mod agent;
4pub mod arrow;
5pub mod authz;
6pub mod batch;
7pub mod browse;
8pub mod change;
9pub mod clients;
10pub mod codes;
11pub mod commands;
12pub mod content;
13pub mod control;
14pub mod destination;
15#[cfg(feature = "cbor")]
16pub mod dispatch;
17pub(crate) mod encoding;
18pub mod error;
19pub mod filter;
20pub mod fork;
21pub mod forward;
22pub mod graph;
23pub mod hashing;
24pub mod headers;
25pub mod hello;
26pub mod http;
27pub mod keys;
28pub mod kv;
29pub mod limits;
30pub mod memory;
31pub mod mutation;
32pub mod query;
33pub mod result;
34pub mod schema;
35pub mod session;
36pub mod snapshot;
37pub mod topics;
38pub mod topology;
39pub mod validate;
40
41#[cfg(feature = "codecs")]
42pub mod codecs;
43#[cfg(feature = "fixtures")]
44pub mod fixtures;
45#[cfg(feature = "cbor")]
46pub mod framing;
47#[cfg(feature = "http-client")]
48pub mod http_client;
49#[cfg(feature = "schema-decode")]
50pub mod writer_schema;
51
52pub mod prelude {
53    pub use crate::agent::{
54        AgentDeadLetter, AgentEnvelope, AgentErrorBody, AgentErrorCode, AgentId, AgentKind,
55        ChannelId, ConversationId, CorrelationId, DeadLetterReason, IdempotencyKey, LogPosition,
56        RecordId, TaskState, TokenUsage,
57    };
58    pub use crate::arrow::{
59        ArrowIpcMessageMetadata, ArrowIpcPolicy, ArrowIpcRejectionCode, ArrowTimestampUnit,
60    };
61    pub use crate::authz::{
62        Action, AuthzError, AuthzReply, Effect, Feature, Grant, ResourceKind, ResourcePattern,
63        Role, RoleBinding,
64    };
65    pub use crate::browse::{BrowseOutcome, BrowseReply, ProjectionInfo, SchemaInfo};
66    pub use crate::content::ContentType;
67    pub use crate::control::{
68        ControlCommand, ControlEnvelope, EdgeExtract, EntitySchema, FieldType, IndexField,
69        IndexSchema, NodeExtract, Projection, ProjectionBinding, ProjectionId, ProjectionKind,
70        RetentionPolicy, SchemaDef, SchemaSource, SourceSelector,
71    };
72    pub use crate::destination::{BackendBinding, BackendResourceId};
73    pub use crate::error::{DecodeError, InvalidError};
74    pub use crate::filter::{
75        Coerce, ConsumerFilter, FaultPolicy, FieldPath, FilterBinding, FilterCodec, FilterConsumer,
76        FilterError, FilterErrorReason, FilterExpr, FilterGroupRef, FilterMutation,
77        FilterMutationOutcome, FilterMutationStatus, FilterRef, FilterSource, FilteredPage,
78        FilteredStart, StopReason, TimestampFormat,
79    };
80    pub use crate::fork::{ForkError, ForkInfo, ForkKind, ForkOutcome, ForkReply, ForkStatus};
81    pub use crate::graph::{
82        EdgeDir, EdgeId, GraphEdge, GraphError, GraphNeighbors, GraphNode, GraphQuery, GraphReply,
83        GraphResult, GraphReturn, GraphStart, GraphUpsert, Hop, NodeId, Path,
84    };
85    pub use crate::hello::{
86        BackendAnnounce, BackendDescriptor, BackendDesiredState, BackendImplementation,
87        BackendLimits, BackendMode, BackendObservedState, BackendReadiness, BackendReadinessCode,
88        BackendReadinessReason, HelloReply, OpVersions, QueryCapabilities, SchemaCapabilities,
89    };
90    pub use crate::keys::{KeyKind, KeyRecord};
91    pub use crate::kv::{
92        KvEntry, KvError, KvMetadata, KvNamespaceInfo, KvOutcome, KvPage, KvReply, MemoryRowScope,
93    };
94    pub use crate::query::{
95        AggCall, AggFunc, Aggregate, CmpOp, Consistency, ConsistencyGate, Dir, Filter, KeyMatch,
96        Page, Predicate, Query, QueryContext, QueryEngine, QueryEnvelope, QueryError,
97        QueryErrorCode, QueryExecutionId, QueryPageRequest, QueryReply, QueryResult, QueryTarget,
98        RawSql, ResolvedQueryTarget, Row, Select, Sort, SqlDialect, Value, VectorQuery, Window,
99    };
100    pub use crate::result::ResultCode;
101    pub use crate::schema::{
102        BinaryValue, DecimalValue, Digest32, FieldValue, LogicalField, LogicalSchema,
103        LogicalSchemaId, LogicalSchemaRef, LogicalType, LogicalTypeKind, MapEntry,
104        SchemaFingerprint, TypedValue, UuidValue,
105    };
106}
laser_wire/lib.rs

laser_wire/
lib.rs
