1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253 |
- package databus
- import (
- "time"
- "go-common/library/conf/env"
- "go-common/library/queue/databus"
- xtime "go-common/library/time"
- )
- type conf struct {
- Key string
- Secret string
- Addr string
- }
- var (
- _defaultAddrConfig = map[string]*conf{
- env.DeployEnvUat: {
- Key: "4c76cbb7a985ac90",
- Secret: "43bb22ce34a6b13e7814f09cb8116522",
- Addr: "172.18.33.50:6205",
- },
- env.DeployEnvPre: {
- Key: "4c76cbb7a985ac90",
- Secret: "8c22a196bf00d623b69cba4e61b1f7dc",
- Addr: "172.18.21.90:6205",
- },
- env.DeployEnvProd: {
- Key: "4c76cbb7a985ac90",
- Secret: "8c22a196bf00d623b69cba4e61b1f7dc",
- Addr: "172.18.21.90:6205",
- },
- }
- _defaultConfig = &databus.Config{
- Key: "0PtMsLLxWyyvoTgAyLCD",
- Secret: "0PtMsLLxWyyvoTgAyLCE",
- Group: "AegisResource-MainArchive-P",
- Topic: "AegisResource-T",
- Action: "pub",
- Buffer: 10240,
- Name: "aegis-admin/databus",
- Proto: "tcp",
- Addr: "172.16.33.158:6205",
- Active: 100,
- Idle: 10,
- DialTimeout: xtime.Duration(time.Millisecond * 200),
- ReadTimeout: xtime.Duration(time.Millisecond * 200),
- WriteTimeout: xtime.Duration(time.Millisecond * 200),
- IdleTimeout: xtime.Duration(time.Second * 80),
- }
- )
|