48 lines
806 B
Go
48 lines
806 B
Go
|
package service
|
||
|
|
||
|
import (
|
||
|
pb "github.com/unistack-org/micro-registry-service/v3/proto"
|
||
|
"github.com/unistack-org/micro/v3/registry"
|
||
|
)
|
||
|
|
||
|
type serviceWatcher struct {
|
||
|
stream pb.Registry_WatchService
|
||
|
closed chan bool
|
||
|
}
|
||
|
|
||
|
func (s *serviceWatcher) Next() (*registry.Result, error) {
|
||
|
// check if closed
|
||
|
select {
|
||
|
case <-s.closed:
|
||
|
return nil, registry.ErrWatcherStopped
|
||
|
default:
|
||
|
}
|
||
|
|
||
|
r, err := s.stream.Recv()
|
||
|
if err != nil {
|
||
|
return nil, err
|
||
|
}
|
||
|
|
||
|
return ®istry.Result{
|
||
|
Action: r.Action,
|
||
|
Service: ToService(r.Service),
|
||
|
}, nil
|
||
|
}
|
||
|
|
||
|
func (s *serviceWatcher) Stop() {
|
||
|
select {
|
||
|
case <-s.closed:
|
||
|
return
|
||
|
default:
|
||
|
close(s.closed)
|
||
|
s.stream.Close()
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func newWatcher(stream pb.Registry_WatchService) registry.Watcher {
|
||
|
return &serviceWatcher{
|
||
|
stream: stream,
|
||
|
closed: make(chan bool),
|
||
|
}
|
||
|
}
|