Struct ReplicationManager 

pub struct ReplicationManager {
    pub dropped_total: AtomicU64,
    /* private fields */
}

In-memory manager of per-bucket replication configurations + per- (bucket, key) replication statuses.

Fields

dropped_total: AtomicU64

Bumped each time the dispatcher exhausts its retry budget on a destination PUT. Exposed publicly so the metrics layer can poll without taking the configuration lock.

Implementations

impl ReplicationManager

pub fn new() -> Self

Empty manager — no bucket has any replication rules.

pub fn put(&self, bucket: &str, config: ReplicationConfig)

put_bucket_replication handler entry. The bucket’s existing configuration is fully replaced (S3 spec — PutBucketReplication is upsert-style at the bucket scope, not per-rule patch).

pub fn get(&self, bucket: &str) -> Option<ReplicationConfig>

get_bucket_replication handler entry. Returns None when nothing is registered (AWS S3 returns ReplicationConfigurationNotFoundError in that case; the service-layer handler maps None accordingly).

pub fn delete(&self, bucket: &str)

Drop the configuration for bucket. Idempotent.

pub fn to_json(&self) -> Result<String, Error>

Serialise the entire manager state (configurations + per-key statuses) to JSON.

pub fn from_json(s: &str) -> Result<Self, Error>

Restore a manager from a previously-emitted snapshot. The dropped_total counter is reset to 0 — historical drops are runtime metrics, not configuration.

pub fn match_rule( &self, bucket: &str, key: &str, object_tags: &[(String, String)], ) -> Option<ReplicationRule>

Match an object against the bucket’s rules and return the highest-priority enabled rule whose filter matches. Returns None when no rule matches (or no configuration is registered for the bucket). Ties on priority are broken by declaration order — the first such rule wins.

pub fn record_status(&self, bucket: &str, key: &str, status: ReplicationStatus)

Stamp the per-(bucket, key) replication status. Replaces any previous entry — a Failed follows Pending, etc.

pub fn lookup_status( &self, bucket: &str, key: &str, ) -> Option<ReplicationStatus>

Look up the recorded replication status for (bucket, key). Returns None when no PUT to this key has triggered replication (= the object is not under any replication rule, or it predates the rule’s creation).

Trait Implementations

impl Debug for ReplicationManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ReplicationManager

fn default() -> Self

Returns the “default value” for a type.