Module reactive 

Reactive messaging system for agent-to-agent terminal communication. Port of Go’s pkg/reactive/.

Provides message injection into terminal panes, agent registration, rate limiting, message sanitization, audit logging, and cross-host polling via AgentMux cloud service.

Re-exports

pub use handler::get_global_handler;

pub use handler::Handler;

pub use handler::ReactiveHandler;

pub use poller::Poller;

pub use sanitize::format_injected_message;

pub use sanitize::sanitize_message;

pub use sanitize::validate_agent_id;

pub use sanitize::validate_agentmux_url;

pub use types::*;

Modules

handler

poller

registry

File-based cross-instance agent registry.

sanitize

types

Constants

AUDIT_LOG_MAX 🔒

Maximum entries in the audit log ring buffer.

DEFAULT_POLL_INTERVAL_SECS

Default poll interval for AgentMux poller (seconds).

MAX_MESSAGE_LENGTH

Maximum message length in bytes.

RATE_LIMIT_MAX 🔒

Rate limit: max tokens (requests per second).

TRUNCATION_SUFFIX

Suffix appended when a message is truncated.

Functions

now_unix_millis 🔒

Get current time as Unix milliseconds.

sha256_hex 🔒

Compute SHA-256 hex digest of a string (for audit log privacy).