Function NewSource

goku-service/discovery/sources.go:102–119

NewSource newSource

(name string, d Discovery)

//NewSource newSource
func NewSource(name string, d Discovery) (*SourceDiscovery, error) {

	if d == nil || reflect.ValueOf(d).IsNil() {
		return nil, ErrorEmptyDiscovery
	}

	s := &SourceDiscovery{
		name:               name,
		discovery:          d,
		healthCheckHandler: new(health.CheckBox),
		services:           make(map[string]*common.Service),
		locker:             sync.RWMutex{},
	}

	d.SetCallback(s.SetServices)

	return s, d.Open()
}