update
This commit is contained in:
@@ -2,12 +2,12 @@ package consul
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
"fmt"
|
||||||
|
"sort"
|
||||||
|
"time"
|
||||||
|
|
||||||
"github.com/hashicorp/consul/api"
|
"github.com/hashicorp/consul/api"
|
||||||
"github.com/pkg/errors"
|
"github.com/pkg/errors"
|
||||||
"google.golang.org/grpc/resolver"
|
"google.golang.org/grpc/resolver"
|
||||||
"sort"
|
|
||||||
"strings"
|
|
||||||
"time"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
const schemeName = "consul"
|
const schemeName = "consul"
|
||||||
@@ -116,7 +116,7 @@ func (c *consulResolver) watchService() {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
defaultLog.Errorf("%s update service state err: %s", err, c.tgt.String())
|
defaultLog.Errorf("%s update service state err: %s", err, c.tgt.String())
|
||||||
} else {
|
} else {
|
||||||
defaultLog.Infof("%s update service num:%d (%s)", c.tgt.String(), len(addrs), strings.Join(addrs, ", "))
|
//defaultLog.Infof("%s update service num:%d (%s)", c.tgt.String(), len(addrs), strings.Join(addrs, ", "))
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user