fix(fmt&statsd): fix import fmt and remove stastsd bucket host name

kafka/kafka.go

@@ -1,9 +1,10 @@
 package kafka
 
 import (
+	"time"
+
 	"github.com/Shopify/sarama"
 	"github.com/lingmiaotech/tonic/configs"
-	"time"
 )
 
 type Class struct {
@@ -25,15 +26,15 @@ func InitKafka() (err error) {
 
 	brokers := configs.GetStringSlice("kafka.brokers")
 
-	configs := sarama.NewConfig()
-	configs.Producer.RequiredAcks = sarama.WaitForLocal       // Only wait for the leader to ack
-	configs.Producer.Compression = sarama.CompressionNone     // Compress messages
-	configs.Producer.Flush.Frequency = 500 * time.Millisecond // Flush batches every 500ms
-	configs.Producer.Retry.Max = 3
-	configs.Producer.Return.Errors = true
-	configs.Producer.Return.Successes = true
+	cfg := sarama.NewConfig()
+	cfg.Producer.RequiredAcks = sarama.WaitForLocal       // Only wait for the leader to ack
+	cfg.Producer.Compression = sarama.CompressionNone     // Compress messages
+	cfg.Producer.Flush.Frequency = 500 * time.Millisecond // Flush batches every 500ms
+	cfg.Producer.Retry.Max = 3
+	cfg.Producer.Return.Errors = true
+	cfg.Producer.Return.Successes = true
 
-	producer, err := sarama.NewSyncProducer(brokers, configs)
+	producer, err := sarama.NewSyncProducer(brokers, cfg)
 	if err != nil {
 		return err
 	}

logging/kafka_logger.go

@@ -2,10 +2,11 @@ package logging
 
 import (
 	"errors"
+	"time"
+
 	"github.com/Shopify/sarama"
 	"github.com/lingmiaotech/tonic/kafka"
 	"github.com/sirupsen/logrus"
-	"time"
 )
 
 type KafkaHook struct {

redis/redis.go

@@ -2,6 +2,7 @@ package redis
 
 import (
 	"fmt"
+
 	"github.com/go-redis/redis"
 	"github.com/lingmiaotech/tonic/configs"
 )

request/request.go

@@ -3,8 +3,9 @@ package request
 import (
 	"bytes"
 	"encoding/json"
-	"github.com/levigross/grequests"
 	"net/http"
+
+	"github.com/levigross/grequests"
 )
 
 type Opts grequests.RequestOptions

server.go

@@ -3,6 +3,8 @@ package tonic
 import (
 	"errors"
 	"fmt"
+	"io/ioutil"
+
 	"github.com/CrowdSurge/banner"
 	"github.com/gin-gonic/gin"
 	"github.com/lingmiaotech/tonic/configs"
@@ -12,7 +14,6 @@ import (
 	"github.com/lingmiaotech/tonic/redis"
 	"github.com/lingmiaotech/tonic/sentry"
 	"github.com/lingmiaotech/tonic/statsd"
-	"io/ioutil"
 )
 
 type Server struct {

statsd/statsd.go

@@ -2,11 +2,11 @@ package statsd
 
 import (
 	"fmt"
+	"time"
+
 	"github.com/lingmiaotech/tonic/configs"
 	"github.com/lingmiaotech/tonic/logging"
 	"gopkg.in/alexcesaro/statsd.v2"
-	"os"
-	"time"
 )
 
 type InstanceClass struct {
@@ -59,17 +59,17 @@ func Gauge(bucket string, n int) {
 }
 
 func getBucket(bucket string) string {
-	hostName, err := os.Hostname()
-	if err != nil {
-		hostName = "UNKNOWNHOST"
-	}
-	return fmt.Sprintf("%v.%v.%v", hostName, Instance.AppName, bucket)
+	return fmt.Sprintf("%v.%v", Instance.AppName, bucket)
 }
 
 func NewTimer() Timer {
 	return Timer{start: time.Now()}
 }
 
+func NewCustomTimer(t time.Time) Timer {
+	return Timer{start: t}
+}
+
 // Send sends the time elapsed since the creation of the Timing.
 func (t Timer) Send(bucket string) {
 	Timing(bucket, int(t.Duration()/time.Millisecond))