laser-sdk 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 
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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115

#![forbid(unsafe_code)]

#[cfg(doctest)]
#[doc = include_str!("../README.md")]
mod crate_readme {}

#[cfg(doctest)]
#[doc = include_str!("../../README.md")]
mod workspace_readme {}

#[cfg(feature = "a2a-bridge")]
pub mod a2a;
#[cfg(feature = "agent")]
pub mod agent;
#[cfg(feature = "agui")]
pub mod agui;
#[cfg(feature = "agent")]
pub mod batching;
#[cfg(feature = "agent")]
pub mod blob;
// The `bridge_hops` loop guard both protocol bridges stamp.
#[cfg(any(feature = "a2a-bridge", feature = "mcp-bridge"))]
mod bridge_hops;
pub mod capabilities;
#[cfg(feature = "streaming")]
mod connect_options;
#[cfg(feature = "agent")]
pub mod context;
#[cfg(feature = "agent")]
pub mod context_scope;
// The shared control-command publish path, used by the projection registry
// and session source registration.
#[cfg(any(feature = "projections", feature = "agent"))]
mod control;
#[cfg(feature = "agent")]
pub mod crash_context;
#[cfg(feature = "streaming")]
pub mod cursor;
#[cfg(feature = "destinations")]
pub mod destinations;
#[cfg(any(feature = "a2a-bridge", feature = "mcp-bridge"))]
pub mod edge_auth;
pub mod error;
pub mod filters;
pub mod fork;
#[cfg(feature = "agent")]
pub mod govern;
#[cfg(feature = "graph")]
pub mod graph;
#[cfg(feature = "agent")]
pub mod intent;
pub mod kv;
#[cfg(feature = "streaming")]
pub mod laser;
#[cfg(any(
    feature = "filters",
    feature = "fork",
    feature = "destinations",
    feature = "graph",
    feature = "kv",
    feature = "projections",
    feature = "query",
    feature = "rbac"
))]
mod managed;
#[cfg(feature = "streaming")]
mod managed_route;
#[cfg(feature = "mcp-bridge")]
pub mod mcp;
#[cfg(feature = "agent")]
pub mod memory;
#[cfg(feature = "streaming")]
pub mod message;
#[cfg(feature = "streaming")]
mod poll;
pub mod prelude;
#[cfg(feature = "projections")]
pub mod projections;
pub mod provenance;
#[cfg(feature = "streaming")]
mod publish_options;
pub mod query;
#[cfg(feature = "rbac")]
pub mod rbac;
mod retry;
#[cfg(feature = "schema-codecs")]
pub mod schema_codecs;
#[cfg(feature = "sign")]
pub mod sign;
pub mod snapshot;
#[cfg(feature = "agent")]
pub mod state_store;
#[cfg(feature = "streaming")]
pub mod stream;
#[cfg(feature = "agent")]
pub mod swarm;
#[cfg(feature = "agent")]
pub mod testing;
#[cfg(feature = "streaming")]
pub mod typed;
pub mod types;
#[cfg(feature = "watch")]
pub mod watch;

pub use error::LaserError;
// The wire contract crate, re-exported whole as `laser_sdk::wire::*` (the
// per-module shims above keep the historical paths working too).
pub use laser_wire as wire;
// The underlying Apache Iggy client crate, re-exported whole as
// `laser_sdk::iggy::*`. The SDK's own surface hands back iggy types (a
// `Laser::client()` handle, an `iggy_consumer_group()` builder, `Identifier`,
// `PollingStrategy`, header keys), so a consumer that drops to that seam names
// them through here at the exact version the SDK builds against, instead of
// adding a separate `iggy` dependency that must be kept version-matched by hand.
pub use iggy;