79 lines
1.3 KiB
Go
79 lines
1.3 KiB
Go
package registry
|
|
|
|
import (
|
|
"errors"
|
|
"strings"
|
|
|
|
"github.com/micro/mdns"
|
|
)
|
|
|
|
type mdnsWatcher struct {
|
|
wo WatchOptions
|
|
ch chan *mdns.ServiceEntry
|
|
exit chan struct{}
|
|
}
|
|
|
|
func (m *mdnsWatcher) Next() (*Result, error) {
|
|
for {
|
|
select {
|
|
case e := <-m.ch:
|
|
txt, err := decode(e.InfoFields)
|
|
if err != nil {
|
|
continue
|
|
}
|
|
|
|
if len(txt.Service) == 0 || len(txt.Version) == 0 {
|
|
continue
|
|
}
|
|
|
|
// Filter watch options
|
|
// wo.Service: Only keep services we care about
|
|
if len(m.wo.Service) > 0 && txt.Service != m.wo.Service {
|
|
continue
|
|
}
|
|
|
|
var action string
|
|
|
|
if e.TTL == 0 {
|
|
action = "delete"
|
|
} else {
|
|
action = "create"
|
|
}
|
|
|
|
service := &Service{
|
|
Name: txt.Service,
|
|
Version: txt.Version,
|
|
Endpoints: txt.Endpoints,
|
|
}
|
|
|
|
// TODO: don't hardcode .local.
|
|
if !strings.HasSuffix(e.Name, "."+service.Name+".local.") {
|
|
continue
|
|
}
|
|
|
|
service.Nodes = append(service.Nodes, &Node{
|
|
Id: strings.TrimSuffix(e.Name, "."+service.Name+".local."),
|
|
Address: e.AddrV4.String(),
|
|
Port: e.Port,
|
|
Metadata: txt.Metadata,
|
|
})
|
|
|
|
return &Result{
|
|
Action: action,
|
|
Service: service,
|
|
}, nil
|
|
case <-m.exit:
|
|
return nil, errors.New("watcher stopped")
|
|
}
|
|
}
|
|
}
|
|
|
|
func (m *mdnsWatcher) Stop() {
|
|
select {
|
|
case <-m.exit:
|
|
return
|
|
default:
|
|
close(m.exit)
|
|
}
|
|
}
|