| | |
|---|
| | | ModeCluster = "cluster" |
|---|
| | | retryMaxAttempts = 3 |
|---|
| | | groupExpect = 3 |
|---|
| | | DefaultEncryptKey = "bjbasic@aiotlink" |
|---|
| | | tagKeyClusterID = "syncer-cluster-name" |
|---|
| | | DefaultEncryptKey = "bjbasic@aiotlink" |
|---|
| | | tagKeyClusterID = "syncer-cluster-name" |
|---|
| | | TagKeyClusterPort = "syncer-cluster-port" |
|---|
| | | TagKeyRPCPort = "syncer-rpc-port" |
|---|
| | | BroadcastIP = "255.255.255.255" |
|---|
| | | BroadcastPort = 30193 |
|---|
| | | BroadcastInterval = 5 |
|---|
| | | MaxQueryRespSize = 50 * 1024 * 1024 |
|---|
| | | MaxQuerySize = 50 * 1024 * 1024 |
|---|
| | | MaxUserEventSize = 5 * 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{ |
|---|
| | |
|---|
| | | |
|---|
| | | return addr.IP.String(), addr.Port, nil |
|---|
| | | } |
|---|
| | | |
|---|
