From dec9097ce7863e2707fb071592ed971e4449f46e Mon Sep 17 00:00:00 2001
From: ning1875 <907974064@qq.com>
Date: Sat, 13 Mar 2021 13:21:05 +0800
Subject: [PATCH] =?UTF-8?q?transfer=E5=86=99m3db=E5=87=BA=E9=94=99?=
 =?UTF-8?q?=E6=97=B6=E6=89=93=E5=8D=B0metric=E4=BF=A1=E6=81=AF=E5=B8=AE?=
 =?UTF-8?q?=E5=8A=A9=E5=AE=9A=E4=BD=8D=20(#615)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

* m3db writetagged应该并发做，不然会导致transfer rpc变慢

* go func指针传参问题

* 新增k8s-mon三个大盘文件

* 新增k8s-mon三个大盘文件

* 修改k8s-mon三个大盘文件

* transfer写m3db出错时打印metric信息帮助定位
---
 src/modules/transfer/backend/m3db/m3db.go | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/src/modules/transfer/backend/m3db/m3db.go b/src/modules/transfer/backend/m3db/m3db.go
index fc5b0775..1f361c93 100644
--- a/src/modules/transfer/backend/m3db/m3db.go
+++ b/src/modules/transfer/backend/m3db/m3db.go
@@ -115,7 +115,12 @@ func (p *Client) Push2Queue(items []*dataobj.MetricValue) {
 				xtime.Second,
 				nil)
 			if err != nil {
-				logger.Errorf("unable to writeTagged: %s", err)
+				logger.Errorf("[endpoint:%s][metrics_name:%s][metrics_ts:%d][metrics_detail:%+v]unable to writeTagged: %s",
+					dm.Endpoint,
+					dm.Metric,
+					dm.Timestamp,
+					dm,
+					err)
 				atomic.AddInt32(&errCnt, 1)
 			}
 			wg.Done()