laser-sdk 0.8.1

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
// The managed key-value surface. Wire types, codes, and caps live in
// laser-wire and are re-exported here unconditionally. The `Kv` handle and
// its fluent builders stay in this crate behind the `kv` feature.

pub use laser_wire::codes::{
    AGDX_KV_BASE, AGDX_KV_CAS_CODE, AGDX_KV_CAS_FENCED_CODE, AGDX_KV_COPY_CODE,
    AGDX_KV_DELETE_CODE, AGDX_KV_DELETE_MANY_CODE, AGDX_KV_EXISTS_CODE, AGDX_KV_EXPIRE_CODE,
    AGDX_KV_GET_CODE, AGDX_KV_LEASE_CODE, AGDX_KV_LEASE_RENEW_CODE, AGDX_KV_MOVE_CODE,
    AGDX_KV_NAMESPACES_CODE, AGDX_KV_PATCH_CODE, AGDX_KV_RELEASE_CODE, AGDX_KV_SCAN_CODE,
    AGDX_KV_SET_CODE, KV_LEASE_OP_VERSION, KV_OP_VERSION,
};
pub use laser_wire::kv::{
    CasExpect, KvCasFenced, KvEntry, KvError, KvGet, KvLease, KvLeaseRenew, KvMetadata,
    KvNamespaceInfo, KvPage, KvRelease,
};
pub use laser_wire::limits::{
    DEFAULT_NAMESPACE, DEFAULT_SCAN_LIMIT, MAX_HOLDER_ID_BYTES, MAX_KEY_BYTES,
    MAX_LEASE_TTL_MICROS, MAX_SCAN_LIMIT, MAX_VALUE_BYTES, MIN_LEASE_TTL_MICROS,
};
pub use laser_wire::mutation::MutationPosition;

#[cfg(feature = "kv")]
mod client;
#[cfg(feature = "kv")]
mod coordination;
#[cfg(feature = "kv")]
pub use client::{Kv, KvCopyRequest, KvDeleteManyRequest, KvScanRequest, KvSetRequest, Lease};
#[cfg(feature = "kv")]
pub use coordination::{
    AmbiguousMutationRecovery, DEFAULT_ATTEMPT_TIMEOUT, DedicatedKvTransport,
    DynManagedKvTransport, FencedLeaseClient, LocalManagedKvTransport, ManagedKvTransport,
    PreparedMutation, SharedKvTransport,
};