ing

Gopkg.lock

@@ -0,0 +1,259 @@
+# This file is autogenerated, do not edit; changes may be undone by the next 'dep ensure'.
+
+
+[[projects]]
+  branch = "master"
+  name = "git.loafle.net/commons/configuration-go"
+  packages = ["."]
+  revision = "29e01e1ff2d2e5651b0e66cbc11a7e0d1e790a53"
+
+[[projects]]
+  branch = "master"
+  name = "git.loafle.net/commons/logging-go"
+  packages = ["."]
+  revision = "ded250cfe021f307efff8d1f5cdb8a11a5d9297f"
+
+[[projects]]
+  branch = "master"
+  name = "git.loafle.net/commons/server-go"
+  packages = [
+    ".",
+    "client",
+    "socket",
+    "socket/web",
+    "socket/web/client"
+  ]
+  revision = "1cae23cf7819d56fd399346a1dc30af6a82d1a93"
+
+[[projects]]
+  branch = "master"
+  name = "git.loafle.net/commons/util-go"
+  packages = ["context"]
+  revision = "1966a985759721fd451171a78a0b8f4524afc644"
+
+[[projects]]
+  branch = "master"
+  name = "git.loafle.net/overflow/central-api"
+  packages = ["golang"]
+  revision = "36863543bc7a29e359067400263473a8223eba20"
+
+[[projects]]
+  branch = "master"
+  name = "git.loafle.net/overflow/commons-go"
+  packages = [
+    "config/external",
+    "config/probe",
+    "core/config",
+    "core/interfaces",
+    "core/util",
+    "model/data"
+  ]
+  revision = "078a39712d33c131303cf2705cca185da18cc196"
+
+[[projects]]
+  branch = "master"
+  name = "git.loafle.net/overflow/external-go"
+  packages = [
+    ".",
+    "grpc",
+    "influxdb",
+    "kafka",
+    "redis"
+  ]
+  revision = "42e9cb7c30edf264548145a08505fc36cf041ef5"
+
+[[projects]]
+  branch = "master"
+  name = "git.loafle.net/overflow/gateway"
+  packages = ["."]
+  revision = "cadaf5fb7feccdfdc91371810d95063210dee55b"
+
+[[projects]]
+  branch = "master"
+  name = "git.loafle.net/overflow/gateway_rpc"
+  packages = ["server"]
+  revision = "ba1c70ca26de859a8ebd528f7f51424dd02451cf"
+
+[[projects]]
+  name = "github.com/BurntSushi/toml"
+  packages = ["."]
+  revision = "b26d9c308763d68093482582cea63d69be07a0f0"
+  version = "v0.3.0"
+
+[[projects]]
+  name = "github.com/golang/protobuf"
+  packages = [
+    "proto",
+    "ptypes",
+    "ptypes/any",
+    "ptypes/duration",
+    "ptypes/timestamp"
+  ]
+  revision = "b4deda0973fb4c70b50d226b1af49f3da59f5265"
+  version = "v1.1.0"
+
+[[projects]]
+  name = "github.com/gomodule/redigo"
+  packages = [
+    "internal",
+    "redis"
+  ]
+  revision = "9c11da706d9b7902c6da69c592f75637793fe121"
+  version = "v2.0.0"
+
+[[projects]]
+  name = "github.com/influxdata/influxdb"
+  packages = [
+    "client/v2",
+    "models",
+    "pkg/escape"
+  ]
+  revision = "02d7d4f043b34ecb4e9b2dbec298c6f9450c2a32"
+  version = "v1.5.2"
+
+[[projects]]
+  name = "github.com/klauspost/compress"
+  packages = [
+    "flate",
+    "gzip",
+    "zlib"
+  ]
+  revision = "6c8db69c4b49dd4df1fff66996cf556176d0b9bf"
+  version = "v1.2.1"
+
+[[projects]]
+  name = "github.com/klauspost/cpuid"
+  packages = ["."]
+  revision = "ae7887de9fa5d2db4eaa8174a7eff2c1ac00f2da"
+  version = "v1.1"
+
+[[projects]]
+  name = "github.com/klauspost/crc32"
+  packages = ["."]
+  revision = "cb6bfca970f6908083f26f39a79009d608efd5cd"
+  version = "v1.1"
+
+[[projects]]
+  branch = "master"
+  name = "github.com/segmentio/kafka-go"
+  packages = ["."]
+  revision = "44a19ca9cf5925ba3c5153dd0d9e5b44e8dfd717"
+
+[[projects]]
+  name = "github.com/valyala/fasthttp"
+  packages = [
+    ".",
+    "fasthttputil"
+  ]
+  revision = "d42167fd04f636e20b005e9934159e95454233c7"
+  version = "v20160617"
+
+[[projects]]
+  name = "go.uber.org/atomic"
+  packages = ["."]
+  revision = "1ea20fb1cbb1cc08cbd0d913a96dead89aa18289"
+  version = "v1.3.2"
+
+[[projects]]
+  name = "go.uber.org/multierr"
+  packages = ["."]
+  revision = "3c4937480c32f4c13a875a1829af76c98ca3d40a"
+  version = "v1.1.0"
+
+[[projects]]
+  name = "go.uber.org/zap"
+  packages = [
+    ".",
+    "buffer",
+    "internal/bufferpool",
+    "internal/color",
+    "internal/exit",
+    "zapcore"
+  ]
+  revision = "eeedf312bc6c57391d84767a4cd413f02a917974"
+  version = "v1.8.0"
+
+[[projects]]
+  branch = "master"
+  name = "golang.org/x/net"
+  packages = [
+    "context",
+    "http/httpguts",
+    "http2",
+    "http2/hpack",
+    "idna",
+    "internal/timeseries",
+    "trace"
+  ]
+  revision = "2491c5de3490fced2f6cff376127c667efeed857"
+
+[[projects]]
+  name = "golang.org/x/text"
+  packages = [
+    "collate",
+    "collate/build",
+    "internal/colltab",
+    "internal/gen",
+    "internal/tag",
+    "internal/triegen",
+    "internal/ucd",
+    "language",
+    "secure/bidirule",
+    "transform",
+    "unicode/bidi",
+    "unicode/cldr",
+    "unicode/norm",
+    "unicode/rangetable"
+  ]
+  revision = "f21a4dfb5e38f5895301dc265a8def02365cc3d0"
+  version = "v0.3.0"
+
+[[projects]]
+  branch = "master"
+  name = "google.golang.org/genproto"
+  packages = ["googleapis/rpc/status"]
+  revision = "86e600f69ee4704c6efbf6a2a40a5c10700e76c2"
+
+[[projects]]
+  name = "google.golang.org/grpc"
+  packages = [
+    ".",
+    "balancer",
+    "balancer/base",
+    "balancer/roundrobin",
+    "channelz",
+    "codes",
+    "connectivity",
+    "credentials",
+    "encoding",
+    "encoding/proto",
+    "grpclb/grpc_lb_v1/messages",
+    "grpclog",
+    "internal",
+    "keepalive",
+    "metadata",
+    "naming",
+    "peer",
+    "resolver",
+    "resolver/dns",
+    "resolver/passthrough",
+    "stats",
+    "status",
+    "tap",
+    "transport"
+  ]
+  revision = "41344da2231b913fa3d983840a57a6b1b7b631a1"
+  version = "v1.12.0"
+
+[[projects]]
+  name = "gopkg.in/yaml.v2"
+  packages = ["."]
+  revision = "5420a8b6744d3b0345ab293f6fcba19c978f1183"
+  version = "v2.2.1"
+
+[solve-meta]
+  analyzer-name = "dep"
+  analyzer-version = 1
+  inputs-digest = "0fab9ed599390f569d251ef0366027e346711d807ad829d242ab54e1ae16f092"
+  solver-name = "gps-cdcl"
+  solver-version = 1

Gopkg.toml

@@ -0,0 +1,62 @@
+# Gopkg.toml example
+#
+# Refer to https://github.com/golang/dep/blob/master/docs/Gopkg.toml.md
+# for detailed Gopkg.toml documentation.
+#
+# required = ["github.com/user/thing/cmd/thing"]
+# ignored = ["github.com/user/project/pkgX", "bitbucket.org/user/project/pkgA/pkgY"]
+#
+# [[constraint]]
+#   name = "github.com/user/project"
+#   version = "1.0.0"
+#
+# [[constraint]]
+#   name = "github.com/user/project2"
+#   branch = "dev"
+#   source = "github.com/myfork/project2"
+#
+# [[override]]
+#   name = "github.com/x/y"
+#   version = "2.4.0"
+#
+# [prune]
+#   non-go = false
+#   go-tests = true
+#   unused-packages = true
+
+
+[[constraint]]
+  branch = "master"
+  name = "git.loafle.net/commons/configuration-go"
+
+[[constraint]]
+  branch = "master"
+  name = "git.loafle.net/commons/logging-go"
+
+[[constraint]]
+  branch = "master"
+  name = "git.loafle.net/commons/server-go"
+
+[[constraint]]
+  branch = "master"
+  name = "git.loafle.net/overflow/commons-go"
+
+[[constraint]]
+  branch = "master"
+  name = "git.loafle.net/overflow/external-go"
+
+[[constraint]]
+  branch = "master"
+  name = "git.loafle.net/overflow/gateway"
+
+[[constraint]]
+  branch = "master"
+  name = "git.loafle.net/overflow/gateway_rpc"
+
+[[constraint]]
+  name = "github.com/valyala/fasthttp"
+  version = "20160617.0.0"
+
+[prune]
+  go-tests = true
+  unused-packages = true

glide.yaml

@@ -1,25 +0,0 @@
-package: git.loafle.net/overflow/probe_gateway_metric
-import:
-- package: git.loafle.net/commons/configuration-go
-- package: git.loafle.net/commons/logging-go
-- package: git.loafle.net/commons/server-go
-  subpackages:
-  - socket
-  - socket/web
-- package: git.loafle.net/overflow/commons-go
-  subpackages:
-  - config/external
-  - config/probe
-- package: git.loafle.net/overflow/gateway
-  subpackages:
-  - external
-  - external/grpc
-  - external/kafka
-  - external/redis
-  - subscribe/redis
-- package: git.loafle.net/overflow/gateway_rpc
-  subpackages:
-  - server
-- package: github.com/valyala/fasthttp
-  version: ^20160617.0.0
-- package: git.loafle.net/overflow/external-go

main.go

@@ -28,6 +28,8 @@ func init() {
 }
 
 func main() {
+	defer logging.Logger().Sync()
+
 	_config := &config.Config{}
 	configuration.SetConfigPath(*configDir)
 	if err := configuration.Load(_config, "config.json"); nil != err {