laser_wire/
lib.rs

1#![forbid(unsafe_code)]
2
3pub mod agent;
4pub mod agent_workflow;
5pub mod arrow;
6pub mod authz;
7pub mod batch;
8pub mod browse;
9pub mod change;
10pub mod checkpoint;
11pub mod clients;
12pub mod codes;
13pub mod commands;
14pub mod content;
15pub mod control;
16pub mod destination;
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 snapshot;
36pub mod source;
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
50pub mod prelude {
51    pub use crate::agent::{
52        AgentDeadLetter, AgentEnvelope, AgentErrorBody, AgentErrorCode, AgentId, AgentKind,
53        ChannelId, ConversationId, CorrelationId, DeadLetterReason, IdempotencyKey, LogPosition,
54        RecordId, TaskState, TokenUsage,
55    };
56    pub use crate::arrow::{
57        ArrowIpcMessageMetadata, ArrowIpcPolicy, ArrowIpcRejectionCode, ArrowTimestampUnit,
58    };
59    pub use crate::authz::{
60        Action, AuthzError, AuthzReply, Effect, Feature, Grant, ResourceKind, ResourcePattern,
61        Role, RoleBinding, SupervisorActorAssertion, SupervisorActorClaims,
62        SupervisorAssertionAction,
63    };
64    pub use crate::browse::{BrowseOutcome, BrowseReply, ProjectionInfo, SchemaInfo};
65    pub use crate::checkpoint::{
66        AttemptColumnMetrics, AttemptObject, CheckpointError, CheckpointMutationResult,
67        CheckpointMutationStamp, CheckpointOwnerId, CheckpointOwnerLease,
68        CheckpointReadConsistency, CheckpointReply, CheckpointRequestEnvelope, CheckpointRequestId,
69        CompletedAttempt, CredentialGeneration, DestinationBlock, DestinationBlockCode,
70        DestinationCheckpointPage, DestinationCheckpointStatus, DestinationCheckpointView,
71        DestinationEffectiveState, DestinationGetRequest, DestinationListFilter,
72        DestinationListRequest, IcebergCommitRequirement, PartitionCheckpoint,
73        PartitionLifecycleChange, PartitionLifecycleState, PreparedAttempt, PreparedAttemptId,
74        PreparedAttemptSummary, PreparedTableRequirements, PublicCheckpointMutation,
75        QueryRouteListRequest, QueryRoutePage, RepairAction, RepairRecord,
76        ReplicatedCheckpointMutation, ReplicatedCheckpointMutationBody, RetentionGap,
77        SourceOffsetRange,
78    };
79    pub use crate::content::ContentType;
80    pub use crate::control::{
81        ControlCommand, ControlEnvelope, EdgeExtract, EntitySchema, FieldType, IndexField,
82        IndexSchema, NodeExtract, Projection, ProjectionBinding, ProjectionId, ProjectionKind,
83        RetentionPolicy, SchemaDef, SchemaSource, SourceSelector,
84    };
85    pub use crate::destination::{
86        BackendBinding, BackendResourceId, DestinationDesiredState, DestinationErrorPolicy,
87        DestinationId, DestinationOperationId, FileFormat, MaterializationDestination,
88        NewPartitionPolicy, PartitionStart, PhysicalTable, ProjectionRef, QueryRoute, QueryRouteId,
89        QueryRouteTarget, RecreatedPartitionPolicy, StartPolicy, TableFormat,
90    };
91    pub use crate::error::{DecodeError, InvalidError};
92    pub use crate::filter::{
93        Coerce, ConsumerFilter, FaultPolicy, FieldPath, FilterBinding, FilterCodec, FilterConsumer,
94        FilterError, FilterErrorReason, FilterExpr, FilterGroupRef, FilterMutation,
95        FilterMutationOutcome, FilterMutationStatus, FilterRef, FilterSource, FilteredPage,
96        FilteredStart, ReadMode, StopReason, TimestampFormat,
97    };
98    pub use crate::fork::{ForkError, ForkInfo, ForkKind, ForkOutcome, ForkReply, ForkStatus};
99    pub use crate::graph::{
100        EdgeDir, EdgeId, GraphEdge, GraphError, GraphNeighbors, GraphNode, GraphQuery, GraphReply,
101        GraphResult, GraphReturn, GraphStart, GraphUpsert, Hop, NodeId, Path,
102    };
103    pub use crate::hello::{
104        BackendAnnounce, BackendDescriptor, BackendDesiredState, BackendImplementation,
105        BackendLimits, BackendMode, BackendObservedState, BackendReadiness, BackendReadinessCode,
106        BackendReadinessReason, HelloReply, MaintenanceCapabilities, MaterializationCapability,
107        OpVersions, QueryCapabilities, QueryPagingCapability, SchemaCapabilities,
108        TimeTravelCapability,
109    };
110    pub use crate::keys::{KeyKind, KeyRecord};
111    pub use crate::kv::{
112        KvEntry, KvError, KvMetadata, KvNamespaceInfo, KvOutcome, KvPage, KvReply, MemoryRowScope,
113    };
114    pub use crate::query::{
115        AggCall, AggFunc, Aggregate, BoundaryRelation, CmpOp, Consistency, ConsistencyGate, Dir,
116        Filter, KeyMatch, MaterializationBoundary, Page, Predicate, Query, QueryCancelEnvelope,
117        QueryCancelReply, QueryContext, QueryEngine, QueryEnvelope, QueryError, QueryErrorCode,
118        QueryExecutionId, QueryExecutionState, QueryExecutionStatus, QueryPageEnvelope,
119        QueryPageRequest, QueryReply, QueryResult, QueryStatusEnvelope, QueryStatusReply,
120        QueryTarget, RawSql, ResolvedQueryTarget, Row, Select, SnapshotSelector, Sort, SqlDialect,
121        Value, VectorQuery, Window,
122    };
123    pub use crate::result::ResultCode;
124    pub use crate::schema::{
125        BinaryValue, DecimalValue, Digest32, FieldValue, LogicalField, LogicalSchema,
126        LogicalSchemaId, LogicalSchemaRef, LogicalType, LogicalTypeKind, MapEntry,
127        SchemaFingerprint, TypedValue, UuidValue,
128    };
129    pub use crate::source::{
130        PhysicalClusterIncarnation, SourceCut, SourceIncarnation, SourcePartitionCut, SourceScope,
131    };
132}
laser_wire/lib.rs

laser_wire/
lib.rs
