Temporarily disable blacklisting
This commit is contained in:
parent
d31cd76b8c
commit
02a0eb29d2
2
selector/cache/cache.go
vendored
2
selector/cache/cache.go
vendored
@ -349,10 +349,12 @@ func (c *cacheSelector) Select(service string, opts ...selector.SelectOption) (s
|
|||||||
services = filter(services)
|
services = filter(services)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
services, err = c.bl.Filter(services)
|
services, err = c.bl.Filter(services)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
*/
|
||||||
|
|
||||||
// if there's nothing left, return
|
// if there's nothing left, return
|
||||||
if len(services) == 0 {
|
if len(services) == 0 {
|
||||||
|
@ -50,10 +50,12 @@ func (r *defaultSelector) Select(service string, opts ...SelectOption) (Next, er
|
|||||||
}
|
}
|
||||||
|
|
||||||
// apply the blacklist
|
// apply the blacklist
|
||||||
|
/*
|
||||||
services, err = r.bl.Filter(services)
|
services, err = r.bl.Filter(services)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
*/
|
||||||
|
|
||||||
// if there's nothing left, return
|
// if there's nothing left, return
|
||||||
if len(services) == 0 {
|
if len(services) == 0 {
|
||||||
|
@ -30,6 +30,8 @@ func TestDefaultSelector(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func TestBlackList(t *testing.T) {
|
func TestBlackList(t *testing.T) {
|
||||||
|
return
|
||||||
|
|
||||||
r := mock.NewRegistry()
|
r := mock.NewRegistry()
|
||||||
|
|
||||||
r.Register(®istry.Service{
|
r.Register(®istry.Service{
|
||||||
|
Loading…
Reference in New Issue
Block a user