fn generate_replica_map_for_all_topics_handler(&self, actions: &mut TopicActions) {
        debug!("updating replica maps for topics are in pending state");

        // loop through topics & generate replica map (if needed)
        self.topic_store().visit_values(|topic| {
            if topic.status.need_replica_map_recal() {
                let name = topic.key();
                debug!("Generate R-MAP for: {:?}", name);
                // topic status to collect modifications
                self.update_actions_next_state(topic, actions);
            }
        });
    }
///
/// Generate Replica Map for all Topics handler
///
/// # Remarks
/// Generally triggered when a new live borker joins the cluster.
/// The handler performs the following operations:
/// * loop through all topics and identify the ones waiting for replica map
/// * generate replica map
/// * push push result to KV topic queue (if replica map generations succeeded)
///
Generate Replica Map for all Topics handler
Generate Replica Map for all Topics handler
fn generate_replica_map_for_all_topics_handler(&self, actions: &mut TopicActions) {
        debug!("updating replica maps for topics are in pending state");
        // loop through topics & generate replica map (if needed)
        self.topic_store().visit_values(|topic| {
            if topic.status.need_replica_map_recal() {
                let name = topic.key();
                debug!("Generate R-MAP for: {:?}", name);
                // topic status to collect modifications
                self.update_actions_next_state(topic, actions);
            }
        });
    }
fn generate_replica_map_for_all_topics_handler ( & self , actions : & mut TopicActions ) { debug ! ( " " ) ; // loop through topics & generate replica map (if needed) self . topic_store ( ) . visit_values ( | topic | { if topic . status . need_replica_map_recal ( ) { let name = topic . key ( ) ; debug ! ( " " name ) ; // topic status to collect modifications self . update_actions_next_state ( topic , actions ) ; } } ) ; }
Generate Replica Map for all Topics handler
Generate Replica Map for all Topics handler
&self
actions
&mut TopicActions
&self
actions
&mut TopicActions
remarks
Generally triggered when a new live borker joins the cluster.
The handler performs the following operations:
loop through all topics and identify the ones waiting for replica map
generate replica map
push push result to KV topic queue (if replica map generations succeeded)
Generally triggered when a new live borker joins the cluster . The handler performs the following operations : loop through all topics and identify the ones waiting for replica map generate replica map push push result to KV topic queue ( if replica map generations succeeded )