This is an automated email from the ASF dual-hosted git repository. justxuewei pushed a commit to branch feat-adasvc in repository https://gitbox.apache.org/repos/asf/dubbo-go.git
commit 8b12eacc18bc90a7a85f7ea2c8c40f77b43fb795 Author: XavierNiu <[email protected]> AuthorDate: Sun Dec 5 19:45:29 2021 +0800 fix(adasvc): fix incorrect type --- cluster/cluster/adaptivesvc/cluster_invoker.go | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/cluster/cluster/adaptivesvc/cluster_invoker.go b/cluster/cluster/adaptivesvc/cluster_invoker.go index 5678778..8c9c40d 100644 --- a/cluster/cluster/adaptivesvc/cluster_invoker.go +++ b/cluster/cluster/adaptivesvc/cluster_invoker.go @@ -61,9 +61,6 @@ func (ivk *adaptiveServiceClusterInvoker) Invoke(ctx context.Context, invocation // invoke result := invoker.Invoke(ctx, invocation) - // TODO(justxuewei): remove after test - logger.Debugf("result: Result: %#v", result.Attachments()) - // update metrics remainingStr := result.Attachment(constant.AdaptiveServiceRemainingKey, "").(string) remaining, err := strconv.Atoi(remainingStr) @@ -74,7 +71,7 @@ func (ivk *adaptiveServiceClusterInvoker) Invoke(ctx context.Context, invocation logger.Debugf("[adasvc cluster] The server status was received successfully, %s: %#v", constant.AdaptiveServiceRemainingKey, remainingStr) err = metrics.LocalMetrics.SetMethodMetrics(invoker.GetURL(), - invocation.MethodName(), metrics.HillClimbing, remaining) + invocation.MethodName(), metrics.HillClimbing, uint64(remaining)) if err != nil { logger.Warnf("adaptive service metrics update is failed, err: %v", err) return &protocol.RPCResult{Err: err}
