forge.comm
Python comm package; imports are explicit from this package.
Python comm package; imports are explicit from this package.
Package contract
| Field | Value |
|---|---|
| Language | python |
| Source version | 0.1.0 |
| Manifest | forge-py/pyproject.toml |
| Source files | 7 |
| Evidence | Source reference; registry publication and runtime conformance are separate checks |
Import boundary
import forge.commUse a source checkout or your verified private registry. Manifest coordinates identify the package; they do not establish that a public registry release exists.
Source reference
Download package reference JSON. Each original source file and generated declaration artifact has its own SHA-256 digest. Function bodies and constant values are omitted from downloads. These are source declaration inventories, not compiler-resolved rustdoc, TypeDoc, DocC, or Dokka output. Private modules can contain public declarations that are not reachable through the package boundary; consult the entry point before importing.
channel.py
Read declaration text · 6 declaration entries
class ChannelTransport()
def __init__(self, send_queue: asyncio.Queue[AgentMessage], recv_queue: asyncio.Queue[AgentMessage]) -> None
def create_pair(cls, capacity: int=32) -> tuple[ChannelTransport, ChannelTransport]
async def send(self, message: AgentMessage) -> None
async def receive(self) -> AgentMessage
def close(self) -> Noneerrors.py
Read declaration text · 19 declaration entries
class CommError(ForgeError)
class CommSerializationError(CommError)
def __init__(self, reason: str) -> None
class CommDeserializationError(CommError)
def __init__(self, reason: str) -> None
class CommTransportError(CommError)
def __init__(self, reason: str) -> None
class CommNotConnectedError(CommError)
def __init__(self) -> None
class CommChannelClosedError(CommError)
def __init__(self, reason: str='channel closed') -> None
class CommSignatureInvalidError(CommError)
def __init__(self, message_id: str) -> None
class CommProtocolNegotiationError(CommError)
def __init__(self, reason: str) -> None
class CommMessageTooLargeError(CommError)
def __init__(self, size: int, max_size: int) -> None
class CommTimeoutError(CommError)
def __init__(self, operation: str, timeout_seconds: float) -> Nonemessage.py
Read declaration text · 10 declaration entries
class AgentMessage()
def new(sender: str, recipient: str, protocol: str, message_type: str, payload: Any) -> AgentMessage
def kind(self) -> str
def is_signed(self) -> bool
def with_correlation_id(self, correlation_id: str) -> AgentMessage
def with_reply_to(self, reply_to: str) -> AgentMessage
def to_dict(self) -> dict[str, Any]
def from_dict(data: dict[str, Any]) -> AgentMessage
def to_json(self) -> str
def from_json(data: str) -> AgentMessagenoop.py
Read declaration text · 3 declaration entries
class NoopTransport()
async def send(self, message: AgentMessage) -> None
async def receive(self) -> AgentMessageprotocol.py
Read declaration text · 3 declaration entries
class ProtocolOffer()
class ProtocolAccept()
def negotiate_protocol(offer: ProtocolOffer, supported_versions: list[int]) -> ProtocolAccepttransport.py
Read declaration text · 3 declaration entries
class MessageTransport(Protocol)
async def send(self, message: AgentMessage) -> None
async def receive(self) -> AgentMessage