laser-sdk 0.0.2

Open data-platform SDK over Apache Iggy: typed streaming, declared projections and a query DSL, a key-value store, copy-on-write forks, and an optional agent runtime with the Agent Data Exchange Protocol (AGDX).
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50

// 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_CODE, AGDX_REGISTER_SCHEMA_CODE, CONTROL_OP_VERSION,
    FORK_OP_VERSION, QUERY_OP_VERSION,
};
pub use laser_wire::control::{
    ControlCommand, ControlEnvelope, Delivery, EdgeExtract, EntitySchema, FieldType, IndexField,
    IndexSchema, IndexSchemaBuilder, NodeExtract, Projection, ProjectionBinding,
    ProjectionBindingBuilder, ProjectionBuilder, ProjectionId, ProjectionKind, RetentionPolicy,
    SchemaDef, SchemaSource, SourceSelector, Target, TargetRole,
};
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, CmpOp, Consistency, Dir, Filter, KeyMatch, Page, Predicate, Query,
    QueryBuilder, QueryEnvelope, QueryError, QueryReply, QueryResult, RawSql, Row, Select, Sort,
    TextQuery, Value, VectorQuery, Window,
};
pub use laser_wire::result::ResultCode;
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};