From cc78224958e1b51ebdc5cbeb6f11cc3a7a08283d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E5=BF=97=E4=BF=A1?= <lizhixin@B-C0A1LVDL-2144.local> Date: Wed, 9 Dec 2020 10:15:05 +0800 Subject: [PATCH] fmt file --- cluster/router/healthcheck/default_health_check.go | 3 +-- common/constant/key.go | 1 - registry/zookeeper/registry.go | 2 +- 3 files changed, 2 insertions(+), 4 deletions(-) diff --git a/cluster/router/healthcheck/default_health_check.go b/cluster/router/healthcheck/default_health_check.go index a59e58ff6..f1ae9c20a 100644 --- a/cluster/router/healthcheck/default_health_check.go +++ b/cluster/router/healthcheck/default_health_check.go @@ -48,7 +48,7 @@ type DefaultHealthChecker struct { // IsHealthy evaluates the healthy state on the given Invoker based on the number of successive bad request // and the current active request func (c *DefaultHealthChecker) IsHealthy(invoker protocol.Invoker) bool { - if !protocol.GetInvokerHealthyStatus(invoker){ + if !protocol.GetInvokerHealthyStatus(invoker) { return false } @@ -96,7 +96,6 @@ func (c *DefaultHealthChecker) getCircuitBreakerSleepWindowTime(status *protocol return int64(sleepWindow) } - // GetRequestSuccessiveFailureThreshold return the requestSuccessiveFailureThreshold bound to this DefaultHealthChecker func (c *DefaultHealthChecker) GetRequestSuccessiveFailureThreshold() int32 { return c.requestSuccessiveFailureThreshold diff --git a/common/constant/key.go b/common/constant/key.go index b10d12d79..786c6ed01 100644 --- a/common/constant/key.go +++ b/common/constant/key.go @@ -90,7 +90,6 @@ const ( RETRY_TIMES_KEY = "retry.times" CYCLE_REPORT_KEY = "cycle.report" DEFAULT_BLACK_LIST_RECOVER_BLOCK = 10 - ) const ( diff --git a/registry/zookeeper/registry.go b/registry/zookeeper/registry.go index 76fc052b6..fe492c2b1 100644 --- a/registry/zookeeper/registry.go +++ b/registry/zookeeper/registry.go @@ -212,7 +212,7 @@ func (r *zkRegistry) registerTempZookeeperNode(root string, node string) error { r.cltLock.Lock() defer r.cltLock.Unlock() - if r.client == nil{ + if r.client == nil { return perrors.WithStack(perrors.New("zk client already been closed")) } err = r.client.Create(root) -- GitLab