Crate krabka_replicator 

krabka-replicator: cross-cluster geo-replication for Krabka.

Re-exports

pub use error::ReplicatorError;

pub use error::Result;

Modules

admin_util

Shared admin/IO helpers used by replicator engine tasks.

checkpoint_store

Position recovery: persist the worker’s [SourceOffset] to a compacted internal topic on the TARGET cluster, keyed by flow name.

config

Replicator configuration model (clusters / flows / policies).

error

Replicator error type.

ids

Domain newtypes for the replicator crate.

mm2

MirrorMaker-2 byte-compatible record codecs.

naming

Remote-topic naming and loop-prevention primitives.

offset_sync_store

In-memory source-to-target offset translation built from MM2 offset-sync records. Translation is “at-or-before”: find the latest sync with upstream <= committed, then downstream + (committed - upstream). Never maps past un-replicated data.

record

The payload that travels through the connect runtime for one replicated record.

residency

Deny-wins residency gate. A topic-flow is permitted unless a matching policy denies it. The semantics mirror Krabka’s ACL authorizer: DENY beats ALLOW. An allow_zones list means “only these zones are allowed”, which is deny-by-default for the matched topic.

selector

Include/exclude name selectors. * is a glob wildcard; patterns are anchored.

sink

Sink side: residency gate, naming, and provenance loop-guard, then produce to the target and emit source-to-target offset syncs.

source

Source side: a consumer on the source cluster that emits ReplicatedRecords and snapshots all partition positions as a [SourceOffset].

supervisor

Supervisor: top-level task tree that owns and restarts replication workers.

tasks

Background tasks that run alongside the main replication workers.

worker

Per-flow replication worker. It drives one directional connect pipeline from SourceConsumer to TargetSink, plus the heartbeat and checkpoint background tasks, with build-retry resilience and clean shutdown.