Modules
Messaging and notification system for the Jido ecosystem.
Runtime bridge between Jido.Messaging and Jido.Chat.Adapter.
Behaviour for channel-specific health checking.
GenServer that manages an agent's participation in a specific room thread.
DynamicSupervisor for spawning and managing AgentRunner processes.
Telemetry-based audit logging for Jido.Messaging events.
Runtime-editable bridge configuration for adapter-backed ingress/egress.
Adapter bridge metadata struct.
Channel bridge discovery and lookup.
Declarative spec for creating a bridge-backed room topology.
Runtime bridge process for a single configured bridge.
Runtime bridge health/status snapshot.
Dynamic supervisor for bridge runtime workers.
Runtime-editable bridge and routing control plane.
Canonical runtime delivery context for Jido.Messaging.
Dead-letter storage and replay control plane for terminal outbound failures.
Supervisor for partitioned dead-letter replay workers.
Central message deduplication using ETS with TTL.
Outbound message delivery pipeline through Jido.Messaging.OutboundGateway.
Per-bridge outbound retry/backoff policy.
Bridges messages between Telegram and Discord via Signal Bus subscription.
A ReAct-based chat agent that participates in bridged conversations.
Echo back the input text
Provide help about the bridge system
Get the current time
Wrapper that runs the ChatAgent within the Jido.Messaging AgentRunner framework.
A Jido Sensor that emits periodic heartbeat messages to a chat room.
Demo messaging instance for the echo bot demo.
Supervisor for the demo messaging service.
YAML-backed bootstrap helpers for demo runtime topology.
Unified directory lookup and search APIs.
Gating hook for authorization decisions.
Inbound routing boundary from raw adapter payloads into runtime ingest.
Inbound message processing pipeline.
Canonical normalized ingress result for webhook and non-webhook payload paths.
Shared ingress sink for adapter-owned listener workers.
Normalized provider ingress subscription state for a bridge.
Bridge-scoped ingress subscription provisioning.
Represents a channel instance (e.g., a Telegram bot, Discord connection).
Per-instance lifecycle worker that runs connection probes and reconnect policy.
Per-instance GenServer that tracks lifecycle state and emits signals.
Dynamic supervisor for channel instances.
Deterministic media normalization and bounded policy checks.
Canonical persisted runtime message model for Jido.Messaging.
Moderation behaviour and utilities for message filtering.
A simple keyword-based content filter.
Rate limiting moderator to prevent message flooding.
Normalized message envelope for routing and transport.
Deterministic command parser for normalized inbound message text.
Command and mention normalization for MsgContext.
Onboarding flow orchestration APIs.
Persisted onboarding flow state.
Deterministic onboarding state transitions with persisted idempotency.
Dynamic supervisor for onboarding workers partitioned by onboarding ID.
Runtime process for a single onboarding flow.
Partitioned outbound gateway for send/edit delivery operations.
Supervisor for outbound gateway partition workers.
Outbound bridge router for runtime-configurable adapter delivery.
Behaviour for Jido.Messaging storage adapters.
In-memory ETS adapter for Jido.Messaging.
Optional Phoenix.PubSub integration for cross-node events and LiveView support.
Represents a binding between an internal room and an external platform room.
GenServer that manages a single room's state.
DynamicSupervisor for spawning and managing RoomServer processes.
Runtime-editable routing policy for outbound bridge delivery decisions.
Runtime state holder for a Jido.Messaging instance.
Centralized security boundary for inbound verification and outbound sanitization.
Default security adapter.
Per-instance message sender with retry queue and exponential backoff.
Session key derivation for conversation scoping.
Partitioned route-state manager for deterministic session routing.
Partition process for session route state.
Supervisor for partitioned session-routing workers.
Signal emission for messaging events using dual-emission pattern.
Signal extension for message correlation tracking in Jido.Messaging.
Streaming response support for progressive message updates.
Main supervisor for a Jido.Messaging instance.
Canonical persisted thread model for Jido.Messaging.
Validation helpers for bridge-room topology payloads.
Generic webhook Plug for adapter-backed bridges.
Mix Tasks
Starts a demo messaging service.