nexo-core 0.2.1

Agent runtime: event bus, sessions, plugin trait, heartbeat, A2A delegation.
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

//! Admin RPC dispatcher.
//!
//! Receives JSON-RPC requests with `app:` ID prefix initiated by
//! microapps over their stdio transport, looks up the handler for
//! `nexo/admin/<domain>/<method>`, checks the operator-granted
//! capability, runs the handler, and returns a typed result.
//!
//! Sub-phase scope:
//! - **82.10.a** (this file): single mock `nexo/admin/echo` handler
//!   for end-to-end shape validation. Capability gates + audit
//!   land in 82.10.b.
//! - **82.10.b**: `CapabilitySet`, boot validation, audit log.
//! - **82.10.c-f**: 5 admin domains (agents / credentials /
//!   pairing / llm_providers / channels).

pub mod agent_events_sqlite;
pub mod audit;
pub mod audit_sqlite;
pub mod broker_pairing_trigger;
pub mod capabilities;
pub mod channel_outbound;
pub mod dispatcher;
pub mod domains;
pub mod escalations_sqlite;
pub mod pairing_trigger;
pub mod processing_sqlite;
pub mod router;
pub mod transcript_appender;
pub mod wa_bot;

pub use agent_events_sqlite::{AgentEventLog, AgentEventLogFilter, SqliteAgentEventLog};
pub use audit_sqlite::{format_rows_as_json, format_rows_as_table, SqliteAdminAuditWriter};
pub use escalations_sqlite::SqliteEscalationStore;
pub use processing_sqlite::SqliteProcessingControlStore;

pub use audit::{
    hash_params, now_epoch_ms, AdminAuditReader, AdminAuditResult, AdminAuditRow, AdminAuditWriter,
    AuditTailFilter, AuditTailPage, InMemoryAuditWriter,
};
pub use broker_pairing_trigger::{spawn_pairing_inbound_subscriber, BrokerPairingTrigger};
pub use capabilities::{
    validate_capabilities_at_boot, AdminCapabilityDecl, CapabilityBootError, CapabilityBootReport,
    CapabilityBootWarn, CapabilitySet,
};
pub use channel_outbound::{
    ChannelOutboundDispatcher, ChannelOutboundError, OutboundAck, OutboundMessage,
};
pub use dispatcher::{AdminRpcDispatcher, AdminRpcError, AdminRpcResult};
pub use pairing_trigger::{
    PairingChannelTrigger, PairingChannelTriggers, PairingContext, PairingHandle,
    PairingTriggerError, PAIRING_DEFAULT_TIMEOUT,
};
pub use router::{AdminOutboundWriter, DispatcherAdminRouter};