Enum LifecycleEvent 

pub enum LifecycleEvent {
    Open {
        ctx: OpenContext,
        reply: Sender<Result<ReplicatorHandle>>,
    },
    ChangeRole {
        new_role: Role,
        reply: Sender<Result<String>>,
    },
    Close {
        reply: Sender<Result<()>>,
    },
    Abort,
}

Lifecycle events delivered on the lifecycle channel. Rare but high-priority — handle immediately (blocks reconfiguration).

Variants

Open

Replica opened. Create replicator, return handle to runtime.

The user creates the replicator (e.g., WalReplicator::create()), keeps the user-facing handles, and returns the ReplicatorHandle to the runtime.

Fields

ctx: OpenContext

reply: Sender<Result<ReplicatorHandle>>

ChangeRole

Role changed. Start/stop background work accordingly.

Reply with the new listening address (e.g., “http://0.0.0.0:8080”) or empty string if not listening in this role.

Fields

new_role: Role

reply: Sender<Result<String>>

Close

Graceful shutdown. Drain in-flight work, flush state, release resources. The runtime calls the replicator’s Close after this returns.

Fields

reply: Sender<Result<()>>

Abort

Ungraceful termination. Release resources best-effort and return immediately. No reply channel — the runtime doesn’t wait.