INNER CODE UNIT · Go
NewComparator
simagix/keyhole · comparator.go:57
func NewComparator(source string, target string) (*Comparator, error) {
var err error
var logger = gox.GetLogger("comparator")
var validator = Comparator{nsMap: map[string]NamespaceStats{}, messages: []ErrorMessage{},
mutex: sync.Mutex{}}
if validator.source, err = GetMongoClientFromPool(source); err != nil {
logger.Errorf(`error connecting %v`, source)
return &validator, err
}
stats := &mdb.ClusterStats{Logger: logger}
if err = stats.GetClusterStatsSummary(validator.source); err != nil {
return &validator, err
}
logger.Infof(`source: %v`, stats.GetClusterShortSummary(validator.source))
if validator.target, err = GetMongoClientFromPool(target); err != nil {
logger.Errorf(`error connecting %v`, target)
return &validator, err
}