Struct S3LockManager 

pub struct S3LockManager { /* private fields */ }

S3-based implementation of ObjectLockManager.

Uses conditional PUT (If-None-Match: *) for atomic lock acquisition. Lock files contain instance_id and deadline; stale locks (past deadline) can be overwritten.

Lock File Format

Lock files are stored at {hash}.lock as JSON:

{
  "instance_id": "uuid-of-leader-instance",
  "acquired_at": "2025-12-14T10:30:00Z",
  "deadline": "2025-12-14T10:35:00Z"
}

Meta File Format

Meta files are stored at {hash}.meta as empty objects (presence-only).

Implementations

impl S3LockManager

pub const DEFAULT_LOCK_TIMEOUT: Duration

Default lock timeout: 300 seconds (5 minutes).

pub fn new(client: Arc<S3ObjectBlockClient>, instance_id: String) -> Self

Create a new S3 lock manager.

Arguments

• client - S3 client for object operations
• instance_id - Unique identifier for this instance (e.g., UUID)

pub fn with_timeout(self, timeout: Duration) -> Self

Create with a custom lock timeout.

Trait Implementations

impl ObjectLockManager for S3LockManager

fn has_meta(&self, hash: SequenceHash) -> BoxFuture<'static, Result<bool>>

Check if meta file exists (block already offloaded).

fn try_acquire_lock( &self, hash: SequenceHash, ) -> BoxFuture<'static, Result<bool>>

Try to acquire a lock for the given block.

fn create_meta(&self, hash: SequenceHash) -> BoxFuture<'static, Result<()>>

Create the meta file after successful offload.

fn release_lock(&self, hash: SequenceHash) -> BoxFuture<'static, Result<()>>

Release the lock by deleting the lock file.