重构之前的db操作的代码

chenshijun

2019-08-05 7d1bbdc8a9a4854edb6d45877fb0d2b9ce12478b

 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{