From 7d1bbdc8a9a4854edb6d45877fb0d2b9ce12478b Mon Sep 17 00:00:00 2001
From: chenshijun <csj_sky@126.com>
Date: 星期一, 05 八月 2019 09:46:29 +0800
Subject: [PATCH] 重构之前的db操作的代码

---
 config.go |   13 ++++++++-----
 1 files changed, 8 insertions(+), 5 deletions(-)

diff --git a/config.go b/config.go
index f24c38a..950e3a1 100644
--- a/config.go
+++ b/config.go
@@ -28,8 +28,8 @@
 )
 
 const (
-	DefaultBindPort    = 5000//30190
-	DefaultRPCPort     = 7373//30191
+	DefaultBindPort    = 30190
+	DefaultRPCPort     = 30191
 	DefaultClusterPort = 30192
 	ModeSingle         = "single"
 	ModeCluster        = "cluster"
@@ -39,14 +39,17 @@
 	tagKeyClusterID  = "syncer-cluster-name"
 	TagKeyClusterPort  = "syncer-cluster-port"
 	TagKeyRPCPort      = "syncer-rpc-port"
+	MaxQueryRespSize = 50 * 1024 *1024
+	MaxQuerySize = 1024 *1024
+	MaxUserEventSize = 1024
 )
 
 // DefaultConfig default config
 func DefaultConfig() *Config {
 	agentConf := agent.DefaultConfig()
-	agentConf.QueryResponseSizeLimit = 50 * 1024 *1024
-	agentConf.QuerySizeLimit = 50 * 1024 *1024
-	agentConf.UserEventSizeLimit = 1024
+	agentConf.QueryResponseSizeLimit = MaxQueryRespSize
+	agentConf.QuerySizeLimit = MaxQuerySize
+	agentConf.UserEventSizeLimit = MaxUserEventSize
 	agentConf.BindAddr = fmt.Sprintf("0.0.0.0:%d", DefaultBindPort)
 	agentConf.RPCAddr = fmt.Sprintf("0.0.0.0:%d", DefaultRPCPort)
 	return &Config{

--
Gitblit v1.8.0