| 27 | ) |
| 28 | |
| 29 | type etcdRegistry struct { |
| 30 | client *clientv3.Client |
| 31 | options registry.Options |
| 32 | |
| 33 | sync.RWMutex |
| 34 | register map[string]uint64 |
| 35 | leases map[string]clientv3.LeaseID |
| 36 | keepaliveChs map[string]<-chan *clientv3.LeaseKeepAliveResponse |
| 37 | keepaliveStop map[string]chan bool |
| 38 | } |
| 39 | |
| 40 | func NewEtcdRegistry(opts ...registry.Option) registry.Registry { |
| 41 | e := &etcdRegistry{ |
nothing calls this directly
no outgoing calls
no test coverage detected