runtimepy.net.arbiter.tcp package

Submodules

runtimepy.net.arbiter.tcp.json module

A module implementing JSON-message connection factories.

class runtimepy.net.arbiter.tcp.json.TcpJsonMessageConnection(transport: Transport, protocol: QueueProtocol, **kwargs)

Bases: JsonMessageConnection, TcpConnection

A TCP connection interface for JSON messaging.

class runtimepy.net.arbiter.tcp.json.UdpJsonMessageConnection(transport: DatagramTransport, protocol: UdpQueueProtocol, **kwargs)

Bases: JsonMessageConnection, UdpPrefixedMessageConnection

A UDP connection interface for JSON messaging.

class runtimepy.net.arbiter.tcp.json.WebsocketJsonMessageConnection(protocol: ClientConnection | ServerConnection, **kwargs)

Bases: JsonMessageConnection, WebsocketConnection

A websocket connection interface for JSON messaging.

Module contents

A module implementing a basic TCP connection factory that can be extended.

class runtimepy.net.arbiter.tcp.TcpConnectionFactory

Bases: ConnectionFactory, Generic[T]

A class implementing a basic TCP connection factory.

async client(name: str, *args, **kwargs) → Connection

Create a client connection.

kind: type[T]

async server_task(stop_sig: Event, manager: ConnectionManager, started_sem: Semaphore, *args, **kwargs) → Awaitable[None]

Create a task that will run a connection server.