Skip to main content

Crate meerkat_comms

Crate meerkat_comms 

Source
Expand description

Inter-agent communication for Meerkat instances.

Re-exports§

pub use event_injector::CommsEventInjector;
pub use identity::IdentityError;
pub use identity::Keypair;
pub use identity::PubKey;
pub use identity::Signature;
pub use inbox::AdmissionOutcome;
pub use inbox::DropReason;
pub use inbox::Inbox;
pub use inbox::InboxError;
pub use inbox::InboxSender;
pub use inproc::InprocPeerInfo;
pub use inproc::InprocRegistry;
pub use inproc::InprocSendError;
pub use inproc::RegistrationOutcome;
pub use inproc::RegistrationRejection;
pub use io_task::IoTaskError;
pub use io_task::handle_connection;
pub use plain_listener::PlainIngressFault;
pub use plain_listener::PlainIngressFaults;
pub use plain_listener::handle_plain_connection;
pub use router::CommsConfig;
pub use router::DEFAULT_MAX_MESSAGE_BYTES;
pub use router::Router;
pub use router::SendError;
pub use transport::codec::EnvelopeFrame;
pub use transport::codec::TransportCodec;
pub use transport::PeerAddr;
pub use transport::TransportError;
pub use trust::TrustEntry;
pub use trust::TrustError;
pub use trust::TrustResolveError;
pub use trust::TrustStore;
pub use trust::TrustedPeersView;
pub use types::Envelope;
pub use types::InboxItem;
pub use types::MessageKind;
pub use types::Status;
pub use runtime::comms_bootstrap::CommsAdvertise;
pub use runtime::comms_bootstrap::CommsBootstrap;
pub use runtime::comms_bootstrap::CommsBootstrapError;
pub use runtime::comms_bootstrap::CommsBootstrapMode;
pub use runtime::comms_bootstrap::ParentCommsContext;
pub use runtime::comms_bootstrap::PreparedComms;
pub use runtime::comms_config::CoreCommsConfig;
pub use runtime::comms_config::ResolvedCommsConfig;
pub use runtime::comms_runtime::CommsRuntime;
pub use runtime::comms_runtime::CommsRuntimeError;
pub use runtime::comms_runtime::CommsToolMaterial;
pub use runtime::comms_runtime::PeerRequestResponseAuthority;
pub use agent::dispatcher::CommsToolDispatcher;
pub use agent::dispatcher::DynCommsToolDispatcher;
pub use agent::dispatcher::NoOpDispatcher;
pub use agent::dispatcher::comms_tool_defs;
pub use mcp::tools::RuntimeCommsCommandHandle;
pub use mcp::tools::ToolContext;
pub use mcp::tools::comms_tool_unavailable_reason;
pub use mcp::tools::handle_tools_call;
pub use mcp::tools::handle_tools_call_with_context;
pub use mcp::tools::tools_list;

Modules§

agent
Agent-facing comms tool dispatch and message projection types.
event_injector
Concrete EventInjector implementation wrapping InboxSender.
identity
Cryptographic identity types for Meerkat comms.
inbox
Thread-safe inbox for Meerkat comms.
inproc
In-process message transport for peer communication within one runtime.
io_task
IO task for handling incoming connections.
mcp
MCP tool implementations for Meerkat comms.
peer_meta
Re-export PeerMeta from meerkat-core.
plain_listener
Plain-text connection handler for unauthenticated event ingestion.
router
Router for Meerkat comms - high-level send API.
runtime
Comms runtime and integration helpers.
transport
Transport layer for Meerkat comms.
trust
Trust management for Meerkat comms.
types
Core message types for Meerkat comms.

Structs§

PeerMeta
Supplementary metadata attached to a peer for discovery.

Enums§

SenderContentTaint
Sender-declared content-taint classification for peer content.

Functions§

validate_keep_alive
Confirm keep-alive mode availability when the comms crate is compiled in.