Method enqueue

nodedb-crdt/src/deferred.rs:80–113

(
        &mut self,
        peer_id: u64,
        user_id: u64,
        tenant_id: u64,
        delta: Vec<u8>,
        collection: String,
        constraint_name: String,
        attempt: u32,
    

    /// * `ttl_secs` — seconds from now until this entry expires
    #[allow(clippy::too_many_arguments)]
    pub fn enqueue(
        &mut self,
        peer_id: u64,
        user_id: u64,
        tenant_id: u64,
        delta: Vec<u8>,
        collection: String,
        constraint_name: String,
        attempt: u32,
        max_retries: u32,
        now_ms: u64,
        first_retry_after_ms: u64,
        ttl_secs: u64,
    ) -> u64 {
        let id = self.next_id;
        self.next_id += 1;

        let entry = DeferredEntry {
            id,
            peer_id,
            user_id,
            tenant_id,
            delta,
            collection,
            constraint_name,
            attempt,
            max_retries,
            next_retry_ms: now_ms + first_retry_after_ms,
            ttl_deadline_ms: now_ms + (ttl_secs * 1000),
        };

        self.entries.push_back(entry);
        id
    }

    /// Poll for entries ready for retry.
    ///