laser-sdk 0.2.0

// The query surface. The wire contract (types, codes, headers, topics, caps)
// lives in the laser-wire crate and is re-exported here unconditionally so
// every historical `laser_sdk::query::*` import keeps resolving. The runtime
// half (publish/query/browse/control builders, `Record` lowering onto iggy
// headers) stays in this crate behind the `query` feature.

pub use laser_wire::browse::{
    BrowseOutcome, BrowseReply, DecodeRecord, GetProjection, GetSchema, ListProjections,
    ListSchemas, ProjectionInfo, RegisterSchema, SchemaInfo,
};
pub use laser_wire::codes::{
    AGDX_COMMAND_BASE, AGDX_DECODE_RECORD_CODE, AGDX_FORK_BASE, AGDX_FORK_CREATE_CODE,
    AGDX_FORK_DELETE_CODE, AGDX_FORK_LIST_CODE, AGDX_FORK_PROMOTE_CODE, AGDX_FORK_PUT_CODE,
    AGDX_GET_PROJECTION_CODE, AGDX_GET_SCHEMA_CODE, AGDX_HELLO_CODE, AGDX_LIST_PROJECTIONS_CODE,
    AGDX_LIST_SCHEMAS_CODE, AGDX_QUERY_CANCEL_CODE, AGDX_QUERY_CODE, AGDX_QUERY_PAGE_CODE,
    AGDX_QUERY_STATUS_CODE, AGDX_REGISTER_SCHEMA_CODE, CONTROL_OP_VERSION, FORK_OP_VERSION,
    QUERY_OP_VERSION,
};
pub use laser_wire::control::{
    ControlCommand, ControlEnvelope, EdgeExtract, EntitySchema, FieldType, IndexField, IndexSchema,
    IndexSchemaBuilder, NodeExtract, Projection, ProjectionBinding, ProjectionBindingBuilder,
    ProjectionBuilder, ProjectionId, ProjectionKind, RetentionPolicy, SchemaDef, SchemaSource,
    SourceSelector,
};
pub use laser_wire::headers::{
    CONTENT_TYPE, FIELD_MESSAGE_TYPE, FIELD_TS, IDX_PREFIX, INLINE_PAYLOAD, PROJECTION_REF,
    SCHEMA_ID, VECTOR_FIELD, WINDOW_START,
};
pub use laser_wire::hello::HelloReply;
pub use laser_wire::limits::{
    DEFAULT_STREAM_PAGE_SIZE, MAX_INDEX_ENTRIES_PER_RECORD, MAX_PAGE_SIZE,
};
pub use laser_wire::query::{
    AggCall, AggFunc, Aggregate, BoundaryRelation, CmpOp, Consistency, Dir, Filter, KeyMatch,
    MaterializationBoundary, Page, Predicate, Query, QueryBuilder, QueryCancelEnvelope,
    QueryCancelReply, QueryContext, QueryEngine, QueryEnvelope, QueryError, QueryErrorCode,
    QueryExecutionId, QueryExecutionState, QueryExecutionStatus, QueryPageEnvelope,
    QueryPageRequest, QueryReply, QueryResult, QueryStatusEnvelope, QueryStatusReply, QueryTarget,
    RawSql, ResolvedQueryTarget, Row, Select, SnapshotSelector, Sort, SqlDialect, TextQuery, Value,
    VectorQuery, Window,
};
pub use laser_wire::result::ResultCode;
pub use laser_wire::schema::TypedValue;
pub use laser_wire::topics::{CONTROL_TOPIC, DLQ_TOPIC, OPS_STREAM};

// The native-only BSON row decoder rides the `query` feature (it is what pulls
// `laser-wire/bson` in), so it lives on the query surface, not the open
// streaming codec set.
#[cfg(feature = "query")]
pub use laser_wire::codecs::Bson;

#[cfg(feature = "query")]
pub(crate) mod client;

#[cfg(feature = "query")]
pub use client::{QueryRequest, QueryRows, TypedQueryRows};