Method Chan

services/failure_watcher.go:28–35

Chan returns channel for this watcher. If watcher is nil, returns nil channel. Errors returned on the channel include failure case and service description.

()

// Chan returns channel for this watcher. If watcher is nil, returns nil channel.
// Errors returned on the channel include failure case and service description.
func (w *FailureWatcher) Chan() <-chan error {
	// Graceful handle the case FailureWatcher has not been initialized,
	// to simplify the code in the components using it.
	if w == nil {
		return nil
	}
	return w.ch
}

func (w *FailureWatcher) WatchService(service Service) {
	// Ensure that if the caller request to watch a service, then the FailureWatcher