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 fork;
20pub mod forward;
21pub mod graph;
22pub mod hashing;
23pub mod headers;
24pub mod hello;
25pub mod http;
26pub mod keys;
27pub mod kv;
28pub mod limits;
29pub mod memory;
30pub mod mutation;
31pub mod query;
32pub mod result;
33pub mod schema;
34pub mod snapshot;
35pub mod source;
36pub mod topics;
37pub mod topology;
38pub mod validate;
39
40#[cfg(feature = "codecs")]
41pub mod codecs;
42#[cfg(feature = "fixtures")]
43pub mod fixtures;
44#[cfg(feature = "cbor")]
45pub mod framing;
46#[cfg(feature = "http-client")]
47pub mod http_client;
48
49pub mod prelude {
50    pub use crate::agent::{
51        AgentDeadLetter, AgentEnvelope, AgentErrorBody, AgentErrorCode, AgentId, AgentKind,
52        ChannelId, ConversationId, CorrelationId, DeadLetterReason, IdempotencyKey, LogPosition,
53        RecordId, TaskState, TokenUsage,
54    };
55    pub use crate::arrow::{
56        ArrowIpcMessageMetadata, ArrowIpcPolicy, ArrowIpcRejectionCode, ArrowTimestampUnit,
57    };
58    pub use crate::authz::{
59        Action, AuthzError, AuthzReply, Effect, Feature, Grant, ResourceKind, ResourcePattern,
60        Role, RoleBinding, SupervisorActorAssertion, SupervisorActorClaims,
61        SupervisorAssertionAction,
62    };
63    pub use crate::browse::{BrowseOutcome, BrowseReply, ProjectionInfo, SchemaInfo};
64    pub use crate::checkpoint::{
65        AttemptColumnMetrics, AttemptObject, CheckpointError, CheckpointMutationResult,
66        CheckpointMutationStamp, CheckpointOwnerId, CheckpointOwnerLease,
67        CheckpointReadConsistency, CheckpointReply, CheckpointRequestEnvelope, CheckpointRequestId,
68        CompletedAttempt, CredentialGeneration, DestinationBlock, DestinationBlockCode,
69        DestinationCheckpointPage, DestinationCheckpointStatus, DestinationCheckpointView,
70        DestinationEffectiveState, DestinationGetRequest, DestinationListFilter,
71        DestinationListRequest, IcebergCommitRequirement, PartitionCheckpoint,
72        PartitionLifecycleChange, PartitionLifecycleState, PreparedAttempt, PreparedAttemptId,
73        PreparedAttemptSummary, PreparedTableRequirements, PublicCheckpointMutation,
74        QueryRouteListRequest, QueryRoutePage, RepairAction, RepairRecord,
75        ReplicatedCheckpointMutation, ReplicatedCheckpointMutationBody, RetentionGap,
76        SourceOffsetRange,
77    };
78    pub use crate::content::ContentType;
79    pub use crate::control::{
80        ControlCommand, ControlEnvelope, EdgeExtract, EntitySchema, FieldType, IndexField,
81        IndexSchema, NodeExtract, Projection, ProjectionBinding, ProjectionId, ProjectionKind,
82        RetentionPolicy, SchemaDef, SchemaSource, SourceSelector,
83    };
84    pub use crate::destination::{
85        BackendBinding, BackendResourceId, DestinationDesiredState, DestinationErrorPolicy,
86        DestinationId, DestinationOperationId, FileFormat, MaterializationDestination,
87        NewPartitionPolicy, PartitionStart, PhysicalTable, ProjectionRef, QueryRoute, QueryRouteId,
88        QueryRouteTarget, RecreatedPartitionPolicy, StartPolicy, TableFormat,
89    };
90    pub use crate::error::{DecodeError, InvalidError};
91    pub use crate::fork::{ForkError, ForkInfo, ForkKind, ForkOutcome, ForkReply, ForkStatus};
92    pub use crate::graph::{
93        EdgeDir, EdgeId, GraphEdge, GraphError, GraphNeighbors, GraphNode, GraphQuery, GraphReply,
94        GraphResult, GraphReturn, GraphStart, GraphUpsert, Hop, NodeId, Path,
95    };
96    pub use crate::hello::{
97        BackendAnnounce, BackendDescriptor, BackendDesiredState, BackendImplementation,
98        BackendLimits, BackendMode, BackendObservedState, BackendReadiness, BackendReadinessCode,
99        BackendReadinessReason, HelloReply, MaintenanceCapabilities, MaterializationCapability,
100        OpVersions, QueryCapabilities, QueryPagingCapability, SchemaCapabilities,
101        TimeTravelCapability,
102    };
103    pub use crate::keys::{KeyKind, KeyRecord};
104    pub use crate::kv::{
105        KvEntry, KvError, KvMetadata, KvNamespaceInfo, KvOutcome, KvPage, KvReply, MemoryRowScope,
106    };
107    pub use crate::query::{
108        AggCall, AggFunc, Aggregate, BoundaryRelation, CmpOp, Consistency, ConsistencyGate, Dir,
109        Filter, KeyMatch, MaterializationBoundary, Page, Predicate, Query, QueryCancelEnvelope,
110        QueryCancelReply, QueryContext, QueryEngine, QueryEnvelope, QueryError, QueryErrorCode,
111        QueryExecutionId, QueryExecutionState, QueryExecutionStatus, QueryPageEnvelope,
112        QueryPageRequest, QueryReply, QueryResult, QueryStatusEnvelope, QueryStatusReply,
113        QueryTarget, RawSql, ResolvedQueryTarget, Row, Select, SnapshotSelector, Sort, SqlDialect,
114        Value, VectorQuery, Window,
115    };
116    pub use crate::result::ResultCode;
117    pub use crate::schema::{
118        BinaryValue, DecimalValue, Digest32, FieldValue, LogicalField, LogicalSchema,
119        LogicalSchemaId, LogicalSchemaRef, LogicalType, LogicalTypeKind, MapEntry,
120        SchemaFingerprint, TypedValue, UuidValue,
121    };
122    pub use crate::source::{
123        PhysicalClusterIncarnation, SourceCut, SourceIncarnation, SourcePartitionCut, SourceScope,
124    };
125}
laser_wire/lib.rs

laser_wire/
lib.rs
