Skip to content

LinkClient

autogen.beta.network.transport.link.LinkClient #

Bases: Protocol

Tenant-side handle to the hub.

The HubClient opens one LinkClient per process per hub and multiplexes any number of registered AgentClients through it.

endpoint_id instance-attribute #

endpoint_id

open async #

open()

Connect, perform hello handshake, await welcome.

LocalLink makes this a no-op — connection is implicit when the link is created.

Source code in autogen/beta/network/transport/link.py
async def open(self) -> None:
    """Connect, perform ``hello`` handshake, await ``welcome``.

    ``LocalLink`` makes this a no-op — connection is implicit when
    the link is created.
    """
    ...

send_frame async #

send_frame(frame)

Push a frame towards the hub.

Source code in autogen/beta/network/transport/link.py
async def send_frame(self, frame: Frame) -> None:
    """Push a frame towards the hub."""
    ...

frames #

frames()

Async iterator of inbound frames from the hub.

Iteration ends when close() is called.

Source code in autogen/beta/network/transport/link.py
def frames(self) -> AsyncIterator[Frame]:
    """Async iterator of inbound frames from the hub.

    Iteration ends when ``close()`` is called.
    """
    ...

close async #

close()

Drain queues, signal close to the hub-side handler.

Source code in autogen/beta/network/transport/link.py
async def close(self) -> None:
    """Drain queues, signal close to the hub-side handler."""
    ...