Module mz_storage::boundary::tcp_boundary::server

TCP boundary server

Structs

Shared 🔒

Shared state between main server loop and client-specific task.

SourceState 🔒

Shared per-subscription state

TcpEventLinkHandle

A handle to the boundary service. Implements StorageCapture to capture sources.

UnboundedEventPusher 🔒

Helper struct to capture data into a sender and drop tokens once dropped itself.

Enums

WorkerResponse 🔒

Response from Timely workers to network handler.

Functions

accept 🔒

Accept connections on listener and listening for data on worker_rx.

framed_server 🔒

Constructs a framed connection for the server.

handle_compute 🔒

Handle the server side of a compute client connection in socket, identified by client_id. state is a handle to the shared state.

handle_compute_inner 🔒

Inner portion to handle a compute client.

serve

Start the boundary server listening for connections on addr.

Type Definitions

ClientId 🔒

Unique client identifier, only used internally

FramedServer 🔒

A framed connection from the server’s perspective.

SourceRequestSender 🔒

Alias for a commonly used type for sending source instantiation requests.