Module mz_storage::boundary::tcp_boundary::client

source · [−]
Expand description

TCP boundary client

Structs

ClientState 🔒
DropReplay 🔒

Utility to send a message on drop.

SubscriptionState 🔒
TcpEventLinkClientHandle

A handle to the storage client. Implements ComputeReplay.

UnboundedEventPuller 🔒

Puller reading from a receiver channel.

WorkerState 🔒

State per worker and source.

Enums

Announce 🔒

Announcement protocol from a Timely worker to the storage client.

Functions

connect

Connect to a storage boundary server. Returns a handle to replay sources and a join handle to await termination.

framed_client 🔒

Constructs a framed connection for the client.

run_client 🔒

Communicate data and subscriptions on stream, receiving local replay notifications on announce_rx. workers is the number of local Timely workers.

Type Definitions

FramedClient 🔒

A framed connection from the client’s perspective.