laser-wire 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 
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

// Ops stream + topics. The control surface rides a dedicated `_agdx` ops
// stream, separate from the user data stream. Topic names drop the `agdx.`
// prefix because the `_agdx` stream already namespaces them. A pinned wire
// contract: drift breaks the managed control surface silently. `_agdx/dlq`
// collects dead-letter capsules, each JSON capsule tagged with a `kind`
// discriminator.

/// The ops stream name (`_agdx`).
pub const OPS_STREAM: &str = "_agdx";
/// Ops topic: projection control commands.
pub const CONTROL_TOPIC: &str = "control.commands";
/// Ops topic: the universal dead-letter topic (capsules carry a `kind`).
pub const DLQ_TOPIC: &str = "dlq";
/// The change-feed topic on the ops stream: one [`ChangeRecord`] per committed
/// projector batch for a binding that opted into `notify`. This is a pinned
/// Iggy-binding constant like its two sibling topics.
///
/// [`ChangeRecord`]: crate::change::ChangeRecord
pub const CHANGES_TOPIC: &str = "changes";

pub const AGENT_SESSIONS: &str = "agent.sessions";
pub const AGENT_STREAMS: &str = "agent.streams";
pub const AGENT_HEARTBEATS: &str = "agent.heartbeats";
pub const AGENT_CONTROL: &str = "agent.control";
pub const AGENT_MEMORY: &str = "agent.memory";
pub const AGENT_DLQ: &str = "agent.dlq";
pub const AGENT_AUDIT: &str = "agent.audit";
pub const AGENT_JOURNAL: &str = "agent.workflow_journal";
pub const AGENT_REGISTRY: &str = "agent.registry";

/// The ops stream topic that holds one stream's records of an ops `surface`
/// (such as [`CHANGES_TOPIC`] or [`DLQ_TOPIC`]) under stream tenancy,
/// `stream:<stream>/_agdx/<surface>`.
pub fn stream_ops_topic(stream: &str, surface: &str) -> String {
    crate::authz::scoped_resource(stream, &format!("_agdx/{surface}"))
}