use fasthttp, begin flatbuffer

blind-oracle · Sep 29, 2019 · 142184a · 142184a
1 parent 28694a0
commit 142184a
Show file tree

Hide file tree

Showing 6 changed files with 360 additions and 21 deletions.
diff --git a/flatm.fbs b/flatm.fbs
@@ -0,0 +1,23 @@
+namespace flatm;
+
+table Attr {
+    name: string;
+    value: string;
+}
+
+table Metric {
+    host: string;
+    service: string;
+    state: string;
+    description: string;
+    time: int64;
+    value: float64;
+    tags: [string];
+    attrs: [Attr];
+}
+
+table Batch {
+    metrics: [Metric];
+}
+
+root_type Batch;
diff --git a/flatm/Attr.go b/flatm/Attr.go
diff --git a/flatm/Batch.go b/flatm/Batch.go
diff --git a/flatm/Metric.go b/flatm/Metric.go
diff --git a/outputTgt.go b/outputTgt.go
@@ -4,7 +4,7 @@ import (
 	"context"
 	fmt "fmt"
 	"net"
-	"net/http"
+	fh "github.com/valyala/fasthttp"
 	"net/url"
 	"sync"
 	"sync/atomic"
@@ -89,8 +89,12 @@ func newOutputTgt(h string, cf *outputCfg, o *output) (*target, error) {
 
 			c.alive = true
 			c.writeBatch = c.writeBatchClickhouse
-			c.httpCli = &http.Client{
-				Timeout: c.timeoutWrite,
+			// c.httpCli = &http.Client{
+			// 	Timeout: c.timeoutWrite,
+			// }
+
+			c.httpCli = &fh.Client{
+				WriteTimeout: c.timeoutWrite,
 			}
 
 			u, err := url.Parse(h)