/// Inserts a new entry in the ingress history.
Inserts a new entry in the ingress history.
Inserts a new entry in the ingress history .
pub fn insert(&mut self, message_id: MessageId, status: IngressStatus, time: Time) {
        // Store the associated expiry time for the given message id only for a
        // "terminal" ingress status. This way we are not risking deleting any status
        // for a message that is still not in a terminal status.
        if let IngressStatus::Completed { .. } | IngressStatus::Failed { .. } = status {
            Arc::make_mut(&mut self.pruning_times)
                .entry(time + MAX_INGRESS_TTL)
                .or_default()
                .insert(message_id.clone());
        }
        Arc::make_mut(&mut self.statuses).insert(message_id, status);
    }
pub fn insert ( & mut self , message_id : MessageId , status : IngressStatus , time : Time ) { // Store the associated expiry time for the given message id only for a // "terminal" ingress status. This way we are not risking deleting any status // for a message that is still not in a terminal status. if let IngressStatus :: Completed { .. } | IngressStatus :: Failed { .. } = status { Arc :: make_mut ( & mut self . pruning_times ) . entry ( time + MAX_INGRESS_TTL ) . or_default ( ) . insert ( message_id . clone ( ) ) ; } Arc :: make_mut ( & mut self . statuses ) . insert ( message_id , status ) ; }
Inserts a new entry in the ingress history.
Inserts a new entry in the ingress history .
&mut self
message_id
MessageId
status
IngressStatus
time
Time