overflow_backup_2018_0455/deprecated_overflow_gateway_web
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

config has been changed.

Browse Source
This commit is contained in:
crusader 2017-09-19 17:28:21 +09:00
parent 918775c49b
commit 0bc87ebdc5
11 changed files with 71 additions and 85 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
conf/conf.go Normal file
View File

@ -0,0 +1,16 @@
package conf
import (
ofc "git.loafle.net/overflow/overflow_config"
)
var Config Conf
type Conf struct {
Server ofc.Server `json:"server" yaml:"server" toml:"server"`
Auth ofc.Auth `json:"auth" yaml:"auth" toml:"auth"`
Websocket ofc.Websocket `json:"websocket" yaml:"websocket" toml:"websocket"`
GRPC ofc.GRPC `json:"gRPC" yaml:"gRPC" toml:"gRPC"`
Redis ofc.Redis `json:"redis" yaml:"redis" toml:"redis"`
Handlers map[string]ofc.Handler `json:"handlers" yaml:"handlers" toml:"handlers"`
}

28
config.json
View File

@ -57,33 +57,5 @@
}
}
},
"logging": {
"level": "debug",
"development": true,
"disableCaller": true,
"disableStacktrace": true,
"sampling": {
"initial": 100,
"thereafter": 100
},
"encoding": "console",
"encoderConfig": {
"messageKey": "message",
"levelKey": "level",
"timeKey": "time",
"nameKey": "name",
"callerKey": "caller",
"stacktraceKey": "stacktrace",
"lineEnding": "\n",
"levelEncoder": "color",
"timeEncoder": "ISO8601",
"durationEncoder": "string",
"callerEncoder": "full",
"nameEncoder": "full"
},
"outputPaths": ["stdout", "/tmp/logs"],
"errorOutputPaths": ["stderr"]
}
}

18
glide.yaml
View File

@ -1,25 +1,31 @@
package: git.loafle.net/overflow/overflow_gateway_web
import:
- package: git.loafle.net/commons_go/config
- package: git.loafle.net/commons_go/grpc_pool
- package: git.loafle.net/commons_go/logging
- package: git.loafle.net/commons_go/redis_pool
- package: git.loafle.net/commons_go/util
subpackages:
- channel
- package: git.loafle.net/overflow/overflow_api_server
subpackages:
- golang
- package: git.loafle.net/overflow/overflow_subscriber
subpackages:
- redis
- package: github.com/dgrijalva/jwt-go
version: v3.0.0
- package: github.com/garyburd/redigo
version: v1.1.0
subpackages:
- redis
- package: github.com/valyala/fasthttp
version: v20160617
- package: go.uber.org/zap
version: v1.6.0
- package: google.golang.org/grpc
version: v1.5.2
version: v1.6.0
subpackages:
- metadata
- package: git.loafle.net/overflow/overflow_gateway_websocket
- package: git.loafle.net/commons_go/config
- package: git.loafle.net/commons_go/redis_pool
- package: github.com/dgrijalva/jwt-go
version: v3.0.0
- package: git.loafle.net/commons_go/grpc_pool
- package: git.loafle.net/overflow/overflow_config

8
grpc/pool.go
View File

@ -4,9 +4,9 @@ import (
"context"
"fmt"
"git.loafle.net/commons_go/config"
cgp "git.loafle.net/commons_go/grpc_pool"
"git.loafle.net/commons_go/logging"
"git.loafle.net/overflow/overflow_gateway_web/conf"
)
var _pool cgp.Pool
@ -16,9 +16,9 @@ func InitializePool(ctx context.Context) {
h := &poolHandlers{
ctx: ctx,
}
h.cfg = config.Sub("grpc")
h.MaxIdle = h.cfg.GetInt("pool.MaxIdle")
h.MaxCapacity = h.cfg.GetInt("pool.MaxCapacity")
h.MaxIdle = conf.Config.GRPC.Pool.MaxIdle
h.MaxCapacity = conf.Config.GRPC.Pool.MaxCapacity
_pool, err = cgp.New(ctx, h)
if nil != err {

5
grpc/pool_handlers.go
View File

@ -5,20 +5,19 @@ import (
"google.golang.org/grpc"
"git.loafle.net/commons_go/config"
cgp "git.loafle.net/commons_go/grpc_pool"
oas "git.loafle.net/overflow/overflow_api_server/golang"
"git.loafle.net/overflow/overflow_gateway_web/conf"
)
type poolHandlers struct {
cgp.PoolHandlers
ctx context.Context
cfg config.Configurator
}
func (h *poolHandlers) OnCreate() (*grpc.ClientConn, interface{}, error) {
var err error
conn, err := grpc.Dial(config.GetString("grpc.addr"), grpc.WithInsecure())
conn, err := grpc.Dial(conf.Config.GRPC.Addr, grpc.WithInsecure())
if nil != err {
return nil, nil, err
}

21
handler/web_socket_handlers.go
View File

@ -4,28 +4,29 @@ import (
"context"
"time"
"git.loafle.net/commons_go/config"
"git.loafle.net/overflow/overflow_gateway_web/conf"
ogw "git.loafle.net/overflow/overflow_gateway_websocket"
)
type webSocketHandlers struct {
ogw.SocketHandlers
ctx context.Context
cfg config.Configurator
}
func NewWebSocketHandler(ctx context.Context) ogw.SocketHandler {
h := &webSocketHandlers{
ctx: ctx,
}
h.cfg = config.Sub("handlers.web")
h.MaxMessageSize = h.cfg.GetInt64("socket.MaxMessageSize")
h.WriteTimeout = h.cfg.GetDuration("socket.WriteTimeout") * time.Second
h.ReadTimeout = h.cfg.GetDuration("socket.ReadTimeout") * time.Second
h.PongTimeout = h.cfg.GetDuration("socket.PongTimeout") * time.Second
h.PingTimeout = h.cfg.GetDuration("socket.PingTimeout") * time.Second
h.PingPeriod = h.cfg.GetDuration("socket.PingPeriod") * time.Second
h.BinaryMessage = h.cfg.GetBool("socket.BinaryMessage")
cfg := conf.Config.Handlers["web"]
h.MaxMessageSize = cfg.Socket.MaxMessageSize
h.WriteTimeout = cfg.Socket.WriteTimeout * time.Second
h.ReadTimeout = cfg.Socket.ReadTimeout * time.Second
h.PongTimeout = cfg.Socket.PongTimeout * time.Second
h.PingTimeout = cfg.Socket.PingTimeout * time.Second
h.PingPeriod = cfg.Socket.PingPeriod * time.Second
h.BinaryMessage = cfg.Socket.BinaryMessage
ph := newWebJSONRpcHandler(ctx)

23
main.go
View File

@ -3,10 +3,10 @@ package main
import (
"context"
"flag"
"log"
"git.loafle.net/commons_go/config"
"git.loafle.net/commons_go/logging"
"git.loafle.net/overflow/overflow_gateway_web/conf"
"git.loafle.net/overflow/overflow_gateway_web/grpc"
"git.loafle.net/overflow/overflow_gateway_web/handler"
"git.loafle.net/overflow/overflow_gateway_web/redis"
@ -15,11 +15,15 @@ import (
)
func main() {
configPath := flag.String("config", ".", "The path of config file")
configPath := flag.String("config", "./", "The path of config file")
flag.Parse()
loadConfig(*configPath)
config.SetConfigPath(*configPath)
if err := config.Load(&conf.Config, "config.json"); nil != err {
panic(err)
}
ctx := context.Background()
defer logging.Logger.Sync()
@ -32,16 +36,7 @@ func main() {
subscribe.Subscribe(ctx, rp.Get())
s.HandleSocket(config.GetString("handlers.web.entry"), wsh)
s.HandleSocket(conf.Config.Handlers["web"].Entry, wsh)
s.ListenAndServe(config.GetString("server.addr"))
}
func loadConfig(path string) {
config.SetConfigName("config")
config.AddConfigPath(path)
err := config.ReadInConfig()
if nil != err {
log.Fatalf("config error: %v", err)
}
s.ListenAndServe(conf.Config.Server.Addr)
}

9
redis/pool.go
View File

@ -4,7 +4,8 @@ import (
"context"
"time"
"git.loafle.net/commons_go/config"
"git.loafle.net/overflow/overflow_gateway_web/conf"
rp "git.loafle.net/commons_go/redis_pool"
)
@ -12,9 +13,9 @@ func NewPool(ctx context.Context) rp.Pool {
h := &poolHandlers{
ctx: ctx,
}
h.cfg = config.Sub("redis")
h.MaxIdle = h.cfg.GetInt("pool.MaxIdle")
h.IdleTimeout = h.cfg.GetDuration("pool.IdleTimeout") * time.Second
h.MaxIdle = conf.Config.Redis.Pool.MaxIdle
h.IdleTimeout = conf.Config.Redis.Pool.IdleTimeout * time.Second
p := rp.NewPool(ctx, h)

8
redis/pool_handlers.go
View File

@ -4,20 +4,18 @@ import (
"context"
"time"
"github.com/garyburd/redigo/redis"
"git.loafle.net/commons_go/config"
rp "git.loafle.net/commons_go/redis_pool"
"git.loafle.net/overflow/overflow_gateway_web/conf"
"github.com/garyburd/redigo/redis"
)
type poolHandlers struct {
rp.PoolHandlers
ctx context.Context
cfg config.Configurator
}
func (h *poolHandlers) Dial() (redis.Conn, error) {
return redis.Dial(h.cfg.GetString("network"), h.cfg.GetString("addr"))
return redis.Dial(conf.Config.Redis.Network, conf.Config.Redis.Addr)
}
func (h *poolHandlers) TestOnBorrow(c redis.Conn, t time.Time) error {

4
server/server.go
View File

@ -3,7 +3,7 @@ package server
import (
"context"
"git.loafle.net/commons_go/config"
"git.loafle.net/overflow/overflow_gateway_web/conf"
ogw "git.loafle.net/overflow/overflow_gateway_websocket"
)
@ -13,7 +13,7 @@ func NewServer(ctx context.Context) ogw.Server {
h := newServerHandler(ctx)
_s := ogw.NewServer(ctx, h)
ofSigningKey = []byte(config.GetString("auth.signingKey"))
ofSigningKey = []byte(conf.Config.Auth.SigningKey)
return _s
}

16
server/server_handlers.go
View File

@ -5,11 +5,10 @@ import (
"fmt"
"time"
"git.loafle.net/commons_go/config"
"git.loafle.net/overflow/overflow_gateway_web/conf"
ogw "git.loafle.net/overflow/overflow_gateway_websocket"
jwt "github.com/dgrijalva/jwt-go"
"github.com/valyala/fasthttp"
ogw "git.loafle.net/overflow/overflow_gateway_websocket"
)
var ofSigningKey []byte
@ -18,11 +17,11 @@ func newServerHandler(ctx context.Context) ogw.ServerHandler {
h := &serverHandlers{
ctx: ctx,
}
h.cfg = config.Sub("websocket")
h.HandshakeTimeout = h.cfg.GetDuration("HandshakeTimeout") * time.Second
h.ReadBufferSize = h.cfg.GetInt("ReadBufferSize")
h.WriteBufferSize = h.cfg.GetInt("WriteBufferSize")
h.EnableCompression = h.cfg.GetBool("EnableCompression")
h.HandshakeTimeout = conf.Config.Websocket.HandshakeTimeout * time.Second
h.ReadBufferSize = conf.Config.Websocket.ReadBufferSize
h.WriteBufferSize = conf.Config.Websocket.WriteBufferSize
h.EnableCompression = conf.Config.Websocket.EnableCompression
return h
}
@ -30,7 +29,6 @@ func newServerHandler(ctx context.Context) ogw.ServerHandler {
type serverHandlers struct {
ogw.ServerHandlers
ctx context.Context
cfg config.Configurator
}
func (h *serverHandlers) OnConnection(soc ogw.Socket) {