Module live_replication 

Continuous, bounded replication on caller-authenticated protobuf streams. One feed is shared by every observer/replicator of a local Thread. Incoming metadata writes never move a checkout or install unrequested source blobs.

Modules

input

Allocation-free protobuf shape checks for live frames, before prost builds repeated-message vectors. This bounds protobuf framing and retained input; it is not a bound on arbitrary canonical MessagePack object decoding.

Structs

Feed

Create once per Thread, then clone. This observes writes from other local processes using the durable generation; it does not poll once per stream.

Enums

Activity

A permission-only recheck must not wait for an output memory reservation already retained by this stream. Work may produce one bounded output frame.

Error

Side

Traits

ActivityGuard

Hosts can charge database work and output memory separately. Finishing the work releases execution slots while the returned lease covers delivery. Devices without a shared work scheduler can keep returning ().

Functions

run

Call after validating the opening, endpoint bindings, Thread, and facets. authorize rechecks the live host permission, including expiry/revocation. It runs before every admission and output, including queued output. Readers must enforce the negotiated frame bound before allocating message bodies.

Type Aliases

Result