1
0
mirror of https://github.com/go-micro/go-micro.git synced 2024-12-18 08:26:38 +02:00
go-micro/registry/service/watcher.go

48 lines
798 B
Go
Raw Normal View History

2019-09-09 17:57:57 +02:00
package service
import (
"github.com/micro/go-micro/v2/registry"
pb "github.com/micro/go-micro/v2/registry/service/proto"
2019-09-09 17:57:57 +02:00
)
type serviceWatcher struct {
stream pb.Registry_WatchService
closed chan bool
}
func (s *serviceWatcher) Next() (*registry.Result, error) {
2019-12-03 09:25:58 +02:00
// check if closed
select {
case <-s.closed:
return nil, registry.ErrWatcherStopped
default:
}
2019-09-09 17:57:57 +02:00
2019-12-03 09:25:58 +02:00
r, err := s.stream.Recv()
if err != nil {
return nil, err
2019-09-09 17:57:57 +02:00
}
2019-12-03 09:25:58 +02:00
return &registry.Result{
Action: r.Action,
Service: ToService(r.Service),
}, nil
2019-09-09 17:57:57 +02:00
}
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),
}
}