config

type Config struct {
	Host             string
	Port             int
	AdminHost        string
	AdminPort        int
	LogLevel         string
	LogDir           string
	LogFormat        string
	Accounts         map[string]string
	EnableAccessLog  bool
	AdminRedis       RedisConf
	Pool             RedisPool
	SecondaryStorage *SecondaryStorage

	// Default publish params
	TTLSecond   int
	DelaySecond int
	TriesNum    int
	// Default consume params
	TTRSecond     int
	TimeoutSecond int
}

type PresetConfigForTest struct {
	*Config
	// contains filtered or unexported fields
}

type RedisConf struct {
	Addr       string
	Password   string
	DB         int
	PoolSize   int
	MigrateTo  string // If this is not empty, all the PUBLISH will go to that pool
	MasterName string
	Version    string

	EnableSecondaryStorage bool

	// number of seconds. when job's delay second is greater than pumpStorageThresh,
	//it will be written to storage if enabled
	SecondaryStorageThresholdSeconds int64
}

type RedisPool map[string]RedisConf

type SecondaryStorage struct {
	Spanner *SpannerConfig
	// max number of jobs that storage pumps per batch
	MaxJobPumpBatchSize int64
}

type SpannerConfig struct {
	Project         string
	Instance        string
	Database        string
	CredentialsFile string
	TableName       string
}