Details
Description
func (top_detect_svc *TopologyChangeDetectorSvc) validateTargetTopology() ([]uint16, map[uint16]string, error) {
|
defer top_detect_svc.logger.Infof("TopologyChangeDetectorSvc for pipeline %v validateTargetTopology completed", top_detect_svc.pipeline.Topic())
|
|
targetClusterCompatibility, targetServerVBMap, err := top_detect_svc.getTargetBucketInfo()
|
|
if err != nil {
|
top_detect_svc.logger.Warnf("Skipping target check since received error retrieving target bucket info for %v. err=%v", top_detect_svc.pipeline.Topic(), err)
|
return nil, nil, err
|
}
|
If an error occurs, the word "completed" should not be printed.