From 4a588bde13d4a130278aa0fdc222870395ea4c54 Mon Sep 17 00:00:00 2001
From: zenghongru <zenghongru@gmail.com>
Date: Tue, 15 Jun 2021 15:57:34 +0800
Subject: [PATCH] feat: agent

---
 agent/agent.go       |  4 ++--
 script/tablestore.go | 23 +++++++++++++++++++++++
 2 files changed, 25 insertions(+), 2 deletions(-)
 create mode 100644 script/tablestore.go

diff --git a/agent/agent.go b/agent/agent.go
index 9fb0137..102b805 100644
--- a/agent/agent.go
+++ b/agent/agent.go
@@ -263,12 +263,12 @@ func (a *Agent) collectAndSend(ctx context.Context, buf *bytes.Buffer, r *ring.R
 	}
 
 	body.Profile = pf
-	body.SendTime = time.Now().UnixNano()
+	body.SendTime = time.Now().Unix()
 	pp, err := gprofile.ParseData(buf.Bytes())
 	if err != nil {
 		return fmt.Errorf("fail to parse profile[%s] data: %w", profileType.String(), err)
 	}
-	body.CreateTime = pp.TimeNanos
+	body.CreateTime = pp.TimeNanos / 1e9
 
 	req := a.c.NewRequest().Post().WithPath("/v1/profile").WithJSONBody(&body)
 	resp, err := a.c.Do(ctx, req)
diff --git a/script/tablestore.go b/script/tablestore.go
new file mode 100644
index 0000000..83d5468
--- /dev/null
+++ b/script/tablestore.go
@@ -0,0 +1,23 @@
+package script
+
+import (
+	"github.com/aliyun/aliyun-tablestore-go-sdk/v5/tablestore"
+	"github.com/xiaojiaoyu100/profiler/collector/env"
+	"go.uber.org/zap"
+	"golang.org/x/tools/go/ssa/interp/testdata/src/fmt"
+)
+
+func InitOTS(env *env.Env) {
+	createTableReq := tablestore.CreateTableRequest{
+		TableMeta:          nil,
+		TableOption:        nil,
+		ReservedThroughput: nil,
+		StreamSpec:         nil,
+		IndexMetas:         nil,
+	}
+	_, err := env.TablestoreClient().Client.CreateTable(&createTableReq)
+	if err != nil {
+		env.Logger().Info(fmt.Sprintf("fail to create table %s", env.TablestoreClient().TableName), zap.Error(err))
+		return
+	}
+}