mirror of
https://github.com/go-kratos/kratos.git
synced 2025-03-21 21:27:16 +02:00
fix: consul lint error (#1530)
* fix: consul lint error * fix: services init eroor
This commit is contained in:
parent
5e88a20cd4
commit
3b477e7e52
@ -37,7 +37,9 @@ func (d *Client) Service(ctx context.Context, service string, index uint64, pass
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, 0, err
|
return nil, 0, err
|
||||||
}
|
}
|
||||||
var services []*registry.ServiceInstance
|
|
||||||
|
services := make([]*registry.ServiceInstance, 0)
|
||||||
|
|
||||||
for _, entry := range entries {
|
for _, entry := range entries {
|
||||||
var version string
|
var version string
|
||||||
for _, tag := range entry.Service.Tags {
|
for _, tag := range entry.Service.Tags {
|
||||||
@ -111,7 +113,7 @@ func (d *Client) Register(ctx context.Context, svc *registry.ServiceInstance, en
|
|||||||
for {
|
for {
|
||||||
select {
|
select {
|
||||||
case <-ticker.C:
|
case <-ticker.C:
|
||||||
d.cli.Agent().UpdateTTL("service:"+svc.ID, "pass", "pass")
|
_ = d.cli.Agent().UpdateTTL("service:"+svc.ID, "pass", "pass")
|
||||||
case <-d.ctx.Done():
|
case <-d.ctx.Done():
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
@ -33,10 +33,8 @@ type Config struct {
|
|||||||
|
|
||||||
// Registry is consul registry
|
// Registry is consul registry
|
||||||
type Registry struct {
|
type Registry struct {
|
||||||
cfg *Config
|
|
||||||
cli *Client
|
cli *Client
|
||||||
enableHealthCheck bool
|
enableHealthCheck bool
|
||||||
|
|
||||||
registry map[string]*serviceSet
|
registry map[string]*serviceSet
|
||||||
lock sync.RWMutex
|
lock sync.RWMutex
|
||||||
}
|
}
|
||||||
@ -104,7 +102,7 @@ func (r *Registry) Watch(ctx context.Context, name string) (registry.Watcher, er
|
|||||||
set, ok := r.registry[name]
|
set, ok := r.registry[name]
|
||||||
if !ok {
|
if !ok {
|
||||||
set = &serviceSet{
|
set = &serviceSet{
|
||||||
watcher: make(map[*watcher]struct{}, 0),
|
watcher: make(map[*watcher]struct{}),
|
||||||
services: &atomic.Value{},
|
services: &atomic.Value{},
|
||||||
serviceName: name,
|
serviceName: name,
|
||||||
}
|
}
|
||||||
|
@ -21,11 +21,11 @@ func (w *watcher) Next() (services []*registry.ServiceInstance, err error) {
|
|||||||
err = w.ctx.Err()
|
err = w.ctx.Err()
|
||||||
case <-w.event:
|
case <-w.event:
|
||||||
}
|
}
|
||||||
|
|
||||||
ss, ok := w.set.services.Load().([]*registry.ServiceInstance)
|
ss, ok := w.set.services.Load().([]*registry.ServiceInstance)
|
||||||
|
|
||||||
if ok {
|
if ok {
|
||||||
for _, s := range ss {
|
services = append(services, ss...)
|
||||||
services = append(services, s)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
@ -1,4 +1,3 @@
|
|||||||
./contrib/registry/nacos
|
./contrib/registry/nacos
|
||||||
./contrib/registry/consul
|
|
||||||
./contrib/registry/kubernetes
|
./contrib/registry/kubernetes
|
||||||
./contrib/registry/zookeeper
|
./contrib/registry/zookeeper
|
||||||
|
Loading…
x
Reference in New Issue
Block a user