Struct DistributedLockManager 

pub struct DistributedLockManager {
    pub node_id: u32,
    pub coordinator_id: u32,
    /* private fields */
}

Fields

node_id: u32

현재 노드의 고유 ID

coordinator_id: u32

락 인가를 총괄할 마스터(또는 특정 파티션의 리더) 노드 ID

Implementations

impl DistributedLockManager

pub fn new( node_id: u32, coordinator_id: u32, lock_in_rx: Receiver<LockMessage>, lock_out_tx: Sender<LockMessage>, ) -> Arc<Self>

pub async fn acquire( &self, table: &str, key: &[u8], lease_ms: u64, timeout: Duration, ) -> Result<u64, DlmError>

[클라이언트 파트] 락을 비동기로 요청하고 획득할 때까지 대기합니다.

pub async fn release(&self, table: &str, key: &[u8], fencing_token: u64)

[클라이언트 파트] 획득한 락을 자발적으로 반환합니다.

pub async fn run_receiver_loop(self: Arc<Self>)

[백그라운드 루프] Inbound로 들어오는 LockMessage 지속 처리