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 checkpoint;
10pub mod clients;
11pub mod codes;
12pub mod commands;
13pub mod content;
14pub mod control;
15pub mod destination;
16#[cfg(feature = "cbor")]
17pub mod dispatch;
18pub(crate) mod encoding;
19pub mod error;
20pub mod filter;
21pub mod fork;
22pub mod forward;
23pub mod graph;
24pub mod hashing;
25pub mod headers;
26pub mod hello;
27pub mod http;
28pub mod keys;
29pub mod kv;
30pub mod limits;
31pub mod memory;
32pub mod mutation;
33pub mod query;
34pub mod result;
35pub mod schema;
36pub mod session;
37pub mod snapshot;
38pub mod source;
39pub mod topics;
40pub mod topology;
41pub mod validate;
42
43#[cfg(feature = "codecs")]
44pub mod codecs;
45#[cfg(feature = "fixtures")]
46pub mod fixtures;
47#[cfg(feature = "cbor")]
48pub mod framing;
49#[cfg(feature = "http-client")]
50pub mod http_client;
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, SupervisorActorAssertion, SupervisorActorClaims,
64        SupervisorAssertionAction,
65    };
66    pub use crate::browse::{BrowseOutcome, BrowseReply, ProjectionInfo, SchemaInfo};
67    pub use crate::checkpoint::{
68        AttemptColumnMetrics, AttemptObject, CheckpointError, CheckpointMutationResult,
69        CheckpointMutationStamp, CheckpointOwnerId, CheckpointOwnerLease,
70        CheckpointReadConsistency, CheckpointReply, CheckpointRequestEnvelope, CheckpointRequestId,
71        CompletedAttempt, CredentialGeneration, DestinationBlock, DestinationBlockCode,
72        DestinationCheckpointPage, DestinationCheckpointStatus, DestinationCheckpointView,
73        DestinationEffectiveState, DestinationGetRequest, DestinationListFilter,
74        DestinationListRequest, IcebergCommitRequirement, PartitionCheckpoint,
75        PartitionLifecycleChange, PartitionLifecycleState, PreparedAttempt, PreparedAttemptId,
76        PreparedAttemptSummary, PreparedTableRequirements, PublicCheckpointMutation,
77        QueryRouteListRequest, QueryRoutePage, RepairAction, RepairRecord,
78        ReplicatedCheckpointMutation, ReplicatedCheckpointMutationBody, RetentionGap,
79        SourceOffsetRange,
80    };
81    pub use crate::content::ContentType;
82    pub use crate::control::{
83        ControlCommand, ControlEnvelope, EdgeExtract, EntitySchema, FieldType, IndexField,
84        IndexSchema, NodeExtract, Projection, ProjectionBinding, ProjectionId, ProjectionKind,
85        RetentionPolicy, SchemaDef, SchemaSource, SourceSelector,
86    };
87    pub use crate::destination::{
88        BackendBinding, BackendResourceId, DestinationDesiredState, DestinationErrorPolicy,
89        DestinationId, DestinationOperationId, FileFormat, MaterializationDestination,
90        NewPartitionPolicy, PartitionStart, PhysicalTable, ProjectionRef, QueryRoute, QueryRouteId,
91        QueryRouteTarget, RecreatedPartitionPolicy, StartPolicy, TableFormat,
92    };
93    pub use crate::error::{DecodeError, InvalidError};
94    pub use crate::filter::{
95        Coerce, ConsumerFilter, FaultPolicy, FieldPath, FilterBinding, FilterCodec, FilterConsumer,
96        FilterError, FilterErrorReason, FilterExpr, FilterGroupRef, FilterMutation,
97        FilterMutationOutcome, FilterMutationStatus, FilterRef, FilterSource, FilteredPage,
98        FilteredStart, ReadMode, StopReason, TimestampFormat,
99    };
100    pub use crate::fork::{ForkError, ForkInfo, ForkKind, ForkOutcome, ForkReply, ForkStatus};
101    pub use crate::graph::{
102        EdgeDir, EdgeId, GraphEdge, GraphError, GraphNeighbors, GraphNode, GraphQuery, GraphReply,
103        GraphResult, GraphReturn, GraphStart, GraphUpsert, Hop, NodeId, Path,
104    };
105    pub use crate::hello::{
106        BackendAnnounce, BackendDescriptor, BackendDesiredState, BackendImplementation,
107        BackendLimits, BackendMode, BackendObservedState, BackendReadiness, BackendReadinessCode,
108        BackendReadinessReason, HelloReply, MaintenanceCapabilities, MaterializationCapability,
109        OpVersions, QueryCapabilities, QueryPagingCapability, SchemaCapabilities,
110        TimeTravelCapability,
111    };
112    pub use crate::keys::{KeyKind, KeyRecord};
113    pub use crate::kv::{
114        KvEntry, KvError, KvMetadata, KvNamespaceInfo, KvOutcome, KvPage, KvReply, MemoryRowScope,
115    };
116    pub use crate::query::{
117        AggCall, AggFunc, Aggregate, BoundaryRelation, CmpOp, Consistency, ConsistencyGate, Dir,
118        Filter, KeyMatch, MaterializationBoundary, Page, Predicate, Query, QueryCancelEnvelope,
119        QueryCancelReply, QueryContext, QueryEngine, QueryEnvelope, QueryError, QueryErrorCode,
120        QueryExecutionId, QueryExecutionState, QueryExecutionStatus, QueryPageEnvelope,
121        QueryPageRequest, QueryReply, QueryResult, QueryStatusEnvelope, QueryStatusReply,
122        QueryTarget, RawSql, ResolvedQueryTarget, Row, Select, SnapshotSelector, Sort, SqlDialect,
123        Value, VectorQuery, Window,
124    };
125    pub use crate::result::ResultCode;
126    pub use crate::schema::{
127        BinaryValue, DecimalValue, Digest32, FieldValue, LogicalField, LogicalSchema,
128        LogicalSchemaId, LogicalSchemaRef, LogicalType, LogicalTypeKind, MapEntry,
129        SchemaFingerprint, TypedValue, UuidValue,
130    };
131    pub use crate::source::{
132        PhysicalClusterIncarnation, SourceCut, SourceIncarnation, SourcePartitionCut, SourceScope,
133    };
134}
laser_wire/lib.rs

laser_wire/
lib.rs
