replicationTaskExecutor nsreplication.TaskExecutor,
currentCluster string,
return &eagerNamespaceRefresherImpl{
metadataManager: metadataManager,
namespaceRegistry: namespaceRegistry,
logger: logger,
clientBean: clientBean,
replicationTaskExecutor: replicationTaskExecutor,
currentCluster: currentCluster,
metricsHandler: metricsHandler,
}
}
func (e *eagerNamespaceRefresherImpl) SyncNamespaceFromSourceCluster(