laser-wire 0.8.2

LaserData SDK over Apache Iggy: typed streaming, operational and lakehouse query, materialization destinations, key-value state, copy-on-write forks, and an optional agent runtime with the Agent Data Exchange Protocol (AGDX).
Documentation
pub mod catalog;
#[cfg(feature = "filter-eval")]
mod cbor;
#[cfg(feature = "filter-eval")]
pub mod codecs;
pub mod coerce;
#[cfg(feature = "filter-eval")]
pub mod eval;
pub mod expr;
#[cfg(feature = "filter-eval")]
pub mod headers;
pub mod path;
pub mod read;
pub mod text;

pub use catalog::{
    CatalogPosition, FilterBinding, FilterBindingPage, FilterCatalogCommand, FilterCatalogLimits,
    FilterCatalogOutcome, FilterCatalogReply, FilterCatalogVersion, FilterDetail,
    FilterGroupIdentity, FilterGroupRef, FilterMutation, FilterMutationOutcome,
    FilterMutationRequest, FilterMutationResult, FilterMutationStatus, FilterPage, FilterPolicyRef,
    FilterRevisionInfo, FilterRevisionPage, FilterRevisionRef, FilterState, FilterSummary,
    GetFilter, GetFilterBinding, GetFilterOperation, GroupFilterSpec, GroupPolicyUnbound,
    ListFilterBindings, ListFilterRevisions, ListFilters, ResolveFilterPolicy,
    ResolvedFilterPolicy, WatchFilterCatalog,
};
pub use coerce::{ExactDecimal, TimestampFormat};
pub use expr::{
    Coerce, CoercedPredicate, ConsumerFilter, FILTER_EVALUATOR_VERSION, FaultPolicy, FilterCodec,
    FilterExpr, HeaderPredicate, RecordPolicy,
};
pub use path::{FieldPath, PathSegment};
pub use read::{
    AckReceipt, AppliedPolicy, Continuation, ExecutionMode, ExplainNode, FaultReason,
    FilterConsumer, FilterDecodeLimits, FilterError, FilterErrorReason, FilterExplanation,
    FilterHeader, FilterOutcome, FilterPreview, FilterPreviewRequest, FilterRef, FilterReply,
    FilterSource, FilterTestRequest, FilterTestResult, FilterValidation, FilteredAck, FilteredPage,
    FilteredPollRequest, FilteredStart, HeaderScalar, PreviewRecord, ReadMode, RecordFault,
    SourceGeneration, StopReason, Truth, Verdict,
};
pub use text::{TextMatch, TextMatcher, TextPredicate};